transport

type AnyEndpoint ¶

type AnyEndpoint func(ctx context.Context, request interface{}) (interface{}, error)

type Decoder ¶ added in v0.4.0

type Decoder[T any] func(ctx context.Context, payload []byte) (T, error)

Decoder is the inverse of Encoder: given a payload (and any broker metadata the transport extracted into ctx) it returns the decoded value or an error.

type EmptyResEndpoint ¶

type EmptyResEndpoint[I any] func(ctx context.Context, request I) error

type Encoder ¶ added in v0.4.0

type Encoder[T any] func(ctx context.Context, v T) ([]byte, error)

Encoder turns an application value into the byte payload that goes on the wire. Returns an error if the value cannot be marshalled.

type Endpoint ¶

type Endpoint[I, O any] func(ctx context.Context, request I) (O, error)

type ErrorHandler ¶

type ErrorHandler interface {
	Handle(ctx context.Context, err error)
}

type Handler ¶ added in v0.4.0

type Handler[T any] interface {
	Handle(ctx context.Context, event T) error
}

Handler is implemented by application code that consumes events. Returning a non-nil error signals the transport to nack / retry the message according to its semantics.

type HandlerFunc ¶ added in v0.4.0

type HandlerFunc[T any] func(ctx context.Context, event T) error

HandlerFunc adapts a plain function to the Handler interface.

func (f HandlerFunc[T]) Handle(ctx context.Context, event T) error