dummy

Documentation

Index

• Variables
• type Queue
  • func New() *Queue
  • func (q *Queue) Close() error
  • func (q *Queue) Put(data []byte) error
  • func (q *Queue) ReadChan() <-chan []byte

Variables

var Timeout = 10 * time.Second

Types

type Queue

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

func New

func New() *Queue

func (*Queue) Close

func (q *Queue) Close() error

func (*Queue) Put

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

func (*Queue) ReadChan

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