OpenTelemetry

bun add @effect/opentelemetry @opentelemetry/exporter-trace-otlp-http @opentelemetry/sdk-trace-base

import { NodeSdk } from "@effect/opentelemetry";
import { OTLPTraceExporter } from "@opentelemetry/exporter-trace-otlp-http";
import { BatchSpanProcessor } from "@opentelemetry/sdk-trace-base";

const NodeSdkLive = NodeSdk.layer(() => ({
  resource: { serviceName: "my-api" },
  spanProcessor: new BatchSpanProcessor(
    new OTLPTraceExporter({
      url: "http://localhost:4318/v1/traces",
    }),
  ),
}));

const AppLive = Layer.mergeAll(UsersRepoLive).pipe(
  Layer.provideMerge(NodeSdkLive),
);

export const runtime = ManagedRuntime.make(AppLive);
export const effectProcedure = makeEffectORPC(runtime);

const getUser = effectProcedure
  .traced("users.get_by_id")
  .input(z.object({ id: z.string() }))
  .effect(function* ({ input }) {
    const usersRepo = yield* UsersRepo;
    return yield* usersRepo.findById(input.id);
  });

cd examples/hono
docker compose up