| 2057 | `,(0,OR8.getConflictResolutionRecipe)(Y,q))}return _}}Im4.MetricStorageRegistry=fU1});var Fm4=m((Bm4)=>{Object.defineProperty(Bm4,"__esModule",{value:!0});Bm4.MultiMetricStorage=void 0;class pm4{_backingStorages;constructor(q){this._backingStorages=q}record(q,K,_,z){this._backingStorages.forEach((Y)=>{Y.record(q,K,_,z)})}}Bm4.MultiMetricStorage=pm4});var nm4=m((cm4)=>{Object.defineProperty(cm4,"__esModule",{value:!0});cm4.BatchObservableResultImpl=cm4.ObservableResultImpl=void 0;var Yy6=nK(),Um4=Ws6(),RWz=AR8();class Qm4{_instrumentName;_valueType;_buffer=new Um4.AttributeHashMap;constructor(q,K){this._instrumentName=q,this._valueType=K}observe(q,K={}){if(typeof q!=="number"){Yy6.diag.warn(`non-number value provided to metric ${this._instrumentName}: ${q}`);return}if(this._valueType===Yy6.ValueType.INT&&!Number.isInteger(q)){if(Yy6.diag.warn(`INT value type cannot accept a floating-point value for ${this._instrumentName}, ignoring the fractional digits.`),q=Math.trunc(q),!Number.isInteger(q))return}this._buffer.set(K,q)}}cm4.ObservableResultImpl=Qm4;class dm4{_buffer=new Map;observe(q,K,_={}){if(!(0,RWz.isObservableInstrument)(q))return;let z=this._buffer.get(q);if(z==null)z=new Um4.AttributeHashMap,this._buffer.set(q,z);if(typeof K!=="number"){Yy6.diag.warn(`non-number value provided to metric ${q._descriptor.name}: ${K}`);return}if(q._descriptor.valueType===Yy6.ValueType.INT&&!Number.isInteger(K)){if(Yy6.diag.warn(`INT value type cannot accept a floating-point value for ${q._descriptor.name}, ignoring the fractional digits.`),K=Math.trunc(K),!Number.isInteger(K))return}z.set(_,K)}}cm4.BatchObservableResultImpl=dm4});var tm4=m((am4)=>{Object.defineProperty(am4,"__esModule",{value:!0});am4.ObservableRegistry=void 0;var SWz=nK(),im4=AR8(),rm4=nm4(),fs6=Wm();class om4{_callbacks=[];_batchCallbacks=[];addCallback(q,K){if(this._findCallback(q,K)>=0)return;this._callbacks.push({callback:q,instrument:K})}removeCallback(q,K){let _=this._findCallback(q,K);if(_<0)return;this._callbacks.splice(_,1)}addBatchCallback(q,K){let _=new Set(K.filter(im4.isObservableInstrument));if(_.size===0){SWz.diag.error("BatchObservableCallback is not associated with valid instruments",K);return}if(this._findBatchCallback(q,_)>=0)return;this._batchCallbacks.push({callback:q,instruments:_})}removeBatchCallback(q,K){let _=new Set(K.filter(im4.isObservableInstrument)),z=this._findBatchCallback(q,_);if(z<0)return;this._batchCallbacks.splice(z,1)}async observe(q,K){let _=this._observeCallbacks(q,K),z=this._observeBatchCallbacks(q,K);return(await(0,fs6.PromiseAllSettled)([..._,...z])).filter(fs6.isPromiseAllSettledRejectionResult).map((A)=>A.reason)}_observeCallbacks(q,K){return this._callbacks.map(async({callback:_,instrument:z})=>{let Y=new rm4.ObservableResultImpl(z._descriptor.name,z._descriptor.valueType),$=Promise.resolve(_(Y));if(K!=null)$=(0,fs6.callWithTimeout)($,K);await $,z._metricStorages.forEach((A)=>{A.record(Y._buffer,q)})})}_observeBatchCallbacks(q,K){return this._batchCallbacks.map(async({callback:_,instruments:z})=>{let Y=new rm4.BatchObservableResultImpl,$=Promise.resolve(_(Y));if(K!=null)$=(0,fs6.callWithTimeout)($,K);await $,z.forEach((A)=>{let O=Y._buffer.get(A);if(O==null)return;A._metricStorages.forEach((w)=>{w.record(O,q)})})})}_findCallback(q,K){return this._callbacks.findIndex((_)=>{return _.callback===q&&_.instrument===K})}_findBatchCallback(q,K){return this._batchCallbacks.findIndex((_)=>{return _.callback===q&&(0,fs6.setEquals)(_.instruments,K)})}}am4.ObservableRegistry=om4});var _p4=m((qp4)=>{Object.defineProperty(qp4,"__esModule",{value:!0});qp4.SyncMetricStorage=void 0;var CWz=MU1(),bWz=WU1(),xWz=DU1();class em4 extends CWz.MetricStorage{_attributesProcessor;_aggregationCardinalityLimit;_deltaMetricStorage;_temporalMetricStorage;constructor(q,K,_,z,Y){super(q);this._attributesProcessor=_,this._aggregationCardinalityLimit=Y,this._deltaMetricStorage=new bWz.DeltaMetricProcessor(K,this._aggregationCardinalityLimit),this._temporalMetricStorage=new xWz.TemporalMetricProcessor(K,z)}record(q,K,_,z){K=this._attributesProcessor.process(K,_),this._deltaMetricStorage.record(q,K,_,z)}collect(q,K){let _=this._deltaMetricStorage.collect();return this._temporalMetricStorage.buildMetrics(q,this._instrumentDescriptor,_,K)}}qp4.SyncMetricStorage=em4});var wR8=m((Op4)=>{Object.defineProperty(Op4,"__esModule",{value:!0});Op4.createDenyListAttributesProcessor=Op4.createAllowListAttributesProcessor=Op4.createMultiAttributesProcessor=Op4.createNoopAttributesProcessor=void 0;class zp4{process(q,K){return q}}class Yp4{_processors;constructor(q){this._processors=q}process(q,K){let _=q;for(let z of this._processors)_=z.process(_,K);return _}}class $p4{_allowedAttributeNames;constructor(q){this._allowedAttributeNames=q}process(q,K){let _={};return Object.keys(q).filter((z)=>this._allowedAttributeNames.includes(z)).forEach((z)=>_[z]=q[z]),_}}class Ap4{_deniedAttributeNames;constructor(q){this._deniedAttributeNames=q}process(q,K){let _={};return Object.keys(q).filter((z)=>!this._deniedAttributeNames.includes(z)).forEach((z)=>_[z]=q[z]),_}}function IWz(){return BWz}Op4.createNoopAttributesProcessor=IWz;function uWz(q){return new Yp4(q)}Op4.createMultiAttributesProcessor=uWz;function mWz(q){return new $p4(q)}Op4.createAllowListAttributesProcessor=mWz;function pWz(q){return new Ap4(q)}Op4.createDenyListAttributesProcessor=pWz;var BWz=new zp4});var Mp4=m((Hp4)=>{Object.defineProperty(Hp4,"__esModule",{value:!0});Hp4.MeterSharedState=void 0;var QWz=Ps6(),dWz=Hm4(),cWz=Wm(),lWz=ym4(),nWz=mm4(),iWz=Fm4(),rWz=tm4(),oWz=_p4(),aWz=wR8();class jp4{_meterProviderSharedState;_instrumentationScope;metricStorageRegistry=new nWz.MetricStorageRegistry;observableRegistry=new rWz.ObservableRegistry;meter;constructor(q,K){this._meterProviderSharedState=q,this._instrumentationScope=K,this.meter=new dWz.Meter(this)}registerMetricStorage(q){let K=this._registerMetricStorage(q,oWz.SyncMetricStorage);if(K.length===1)return K[0];return new iWz.MultiMetricStorage(K)}registerAsyncMetricStorage(q){return this._registerMetricStorage(q,lWz.AsyncMetricStorage)}async collect(q,K,_){let z=await this.observableRegistry.observe(K,_?.timeoutMillis),Y=this.metricStorageRegistry.getStorages(q);if(Y.length===0)return null;let $=Y.map((A)=>{return A.collect(q,K)}).filter(cWz.isNotNullish);if($.length===0)return{errors:z};return{scopeMetrics:{scope:this._instrumentationScope,metrics:$},errors:z}}_registerMetricStorage(q,K){let z=this._meterProviderSharedState.viewRegistry.findViews(q,this._instrumentationScope).map((Y)=>{let $=(0,QWz.createInstrumentDescriptorWithView)(Y,q),A=this.metricStorageRegistry.findOrUpdateCompatibleStorage($);if(A!=null)return A;let O=Y.aggregation.createAggregator($),w=new K($,O,Y.attributesProcessor,this._meterProviderSharedState.metricCollectors,Y.aggregationCardinalityLimit);return this.metricStorageRegistry.register(w),w});if(z.length===0){let $=this._meterProviderSharedState.selectAggregations(q.type).map(([A,O])=>{let w=this.metricStorageRegistry.findOrUpdateCompatibleCollectorStorage(A,q);if(w!=null)return w;let j=O.createAggregator(q),H=A.selectCardinalityLimit(q.type),J=new K(q,j,(0,aWz.createNoopAttributesProcessor)(),[A],H);return this.metricStorageRegistry.registerForCollector(A,J),J});z=z.concat($)}return z}}Hp4.MeterSharedState=jp4});var Dp4=m((Pp4)=>{Object.defineProperty(Pp4,"__esModule",{value:!0});Pp4.MeterProviderSharedState=void 0;var sWz=Wm(),tWz=iu4(),eWz=Mp4(),qDz=Xs6();class Xp4{resource;viewRegistry=new tWz.ViewRegistry;metricCollectors=[];meterSharedStates=new Map;constructor(q){this.resource=q}getMeterSharedState(q){let K=(0,sWz.instrumentationScopeId)(q),_=this.meterSharedStates.get(K);if(_==null)_=new eWz.MeterSharedState(this,q),this.meterSharedStates.set(K,_);return _}selectAggregations(q){let K=[];for(let _ of this.metricCollectors)K.push([_,(0,qDz.toAggregation)(_.selectAggregation(q))]);return K}}Pp4.MeterProviderSharedState=Xp4});var Tp4=m((Zp4)=>{Object.defineProperty(Zp4,"__esModule",{value:!0});Zp4.MetricCollector=void 0;var KDz=Oz();class fp4{_sharedState;_metricReader;constructor(q,K){this._sharedState=q,this._metricReader=K}async collect(q){let K=(0,KDz.millisToHrTime)(Date.now()),_=[],z=[],Y=Array.from(this._sharedState.meterSharedStates.values()).map(async($)=>{let A=await $.collect(this,K,q);if(A?.scopeMetrics!=null)_.push(A.scopeMetrics);if(A?.errors!=null)z.push(...A.errors)});return await Promise.all(Y),{resourceMetrics:{resource:this._sharedState.resource,scopeMetrics:_},errors:z}}async forceFlush(q){await this._metricReader.forceFlush(q)}async shutdown(q){await this._metricReader.shutdown(q)}selectAggregationTemporality(q){return this._metricReader.selectAggregationTemporality(q)}selectAggregation(q){return this._metricReader.selectAggregation(q)}selectCardinalityLimit(q){return this._metricReader.selectCardinalityLimit?.(q)??2000}}Zp4.MetricCollector=fp4});var jR8=m((kp4)=>{Object.defineProperty(kp4,"__esModule",{value:!0});kp4.ExactPredicate=kp4.PatternPredicate=void 0;var _Dz=/[\^$\\.+?()[\]{}|]/g;class ZU1{_matchAll;_regexp;constructor(q){if(q==="*")this._matchAll=!0,this._regexp=/.*/;else this._matchAll=!1,this._regexp=new RegExp(ZU1.escapePattern(q))}match(q){if(this._matchAll)return!0;return this._regexp.test(q)}static escapePattern(q){return`^${q.replace(_Dz,"\\$&").replace("*",".*")}$`}static hasWildcard(q){return q.includes("*")}}kp4.PatternPredicate=ZU1;class vp4{_matchAll;_pattern;constructor(q){this._matchAll=q===void 0,this._pattern=q}match(q){if(this._matchAll)return!0;if(q===this._pattern)return!0;return!1}}kp4.ExactPredicate=vp4});var Rp4=m((Ep4)=>{Object.defineProperty(Ep4,"__esModule",{value:!0});Ep4.InstrumentSelector=void 0;var Np4=jR8();class yp4{_nameFilter;_type;_unitFilter;constructor(q){this._nameFilter=new Np4.PatternPredicate(q?.name??"*"),this._type=q?.type,this._unitFilter=new Np4.ExactPredicate(q?.unit)}getType(){return this._type}getNameFilter(){return this._nameFilter}getUnitFilter(){return this._unitFilter}}Ep4.InstrumentSelector=yp4});var bp4=m((Sp4)=>{Object.defineProperty(Sp4,"__esModule",{value:!0});Sp4.MeterSelector=void 0;var GU1=jR8();class hp4{_nameFilter;_versionFilter;_schemaUrlFilter;constructor(q){this._nameFilter=new GU1.ExactPredicate(q?.name),this._versionFilter=new GU1.ExactPredicate(q?.version),this._schemaUrlFilter=new GU1.ExactPredicate(q?.schemaUrl)}getNameFilter(){return this._nameFilter}getVersionFilter(){return this._versionFilter}getSchemaUrlFilter(){return this._schemaUrlFilter}}Sp4.MeterSelector=hp4});var Bp4=m((mp4)=>{Object.defineProperty(mp4,"__esModule",{value:!0});mp4.View=void 0;var YDz=jR8(),xp4=wR8(),$Dz=Rp4(),ADz=bp4(),Ip4=Xs6();function ODz(q){return q.instrumentName==null&&q.instrumentType==null&&q.instrumentUnit==null&&q.meterName==null&&q.meterVersion==null&&q.meterSchemaUrl==null}function wDz(q){if(ODz(q))throw Error("Cannot create view with no selector arguments supplied");if(q.name!=null&&(q?.instrumentName==null||YDz.PatternPredicate.hasWildcard(q.instrumentName)))throw Error("Views with a specified name must be declared with an instrument selector that selects at most one instrument per meter.")}class up4{name;description;aggregation;attributesProcessor;instrumentSelector;meterSelector;aggregationCardinalityLimit;constructor(q){if(wDz(q),q.attributesProcessors!=null)this.attributesProcessor=(0,xp4.createMultiAttributesProcessor)(q.attributesProcessors);else this.attributesProcessor=(0,xp4.createNoopAttributesProcessor)();this.name=q.name,this.description=q.description,this.aggregation=(0,Ip4.toAggregation)(q.aggregation??{type:Ip4.AggregationType.DEFAULT}),this.instrumentSelector=new $Dz.InstrumentSelector({name:q.instrumentName,type:q.instrumentType,unit:q.instrumentUnit}),this.meterSelector=new ADz.MeterSelector({name:q.meterName,version:q.meterVersion,schemaUrl:q.meterSchemaUrl}),this.aggregationCardinalityLimit=q.aggregationCardinalityLimit}}mp4.View=up4});var Qp4=m((Fp4)=>{Object.defineProperty(Fp4,"__esModule",{value:!0});Fp4.MeterProvider=void 0;var HR8=nK(),jDz=pG6(),HDz=Dp4(),JDz=Tp4(),MDz=Bp4();class gp4{_sharedState;_shutdown=!1;constructor(q){if(this._sharedState=new HDz.MeterProviderSharedState(q?.resource??(0,jDz.defaultResource)()),q?.views!=null&&q.views.length>0)for(let K of q.views)this._sharedState.viewRegistry.addView(new MDz.View(K));if(q?.readers!=null&&q.readers.length>0)for(let K of q.readers){let _=new JDz.MetricCollector(this._sharedState,K);K.setMetricProducer(_),this._sharedState.metricCollectors.push(_)}}getMeter(q,K="",_={}){if(this._shutdown)return HR8.diag.warn("A shutdown MeterProvider cannot provide a Meter"),(0,HR8.createNoopMeter)();return this._sharedState.getMeterSharedState({name:q,version:K,schemaUrl:_.schemaUrl}).meter}async shutdown(q){if(this._shutdown){HR8.diag.warn("shutdown may only be called once per MeterProvider");return}this._shutdown=!0,await Promise.all(this._sharedState.metricCollectors.map((K)=>{return K.shutdown(q)}))}async forceFlush(q){if(this._shutdown){HR8.diag.warn("invalid attempt to force flush after MeterProvider shutdown");return}await Promise.all(this._sharedState.metricCollectors.map((K)=>{return K.forceFlush(q)}))}}Fp4.MeterProvider=gp4});var z26=m((uN)=>{Object.defineProperty(uN,"__esModule",{value:!0});uN.TimeoutError=uN.createDenyListAttributesProcessor=uN.createAllowListAttributesProcessor=uN.AggregationType=uN.MeterProvider=uN.ConsoleMetricExporter=uN.InMemoryMetricExporter=uN.PeriodicExportingMetricReader=uN.MetricReader=uN.InstrumentType=uN.DataPointType=uN.AggregationTemporality=void 0;var XDz=aL8();Object.defineProperty(uN,"AggregationTemporality",{enumerable:!0,get:function(){return XDz.AggregationTemporality}});var dp4=A46();Object.defineProperty(uN,"DataPointType",{enumerable:!0,get:function(){return dp4.DataPointType}});Object.defineProperty(uN,"InstrumentType",{enumerable:!0,get:function(){return dp4.InstrumentType}});var PDz=jU1();Object.defineProperty(uN,"MetricReader",{enumerable:!0,get:function(){return PDz.MetricReader}});var WDz=Iu4();Object.defineProperty(uN,"PeriodicExportingMetricReader",{enumerable:!0,get:function(){return WDz.PeriodicExportingMetricReader}});var DDz=gu4();Object.defineProperty(uN,"InMemoryMetricExporter",{enumerable:!0,get:function(){return DDz.InMemoryMetricExporter}});var fDz=du4();Object.defineProperty(uN,"ConsoleMetricExporter",{enumerable:!0,get:function(){return fDz.ConsoleMetricExporter}});var ZDz=Qp4();Object.defineProperty(uN,"MeterProvider",{enumerable:!0,get:function(){return ZDz.MeterProvider}});var GDz=Xs6();Object.defineProperty(uN,"AggregationType",{enumerable:!0,get:function(){return GDz.AggregationType}});var cp4=wR8();Object.defineProperty(uN,"createAllowListAttributesProcessor",{enumerable:!0,get:function(){return cp4.createAllowListAttributesProcessor}});Object.defineProperty(uN,"createDenyListAttributesProcessor",{enumerable:!0,get:function(){return cp4.createDenyListAttributesProcessor}});var TDz=Wm();Object.defineProperty(uN,"TimeoutError",{enumerable:!0,get:function(){return TDz.TimeoutError}})});var ip4=m((lp4)=>{Object.defineProperty(lp4,"__esModule",{value:!0});lp4.ExceptionEventName=void 0;lp4.ExceptionEventName="exception"});var sp4=m((op4)=>{Object.defineProperty(op4,"__esModule",{value:!0});op4.SpanImpl=void 0;var Kb=nK(),FG=Oz(),Y26=L$6(),kDz=ip4();class rp4{_spanContext;kind;parentSpanContext;attributes={};links=[];events=[];startTime;resource;instrumentationScope;_droppedAttributesCount=0;_droppedEventsCount=0;_droppedLinksCount=0;name;status={code:Kb.SpanStatusCode.UNSET};endTime=[0,0];_ended=!1;_duration=[-1,-1];_spanProcessor;_spanLimits;_attributeValueLengthLimit;_performanceStartTime;_performanceOffset;_startTimeProvided;constructor(q){let K=Date.now();if(this._spanContext=q.spanContext,this._performanceStartTime=FG.otperformance.now(),this._performanceOffset=K-(this._performanceStartTime+(0,FG.getTimeOrigin)()),this._startTimeProvided=q.startTime!=null,this._spanLimits=q.spanLimits,this._attributeValueLengthLimit=this._spanLimits.attributeValueLengthLimit||0,this._spanProcessor=q.spanProcessor,this.name=q.name,this.parentSpanContext=q.parentSpanContext,this.kind=q.kind,this.links=q.links||[],this.startTime=this._getTime(q.startTime??K),this.resource=q.resource,this.instrumentationScope=q.scope,q.attributes!=null)this.setAttributes(q.attributes);this._spanProcessor.onStart(this,q.context)}spanContext(){return this._spanContext}setAttribute(q,K){if(K==null||this._isSpanEnded())return this;if(q.length===0)return Kb.diag.warn(`Invalid attribute key: ${q}`),this;if(!(0,FG.isAttributeValue)(K))return Kb.diag.warn(`Invalid attribute value set for key: ${q}`),this;let{attributeCountLimit:_}=this._spanLimits;if(_!==void 0&&Object.keys(this.attributes).length>=_&&!Object.prototype.hasOwnProperty.call(this.attributes,q))return this._droppedAttributesCount++,this;return this.attributes[q]=this._truncateToSize(K),this}setAttributes(q){for(let[K,_]of Object.entries(q))this.setAttribute(K,_);return this}addEvent(q,K,_){if(this._isSpanEnded())return this;let{eventCountLimit:z}=this._spanLimits;if(z===0)return Kb.diag.warn("No events allowed."),this._droppedEventsCount++,this;if(z!==void 0&&this.events.length>=z){if(this._droppedEventsCount===0)Kb.diag.debug("Dropping extra events.");this.events.shift(),this._droppedEventsCount++}if((0,FG.isTimeInput)(K)){if(!(0,FG.isTimeInput)(_))_=K;K=void 0}let Y=(0,FG.sanitizeAttributes)(K);return this.events.push({name:q,attributes:Y,time:this._getTime(_),droppedAttributesCount:0}),this}addLink(q){return this.links.push(q),this}addLinks(q){return this.links.push(...q),this}setStatus(q){if(this._isSpanEnded())return this;if(this.status={...q},this.status.message!=null&&typeof q.message!=="string")Kb.diag.warn(`Dropping invalid status.message of type '${typeof q.message}', expected 'string'`),delete this.status.message;return this}updateName(q){if(this._isSpanEnded())return this;return this.name=q,this}end(q){if(this._isSpanEnded()){Kb.diag.error(`${this.name} ${this._spanContext.traceId}-${this._spanContext.spanId} - You can only call end() on a span once.`);return}if(this._ended=!0,this.endTime=this._getTime(q),this._duration=(0,FG.hrTimeDuration)(this.startTime,this.endTime),this._duration[0]<0)Kb.diag.warn("Inconsistent start and end time, startTime > endTime. Setting span duration to 0ms.",this.startTime,this.endTime),this.endTime=this.startTime.slice(),this._duration=[0,0];if(this._droppedEventsCount>0)Kb.diag.warn(`Dropped ${this._droppedEventsCount} events because eventCountLimit reached`);this._spanProcessor.onEnd(this)}_getTime(q){if(typeof q==="number"&&q<=FG.otperformance.now())return(0,FG.hrTime)(q+this._performanceOffset);if(typeof q==="number")return(0,FG.millisToHrTime)(q);if(q instanceof Date)return(0,FG.millisToHrTime)(q.getTime());if((0,FG.isTimeInputHrTime)(q))return q;if(this._startTimeProvided)return(0,FG.millisToHrTime)(Date.now());let K=FG.otperformance.now()-this._performanceStartTime;return(0,FG.addHrTimes)(this.startTime,(0,FG.millisToHrTime)(K))}isRecording(){return this._ended===!1}recordException(q,K){let _={};if(typeof q==="string")_[Y26.ATTR_EXCEPTION_MESSAGE]=q;else if(q){if(q.code)_[Y26.ATTR_EXCEPTION_TYPE]=q.code.toString();else if(q.name)_[Y26.ATTR_EXCEPTION_TYPE]=q.name;if(q.message)_[Y26.ATTR_EXCEPTION_MESSAGE]=q.message;if(q.stack)_[Y26.ATTR_EXCEPTION_STACKTRACE]=q.stack}if(_[Y26.ATTR_EXCEPTION_TYPE]||_[Y26.ATTR_EXCEPTION_MESSAGE])this.addEvent(kDz.ExceptionEventName,_,K);else Kb.diag.warn(`Failed to record an exception ${q}`)}get duration(){return this._duration}get ended(){return this._ended}get droppedAttributesCount(){return this._droppedAttributesCount}get droppedEventsCount(){return this._droppedEventsCount}get droppedLinksCount(){return this._droppedLinksCount}_isSpanEnded(){if(this._ended){let q=Error(`Operation attempted on ended Span {traceId: ${this._spanContext.traceId}, spanId: ${this._spanContext.spanId}}`);Kb.diag.warn(`Cannot execute the operation on ended Span {traceId: ${this._spanContext.traceId}, spanId: ${this._spanContext.spanId}}`,q)}return this._ended}_truncateToLimitUtil(q,K){if(q.length<=K)return q;return q.substring(0,K)}_truncateToSize(q){let K=this._attributeValueLengthLimit;if(K<=0)return Kb.diag.warn(`Attribute value limit must be positive, got ${K}`),q;if(typeof q==="string")return this._truncateToLimitUtil(q,K);if(Array.isArray(q))return q.map((_)=>typeof _==="string"?this._truncateToLimitUtil(_,K):_);return q}}op4.SpanImpl=rp4});var Zs6=m((tp4)=>{Object.defineProperty(tp4,"__esModule",{value:!0});tp4.SamplingDecision=void 0;var VDz;(function(q){q[q.NOT_RECORD=0]="NOT_RECORD",q[q.RECORD=1]="RECORD",q[q.RECORD_AND_SAMPLED=2]="RECORD_AND_SAMPLED"})(VDz=tp4.SamplingDecision||(tp4.SamplingDecision={}))});var JR8=m((qB4)=>{Object.defineProperty(qB4,"__esModule",{value:!0});qB4.AlwaysOffSampler=void 0;var NDz=Zs6();class ep4{shouldSample(){return{decision:NDz.SamplingDecision.NOT_RECORD}}toString(){return"AlwaysOffSampler"}}qB4.AlwaysOffSampler=ep4});var MR8=m((zB4)=>{Object.defineProperty(zB4,"__esModule",{value:!0});zB4.AlwaysOnSampler=void 0;var yDz=Zs6();class _B4{shouldSample(){return{decision:yDz.SamplingDecision.RECORD_AND_SAMPLED}}toString(){return"AlwaysOnSampler"}}zB4.AlwaysOnSampler=_B4});var kU1=m((OB4)=>{Object.defineProperty(OB4,"__esModule",{value:!0});OB4.ParentBasedSampler=void 0;var XR8=nK(),EDz=Oz(),$B4=JR8(),vU1=MR8();class AB4{_root;_remoteParentSampled;_remoteParentNotSampled;_localParentSampled;_localParentNotSampled;constructor(q){if(this._root=q.root,!this._root)(0,EDz.globalErrorHandler)(Error("ParentBasedSampler must have a root sampler configured")),this._root=new vU1.AlwaysOnSampler;this._remoteParentSampled=q.remoteParentSampled??new vU1.AlwaysOnSampler,this._remoteParentNotSampled=q.remoteParentNotSampled??new $B4.AlwaysOffSampler,this._localParentSampled=q.localParentSampled??new vU1.AlwaysOnSampler,this._localParentNotSampled=q.localParentNotSampled??new $B4.AlwaysOffSampler}shouldSample(q,K,_,z,Y,$){let A=XR8.trace.getSpanContext(q);if(!A||!(0,XR8.isSpanContextValid)(A))return this._root.shouldSample(q,K,_,z,Y,$);if(A.isRemote){if(A.traceFlags&XR8.TraceFlags.SAMPLED)return this._remoteParentSampled.shouldSample(q,K,_,z,Y,$);return this._remoteParentNotSampled.shouldSample(q,K,_,z,Y,$)}if(A.traceFlags&XR8.TraceFlags.SAMPLED)return this._localParentSampled.shouldSample(q,K,_,z,Y,$);return this._localParentNotSampled.shouldSample(q,K,_,z,Y,$)}toString(){return`ParentBased{root=${this._root.toString()}, remoteParentSampled=${this._remoteParentSampled.toString()}, remoteParentNotSampled=${this._remoteParentNotSampled.toString()}, localParentSampled=${this._localParentSampled.toString()}, localParentNotSampled=${this._localParentNotSampled.toString()}}`}}OB4.ParentBasedSampler=AB4});var VU1=m((JB4)=>{Object.defineProperty(JB4,"__esModule",{value:!0});JB4.TraceIdRatioBasedSampler=void 0;var LDz=nK(),jB4=Zs6();class HB4{_ratio;_upperBound;constructor(q=0){this._ratio=q,this._ratio=this._normalize(q),this._upperBound=Math.floor(this._ratio*4294967295)}shouldSample(q,K){return{decision:(0,LDz.isValidTraceId)(K)&&this._accumulate(K)<this._upperBound?jB4.SamplingDecision.RECORD_AND_SAMPLED:jB4.SamplingDecision.NOT_RECORD}}toString(){return`TraceIdRatioBased{${this._ratio}}`}_normalize(q){if(typeof q!=="number"||isNaN(q))return 0;return q>=1?1:q<=0?0:q}_accumulate(q){let K=0;for(let _=0;_<q.length/8;_++){let z=_*8,Y=parseInt(q.slice(z,z+8),16);K=(K^Y)>>>0}return K}}JB4.TraceIdRatioBasedSampler=HB4});var EU1=m((fB4)=>{Object.defineProperty(fB4,"__esModule",{value:!0});fB4.buildSamplerFromEnv=fB4.loadDefaultConfig=void 0;var yU1=nK(),nU=Oz(),XB4=JR8(),NU1=MR8(),PR8=kU1(),PB4=VU1(),iU;(function(q){q.AlwaysOff="always_off",q.AlwaysOn="always_on",q.ParentBasedAlwaysOff="parentbased_always_off",q.ParentBasedAlwaysOn="parentbased_always_on",q.ParentBasedTraceIdRatio="parentbased_traceidratio",q.TraceIdRatio="traceidratio"})(iU||(iU={}));var WR8=1;function RDz(){return{sampler:DB4(),forceFlushTimeoutMillis:30000,generalLimits:{attributeValueLengthLimit:(0,nU.getNumberFromEnv)("OTEL_ATTRIBUTE_VALUE_LENGTH_LIMIT")??1/0,attributeCountLimit:(0,nU.getNumberFromEnv)("OTEL_ATTRIBUTE_COUNT_LIMIT")??128},spanLimits:{attributeValueLengthLimit:(0,nU.getNumberFromEnv)("OTEL_SPAN_ATTRIBUTE_VALUE_LENGTH_LIMIT")??1/0,attributeCountLimit:(0,nU.getNumberFromEnv)("OTEL_SPAN_ATTRIBUTE_COUNT_LIMIT")??128,linkCountLimit:(0,nU.getNumberFromEnv)("OTEL_SPAN_LINK_COUNT_LIMIT")??128,eventCountLimit:(0,nU.getNumberFromEnv)("OTEL_SPAN_EVENT_COUNT_LIMIT")??128,attributePerEventCountLimit:(0,nU.getNumberFromEnv)("OTEL_SPAN_ATTRIBUTE_PER_EVENT_COUNT_LIMIT")??128,attributePerLinkCountLimit:(0,nU.getNumberFromEnv)("OTEL_SPAN_ATTRIBUTE_PER_LINK_COUNT_LIMIT")??128}}}fB4.loadDefaultConfig=RDz;function DB4(){let q=(0,nU.getStringFromEnv)("OTEL_TRACES_SAMPLER")??iU.ParentBasedAlwaysOn;switch(q){case iU.AlwaysOn:return new NU1.AlwaysOnSampler;case iU.AlwaysOff:return new XB4.AlwaysOffSampler;case iU.ParentBasedAlwaysOn:return new PR8.ParentBasedSampler({root:new NU1.AlwaysOnSampler});case iU.ParentBasedAlwaysOff:return new PR8.ParentBasedSampler({root:new XB4.AlwaysOffSampler});case iU.TraceIdRatio:return new PB4.TraceIdRatioBasedSampler(WB4());case iU.ParentBasedTraceIdRatio:return new PR8.ParentBasedSampler({root:new PB4.TraceIdRatioBasedSampler(WB4())});default:return yU1.diag.error(`OTEL_TRACES_SAMPLER value "${q}" invalid, defaulting to "${iU.ParentBasedAlwaysOn}".`),new PR8.ParentBasedSampler({root:new NU1.AlwaysOnSampler})}}fB4.buildSamplerFromEnv=DB4;function WB4(){let q=(0,nU.getNumberFromEnv)("OTEL_TRACES_SAMPLER_ARG");if(q==null)return yU1.diag.error(`OTEL_TRACES_SAMPLER_ARG is blank, defaulting to ${WR8}.`),WR8;if(q<0||q>1)return yU1.diag.error(`OTEL_TRACES_SAMPLER_ARG=${q} was given, but it is out of range ([0..1]), defaulting to ${WR8}.`),WR8;return q}});var LU1=m((TB4)=>{Object.defineProperty(TB4,"__esModule",{value:!0});TB4.reconfigureLimits=TB4.mergeConfig=TB4.DEFAULT_ATTRIBUTE_VALUE_LENGTH_LIMIT=TB4.DEFAULT_ATTRIBUTE_COUNT_LIMIT=void 0;var GB4=EU1(),DR8=Oz();TB4.DEFAULT_ATTRIBUTE_COUNT_LIMIT=128;TB4.DEFAULT_ATTRIBUTE_VALUE_LENGTH_LIMIT=1/0;function SDz(q){let K={sampler:(0,GB4.buildSamplerFromEnv)()},_=(0,GB4.loadDefaultConfig)(),z=Object.assign({},_,K,q);return z.generalLimits=Object.assign({},_.generalLimits,q.generalLimits||{}),z.spanLimits=Object.assign({},_.spanLimits,q.spanLimits||{}),z}TB4.mergeConfig=SDz;function CDz(q){let K=Object.assign({},q.spanLimits);return K.attributeCountLimit=q.spanLimits?.attributeCountLimit??q.generalLimits?.attributeCountLimit??(0,DR8.getNumberFromEnv)("OTEL_SPAN_ATTRIBUTE_COUNT_LIMIT")??(0,DR8.getNumberFromEnv)("OTEL_ATTRIBUTE_COUNT_LIMIT")??TB4.DEFAULT_ATTRIBUTE_COUNT_LIMIT,K.attributeValueLengthLimit=q.spanLimits?.attributeValueLengthLimit??q.generalLimits?.attributeValueLengthLimit??(0,DR8.getNumberFromEnv)("OTEL_SPAN_ATTRIBUTE_VALUE_LENGTH_LIMIT")??(0,DR8.getNumberFromEnv)("OTEL_ATTRIBUTE_VALUE_LENGTH_LIMIT")??TB4.DEFAULT_ATTRIBUTE_VALUE_LENGTH_LIMIT,Object.assign({},q,{spanLimits:K})}TB4.reconfigureLimits=CDz});var LB4=m((yB4)=>{Object.defineProperty(yB4,"__esModule",{value:!0});yB4.BatchSpanProcessorBase=void 0;var $y6=nK(),Mo=Oz();class NB4{_exporter;_maxExportBatchSize;_maxQueueSize;_scheduledDelayMillis;_exportTimeoutMillis;_isExporting=!1;_finishedSpans=[];_timer;_shutdownOnce;_droppedSpansCount=0;constructor(q,K){if(this._exporter=q,this._maxExportBatchSize=typeof K?.maxExportBatchSize==="number"?K.maxExportBatchSize:(0,Mo.getNumberFromEnv)("OTEL_BSP_MAX_EXPORT_BATCH_SIZE")??512,this._maxQueueSize=typeof K?.maxQueueSize==="number"?K.maxQueueSize:(0,Mo.getNumberFromEnv)("OTEL_BSP_MAX_QUEUE_SIZE")??2048,this._scheduledDelayMillis=typeof K?.scheduledDelayMillis==="number"?K.scheduledDelayMillis:(0,Mo.getNumberFromEnv)("OTEL_BSP_SCHEDULE_DELAY")??5000,this._exportTimeoutMillis=typeof K?.exportTimeoutMillis==="number"?K.exportTimeoutMillis:(0,Mo.getNumberFromEnv)("OTEL_BSP_EXPORT_TIMEOUT")??30000,this._shutdownOnce=new Mo.BindOnceFuture(this._shutdown,this),this._maxExportBatchSize>this._maxQueueSize)$y6.diag.warn("BatchSpanProcessor: maxExportBatchSize must be smaller or equal to maxQueueSize, setting maxExportBatchSize to match maxQueueSize"),this._maxExportBatchSize=this._maxQueueSize}forceFlush(){if(this._shutdownOnce.isCalled)return this._shutdownOnce.promise;return this._flushAll()}onStart(q,K){}onEnd(q){if(this._shutdownOnce.isCalled)return;if((q.spanContext().traceFlags&$y6.TraceFlags.SAMPLED)===0)return;this._addToBuffer(q)}shutdown(){return this._shutdownOnce.call()}_shutdown(){return Promise.resolve().then(()=>{return this.onShutdown()}).then(()=>{return this._flushAll()}).then(()=>{return this._exporter.shutdown()})}_addToBuffer(q){if(this._finishedSpans.length>=this._maxQueueSize){if(this._droppedSpansCount===0)$y6.diag.debug("maxQueueSize reached, dropping spans");this._droppedSpansCount++;return}if(this._droppedSpansCount>0)$y6.diag.warn(`Dropped ${this._droppedSpansCount} spans because maxQueueSize reached`),this._droppedSpansCount=0;this._finishedSpans.push(q),this._maybeStartTimer()}_flushAll(){return new Promise((q,K)=>{let _=[],z=Math.ceil(this._finishedSpans.length/this._maxExportBatchSize);for(let Y=0,$=z;Y<$;Y++)_.push(this._flushOneBatch());Promise.all(_).then(()=>{q()}).catch(K)})}_flushOneBatch(){if(this._clearTimer(),this._finishedSpans.length===0)return Promise.resolve();return new Promise((q,K)=>{let _=setTimeout(()=>{K(Error("Timeout"))},this._exportTimeoutMillis);$y6.context.with((0,Mo.suppressTracing)($y6.context.active()),()=>{let z;if(this._finishedSpans.length<=this._maxExportBatchSize)z=this._finishedSpans,this._finishedSpans=[];else z=this._finishedSpans.splice(0,this._maxExportBatchSize);let Y=()=>this._exporter.export(z,(A)=>{if(clearTimeout(_),A.code===Mo.ExportResultCode.SUCCESS)q();else K(A.error??Error("BatchSpanProcessor: span export failed"))}),$=null;for(let A=0,O=z.length;A<O;A++){let w=z[A];if(w.resource.asyncAttributesPending&&w.resource.waitForAsyncAttributes)$??=[],$.push(w.resource.waitForAsyncAttributes())}if($===null)Y();else Promise.all($).then(Y,(A)=>{(0,Mo.globalErrorHandler)(A),K(A)})})})}_maybeStartTimer(){if(this._isExporting)return;let q=()=>{this._isExporting=!0,this._flushOneBatch().finally(()=>{if(this._isExporting=!1,this._finishedSpans.length>0)this._clearTimer(),this._maybeStartTimer()}).catch((K)=>{this._isExporting=!1,(0,Mo.globalErrorHandler)(K)})};if(this._finishedSpans.length>=this._maxExportBatchSize)return q();if(this._timer!==void 0)return;if(this._timer=setTimeout(()=>q(),this._scheduledDelayMillis),typeof this._timer!=="number")this._timer.unref()}_clearTimer(){if(this._timer!==void 0)clearTimeout(this._timer),this._timer=void 0}}yB4.BatchSpanProcessorBase=NB4});var CB4=m((hB4)=>{Object.defineProperty(hB4,"__esModule",{value:!0});hB4.BatchSpanProcessor=void 0;var xDz=LB4();class RB4 extends xDz.BatchSpanProcessorBase{onShutdown(){}}hB4.BatchSpanProcessor=RB4});var pB4=m((uB4)=>{Object.defineProperty(uB4,"__esModule",{value:!0});uB4.RandomIdGenerator=void 0;var IDz=8,xB4=16;class IB4{generateTraceId=bB4(xB4);generateSpanId=bB4(IDz)}uB4.RandomIdGenerator=IB4;var fR8=Buffer.allocUnsafe(xB4);function bB4(q){return function(){for(let _=0;_<q/4;_++)fR8.writeUInt32BE(Math.random()*4294967296>>>0,_*4);for(let _=0;_<q;_++)if(fR8[_]>0)break;else if(_===q-1)fR8[q-1]=1;return fR8.toString("hex",0,q)}}});var BB4=m((ZR8)=>{Object.defineProperty(ZR8,"__esModule",{value:!0});ZR8.RandomIdGenerator=ZR8.BatchSpanProcessor=void 0;var uDz=CB4();Object.defineProperty(ZR8,"BatchSpanProcessor",{enumerable:!0,get:function(){return uDz.BatchSpanProcessor}});var mDz=pB4();Object.defineProperty(ZR8,"RandomIdGenerator",{enumerable:!0,get:function(){return mDz.RandomIdGenerator}})});var RU1=m((GR8)=>{Object.defineProperty(GR8,"__esModule",{value:!0});GR8.RandomIdGenerator=GR8.BatchSpanProcessor=void 0;var gB4=BB4();Object.defineProperty(GR8,"BatchSpanProcessor",{enumerable:!0,get:function(){return gB4.BatchSpanProcessor}});Object.defineProperty(GR8,"RandomIdGenerator",{enumerable:!0,get:function(){return gB4.RandomIdGenerator}})});var dB4=m((UB4)=>{Object.defineProperty(UB4,"__esModule",{value:!0});UB4.Tracer=void 0;var N0=nK(),TR8=Oz(),gDz=sp4(),FDz=LU1(),UDz=RU1();class FB4{_sampler;_generalLimits;_spanLimits;_idGenerator;instrumentationScope;_resource;_spanProcessor;constructor(q,K,_,z){let Y=(0,FDz.mergeConfig)(K);this._sampler=Y.sampler,this._generalLimits=Y.generalLimits,this._spanLimits=Y.spanLimits,this._idGenerator=K.idGenerator||new UDz.RandomIdGenerator,this._resource=_,this._spanProcessor=z,this.instrumentationScope=q}startSpan(q,K={},_=N0.context.active()){if(K.root)_=N0.trace.deleteSpan(_);let z=N0.trace.getSpan(_);if((0,TR8.isTracingSuppressed)(_))return N0.diag.debug("Instrumentation suppressed, returning Noop Span"),N0.trace.wrapSpanContext(N0.INVALID_SPAN_CONTEXT);let Y=z?.spanContext(),$=this._idGenerator.generateSpanId(),A,O,w;if(!Y||!N0.trace.isSpanContextValid(Y))O=this._idGenerator.generateTraceId();else O=Y.traceId,w=Y.traceState,A=Y;let j=K.kind??N0.SpanKind.INTERNAL,H=(K.links??[]).map((f)=>{return{context:f.context,attributes:(0,TR8.sanitizeAttributes)(f.attributes)}}),J=(0,TR8.sanitizeAttributes)(K.attributes),M=this._sampler.shouldSample(_,O,q,j,J,H);w=M.traceState??w;let X=M.decision===N0.SamplingDecision.RECORD_AND_SAMPLED?N0.TraceFlags.SAMPLED:N0.TraceFlags.NONE,P={traceId:O,spanId:$,traceFlags:X,traceState:w};if(M.decision===N0.SamplingDecision.NOT_RECORD)return N0.diag.debug("Recording is off, propagating context in a non-recording span"),N0.trace.wrapSpanContext(P);let W=(0,TR8.sanitizeAttributes)(Object.assign(J,M.attributes));return new gDz.SpanImpl({resource:this._resource,scope:this.instrumentationScope,context:_,spanContext:P,name:q,kind:j,links:H,parentSpanContext:A,attributes:W,startTime:K.startTime,spanProcessor:this._spanProcessor,spanLimits:this._spanLimits})}startActiveSpan(q,K,_,z){let Y,$,A;if(arguments.length<2)return;else if(arguments.length===2)A=K;else if(arguments.length===3)Y=K,A=_;else Y=K,$=_,A=z;let O=$??N0.context.active(),w=this.startSpan(q,Y,O),j=N0.trace.setSpan(O,w);return N0.context.with(j,A,void 0,w)}getGeneralLimits(){return this._generalLimits}getSpanLimits(){return this._spanLimits}}UB4.Tracer=FB4});var iB4=m((lB4)=>{Object.defineProperty(lB4,"__esModule",{value:!0});lB4.MultiSpanProcessor=void 0;var QDz=Oz();class cB4{_spanProcessors;constructor(q){this._spanProcessors=q}forceFlush(){let q=[];for(let K of this._spanProcessors)q.push(K.forceFlush());return new Promise((K)=>{Promise.all(q).then(()=>{K()}).catch((_)=>{(0,QDz.globalErrorHandler)(_||Error("MultiSpanProcessor: forceFlush failed")),K()})})}onStart(q,K){for(let _ of this._spanProcessors)_.onStart(q,K)}onEnd(q){for(let K of this._spanProcessors)K.onEnd(q)}shutdown(){let q=[];for(let K of this._spanProcessors)q.push(K.shutdown());return new Promise((K,_)=>{Promise.all(q).then(()=>{K()},_)})}}lB4.MultiSpanProcessor=cB4});var tB4=m((aB4)=>{Object.defineProperty(aB4,"__esModule",{value:!0});aB4.BasicTracerProvider=aB4.ForceFlushState=void 0;var dDz=Oz(),cDz=pG6(),lDz=dB4(),nDz=EU1(),iDz=iB4(),rDz=LU1(),Ay6;(function(q){q[q.resolved=0]="resolved",q[q.timeout=1]="timeout",q[q.error=2]="error",q[q.unresolved=3]="unresolved"})(Ay6=aB4.ForceFlushState||(aB4.ForceFlushState={}));class oB4{_config;_tracers=new Map;_resource;_activeSpanProcessor;constructor(q={}){let K=(0,dDz.merge)({},(0,nDz.loadDefaultConfig)(),(0,rDz.reconfigureLimits)(q));this._resource=K.resource??(0,cDz.defaultResource)(),this._config=Object.assign({},K,{resource:this._resource});let _=[];if(q.spanProcessors?.length)_.push(...q.spanProcessors);this._activeSpanProcessor=new iDz.MultiSpanProcessor(_)}getTracer(q,K,_){let z=`${q}@${K||""}:${_?.schemaUrl||""}`;if(!this._tracers.has(z))this._tracers.set(z,new lDz.Tracer({name:q,version:K,schemaUrl:_?.schemaUrl},this._config,this._resource,this._activeSpanProcessor));return this._tracers.get(z)}forceFlush(){let q=this._config.forceFlushTimeoutMillis,K=this._activeSpanProcessor._spanProcessors.map((_)=>{return new Promise((z)=>{let Y,$=setTimeout(()=>{z(Error(`Span processor did not completed within timeout period of ${q} ms`)),Y=Ay6.timeout},q);_.forceFlush().then(()=>{if(clearTimeout($),Y!==Ay6.timeout)Y=Ay6.resolved,z(Y)}).catch((A)=>{clearTimeout($),Y=Ay6.error,z(A)})})});return new Promise((_,z)=>{Promise.all(K).then((Y)=>{let $=Y.filter((A)=>A!==Ay6.resolved);if($.length>0)z($);else _()}).catch((Y)=>z([Y]))})}shutdown(){return this._activeSpanProcessor.shutdown()}}aB4.BasicTracerProvider=oB4});var _g4=m((qg4)=>{Object.defineProperty(qg4,"__esModule",{value:!0});qg4.ConsoleSpanExporter=void 0;var hU1=Oz();class eB4{export(q,K){return this._sendSpans(q,K)}shutdown(){return this._sendSpans([]),this.forceFlush()}forceFlush(){return Promise.resolve()}_exportInfo(q){return{resource:{attributes:q.resource.attributes},instrumentationScope:q.instrumentationScope,traceId:q.spanContext().traceId,parentSpanContext:q.parentSpanContext,traceState:q.spanContext().traceState?.serialize(),name:q.name,id:q.spanContext().spanId,kind:q.kind,timestamp:(0,hU1.hrTimeToMicroseconds)(q.startTime),duration:(0,hU1.hrTimeToMicroseconds)(q.duration),attributes:q.attributes,status:q.status,events:q.events,links:q.links}}_sendSpans(q,K){for(let _ of q)console.dir(this._exportInfo(_),{depth:3});if(K)return K({code:hU1.ExportResultCode.SUCCESS})}}qg4.ConsoleSpanExporter=eB4});var Og4=m(($g4)=>{Object.defineProperty($g4,"__esModule",{value:!0});$g4.InMemorySpanExporter=void 0;var zg4=Oz();class Yg4{_finishedSpans=[];_stopped=!1;export(q,K){if(this._stopped)return K({code:zg4.ExportResultCode.FAILED,error:Error("Exporter has been stopped")});this._finishedSpans.push(...q),setTimeout(()=>K({code:zg4.ExportResultCode.SUCCESS}),0)}shutdown(){return this._stopped=!0,this._finishedSpans=[],this.forceFlush()}forceFlush(){return Promise.resolve()}reset(){this._finishedSpans=[]}getFinishedSpans(){return this._finishedSpans}}$g4.InMemorySpanExporter=Yg4});var Jg4=m((jg4)=>{Object.defineProperty(jg4,"__esModule",{value:!0});jg4.SimpleSpanProcessor=void 0;var oDz=nK(),vR8=Oz();class wg4{_exporter;_shutdownOnce;_pendingExports;constructor(q){this._exporter=q,this._shutdownOnce=new vR8.BindOnceFuture(this._shutdown,this),this._pendingExports=new Set}async forceFlush(){if(await Promise.all(Array.from(this._pendingExports)),this._exporter.forceFlush)await this._exporter.forceFlush()}onStart(q,K){}onEnd(q){if(this._shutdownOnce.isCalled)return;if((q.spanContext().traceFlags&oDz.TraceFlags.SAMPLED)===0)return;let K=this._doExport(q).catch((_)=>(0,vR8.globalErrorHandler)(_));this._pendingExports.add(K),K.finally(()=>this._pendingExports.delete(K))}async _doExport(q){if(q.resource.asyncAttributesPending)await q.resource.waitForAsyncAttributes?.();let K=await vR8.internal._export(this._exporter,[q]);if(K.code!==vR8.ExportResultCode.SUCCESS)throw K.error??Error(`SimpleSpanProcessor: span export failed (status ${K})`)}shutdown(){return this._shutdownOnce.call()}_shutdown(){return this._exporter.shutdown()}}jg4.SimpleSpanProcessor=wg4});var Wg4=m((Xg4)=>{Object.defineProperty(Xg4,"__esModule",{value:!0});Xg4.NoopSpanProcessor=void 0;class Mg4{onStart(q,K){}onEnd(q){}shutdown(){return Promise.resolve()}forceFlush(){return Promise.resolve()}}Xg4.NoopSpanProcessor=Mg4});var fg4=m((mN)=>{Object.defineProperty(mN,"__esModule",{value:!0});mN.SamplingDecision=mN.TraceIdRatioBasedSampler=mN.ParentBasedSampler=mN.AlwaysOnSampler=mN.AlwaysOffSampler=mN.NoopSpanProcessor=mN.SimpleSpanProcessor=mN.InMemorySpanExporter=mN.ConsoleSpanExporter=mN.RandomIdGenerator=mN.BatchSpanProcessor=mN.BasicTracerProvider=void 0;var aDz=tB4();Object.defineProperty(mN,"BasicTracerProvider",{enumerable:!0,get:function(){return aDz.BasicTracerProvider}});var Dg4=RU1();Object.defineProperty(mN,"BatchSpanProcessor",{enumerable:!0,get:function(){return Dg4.BatchSpanProcessor}});Object.defineProperty(mN,"RandomIdGenerator",{enumerable:!0,get:function(){return Dg4.RandomIdGenerator}});var sDz=_g4();Object.defineProperty(mN,"ConsoleSpanExporter",{enumerable:!0,get:function(){return sDz.ConsoleSpanExporter}});var tDz=Og4();Object.defineProperty(mN,"InMemorySpanExporter",{enumerable:!0,get:function(){return tDz.InMemorySpanExporter}});var eDz=Jg4();Object.defineProperty(mN,"SimpleSpanProcessor",{enumerable:!0,get:function(){return eDz.SimpleSpanProcessor}});var qfz=Wg4();Object.defineProperty(mN,"NoopSpanProcessor",{enumerable:!0,get:function(){return qfz.NoopSpanProcessor}});var Kfz=JR8();Object.defineProperty(mN,"AlwaysOffSampler",{enumerable:!0,get:function(){return Kfz.AlwaysOffSampler}});var _fz=MR8();Object.defineProperty(mN,"AlwaysOnSampler",{enumerable:!0,get:function(){return _fz.AlwaysOnSampler}});var zfz=kU1();Object.defineProperty(mN,"ParentBasedSampler",{enumerable:!0,get:function(){return zfz.ParentBasedSampler}});var Yfz=VU1();Object.defineProperty(mN,"TraceIdRatioBasedSampler",{enumerable:!0,get:function(){return Yfz.TraceIdRatioBasedSampler}});var $fz=Zs6();Object.defineProperty(mN,"SamplingDecision",{enumerable:!0,get:function(){return $fz.SamplingDecision}})});import{createHash as Ofz}from"crypto";function Gg4(){Gs6.clear(),CU1.clear()}function bH(){if(!(i6(process.env.ENABLE_BETA_TRACING_DETAILED)&&Boolean(process.env.BETA_TRACING_ENDPOINT)))return!1;return i7()||g8("tengu_trace_lantern",!1)}function rU(q,K=wfz){if(q.length<=K)return{content:q,truncated:!1};return{content:q.slice(0,K)+` |