buffer

Documentation

Index

• type BatchBuffer
  • func NewBatchBuffer(capacity int) *BatchBuffer
  • func (b *BatchBuffer) Add(data *event.OutputEventContext)
  • func (b *BatchBuffer) Buf() []*event.OutputEventContext
  • func (b *BatchBuffer) First() event.Offset
  • func (b *BatchBuffer) Last() event.Offset
  • func (b *BatchBuffer) Len() int
• type Checker
• type Flusher
• type Limiter
  • func NewLimiter(config LimiterConfig, checker Checker) *Limiter
  • func (l *Limiter) Check()
  • func (l *Limiter) Start(ctx context.Context, flush Flusher)
  • func (l *Limiter) Stop()
• type LimiterConfig

Types

type BatchBuffer

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

BatchBuffer is a buffer to cache the input data in Sender.

func NewBatchBuffer

func NewBatchBuffer(capacity int) *BatchBuffer

NewBatchBuffer creates a new BatchBuffer according to the capacity param.

func (*BatchBuffer) Add

func (b *BatchBuffer) Add(data *event.OutputEventContext)

Add adds a new data input buffer.

func (*BatchBuffer) Buf

func (b *BatchBuffer) Buf() []*event.OutputEventContext

Buf returns the cached data in BatchBuffer.

func (*BatchBuffer) First

func (b *BatchBuffer) First() event.Offset

First returns the first OutputEventContext offset.

func (*BatchBuffer) Last

func (b *BatchBuffer) Last() event.Offset

Last returns the last OutputEventContext offset.

func (*BatchBuffer) Len

func (b *BatchBuffer) Len() int

Len returns the usage size.

type Checker

type Checker func() int

type Flusher

type Flusher func()

type Limiter

type Limiter struct {
	Config LimiterConfig
	// contains filtered or unexported fields
}

func NewLimiter

func NewLimiter(config LimiterConfig, checker Checker) *Limiter

func (*Limiter) Check

func (l *Limiter) Check()

func (*Limiter) Start

func (l *Limiter) Start(ctx context.Context, flush Flusher)

func (*Limiter) Stop

func (l *Limiter) Stop()

type LimiterConfig

type LimiterConfig struct {
	// The time interval between two flush operations. And the time unit is millisecond.
	FlushTime int `mapstructure:"flush_time" yaml:"flush_time"`
	// The max cache count when receive the message
	LimitCount int `mapstructure:"limit_count" yaml:"limit_count"`
}