pubsub

Feb 7, 2023

Changes in this version

type MessageReflection

+ func (r MessageReflection) String() string

Dec 14, 2021

Changes in this version

+ type Publisher interface

+ Publish func(ctx context.Context, topic Topic, m interface{}) error

+ type Shutdowner interface

+ Shutdown func(ctx context.Context) error

+ type Subscriber interface

+ Subscribe func(ctx context.Context, topic Topic, handler Handler, option ...SubscribeOption) (Subscription, error)

Nov 22, 2021

Changes in this version

+ var ErrHandlerInputLengthMissMatch = errors.New("handler function must have exactly three input arguments")

+ var ErrHandlerInputNoContext = errors.New("first argument of handler must be a context")

+ var ErrHandlerInputNoTopic = errors.New("second argument of handler must be a topic")

+ var ErrHandlerNotAFunction = errors.New("provided handler is not a function")

+ var ErrHandlerOutputLengthMissMatch = errors.New("handler must have exactly one output argument")

+ var ErrHandlerOutputNoError = errors.New("handler output must implements `error` interface")

+ var ErrNilHandler = errors.New("handler function can not be nil")

+ type Broker interface

+ Publish func(ctx context.Context, topic Topic, m interface{}) error

+ Shutdown func(ctx context.Context) error

+ Subscribe func(ctx context.Context, topic Topic, subscriber Handler, ...) (Subscription, error)

+ type Handler interface

+ Deliver func(ctx context.Context, topic Topic, message interface{}) error

+ Reflect func() MessageReflection

+ func NewHandler(handlerFunc interface{}) Handler

+ type MessageReflection struct

+ Handler reflect.Value

+ MessageKind reflect.Kind

+ MessageType reflect.Type

+ func (r MessageReflection) Accepts(m interface{}) bool

+ type Metadata interface

+ Get func(key interface{}) interface{}

+ Set func(key, val interface{}) Metadata

+ func NewMetadata() Metadata

+ type StoppableSubscription interface

+ Context func() context.Context

+ Stop func()

+ func NewStoppableSubscription(ctx context.Context, id string, topic Topic, handler Handler, ...) (StoppableSubscription, error)

+ type SubscribeOption func(*SubscribeOptions)

+ func DisableAutoAck() SubscribeOption

+ func SubscribeMetadata(meta Metadata) SubscribeOption

+ func WithGroup(name string) SubscribeOption

+ type SubscribeOptions struct

+ AutoAck bool

+ Group string

+ Metadata Metadata

+ func NewSubscribeOptions(opts ...SubscribeOption) SubscribeOptions

+ type Subscription interface

+ Handler func() Handler

+ ID func() string

+ Options func() SubscribeOptions

+ Topic func() Topic

+ Unsubscribe func() error

+ func NewSubscription(id string, topic Topic, handler Handler, unsub UnsubscribeFunc, ...) Subscription

+ type Topic string

+ func (t Topic) String() string

+ type UnsubscribeFunc func() error