queue

Documentation

Index

• type MessageSeqFIFO
  • func NewMessageSeqFifo() *MessageSeqFIFO
  • func (queue *MessageSeqFIFO) Len() int
  • func (queue *MessageSeqFIFO) Pop() *api.MessageSeq
  • func (queue *MessageSeqFIFO) Push(message *api.MessageSeq)

Types

type MessageSeqFIFO

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

func NewMessageSeqFifo

func NewMessageSeqFifo() *MessageSeqFIFO

func (*MessageSeqFIFO) Len

func (queue *MessageSeqFIFO) Len() int

func (*MessageSeqFIFO) Pop

func (queue *MessageSeqFIFO) Pop() *api.MessageSeq

func (*MessageSeqFIFO) Push

func (queue *MessageSeqFIFO) Push(message *api.MessageSeq)