otel

func Instrument ¶

func Instrument(
	ctx context.Context,
	serviceName, serviceVersion string,
) (func(context.Context) error, error)

Instrument bootstraps the OpenTelemetry pipeline. If it does not return an error, make sure to call shutdown for proper cleanup.

func Middleware ¶

func Middleware(next http.Handler) http.Handler

func NewComponent ¶

func NewComponent() composertypes.FlowComponent

func RegisterWith ¶

func RegisterWith(cfg config.Map) (string, error)