queue

Documentation

Index

• type Queue
  • func NewQueue(mtu int, writer io.Writer) *Queue
  • func (q *Queue) Close() error
  • func (q *Queue) SendIn(maxDelay time.Duration)
  • func (b *Queue) SendValue(v proto.Value, maxDelay time.Duration)
  • func (b *Queue) SendValues(vs []proto.Value, maxDelay time.Duration)

Types

type Queue

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

Queue sends out TLV values over a net.PacketConn

func NewQueue

func NewQueue(mtu int, writer io.Writer) *Queue

func (*Queue) Close

func (q *Queue) Close() error

func (*Queue) SendIn

func (q *Queue) SendIn(maxDelay time.Duration)

func (*Queue) SendValue

func (b *Queue) SendValue(v proto.Value, maxDelay time.Duration)

func (*Queue) SendValues

func (b *Queue) SendValues(vs []proto.Value, maxDelay time.Duration)