@effect/opentelemetry
Advanced tools
Comparing version 0.42.5 to 0.42.6
@@ -13,2 +13,3 @@ "use strict"; | ||
var Effect = _interopRequireWildcard(require("effect/Effect")); | ||
var _Function = require("effect/Function"); | ||
var Layer = _interopRequireWildcard(require("effect/Layer")); | ||
@@ -47,5 +48,5 @@ function _getRequireWildcardCache(e) { if ("function" != typeof WeakMap) return null; var r = new WeakMap(), t = new WeakMap(); return (_getRequireWildcardCache = function (e) { return e ? t : r; })(e); } | ||
exports.layer = layer; | ||
const layerFromEnv = additionalAttributes => Layer.effect(Resource, Effect.gen(function* (_) { | ||
const serviceName = yield* _(_effect.Config.string("OTEL_SERVICE_NAME"), _effect.Config.option, Effect.orDie); | ||
const attributes = yield* _(_effect.Config.string("OTEL_RESOURCE_ATTRIBUTES"), _effect.Config.withDefault(""), _effect.Config.map(s => { | ||
const layerFromEnv = additionalAttributes => Layer.effect(Resource, Effect.gen(function* () { | ||
const serviceName = yield* (0, _Function.pipe)(_effect.Config.string("OTEL_SERVICE_NAME"), _effect.Config.option, Effect.orDie); | ||
const attributes = yield* (0, _Function.pipe)(_effect.Config.string("OTEL_RESOURCE_ATTRIBUTES"), _effect.Config.withDefault(""), _effect.Config.map(s => { | ||
const attrs = s.split(","); | ||
@@ -52,0 +53,0 @@ return Arr.reduce(attrs, {}, (acc, attr) => { |
@@ -10,2 +10,3 @@ /** | ||
import * as Effect from "effect/Effect"; | ||
import { pipe } from "effect/Function"; | ||
import * as Layer from "effect/Layer"; | ||
@@ -37,5 +38,5 @@ /** | ||
*/ | ||
export const layerFromEnv = additionalAttributes => Layer.effect(Resource, Effect.gen(function* (_) { | ||
const serviceName = yield* _(Config.string("OTEL_SERVICE_NAME"), Config.option, Effect.orDie); | ||
const attributes = yield* _(Config.string("OTEL_RESOURCE_ATTRIBUTES"), Config.withDefault(""), Config.map(s => { | ||
export const layerFromEnv = additionalAttributes => Layer.effect(Resource, Effect.gen(function* () { | ||
const serviceName = yield* pipe(Config.string("OTEL_SERVICE_NAME"), Config.option, Effect.orDie); | ||
const attributes = yield* pipe(Config.string("OTEL_RESOURCE_ATTRIBUTES"), Config.withDefault(""), Config.map(s => { | ||
const attrs = s.split(","); | ||
@@ -42,0 +43,0 @@ return Arr.reduce(attrs, {}, (acc, attr) => { |
{ | ||
"name": "@effect/opentelemetry", | ||
"version": "0.42.5", | ||
"version": "0.42.6", | ||
"description": "OpenTelemetry integration for Effect", | ||
@@ -20,3 +20,3 @@ "license": "MIT", | ||
"@opentelemetry/semantic-conventions": "^1.24.1", | ||
"effect": "^3.12.5" | ||
"effect": "^3.12.6" | ||
}, | ||
@@ -23,0 +23,0 @@ "peerDependenciesMeta": { |
@@ -17,2 +17,3 @@ /** | ||
import * as Effect from "effect/Effect" | ||
import { pipe } from "effect/Function" | ||
import * as Layer from "effect/Layer" | ||
@@ -71,5 +72,5 @@ | ||
Resource, | ||
Effect.gen(function*(_) { | ||
const serviceName = yield* _(Config.string("OTEL_SERVICE_NAME"), Config.option, Effect.orDie) | ||
const attributes = yield* _( | ||
Effect.gen(function*() { | ||
const serviceName = yield* pipe(Config.string("OTEL_SERVICE_NAME"), Config.option, Effect.orDie) | ||
const attributes = yield* pipe( | ||
Config.string("OTEL_RESOURCE_ATTRIBUTES"), | ||
@@ -76,0 +77,0 @@ Config.withDefault(""), |
Sorry, the diff of this file is not supported yet
Sorry, the diff of this file is not supported yet
Sorry, the diff of this file is not supported yet
193238
2904