queue

Documentation

Index

• type Queue
  • func NewQueue(givenName string) *Queue
  • func (q *Queue) PendingMessages() int

Types

type Queue

type Queue struct {
	Name          string
	InputChannel  chan *message.Message
	OutputChannel chan *message.Message
	// contains filtered or unexported fields
}

Queue represents an in-memory queue, using a slice-basedgit stat data structure, and channel io

func NewQueue

func NewQueue(givenName string) *Queue

NewQueue create a new queue, with given name

func (*Queue) PendingMessages

func (q *Queue) PendingMessages() int