buffer

Documentation

Index

• type Buffer
  • func NewBuffer[T any](bufferSize int, consumer BufferedConsumer[T]) *Buffer[T]
  • func (b *Buffer[T]) Append(ctx context.Context, item T) error
  • func (b *Buffer[T]) Flush(ctx context.Context) error
• type BufferedConsumer

Types

type Buffer

type Buffer[T any] struct {
	// contains filtered or unexported fields
}

func NewBuffer

func NewBuffer[T any](bufferSize int, consumer BufferedConsumer[T]) *Buffer[T]

NewBuffer creates a buffer with a given size.

func (*Buffer[T]) Append

func (b *Buffer[T]) Append(ctx context.Context, item T) error

func (*Buffer[T]) Flush

func (b *Buffer[T]) Flush(ctx context.Context) error

type BufferedConsumer

type BufferedConsumer[T any] func(ctx context.Context, buffer []T) error