queue

Documentation

Index

• Variables
• type Queue
  • func NewChannelQueue(size int) Queue
• type ReadQueue
• type WriteQueue

Variables

var ErrTimeout = errors.New("timeout")

Types

type Queue

type Queue interface {
	Empty() bool
	ReadQueue
	WriteQueue
}

func NewChannelQueue

func NewChannelQueue(size int) Queue

type ReadQueue

type ReadQueue interface {
	BlockingRead() string
	ReadWithTimeout(time.Duration) (string, error)
}

type WriteQueue

type WriteQueue interface {
	Write(string)
	WriteMany([]string)
}