client

Oct 22, 2021

Changes in this version

+ func ExtractDistributedTracingExtension(ctx context.Context, event cloudevents.Event) context.Context

+ func GetDefaultSpanAttributes(e *cloudevents.Event, method string) []attribute.KeyValue

+ func InjectDistributedTracingExtension(ctx context.Context, event cloudevents.Event)

+ func NewClientHTTP(topt []cehttp.Option, copt []client.Option, ...) (client.Client, error)

+ type CloudEventCarrier struct

+ Extension *extensions.DistributedTracingExtension

+ func NewCloudEventCarrier() CloudEventCarrier

+ func NewCloudEventCarrierWithEvent(ctx context.Context, event cloudevents.Event) CloudEventCarrier

+ func (cec CloudEventCarrier) Get(key string) string

+ func (cec CloudEventCarrier) Keys() []string

+ func (cec CloudEventCarrier) Set(key string, value string)

+ type OTelObservabilityService struct

+ func NewOTelObservabilityService(opts ...OTelObservabilityServiceOption) *OTelObservabilityService

+ func (o OTelObservabilityService) InboundContextDecorators() []func(context.Context, binding.Message) context.Context

+ func (o OTelObservabilityService) RecordCallingInvoker(ctx context.Context, event *cloudevents.Event) (context.Context, func(errOrResult error))

+ func (o OTelObservabilityService) RecordReceivedMalformedEvent(ctx context.Context, err error)

+ func (o OTelObservabilityService) RecordRequestEvent(ctx context.Context, event cloudevents.Event) (context.Context, func(errOrResult error, event *cloudevents.Event))

+ func (o OTelObservabilityService) RecordSendingEvent(ctx context.Context, event cloudevents.Event) (context.Context, func(errOrResult error))

+ type OTelObservabilityServiceOption func(*OTelObservabilityService)

+ func WithSpanAttributesGetter(attrGetter func(cloudevents.Event) []attribute.KeyValue) OTelObservabilityServiceOption

+ func WithSpanNameFormatter(nameFormatter func(cloudevents.Event) string) OTelObservabilityServiceOption