batcher

Documentation

Index

• type KafkaBatch
  • func NewKafkaBatch(ctx context.Context, producer *kafka.Writer, frequency time.Duration, ...) (*KafkaBatch, error)
  • func (b *KafkaBatch) RunBatch(ctx context.Context)
  • func (b *KafkaBatch) RunQueueReader(ctx context.Context)
  • func (b *KafkaBatch) Send(event any) error
  • func (b *KafkaBatch) SetLogger(logger Logger)
• type Logger
• type ZeroLogger
  • func (ZeroLogger) Info(args ...interface{})
  • func (ZeroLogger) Warn(args ...interface{})

Types

type KafkaBatch

type KafkaBatch struct {
	sync.Mutex
	// contains filtered or unexported fields
}

func NewKafkaBatch

func NewKafkaBatch(ctx context.Context, producer *kafka.Writer, frequency time.Duration, bufferSize uint) (*KafkaBatch, error)

func (*KafkaBatch) RunBatch

func (b *KafkaBatch) RunBatch(ctx context.Context)

func (*KafkaBatch) RunQueueReader

func (b *KafkaBatch) RunQueueReader(ctx context.Context)

func (*KafkaBatch) Send

func (b *KafkaBatch) Send(event any) error

Send is a wrapper around kafka producer to send logs

func (*KafkaBatch) SetLogger

func (b *KafkaBatch) SetLogger(logger Logger)

type Logger

type Logger interface {
	Info(args ...interface{})
	Warn(args ...interface{})
}

type ZeroLogger

type ZeroLogger struct{}

func (ZeroLogger) Info

func (ZeroLogger) Info(args ...interface{})

func (ZeroLogger) Warn

func (ZeroLogger) Warn(args ...interface{})