ringbuffer

Documentation

Index

• type RingBuffer
  • func New(capacity int) *RingBuffer
  • func (r *RingBuffer) Empty() bool
  • func (r *RingBuffer) Pop() (interface{}, error)
  • func (r *RingBuffer) Push(value interface{})

Types

type RingBuffer

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

RingBuffer holds the ring buffer and the synchronization primitives

func New

func New(capacity int) *RingBuffer

New creates new ring buffer

func (*RingBuffer) Empty

func (r *RingBuffer) Empty() bool

func (*RingBuffer) Pop

func (r *RingBuffer) Pop() (interface{}, error)

Pop removes value from ring buffer.

func (*RingBuffer) Push

func (r *RingBuffer) Push(value interface{})

Push inserts new value to ring buffer. Overflow signals if ring buffer was full when Push was called.