batch

type Batch[T Message] struct {
	// contains filtered or unexported fields
}

type Config struct {
	// BatchTime is the max time interval at which the batch sending is
	// triggered. Defaults to 1s
	BatchTimeout time.Duration
	// MaxBatchBytes is the max size in bytes for a given batch. When this size is
	// reached, the batch is sent. Defaults to 1572864 bytes.
	MaxBatchBytes int64
	// MaxBatchSize is the max number of messages to be sent per batch. When this
	// size is reached, the batch is sent. Defaults to 100.
	MaxBatchSize int64
	// MaxQueueBytes is the max memory used by the batch writer for inflight
	// batches. Defaults to 100MiB
	MaxQueueBytes int64
}

type Message interface {
	Size() int
	IsEmpty() bool
}

type Sender[T Message] struct {
	// contains filtered or unexported fields
}

type WALMessage[T Message] struct {
	// contains filtered or unexported fields
}