Versions in this module Expand all Collapse all v2 v2.0.2 Apr 16, 2020 v2.0.1 Apr 16, 2020 Changes in this version + var LatencyMs = stats.Float64("cloudevents.io/sdk-go/client/latency", ...) + var LatencyView = &view.View + func DefaultIDToUUIDIfNotSet(ctx context.Context, event event.Event) event.Event + func DefaultTimeToNowIfNotSet(ctx context.Context, event event.Event) event.Event + func EventTraceAttributes(e event.EventReader) []trace.Attribute + func TraceSpan(ctx context.Context, e event.Event) (context.Context, *trace.Span) + type Client interface + Request func(ctx context.Context, event event.Event) (*event.Event, error) + Send func(ctx context.Context, event event.Event) error + StartReceiver func(ctx context.Context, fn interface{}) error + func New(obj interface{}, opts ...Option) (Client, error) + func NewDefault() (Client, error) + func NewObserved(protocol interface{}, opts ...Option) (Client, error) + type EventDefaulter func(ctx context.Context, event event.Event) event.Event + func NewDefaultDataContentTypeIfNotSet(contentType string) EventDefaulter + type EventReceiver struct + func NewHTTPReceiveHandler(ctx context.Context, p *thttp.Protocol, fn interface{}) (*EventReceiver, error) + func (r *EventReceiver) ServeHTTP(rw http.ResponseWriter, req *http.Request) + type Invoker interface + Invoke func(context.Context, binding.Message, protocol.ResponseFn) error + IsReceiver func() bool + IsResponder func() bool + type Option func(interface{}) error + func WithEventDefaulter(fn EventDefaulter) Option + func WithForceBinary() Option + func WithForceStructured() Option + func WithTimeNow() Option + func WithTracePropagation() Option + func WithUUIDs() Option + type ReceiveFull func(context.Context, event.Event) protocol.Result
Go to main page