notificationcenter

Oct 3, 2021

Changes in this version

type Message

+ Context func() context.Context

type Receiver

+ func ExtFuncReceiver(f interface{}, decs ...decoder.Decoder) Receiver

+ func ReceiverFrom(handler interface{}) Receiver

Jul 25, 2021

Changes in this version

+ type FuncPublisher func(context.Context, ...interface{}) error

+ func (f FuncPublisher) Publish(ctx context.Context, messages ...interface{}) error

+ type MultiPublisher []Publisher

+ func (p MultiPublisher) Publish(ctx context.Context, messages ...interface{}) error

May 3, 2020

Changes in this version

+ func MultiError(errors ...error) error

Mar 22, 2020

Changes in this version

+ var DefaultRegistry = NewRegistry()

+ var ErrInvalidRegisterParameter = errors.New(`invalid register parameter`)

+ var ErrUndefinedPublisherInterface = errors.New(`undefined publisher interface`)

+ var ErrUndefinedSubscriberInterface = errors.New(`undefined subscriber interface`)

+ func Publish(ctx context.Context, name string, messages ...interface{}) error

+ type ErrorHandler func(msg Message, err error)

+ type FuncReceiver func(msg Message) error

+ func (f FuncReceiver) Receive(msg Message) error

+ type ModelSubscriber struct

+ ErrorHandler ErrorHandler

+ PanicHandler PanicHandler

+ func (s *ModelSubscriber) Close() error

+ func (s *ModelSubscriber) ProcessMessage(msg Message) error

+ func (s *ModelSubscriber) Subscribe(ctx context.Context, receiver Receiver) error

+ type PanicHandler func(msg Message, recoverData interface{})

+ type Publisher interface

+ Publish func(ctx context.Context, messages ...interface{}) error

+ func PublisherByName(name string) Publisher

+ type Receiver interface

+ Receive func(msg Message) error

+ type Registry struct

+ func NewRegistry() *Registry

+ func (r *Registry) Close() error

+ func (r *Registry) Listen(ctx context.Context) (err error)

+ func (r *Registry) OnClose() <-chan bool

+ func (r *Registry) Publish(ctx context.Context, name string, messages ...interface{}) error

+ func (r *Registry) Publisher(name string) Publisher

+ func (r *Registry) Register(params ...interface{}) error

+ func (r *Registry) Subscribe(ctx context.Context, name string, receiver Receiver) error

+ func (r *Registry) Subscriber(name string) Subscriber

Jul 29, 2019

Changes in this version

+ var ErrInterfaceAlreadySubscribed = errors.New("[notificationcenter] interface already subscribed")

+ var ErrInvalidObject = errors.New("[notificationcenter] invalid handler")

+ var ErrInvalidParams = errors.New("[notificationcenter] invalid params")

+ func Close()

+ func Listen() (err error)

+ func OnClose() <-chan bool

+ func Register(name string, elem ...interface{}) error

+ func Send(name string, msg ...interface{}) error

+ func Subscribe(name string, h Handler) error

+ func Unregister(elem ...interface{}) error

+ func UnregisterAllByName(name string, _streamers, _subscribers bool)

+ func Unsubscribe(name string, h Handler) error

+ type FuncHandler func(msg Message) error

+ func (f FuncHandler) Handle(msg Message) error

+ type Handler interface

+ Handle func(msg Message) error

+ type Message interface

+ Ack func() error

+ Body func() []byte

+ ID func() string

+ type MultithreadHandler interface

+ Concurrently func() int

+ func NewMultithreadHandler(count int, handler Handler) MultithreadHandler

+ type Streamer interface

+ Send func(messages ...interface{}) error

+ func StreamByName(name string) Streamer

+ type Subscriber interface

+ Listen func() error

+ Subscribe func(h Handler) error

+ Unsubscribe func(h Handler) error

+ func SubscriberByName(name string) Subscriber