Versions in this module Expand all Collapse all v2 v2.0.2 Apr 26, 2020 Changes in this version + const BUF_MAX_SIZE + const DURATION_DISCOVER + const DURATION_PROCESS + const DURATION_PRUNE + const R_OK + const W_OK + const X_OK + func NewKernelStub(config Gaffer) (rpc.GafferKernelStub, error) + func NewService(src rpc.GafferService, instances uint32) *service + func NewServiceEx(path, user, group string, args []string) *service + type Event struct + func NewBufferEvent(process rpc.GafferProcess, buf []byte, t rpc.GafferState) *Event + func NewRunningEvent(process rpc.GafferProcess) *Event + func NewStoppedEvent(process rpc.GafferProcess, err error) *Event + func (this *Event) Buf() []byte + func (this *Event) Error() error + func (this *Event) Process() rpc.GafferProcess + func (this *Event) State() rpc.GafferState + func (this *Event) String() string + type Gaffer struct + Clientpool gopi.RPCClientPool + Fifo string + State string + func (Gaffer) Name() string + func (config Gaffer) New(log gopi.Logger) (gopi.Unit, error) + type GafferKernel interface + CreateProcess func(rpc.GafferService) (uint32, error) + CreateProcessEx func(uint32, rpc.GafferService, time.Duration) (uint32, error) + Executables func(bool) []string + Processes func(uint32, uint32) []rpc.GafferProcess + RunProcess func(uint32) error + StopProcess func(uint32) error + type Kernel struct + Root string + func (Kernel) Name() string + func (config Kernel) New(log gopi.Logger) (gopi.Unit, error) + type Process struct + func NewProcess(id uint32, service *service, root string, timeout time.Duration) (*Process, error) + func (this *Process) ExitCode() int64 + func (this *Process) Id() uint32 + func (this *Process) Pid() uint32 + func (this *Process) Service() rpc.GafferService + func (this *Process) Start(out chan<- *Event) error + func (this *Process) State() rpc.GafferState + func (this *Process) Stop() error + func (this *Process) String() string + func (this *Process) Timestamp() time.Time