package
0.0.0-20250311023717-5c21e974eed8
Repository: https://github.com/thrasher-corp/gocryptotrader.git
Documentation: pkg.go.dev

# Functions

GetNewMux returns a new multiplexer to track subsystem updates, if nil dispatcher provided it will default to the global Dispatcher.
IsRunning checks to see if the dispatch service is running.
NewDispatcher creates a new Dispatcher for relaying data.
Start starts the dispatch system by spawning workers and allocating memory.
Stop attempts to stop the dispatch service, this will close all pipe channels flush job list and drop all workers.

# Constants

DefaultHandshakeTimeout defines a workers max length of time to wait on a an unbuffered channel for a receiver before moving on to next route.
DefaultJobsLimit defines a maximum amount of jobs allowed in channel.
DefaultMaxWorkers is the package default worker ceiling amount.
Name is an exported subsystem name.

# Variables

ErrNotRunning defines an error when the dispatcher is not running.

# Structs

Dispatcher defines an internal subsystem communication/change state publisher.
Mux defines a new multiplexer for the dispatch system, these a generated per subsystem.
Pipe defines an outbound object to the desired routine.