pair

Documentation

Index

• type Handler
• type Message
• type Pair
  • func NewPair(watcher Watcher, handler Handler) *Pair
  • func (p *Pair) Listen()
• type Queue
  • func NewQueue() *Queue
  • func (q *Queue) Push(message *Message)
• type Watcher

Types

type Handler

type Handler interface {
	Handle(interface{})
}

type Message

type Message struct {
	Payload interface{}
}

type Pair

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

Pair represents a pair of a watcher and a handler, to which the watcher pushes messages which the handler processes

func NewPair

func NewPair(watcher Watcher, handler Handler) *Pair

func (*Pair) Listen

func (p *Pair) Listen()

Listen begins the actions of the handler and the watcher

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) Push

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

Push pushes a message to the channel

type Watcher

type Watcher interface {
	Watch(queue *Queue)
}