batch

type AutoTuneConfig struct {
	// AutoTune indicates whether the batch sender should auto-tune the batch
	// size based on observed throughput. Defaults to false.
	Enabled bool
	// AutoTuneMinBatchBytes is the minimum batch size in bytes when auto-tuning
	// is enabled. Defaults to 1MiB.
	MinBatchBytes int64
	// AutoTuneMaxBatchBytes is the maximum batch size in bytes when auto-tuning
	// is enabled. Defaults to 50MiB.
	MaxBatchBytes int64
	// AutoTuneConvergenceThreshold is the threshold for convergence when
	// auto-tuning is enabled. Defaults to 0.01 (1%).
	ConvergenceThreshold float64
}

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
	// IgnoreSendErrors indicates whether sending errors should be ignored or
	// not. If set to true, errors will be logged but the batch will continue
	// processing. Defaults to false.
	IgnoreSendErrors bool
	// SendConcurrency is the number of concurrent send goroutines (drainers)
	// used to send batches. When set to 1 (the default) the sender uses a
	// single send goroutine, preserving strict ordering. Values greater than 1
	// are only meaningful for order-independent workloads (e.g. the bulk-ingest
	// snapshot writer) and are never enabled on the ordered replication path.
	SendConcurrency int

	AutoTune AutoTuneConfig
}

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

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

type Option[T Message] func(*Sender[T])

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

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