DMleadgen
46d973904b
Next.js website for Rocky Mountain Vending company featuring: - Product catalog with Stripe integration - Service areas and parts pages - Admin dashboard with Clerk authentication - SEO optimized pages with JSON-LD structured data Co-authored-by: Cursor <cursoragent@cursor.com>
83 lines
No EOL
3.3 KiB
Text
83 lines
No EOL
3.3 KiB
Text
/*
|
|
* Copyright The OpenTelemetry Authors
|
|
*
|
|
* Licensed under the Apache License, Version 2.0 (the "License");
|
|
* you may not use this file except in compliance with the License.
|
|
* You may obtain a copy of the License at
|
|
*
|
|
* https://www.apache.org/licenses/LICENSE-2.0
|
|
*
|
|
* Unless required by applicable law or agreed to in writing, software
|
|
* distributed under the License is distributed on an "AS IS" BASIS,
|
|
* WITHOUT WARRANTIES OR CONDITIONS OF ANY KIND, either express or implied.
|
|
* See the License for the specific language governing permissions and
|
|
* limitations under the License.
|
|
*/
|
|
import { TraceFlags } from '@opentelemetry/api';
|
|
import { internal, ExportResultCode, globalErrorHandler, BindOnceFuture, } from '@opentelemetry/core';
|
|
/**
|
|
* An implementation of the {@link SpanProcessor} that converts the {@link Span}
|
|
* to {@link ReadableSpan} and passes it to the configured exporter.
|
|
*
|
|
* Only spans that are sampled are converted.
|
|
*
|
|
* NOTE: This {@link SpanProcessor} exports every ended span individually instead of batching spans together, which causes significant performance overhead with most exporters. For production use, please consider using the {@link BatchSpanProcessor} instead.
|
|
*/
|
|
export class SimpleSpanProcessor {
|
|
constructor(_exporter) {
|
|
this._exporter = _exporter;
|
|
this._shutdownOnce = new BindOnceFuture(this._shutdown, this);
|
|
this._unresolvedExports = new Set();
|
|
}
|
|
async forceFlush() {
|
|
// await unresolved resources before resolving
|
|
await Promise.all(Array.from(this._unresolvedExports));
|
|
if (this._exporter.forceFlush) {
|
|
await this._exporter.forceFlush();
|
|
}
|
|
}
|
|
onStart(_span, _parentContext) { }
|
|
onEnd(span) {
|
|
var _a, _b;
|
|
if (this._shutdownOnce.isCalled) {
|
|
return;
|
|
}
|
|
if ((span.spanContext().traceFlags & TraceFlags.SAMPLED) === 0) {
|
|
return;
|
|
}
|
|
const doExport = () => internal
|
|
._export(this._exporter, [span])
|
|
.then((result) => {
|
|
var _a;
|
|
if (result.code !== ExportResultCode.SUCCESS) {
|
|
globalErrorHandler((_a = result.error) !== null && _a !== void 0 ? _a : new Error(`SimpleSpanProcessor: span export failed (status ${result})`));
|
|
}
|
|
})
|
|
.catch(error => {
|
|
globalErrorHandler(error);
|
|
});
|
|
// Avoid scheduling a promise to make the behavior more predictable and easier to test
|
|
if (span.resource.asyncAttributesPending) {
|
|
const exportPromise = (_b = (_a = span.resource).waitForAsyncAttributes) === null || _b === void 0 ? void 0 : _b.call(_a).then(() => {
|
|
if (exportPromise != null) {
|
|
this._unresolvedExports.delete(exportPromise);
|
|
}
|
|
return doExport();
|
|
}, err => globalErrorHandler(err));
|
|
// store the unresolved exports
|
|
if (exportPromise != null) {
|
|
this._unresolvedExports.add(exportPromise);
|
|
}
|
|
}
|
|
else {
|
|
void doExport();
|
|
}
|
|
}
|
|
shutdown() {
|
|
return this._shutdownOnce.call();
|
|
}
|
|
_shutdown() {
|
|
return this._exporter.shutdown();
|
|
}
|
|
}
|
|
//# sourceMappingURL=SimpleSpanProcessor.js.map |