logger_batch

type Config struct {
	Name              string
	PluginID          string
	BatchMaxSize      int
	MaxRetryCount     int
	RetryDelay        time.Duration
	RetryDelaySet     bool
	BufferDuration    time.Duration
	InactiveTimeout   time.Duration
	MaxPendingEntries int

	MaxConcurrentDeliveries int
	DeliveryTimeout         time.Duration
	ShutdownTimeout         time.Duration

	RouteID    string
	ServerAddr string
}

type ContextDeliveryFunc func(ctx context.Context, entries []map[string]any, batchMaxSize int) (firstFail int, err error)

type DeliveryFunc func(entries []map[string]any, batchMaxSize int) (firstFail int, err error)

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

type Stats struct {
	Pending     int
	Processing  int
	Buffered    int
	Dropped     int
	Delivered   int
	FailedDrops int
}