internal

package
v1.2.2 Latest Latest
Warning

This package is not in the latest version of its module.

Go to latest
Published: May 29, 2017 License: BSD-2-Clause Imports: 4 Imported by: 0

Documentation

Index

Constants

This section is empty.

Variables

View Source
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) SetLimit added in v1.0.7

func (b *Batcher) SetLimit(limit int)

func (*Batcher) Wait

func (b *Batcher) Wait() error

Jump to

Keyboard shortcuts

? : This menu
/ : Search site
f or F : Jump to
y or Y : Canonical URL