msgbuf

Documentation

Index

• type MessageBuffer
  • func NewMessageBuffer(cap int) *MessageBuffer
  • func (rb *MessageBuffer) Peek() []byte
  • func (rb *MessageBuffer) Pop() []byte
  • func (rb *MessageBuffer) Push(msg []byte) []byte

Types

type MessageBuffer

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

MessageBuffer implements a fixed capacity ringbuffer for items of type []byte.

func NewMessageBuffer

func NewMessageBuffer(cap int) *MessageBuffer

func (*MessageBuffer) Peek

func (rb *MessageBuffer) Peek() []byte

Peek at the front item

func (*MessageBuffer) Pop

func (rb *MessageBuffer) Pop() []byte

Pop front item

func (*MessageBuffer) Push

func (rb *MessageBuffer) Push(msg []byte) []byte

Push new item to back. If the additional item would lead to the capacity being exceeded, remove the front item first.

Returns the removed front item, or nil.