msg

Aug 1, 2020

Changes in this version

+ var SubjectNameRegexp = regexp.MustCompile(`^[a-zA-Z0-9-_]+(\.[a-zA-Z0-9-_]+)*$`)

+ func AssertMsgType(spec MsgSpec, msg interface{}) error

+ type MsgAsyncPublisher interface

+ PublishAsync func(ctx context.Context, spec MsgSpec, msg interface{}, cb func(error)) error

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

+ func (fn MsgAsyncPublisherFunc) Publish(ctx context.Context, spec MsgSpec, msg interface{}) error

+ func (fn MsgAsyncPublisherFunc) PublishAsync(ctx context.Context, spec MsgSpec, msg interface{}, cb func(error)) error

+ func NewMsgAsyncPublisherWithMWs(publisher MsgAsyncPublisher, mws ...MsgAsyncPublisherMiddleware) MsgAsyncPublisherFunc

+ type MsgAsyncPublisherMiddleware func(MsgAsyncPublisherFunc) MsgAsyncPublisherFunc

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

+ type MsgMiddleware func(spec MsgSpec, queue string, handler MsgHandler) MsgHandler

+ type MsgPublisher interface

+ Publish func(ctx context.Context, spec MsgSpec, msg interface{}) error

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

+ func (fn MsgPublisherFunc) Publish(ctx context.Context, spec MsgSpec, msg interface{}) error

+ func NewMsgPublisherWithMWs(publisher MsgPublisher, mws ...MsgPublisherMiddleware) MsgPublisherFunc

+ type MsgPublisherMiddleware func(MsgPublisherFunc) MsgPublisherFunc

+ type MsgSpec interface

+ MsgType func() reflect.Type

+ MsgValue func() interface{}

+ NewMsg func() interface{}

+ SubjectName func() string

+ func MustMsgSpec(subjectName string, newMsg func() interface{}) MsgSpec

+ func MustRawDataMsgSpec(subjectName string) MsgSpec

+ func NewMsgSpec(subjectName string, newMsg func() interface{}) (MsgSpec, error)

+ func NewRawDataMsgSpec(subjectName string) (MsgSpec, error)

+ type MsgSubscriber interface

+ Subscribe func(spec MsgSpec, queue string, handler MsgHandler, opts ...interface{}) error

+ type MsgSubscriberFunc func(MsgSpec, string, MsgHandler, ...interface{}) error

+ func (fn MsgSubscriberFunc) Subscribe(spec MsgSpec, queue string, handler MsgHandler, opts ...interface{}) error

+ type MsgSubscriberWithMWs struct

+ func NewMsgSubscriberWithMWs(subscriber MsgSubscriber, mws ...MsgMiddleware) *MsgSubscriberWithMWs

+ func (subscriber *MsgSubscriberWithMWs) Subscribe(spec MsgSpec, queue string, handler MsgHandler, opts ...interface{}) error