gaffer

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

type Gaffer struct {
	gopi.Config
	Fifo       string             // Location for the UNIX socket
	Clientpool gopi.RPCClientPool // Clientpool to create connnections and stubs
	State      string             // Folder for storing state information
}

type GafferKernel interface {
	gopi.PubSub

	// CreateProcess creates a new process, which is ready to run and returns
	// a unique id for that process
	CreateProcess(rpc.GafferService) (uint32, error)

	// Extended version of create process
	CreateProcessEx(uint32, rpc.GafferService, time.Duration) (uint32, error)

	// RunProcess starts a process in NEW state
	RunProcess(uint32) error

	// StopProcess kills a process in RUNNING state
	StopProcess(uint32) error

	// Processes returns a list of running processes, filtered optionally by
	// process id and service id, both can be zero for 'any'
	Processes(uint32, uint32) []rpc.GafferProcess

	// Return a list of executables under the gaffer root, or returns
	// an empty list if the gaffer root is not defined. When argument
	// is set to true, then recurse into subfolders
	Executables(bool) []string
}

type Kernel struct {
	gopi.Config
	Root string // Root is the path that executables are under
}

type Process struct {
	sync.Mutex
	sync.WaitGroup
	// contains filtered or unexported fields
}