internal

Documentation

Index

• Variables
• func MessageUnwrapperHandler(fn interface{}) msgqueue.HandlerFunc
• func WrapMessage(msg *msgqueue.Message) *msgqueue.Message
• type Batcher
  • func NewBatcher(limit int, fn func([]*msgqueue.Message)) *Batcher
  • func (b *Batcher) Add(msg *msgqueue.Message)
  • func (b *Batcher) Close() error
  • func (b *Batcher) Wait() error

Variables

var ErrNotSupported = errors.New("not supported")

Functions

func MessageUnwrapperHandler

func MessageUnwrapperHandler(fn interface{}) msgqueue.HandlerFunc

func WrapMessage

func WrapMessage(msg *msgqueue.Message) *msgqueue.Message

Types

type Batcher

type Batcher struct {
	// contains filtered or unexported fields
}

func NewBatcher

func NewBatcher(limit int, fn func([]*msgqueue.Message)) *Batcher

func (*Batcher) Add

func (b *Batcher) Add(msg *msgqueue.Message)

func (*Batcher) Close

func (b *Batcher) Close() error

func (*Batcher) Wait

func (b *Batcher) Wait() error