batch

Documentation

Index

• Constants
• type Batcher
  • func NewBatcher(flushInterval time.Duration, maxSizeInBytes int, input *diodes.OneToOne, ...) *Batcher
  • func (b *Batcher) Start()

Constants

const (
	CHANNEL_SIZE = 512
)

Types

type Batcher

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

func NewBatcher

func NewBatcher(
	flushInterval time.Duration,
	maxSizeInBytes int,
	input *diodes.OneToOne,
	writer func([]*rpc.Point),
	done chan struct{},
	droppedMetricFunc func(int),
) *Batcher

func (*Batcher) Start

func (b *Batcher) Start()