@effect/rpc
Advanced tools
Comparing version 0.11.1 to 0.12.0
@@ -96,3 +96,4 @@ 'use strict'; | ||
spanId: span.spanId, | ||
traceId: span.traceId | ||
traceId: span.traceId, | ||
sampled: span.sampled | ||
}, | ||
@@ -110,3 +111,4 @@ hash, | ||
spanId: span.spanId, | ||
traceId: span.traceId | ||
traceId: span.traceId, | ||
sampled: span.sampled | ||
}, | ||
@@ -113,0 +115,0 @@ hash, |
@@ -96,3 +96,4 @@ 'use strict'; | ||
spanId: span.spanId, | ||
traceId: span.traceId | ||
traceId: span.traceId, | ||
sampled: span.sampled | ||
}, | ||
@@ -110,3 +111,4 @@ hash, | ||
spanId: span.spanId, | ||
traceId: span.traceId | ||
traceId: span.traceId, | ||
sampled: span.sampled | ||
}, | ||
@@ -113,0 +115,0 @@ hash, |
@@ -42,2 +42,3 @@ /** | ||
readonly spanId: string; | ||
readonly sampled: boolean; | ||
} | ||
@@ -44,0 +45,0 @@ /** |
@@ -63,3 +63,4 @@ import * as Effect from 'effect/Effect'; | ||
spanId: span.spanId, | ||
traceId: span.traceId | ||
traceId: span.traceId, | ||
sampled: span.sampled | ||
}, | ||
@@ -77,3 +78,4 @@ hash, | ||
spanId: span.spanId, | ||
traceId: span.traceId | ||
traceId: span.traceId, | ||
sampled: span.sampled | ||
}, | ||
@@ -80,0 +82,0 @@ hash, |
import * as Schema from '@effect/schema/Schema'; | ||
import { identity } from 'effect'; | ||
import * as Cause from 'effect/Cause'; | ||
import * as Context from 'effect/Context'; | ||
import * as Effect from 'effect/Effect'; | ||
@@ -12,2 +11,3 @@ import * as Either from 'effect/Either'; | ||
import { Scope } from 'effect/Scope'; | ||
import * as Tracer from 'effect/Tracer'; | ||
import { RpcNotFound, RpcTransportError } from '../Error/dist/effect-rpc-Error.esm.js'; | ||
@@ -83,8 +83,7 @@ import { encode, decode } from './codec.esm.js'; | ||
}), Effect.withSpan(`${router.options.spanPrefix}.${request._tag}`, { | ||
parent: { | ||
_tag: "ExternalSpan", | ||
parent: Tracer.externalSpan({ | ||
spanId: request.spanId, | ||
traceId: request.traceId, | ||
context: Context.empty() | ||
} | ||
sampled: request.sampled | ||
}) | ||
})); | ||
@@ -91,0 +90,0 @@ if (!hasSetup) { |
{ | ||
"name": "@effect/rpc", | ||
"version": "0.11.1", | ||
"version": "0.12.0", | ||
"description": "", | ||
@@ -33,8 +33,8 @@ "main": "dist/effect-rpc.cjs.js", | ||
"devDependencies": { | ||
"@effect/schema": "^0.42.0", | ||
"effect": "2.0.0-next.47" | ||
"@effect/schema": "^0.43.0", | ||
"effect": "2.0.0-next.48" | ||
}, | ||
"peerDependencies": { | ||
"@effect/schema": "^0.42.0", | ||
"effect": "2.0.0-next.47" | ||
"@effect/schema": "^0.43.0", | ||
"effect": "2.0.0-next.48" | ||
}, | ||
@@ -41,0 +41,0 @@ "files": [ |
@@ -8,7 +8,6 @@ 'use strict'; | ||
var Layer = require('effect/Layer'); | ||
var server = require('../../dist/server-245017bb.cjs.dev.js'); | ||
var server = require('../../dist/server-4e6564df.cjs.dev.js'); | ||
require('@effect/schema/Schema'); | ||
require('effect'); | ||
require('effect/Cause'); | ||
require('effect/Context'); | ||
require('effect/Either'); | ||
@@ -18,2 +17,3 @@ require('effect/Option'); | ||
require('effect/Scope'); | ||
require('effect/Tracer'); | ||
require('../../Error/dist/effect-rpc-Error.cjs.dev.js'); | ||
@@ -20,0 +20,0 @@ require('../../SchemaC/dist/effect-rpc-SchemaC.cjs.dev.js'); |
@@ -8,7 +8,6 @@ 'use strict'; | ||
var Layer = require('effect/Layer'); | ||
var server = require('../../dist/server-f1eeb56c.cjs.prod.js'); | ||
var server = require('../../dist/server-8b45d4f1.cjs.prod.js'); | ||
require('@effect/schema/Schema'); | ||
require('effect'); | ||
require('effect/Cause'); | ||
require('effect/Context'); | ||
require('effect/Either'); | ||
@@ -18,2 +17,3 @@ require('effect/Option'); | ||
require('effect/Scope'); | ||
require('effect/Tracer'); | ||
require('../../Error/dist/effect-rpc-Error.cjs.prod.js'); | ||
@@ -20,0 +20,0 @@ require('../../SchemaC/dist/effect-rpc-SchemaC.cjs.prod.js'); |
@@ -5,7 +5,6 @@ 'use strict'; | ||
var server = require('../../dist/server-245017bb.cjs.dev.js'); | ||
var server = require('../../dist/server-4e6564df.cjs.dev.js'); | ||
require('@effect/schema/Schema'); | ||
require('effect'); | ||
require('effect/Cause'); | ||
require('effect/Context'); | ||
require('effect/Effect'); | ||
@@ -18,2 +17,3 @@ require('effect/Either'); | ||
require('effect/Scope'); | ||
require('effect/Tracer'); | ||
require('../../Error/dist/effect-rpc-Error.cjs.dev.js'); | ||
@@ -20,0 +20,0 @@ require('../../SchemaC/dist/effect-rpc-SchemaC.cjs.dev.js'); |
@@ -5,7 +5,6 @@ 'use strict'; | ||
var server = require('../../dist/server-f1eeb56c.cjs.prod.js'); | ||
var server = require('../../dist/server-8b45d4f1.cjs.prod.js'); | ||
require('@effect/schema/Schema'); | ||
require('effect'); | ||
require('effect/Cause'); | ||
require('effect/Context'); | ||
require('effect/Effect'); | ||
@@ -18,2 +17,3 @@ require('effect/Either'); | ||
require('effect/Scope'); | ||
require('effect/Tracer'); | ||
require('../../Error/dist/effect-rpc-Error.cjs.prod.js'); | ||
@@ -20,0 +20,0 @@ require('../../SchemaC/dist/effect-rpc-SchemaC.cjs.prod.js'); |
@@ -171,3 +171,4 @@ import type * as Schema from "@effect/schema/Schema" | ||
spanId: span.spanId, | ||
traceId: span.traceId | ||
traceId: span.traceId, | ||
sampled: span.sampled | ||
}, | ||
@@ -196,3 +197,4 @@ hash, | ||
spanId: span.spanId, | ||
traceId: span.traceId | ||
traceId: span.traceId, | ||
sampled: span.sampled | ||
}, | ||
@@ -199,0 +201,0 @@ hash, |
import * as Schema from "@effect/schema/Schema" | ||
import { identity } from "effect" | ||
import * as Cause from "effect/Cause" | ||
import * as Context from "effect/Context" | ||
import type * as Context from "effect/Context" | ||
import * as Effect from "effect/Effect" | ||
@@ -13,3 +13,3 @@ import * as Either from "effect/Either" | ||
import { Scope } from "effect/Scope" | ||
import type * as Tracer from "effect/Tracer" | ||
import * as Tracer from "effect/Tracer" | ||
import { type RpcEncodeFailure, type RpcError, RpcNotFound, RpcTransportError } from "../Error" | ||
@@ -169,8 +169,7 @@ import type { RpcRequest, RpcResponse } from "../Resolver" | ||
Effect.withSpan(`${router.options.spanPrefix}.${request._tag}`, { | ||
parent: { | ||
_tag: "ExternalSpan", | ||
parent: Tracer.externalSpan({ | ||
spanId: request.spanId, | ||
traceId: request.traceId, | ||
context: Context.empty() | ||
} | ||
sampled: request.sampled | ||
}) | ||
}) | ||
@@ -177,0 +176,0 @@ ) |
@@ -48,2 +48,3 @@ /** | ||
readonly spanId: string | ||
readonly sampled: boolean | ||
} | ||
@@ -50,0 +51,0 @@ |
@@ -35,3 +35,11 @@ { | ||
"incremental": true, | ||
"removeComments": false | ||
"removeComments": false, | ||
"paths": { | ||
"@effect/rpc": [ | ||
"./index.ts" | ||
], | ||
"@effect/rpc/*": [ | ||
"./*.ts" | ||
] | ||
} | ||
}, | ||
@@ -38,0 +46,0 @@ "include": [ |
Sorry, the diff of this file is not supported yet
License Policy Violation
LicenseThis package is not allowed per your license policy. Review the package's license to ensure compliance.
Found 1 instance in 1 package
License Policy Violation
LicenseThis package is not allowed per your license policy. Review the package's license to ensure compliance.
Found 1 instance in 1 package
246262
6474