flusher

type Config struct {
	// MaxConcurrent is the maximum number of goroutines flushing entries concurrently.
	// Defaults to 16.
	MaxConcurrent int `json:"max_concurrent" yaml:"max_concurrent"`

	// MaxRetryTime maximum duration to continue retrying for
	// Defaults to 1 Hour
	MaxRetryTime time.Duration `json:"max_retry_time" yaml:"max_retry_time"`

	// MaxRetryInterval the maximum retry interval duration.
	// Defaults to 1 Minute
	MaxRetryInterval time.Duration `json:"max_retry_interval" yaml:"max_retry_interval"`
}

type FlushFunc func(context.Context) error

type Flusher struct {
	*zap.SugaredLogger
	// contains filtered or unexported fields
}