Function layerTracerProvider

packages/opentelemetry/src/NodeSdk.ts:42–70

(
  processor: SpanProcessor | NonEmptyReadonlyArray<SpanProcessor>,
  config?: Omit<TracerConfig, "resource"> & {
    readonly shutdownTimeout?: DurationInput | undefined
  }
)

 * @category layers
 */
export const layerTracerProvider = (
  processor: SpanProcessor | NonEmptyReadonlyArray<SpanProcessor>,
  config?: Omit<TracerConfig, "resource"> & {
    readonly shutdownTimeout?: DurationInput | undefined
  }
): Layer.Layer<Tracer.OtelTracerProvider, never, Resource.Resource> =>
  Layer.scoped(
    Tracer.OtelTracerProvider,
    Effect.flatMap(
      Resource.Resource,
      (resource) =>
        Effect.acquireRelease(
          Effect.sync(() => {
            const provider = new NodeTracerProvider({
              ...(config ?? undefined),
              resource,
              spanProcessors: Array.isArray(processor) ? (processor as any) : [processor]
            })
            return provider
          }),
          (provider) =>
            Effect.promise(() => provider.forceFlush().then(() => provider.shutdown())).pipe(
              Effect.ignoreLogged,
              Effect.interruptible,
              Effect.timeoutOption(config?.shutdownTimeout ?? 3000)
            )
        )
    )
  )

/**
 * @since 1.0.0