function

May 27, 2022

Changes in this version

+ var ALL = fmt.Sprintf("%U__ALL__", '\\')

+ var DROP = fmt.Sprintf("%U__DROP__", '\\')

+ func Start(ctx context.Context, handler Handle, opts ...Option)

+ type Handle func(ctx context.Context, key, msg []byte) (Messages, error)

+ type Message struct

+ Key []byte

+ Value []byte

+ func MessageTo(to string, value []byte) Message

+ func MessageToAll(value []byte) Message

+ func MessageToDrop() Message

+ type Messages []Message

+ func MessagesBuilder() Messages

+ func (m Messages) Append(msg Message) Messages

+ func (m Messages) Items() []Message

+ type Option interface

+ func WithDrainTimeout(f time.Duration) Option