batch

Documentation

Index

• type Manager
  • func NewManager(handler messageOutbound) *Manager
  • func (bm *Manager) Put(msg *Message, opts ...Option) error
  • func (bm *Manager) Start() error
  • func (bm *Manager) Stop() error
• type Message
• type Option
  • func WithInterval(t time.Duration) Option
  • func WithSizeLimit(limit uint64) Option

Types

type Manager

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

Manager is the manager of batch component

func NewManager

func NewManager(handler messageOutbound) *Manager

NewManager creates a new Manager with callback

func (*Manager) Put

func (bm *Manager) Put(msg *Message, opts ...Option) error

Put puts a batchmessage into the Manager

func (*Manager) Start

func (bm *Manager) Start() error

Start start the Manager

func (*Manager) Stop

func (bm *Manager) Stop() error

Stop stops the Manager

type Message

type Message struct {
	ChainID uint32
	Data    proto.Message
	Target  *peer.AddrInfo // target of broadcast msg is nil
	// contains filtered or unexported fields
}

Message is the message to be batching

type Option

type Option func(cfg *writerConfig)

Option sets parameter for batch

func WithInterval

func WithInterval(t time.Duration) Option

WithInterval sets batch with time interval

func WithSizeLimit

func WithSizeLimit(limit uint64) Option

WithSizeLimit sets batch with limited size