simplebuffer

Documentation

Index

• type InMemoryBuffer
  • func NewInMemoryBuffer(name string, size int64, partition int32, opts ...Option) *InMemoryBuffer
  • func (b *InMemoryBuffer) Ack(_ context.Context, offsets []isb.Offset) []error
  • func (b *InMemoryBuffer) Close() error
  • func (b *InMemoryBuffer) GetMessages(num int) []*isb.Message
  • func (b *InMemoryBuffer) GetName() string
  • func (b *InMemoryBuffer) GetPartitionIdx() int32
  • func (b *InMemoryBuffer) IsEmpty() bool
  • func (b *InMemoryBuffer) IsFull() bool
  • func (b *InMemoryBuffer) NoAck(_ context.Context, _ []isb.Offset)
  • func (b *InMemoryBuffer) Pending(_ context.Context) (int64, error)
  • func (b *InMemoryBuffer) Read(ctx context.Context, count int64) ([]*isb.ReadMessage, error)
  • func (b *InMemoryBuffer) String() string
  • func (b *InMemoryBuffer) Write(_ context.Context, messages []isb.Message) ([]isb.Offset, []error)
• type Option
  • func WithBufferFullWritingStrategy(s dfv1.BufferFullWritingStrategy) Option
  • func WithReadTimeOut(timeout time.Duration) Option

Types

type InMemoryBuffer

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

InMemoryBuffer implements ISB interface.

func NewInMemoryBuffer

func NewInMemoryBuffer(name string, size int64, partition int32, opts ...Option) *InMemoryBuffer

NewInMemoryBuffer returns a new buffer.

func (*InMemoryBuffer) Ack

func (b *InMemoryBuffer) Ack(_ context.Context, offsets []isb.Offset) []error

Ack acknowledges the given offsets

func (*InMemoryBuffer) Close

func (b *InMemoryBuffer) Close() error

Close does nothing.

func (*InMemoryBuffer) GetMessages

func (b *InMemoryBuffer) GetMessages(num int) []*isb.Message

GetMessages gets the first num messages in the in mem buffer this function is for testing purpose

func (*InMemoryBuffer) GetName

func (b *InMemoryBuffer) GetName() string

GetName returns the buffer name.

func (*InMemoryBuffer) GetPartitionIdx

func (b *InMemoryBuffer) GetPartitionIdx() int32

GetPartitionIdx returns the partitionIdx.

func (*InMemoryBuffer) IsEmpty

func (b *InMemoryBuffer) IsEmpty() bool

IsEmpty returns whether the queue is empty.

func (*InMemoryBuffer) IsFull

func (b *InMemoryBuffer) IsFull() bool

IsFull returns whether the queue is full.

func (*InMemoryBuffer) NoAck

func (b *InMemoryBuffer) NoAck(_ context.Context, _ []isb.Offset)

func (*InMemoryBuffer) Pending

func (b *InMemoryBuffer) Pending(_ context.Context) (int64, error)

func (*InMemoryBuffer) Read

func (b *InMemoryBuffer) Read(ctx context.Context, count int64) ([]*isb.ReadMessage, error)

func (*InMemoryBuffer) String

func (b *InMemoryBuffer) String() string

Stringer

func (*InMemoryBuffer) Write

func (b *InMemoryBuffer) Write(_ context.Context, messages []isb.Message) ([]isb.Offset, []error)

type Option

type Option func(options *options) error

func WithBufferFullWritingStrategy

func WithBufferFullWritingStrategy(s dfv1.BufferFullWritingStrategy) Option

WithBufferFullWritingStrategy sets the writing strategy when buffer is full

func WithReadTimeOut

func WithReadTimeOut(timeout time.Duration) Option

WithReadTimeOut is used to set read timeout option