batch

Documentation

Index

• type DispatchHandler
• type Manager
  • func NewBatchManager(ctx context.Context, ni sysmessaging.LocalNodeInfo, di database.Plugin, ...) (Manager, error)
• type Options

Types

type DispatchHandler

type DispatchHandler func(context.Context, *fftypes.Batch, []*fftypes.Bytes32) error

type Manager

type Manager interface {
	RegisterDispatcher(msgTypes []fftypes.MessageType, handler DispatchHandler, batchOptions Options)
	NewMessages() chan<- int64
	Start() error
	Close()
	WaitStop()
}

func NewBatchManager

func NewBatchManager(ctx context.Context, ni sysmessaging.LocalNodeInfo, di database.Plugin, dm data.Manager) (Manager, error)

type Options

type Options struct {
	BatchMaxSize   uint
	BatchTimeout   time.Duration
	DisposeTimeout time.Duration
}