agents

type Job struct {
	Cmd  *exec.Cmd        // Handle to the forked process
	Proc *process.Process // gopsutil process handle for later stats gathering
	Pid  int              // Process ID, not particularlly useful
	Pgid int              // Process Group ID, used for stats/control of the entire tree created
	// contains filtered or unexported fields
}

type JobControl interface {
	Stop() error               // Gracefully end process
	Suspend() error            // Stop scheduling process to be resumed later
	Resume() error             // Resume a previously stopped process
	Kill(int64) error          // Send SIGKILL (or arg os.Signal)
	Done() chan error          // Reflects the child process is done
	Process() *process.Process // Handle to gopsutil process struct for stats
	StdoutByteCount() int64    // Return the number of bytes emitted to STDOUT
}

type ProcessStatCollector struct {
	// contains filtered or unexported fields
}

type ProcessStatCommand struct {
	TimeUpdate bool
	NewTime    time.Duration
}

type ProcessStatSample struct {
	Host        host.HostInfoStat       // See gopsutil for description
	Memory      process.MemoryInfoStat  // See gopsutil for description
	CPUTimes    cpu.CPUTimesStat        // See gopsutil for description
	IOCounters  process.IOCountersStat  // See gopsutil for description
	OpenFiles   []process.OpenFilesStat // See gopsutil for description
	NumThreads  int32                   // Number of threads in use by the child processes (if supported)
	Pid         int32                   // Process ID for the group
	ChildPids   []int32                 // Children process IDs
	CPUPercent  float64                 // Sum of parent and children CPU percent usage
	TimeUTC     time.Time               // Timestamp of collection with location set to UTC
	TimeUnix    int64                   // Timestamp of collection based on seconds elapsed since the unix epoch.
	StdoutBytes int64                   // Running total of bytes emitted via STDOUT by the child process
	UserData    map[string]interface{}  // User provided JSON from invocation (not validated in proc_box!)
}

type ProcessStats interface {
	Sample() error // Take a statistical sample and emit it on AMQP
	NewTicker(time.Duration)
	ReinitializeConnection(*amqp.Connection) error
}

type RemoteControl struct {
	Commands chan RemoteControlCommand // Channel for incoming JSON unmarshalled RemoteControlCommands
	// contains filtered or unexported fields
}

type RemoteControlCommand struct {
	Command   string   // Command to execute
	Arguments []string // Optional arguments
}

type Timer interface {
	Reset() error                        // Clear elapsed time
	Start() error                        // Start counting time from zero
	Stop() error                         // Pause timer
	Resume() error                       // Resume previously paused timer
	ElapsedTime() (time.Duration, error) // Return duration of elapsed time
	Done() chan error                    // Timer has hit the maximum value
}

type WallclockTimer struct {
	// contains filtered or unexported fields
}