Function annotateCosmosResponse

packages/infra/src/otel.ts:84–95

(m: {
  readonly requestCharge?: number | undefined
  readonly returnedRows?: number | undefined
  readonly responseBytes?: number | undefined
  readonly statusCode?: number | undefined
})

    `${a.operation} ${a.collection}`,
    { attributes: dbAttributes(a), kind: "client" as const },
    { captureStackTrace: false }
  )

/**
 * Annotate the current span with OTel-semconv database attributes.
 *
 * Use when the caller already owns the span (e.g. a repository) and the
 * adapter should only contribute db.* semconv attrs without opening a child.
 * Annotates before running so attrs persist even on failure.
 * No-op if there is no current span.
 */
export const annotateDb = (a: DbSpanOptions) => <A, E, R>(self: Effect.Effect<A, E, R>): Effect.Effect<A, E, R> =>
  Effect.flatMap(Effect.annotateCurrentSpan(dbAttributes(a)), () => self.pipe(timeDbOperation(a)))

/** Annotate the current span with response metrics from a DB call. */