store

type Config struct {
	Interval  time.Duration
	BatchSize int
	Capacity  int
	// contains filtered or unexported fields
}

type ErrorHandler interface {
	OnError(err error)
}

type Flusher[T any] interface {
	// Flush sends a batch of entries.
	// ctx controls cancellation, batching, or deadlines.
	Flush(ctx context.Context, entries []T) error
}

type Option func(cfg *Config)

type Store[T any] interface {
	// Write queues one or more entries into the buffer.
	Write(entries ...T)
	// Run starts the background processing loop on the provided context.
	// The loop continues until the context is canceled.
	Run(ctx context.Context)
}