eventBus

Aug 31, 2020

Changes in this version

+ type BeforeCallback = func(topic string, ctx *memstore.Store, events ...interface{}) error

Aug 31, 2020

Changes in this version

+ type Cycle interface

+ SetCycleAfterAll func(topic string, callback CycleCallback)

+ SetCycleAfterSync func(topic string, callback CycleCallback)

+ SetCycleBefore func(topic string, callback CycleCallback)

+ SetCycleError func(topic string, onError ErrorCallback)

+ type CycleCallback = func(topic string, ctx context.Context, events ...interface{})

+ type ErrorCallback = func(topic string, ctx context.Context, err error, events ...interface{})

Jul 30, 2020

Changes in this version

type Controller

+ CloseTopic func(topic string)

Jul 29, 2020

Changes in this version

+ type Callback interface

+ Callback func(topic string, events ...interface{}) error

+ type CallbackFunc = func(topic string, events ...interface{}) error

+ type Controller interface

+ SetTransaction func(topic string, tr bool)

+ WaitAsync func()

+ type EventBus interface

+ func NewBus(logger *golog.Logger) EventBus

+ type Publisher interface

+ Publish func(topic string, events ...interface{})

+ PublishSync func(topic string, events ...interface{}) error

+ PublishSyncNoWait func(topic string, events ...interface{}) error

+ type Subscriber interface

+ Subscribe func(topic string, callback Callback) error

+ SubscribeAsync func(topic string, callback Callback) error

+ UnSubscribe func(topic string, callback Callback)

+ UnSubscribeAll func(callback Callback)