ring

package

v0.1.0 Latest Latest Go to latest Published: Jul 27, 2019 License: MIT Imports: 3 Imported by: 0

Details

This section is empty.

This section is empty.

This section is empty.

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

Buffer represents a circular array of data items.

func NewBuffer(length int) *Buffer

NewBuffer returns an initialized ring buffer.

func (r *Buffer) Close()

func (r *Buffer) Closed() bool

func (r *Buffer) GetAll() ([][]byte, bool)

func (r *Buffer) Has(item []byte) bool

func (r *Buffer) Put(item []byte)

Put an item on the ring buffer.

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

Consumer represents an entity which can read items from a ring buffer. It maintains its own read index, and cache.

func NewConsumer(ring *Buffer, callback func(items [][]byte, w io.WriteCloser) bool, w io.WriteCloser) *Consumer

NewConsumer returns a Consumer, which can read from the passed Buffer.