buf

Documentation

Index

• type RingBuffer
  • func New(size int) *RingBuffer
  • func (buf *RingBuffer) Add(v interface{})
  • func (buf *RingBuffer) Do(f func(interface{}))
  • func (buf *RingBuffer) Last() interface{}

Types

type RingBuffer

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

RingBuffer represents synchronized ring implementation

func New

func New(size int) *RingBuffer

New creates new RingBuffer

func (*RingBuffer) Add

func (buf *RingBuffer) Add(v interface{})

Add adds item to ring

func (*RingBuffer) Do

func (buf *RingBuffer) Do(f func(interface{}))

Do executes provided callback on all non-nil items of a ring

func (*RingBuffer) Last

func (buf *RingBuffer) Last() interface{}

Last returned last item added to the ring