circularbuffer

Documentation

Index

• type CircularBuffer
  • func NewCircularBuffer(size int) *CircularBuffer
  • func (s *CircularBuffer) IsEmpty() bool
  • func (s *CircularBuffer) IsFull() bool
  • func (s *CircularBuffer) Queue(task core.QueuedMessage) error
  • func (s *CircularBuffer) Request() (core.QueuedMessage, error)
  • func (s *CircularBuffer) Shutdown() error

Types

type CircularBuffer

type CircularBuffer struct {
	sync.Mutex
	// contains filtered or unexported fields
}

CircularBuffer for simple queue using buffer channel

func NewCircularBuffer

func NewCircularBuffer(size int) *CircularBuffer

NewCircularBuffer for create new CircularBuffer instance

func (*CircularBuffer) IsEmpty

func (s *CircularBuffer) IsEmpty() bool

IsEmpty returns true if queue is empty

func (*CircularBuffer) IsFull

func (s *CircularBuffer) IsFull() bool

IsFull returns true if queue is full

func (*CircularBuffer) Queue

func (s *CircularBuffer) Queue(task core.QueuedMessage) error

Queue send task to the buffer channel

func (*CircularBuffer) Request

func (s *CircularBuffer) Request() (core.QueuedMessage, error)

Request a new task from channel

func (*CircularBuffer) Shutdown

func (s *CircularBuffer) Shutdown() error

Shutdown the worker