ringbuffer

Documentation

Index

• Constants
• Variables
• type RingBuffer
  • func (b *RingBuffer) LastIndex() uint64
  • func (b *RingBuffer) ReadAt(readIndex uint64) (*rafthashi.Log, uint64, error)
  • func (b *RingBuffer) Write(data *rafthashi.Log) (uint64, error)

Constants

const (
	NoData = 0xFFFFFFFFFFFFFFFF
)

Variables

var New = func(size int) *RingBuffer {
	b := &RingBuffer{
		Size:   size,
		buffer: make([]unsafe.Pointer, size),
	}
	b.writeIndex = NoData
	return b
}

Types

type RingBuffer

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

func (*RingBuffer) LastIndex

func (b *RingBuffer) LastIndex() uint64

func (*RingBuffer) ReadAt

func (b *RingBuffer) ReadAt(readIndex uint64) (*rafthashi.Log, uint64, error)

func (*RingBuffer) Write

func (b *RingBuffer) Write(data *rafthashi.Log) (uint64, error)