dispatch

Documentation

Index

• Constants
• type Dispatcher
  • func NewDispatcher(queue common.Queue) *Dispatcher
  • func (dis *Dispatcher) Dispatch(l *line.Line)
  • func (dis *Dispatcher) DispatchMany(l *line.Line, channels []string)

Constants

const (
	// Prefix of Redis channel to publish messages on
	QUEUE_PREFIX   = "q"
	MAX_QUEUE_SIZE = 4096
)

Types

type Dispatcher

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

func NewDispatcher

func NewDispatcher(queue common.Queue) *Dispatcher

func (*Dispatcher) Dispatch

func (dis *Dispatcher) Dispatch(l *line.Line)

Main method - send the line to relevant plugins

func (*Dispatcher) DispatchMany

func (dis *Dispatcher) DispatchMany(l *line.Line, channels []string)

Dispatch the line to several channels. We need this for QUIT for example, which goes to all channels that user was in.