ringbuffer

README

ringbuffer

Documentation

Index

• type RingBuffer
  • func MakeRingBuffer(size uint64) *RingBuffer
  • func (ring *RingBuffer) Done(pos uint64) error
  • func (ring *RingBuffer) IsEmpty() bool
  • func (ring *RingBuffer) IsFull() bool
  • func (ring *RingBuffer) Read() (uint64, interface{})
  • func (ring *RingBuffer) Write(i interface{}) error

Types

type RingBuffer

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

func MakeRingBuffer

func MakeRingBuffer(size uint64) *RingBuffer

func (*RingBuffer) Done

func (ring *RingBuffer) Done(pos uint64) error

rewrite the pos value

pos,err := ring.Read() if err != nil { xxx } defer ring.Done(pos)

func (*RingBuffer) IsEmpty

func (ring *RingBuffer) IsEmpty() bool

func (*RingBuffer) IsFull

func (ring *RingBuffer) IsFull() bool

check buffer full

func (*RingBuffer) Read

func (ring *RingBuffer) Read() (uint64, interface{})

read the last value

func (*RingBuffer) Write

func (ring *RingBuffer) Write(i interface{}) error

loop write in buffer