Documentation
¶
Index ¶
Constants ¶
This section is empty.
Variables ¶
View Source
var ( // ErrUnexpectedError describes the error when a job panics ErrUnexpectedError = errors.New("Job exited with unexpected error") )
Functions ¶
Types ¶
type Agent ¶
type Agent struct { *quantum.ConnConfig quantum.Registry // contains filtered or unexported fields }
Agent routes job requests to jobs, and runs the jobs with the request
func (*Agent) IsShutdown ¶
func (a *Agent) IsShutdown() chan struct{}
IsShutdown returns a chan that determines whether we're shutdown
type Config ¶
type Config struct { *quantum.ConnConfig Port string Registry quantum.Registry Registrator quantum.Registrator }
Config encapsulates configuration for an agent
type Conn ¶
type Conn struct { mux.Server // Senders OutCh chan string // Receivers SigCh chan os.Signal RequestCh chan quantum.Request // contains filtered or unexported fields }
Conn wraps a Connection
Click to show internal directories.
Click to hide internal directories.