Documentation
¶
Index ¶
Constants ¶
View Source
const ( // Prefix of Redis channel to publish messages on QUEUE_PREFIX = "q" MAX_QUEUE_SIZE = 4096 )
Variables ¶
This section is empty.
Functions ¶
This section is empty.
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.
Source Files
Click to show internal directories.
Click to hide internal directories.