batch

Documentation

Index

• type DispatchHandler
• type DispatchState
• type DispatcherOptions
• type FlushStatus
• type Manager
  • func NewBatchManager(ctx context.Context, ni sysmessaging.LocalNodeInfo, di database.Plugin, ...) (Manager, error)
• type ManagerStatus
• type ProcessorStatus

Types

type DispatchHandler

type DispatchHandler func(context.Context, *DispatchState) error

type DispatchState

type DispatchState struct {
	Persisted fftypes.BatchPersisted
	Messages  []*fftypes.Message
	Data      fftypes.DataArray
	Pins      []*fftypes.Bytes32
}

type DispatcherOptions

type DispatcherOptions struct {
	BatchType      fftypes.BatchType
	BatchMaxSize   uint
	BatchMaxBytes  int64
	BatchTimeout   time.Duration
	DisposeTimeout time.Duration
}

type FlushStatus

type FlushStatus struct {
	LastFlushTime        *fftypes.FFTime `json:"lastFlushStartTime"`
	Flushing             *fftypes.UUID   `json:"flushing,omitempty"`
	Blocked              bool            `json:"blocked"`
	LastFlushError       string          `json:"lastFlushError,omitempty"`
	LastFlushErrorTime   *fftypes.FFTime `json:"lastFlushErrorTime,omitempty"`
	AverageBatchBytes    int64           `json:"averageBatchBytes"`
	AverageBatchMessages float64         `json:"averageBatchMessages"`
	AverageBatchData     float64         `json:"averageBatchData"`
	AverageFlushTimeMS   int64           `json:"averageFlushTimeMS"`
	TotalBatches         int64           `json:"totalBatches"`
	TotalErrors          int64           `json:"totalErrors"`
	// contains filtered or unexported fields
}

FlushStatus is an object that can be returned on REST queries to understand the status of the batch processor

type Manager

type Manager interface {
	RegisterDispatcher(name string, txType fftypes.TransactionType, msgTypes []fftypes.MessageType, handler DispatchHandler, batchOptions DispatcherOptions)
	NewMessages() chan<- int64
	Start() error
	Close()
	WaitStop()
	Status() *ManagerStatus
}

func NewBatchManager

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

type ManagerStatus

type ManagerStatus struct {
	Processors []*ProcessorStatus `json:"processors"`
}

type ProcessorStatus

type ProcessorStatus struct {
	Dispatcher string      `json:"dispatcher"`
	Name       string      `json:"name"`
	Status     FlushStatus `json:"status"`
}