Documentation
¶
Index ¶
Constants ¶
View Source
const ( // DefaultJobsLimit defines a maximum amount of jobs allowed in channel DefaultJobsLimit = 100 // DefaultMaxWorkers is the package default worker ceiling amount DefaultMaxWorkers = 10 // DefaultHandshakeTimeout defines a workers max length of time to wait on a // an unbuffered channel for a receiver before moving on to next route DefaultHandshakeTimeout = 200 * time.Nanosecond )
View Source
const Name = "dispatch"
Name is an exported subsystem name
Variables ¶
View Source
var ( // ErrNotRunning defines an error when the dispatcher is not running ErrNotRunning = errors.New("dispatcher not running") )
Functions ¶
Types ¶
type Dispatcher ¶
type Dispatcher struct {
// contains filtered or unexported fields
}
Dispatcher defines an internal subsystem communication/change state publisher
func NewDispatcher ¶
func NewDispatcher() *Dispatcher
NewDispatcher creates a new Dispatcher for relaying data.
type Mux ¶
type Mux struct {
// contains filtered or unexported fields
}
Mux defines a new multiplexer for the dispatch system, these a generated per subsystem
func GetNewMux ¶
func GetNewMux(d *Dispatcher) *Mux
GetNewMux returns a new multiplexer to track subsystem updates, if nil dispatcher provided it will default to the global Dispatcher.
func (*Mux) Publish ¶
Publish takes in a persistent memory address and dispatches changes to required pipes.
Source Files
Click to show internal directories.
Click to hide internal directories.