flusher

Documentation

Index

• Variables
• func NewFlusher[T any](bufferCapacity int, numBuffer int, flushTimeout time.Duration, ...) *flusherImpl[T]
• type FlushItem
• type Flusher
• type Writer

Variables

var (
	ErrFull     = serviceerror.NewUnavailable("flush buffer is full")
	ErrShutdown = serviceerror.NewUnavailable("flush buffer is shutdown")
)

Functions

func NewFlusher

func NewFlusher[T any](
	bufferCapacity int,
	numBuffer int,
	flushTimeout time.Duration,
	writer Writer[T],
	logger log.Logger,
) *flusherImpl[T]

Types

type FlushItem

type FlushItem[T any] struct {
	Item   T
	Future *future.FutureImpl[struct{}]
}

type Flusher

type Flusher[T any] interface {
	common.Daemon
	Buffer(item T) future.Future[struct{}]
	Flush()
}

type Writer

type Writer[T any] interface {
	Write(items []T) error
}