internal

Documentation

Index

• Variables
• type Queue
  • func NewQueue(capacity int) *Queue
  • func (q *Queue) Close()
  • func (q *Queue) Push(data []byte) error
  • func (q *Queue) Read() <-chan []byte
• type Signal
  • func (s Signal) Send()

Variables

var (
	ErrIsClosed = errors.New("is closed")
	ErrIsFull   = errors.New("is full")
)

Types

type Queue

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

func NewQueue

func NewQueue(capacity int) *Queue

func (*Queue) Close

func (q *Queue) Close()

func (*Queue) Push

func (q *Queue) Push(data []byte) error

func (*Queue) Read

func (q *Queue) Read() <-chan []byte

type Signal

type Signal chan struct{}

func (Signal) Send

func (s Signal) Send()