broker

May 23, 2022

Changes in this version

+ func Consume(ctx context.Context, topic string) <-chan Message

+ func Publish(ctx context.Context, topic string, msg []byte) (string, error)

+ func Register(i Interface) error

+ type Interface interface

+ Consume func(ctx context.Context, topic string) <-chan Message

+ Publish func(ctx context.Context, topic string, msg []byte) (string, error)

+ type Message interface

+ Commit func() error

+ Payload func() []byte