simplebuffer

Documentation

Index

• type InMemoryBuffer
  • func NewInMemoryBuffer(name string, size int64) *InMemoryBuffer
  • func (b *InMemoryBuffer) Ack(_ context.Context, offsets []isb.Offset) []error
  • func (b *InMemoryBuffer) Close() error
  • func (b *InMemoryBuffer) GetName() string
  • func (b *InMemoryBuffer) IsEmpty() bool
  • func (b *InMemoryBuffer) IsFull() bool
  • func (b *InMemoryBuffer) Pending(_ context.Context) (int64, error)
  • func (b *InMemoryBuffer) Rate(_ context.Context) (float64, 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)

Types

type InMemoryBuffer

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

InMemoryBuffer implements ISB interface.

func NewInMemoryBuffer

func NewInMemoryBuffer(name string, size int64) *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) GetName

func (b *InMemoryBuffer) GetName() string

GetName returns the buffer name.

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) Pending

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

func (*InMemoryBuffer) Rate

func (b *InMemoryBuffer) Rate(_ context.Context) (float64, 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)