Documentation ¶
Index ¶
- type Manager
- func (m *Manager) Call(urn string, dst interface{}, args ...interface{}) error
- func (m *Manager) NewProcess(options ...ProcessOptions) error
- func (m *Manager) RestartProcess(name string, typ string) error
- func (m *Manager) StartAllProcess() []error
- func (m *Manager) StartProcess(name string, typ string) error
- func (m *Manager) StopAll() []error
- func (m *Manager) StopProcess(name string, typ string) error
- type ManagerService
- type Metrics
- type Process
- type ProcessInfo
- type ProcessInput
- type ProcessOptions
Constants ¶
This section is empty.
Variables ¶
This section is empty.
Functions ¶
This section is empty.
Types ¶
type Manager ¶
type Manager struct { ServerSocket string SocketDir string Procs map[string]map[string]*ProcessInfo OutBuffer *bytes.Buffer ErrBuffer *bytes.Buffer Errors chan error Metrics chan Metrics RPC *rpc.Server // contains filtered or unexported fields }
Manager type instantiates a new Manager instance
func NewManager ¶
NewManager function returns a new instance of the Manager object
func (*Manager) NewProcess ¶
func (m *Manager) NewProcess(options ...ProcessOptions) error
NewProcess instantiates new processes
func (*Manager) RestartProcess ¶
RestartProcess restarts a process
func (*Manager) StartAllProcess ¶
StartAllProcess starts all procs in the manager
func (*Manager) StartProcess ¶
StartProcess starts all of the sub processes
type ManagerService ¶
type ManagerService struct {
// contains filtered or unexported fields
}
ManagerService type
type Process ¶
type Process struct { Socket string Config []byte Env []string RPC *rpc.Server Token string ServerSocket string Srv *rpc.Client }
Process type represents an RPC service
func (*Process) AddFunction ¶
AddFunction adds a function to the RPC handler
type ProcessInfo ¶
type ProcessInfo struct { Name string Type string Config map[string]interface{} Token string Handler interface{} CMD *airboss.Subprocess Options ProcessOptions Running bool Terminate chan bool PID int Socket string RPC *rpc.Client StartupDelay time.Duration }
ProcessInfo holds information about running processes
type ProcessInput ¶
ProcessInput type
Click to show internal directories.
Click to hide internal directories.