Versions in this module Expand all Collapse all v2 v2.6.0 Apr 26, 2021 Changes in this version + var NewDefault = NewHTTP + var NewObserved = New + func DefaultIDToUUIDIfNotSet(ctx context.Context, event event.Event) event.Event + func DefaultTimeToNowIfNotSet(ctx context.Context, event event.Event) event.Event + type Client interface + Request func(ctx context.Context, event event.Event) (*event.Event, protocol.Result) + Send func(ctx context.Context, event event.Event) protocol.Result + StartReceiver func(ctx context.Context, fn interface{}) error + func New(obj interface{}, opts ...Option) (Client, error) + func NewHTTP(opts ...http.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 ObservabilityService interface + InboundContextDecorators func() []func(context.Context, binding.Message) context.Context + RecordCallingInvoker func(ctx context.Context, event *event.Event) (context.Context, func(errOrResult error)) + RecordReceivedMalformedEvent func(ctx context.Context, err error) + RecordRequestEvent func(ctx context.Context, event event.Event) (context.Context, func(errOrResult error, event *event.Event)) + RecordSendingEvent func(ctx context.Context, event event.Event) (context.Context, func(errOrResult error)) + type Option func(interface{}) error + func WithEventDefaulter(fn EventDefaulter) Option + func WithForceBinary() Option + func WithForceStructured() Option + func WithInboundContextDecorator(dec func(context.Context, binding.Message) context.Context) Option + func WithObservabilityService(service ObservabilityService) Option + func WithPollGoroutines(pollGoroutines int) Option + func WithTimeNow() Option + func WithTracePropagation() Option + func WithUUIDs() Option + type ReceiveFull func(context.Context, event.Event) protocol.Result