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

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

NewBuffer crate 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.