queue

Documentation

Index

• type Message
• type Queue
  • func NewQueue() *Queue
  • func (q *Queue) Channel() chan *Message
  • func (q *Queue) Push(message *Message)

Types

type Message

type Message struct {
	Payload interface{}
	Topic   string
}

type Queue

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

Queue is a wrapper of a go channel, particularly to restrict actions on the channel itself

func NewQueue

func NewQueue() *Queue

func (*Queue) Channel

func (q *Queue) Channel() chan *Message

func (*Queue) Push

func (q *Queue) Push(message *Message)

Push pushes a message to the channel