haro

Jun 17, 2022

Changes in this version

+ type SubscriberConfigFunc func(*subscriberConfig)

Mar 31, 2022

Changes in this version

+ type Topic interface

+ Publish func(context.Context, Payload) error

+ Subscribe func(sub Subscriber[Payload])

+ func DeclareTopic(cfgFuncs ...ConfigFunc) Topic[Payload]

Sep 25, 2020

Changes in this version

type ConfigFunc

+ func OnSuccess(onSuccess func()) ConfigFunc

Jun 24, 2020

Changes in this version

+ var ErrPayloadTypeMismatch = errors.New("Mismatch parameter between subscriber and event payload")

+ var ErrSubscriberInvalidFirstParameter = errors.New("Subscriber should have `context.Context` as the first parameter")

+ var ErrSubscriberInvalidFirstReturnType = errors.New("Subscriber should have return type `error`")

+ var ErrSubscriberInvalidParameters = errors.New("Subscriber should have exactly 2 parameters")

+ var ErrSubscriberInvalidReturnTypes = errors.New("Subscriber should have 1 return type")

+ var ErrSubscriberNotAFunction = errors.New("Subscriber should be a function")

+ type ConfigFunc func(*config)

+ func DelayRetry(delay time.Duration) ConfigFunc

+ func OnError(onError func(error)) ConfigFunc

+ func Retry(count int) ConfigFunc

+ type Pubsub interface

+ DeclareTopic func(topicName string, payload interface{}) error

+ Publish func(ctx context.Context, topicName string, payload interface{}) error

+ RegisterSubscriber func(topicName string, callback Subscriber, configs ...ConfigFunc) error

+ func New() Pubsub

+ type Subscriber interface