collectorbatch

Documentation

Index

• Variables
• type BatchInfo
• type CBatch
  • func NewBatch(ctx context.Context, chName string, limits Limits, ...) *CBatch
  • func (b *CBatch) AddIfInLimit(chName string, d *collectordto.BlockData) (bool, error)
  • func (b *CBatch) Deadline() <-chan time.Time
  • func (b *CBatch) GetBatchForExec() (*executordto.Batch, *BatchInfo)
• type LimitKind
• type Limits
• type SrcInfo

Variables

var ErrBlockDataOutOfLimit = errors.New("block data out of limit")

Types

type BatchInfo

type BatchInfo struct {
	Kind        LimitKind
	BlocksCount uint
	Len         uint
	Size        uint
	Sources     map[string]*SrcInfo
}

type CBatch

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

func NewBatch

func NewBatch(
	ctx context.Context,
	chName string,
	limits Limits,
	calcBatchSize func(b *executordto.Batch) (uint, error),
) *CBatch

func (*CBatch) AddIfInLimit

func (b *CBatch) AddIfInLimit(chName string, d *collectordto.BlockData) (bool, error)

func (*CBatch) Deadline

func (b *CBatch) Deadline() <-chan time.Time

func (*CBatch) GetBatchForExec

func (b *CBatch) GetBatchForExec() (*executordto.Batch, *BatchInfo)

type LimitKind

type LimitKind string

const (
	NoneLimitKind        LimitKind = "None"
	BlocksCountLimitKind LimitKind = "BlocksCountLimit"
	TimeoutLimitKind     LimitKind = "TimeoutLimit"
	LenLimitKind         LimitKind = "LenLimit"
	SizeLimitKind        LimitKind = "SizeLimit"
)

type Limits

type Limits struct {
	BlocksCountLimit uint
	TimeoutLimit     time.Duration
	LenLimit         uint
	SizeLimit        uint
}

type SrcInfo

type SrcInfo struct {
	LastBlockNum uint64
	ItemsCount   uint
}