Documentation ¶
Index ¶
- Constants
- type CTID
- type OSHandle
- type OSNotify
- type OSTID
- type Process
- type ProcessManager
- type Scheduler
- func (s *Scheduler) CreateCronTask(cron, cmd string) (pid int64, err error)
- func (s *Scheduler) CreateFSListenTask(paths []string, cmd string) (int64, error)
- func (s *Scheduler) CreateImmediateCronTask(cron, cmd string) (pid int64, err error)
- func (s *Scheduler) CreateTimingImmediateCronTask(cron, cmd string)
- func (s *Scheduler) FindByCmd(cmd string) (ret []*Process)
- func (s *Scheduler) FindByPID(pid int64) *Process
- func (s *Scheduler) Kill(pid int64)
- func (s *Scheduler) ProcessState() map[int64]*Process
- func (s *Scheduler) Run()
- type TID
Constants ¶
View Source
const ( P_NEW = iota P_READY P_SUSPEND P_RUNNING P_WAIT P_STOPPED )
Variables ¶
This section is empty.
Functions ¶
This section is empty.
Types ¶
type OSNotify ¶
type OSNotify struct {
// contains filtered or unexported fields
}
func NewOSNotify ¶
func NewOSNotify() *OSNotify
type ProcessManager ¶
type ProcessManager struct {
// contains filtered or unexported fields
}
func NewProcessManager ¶
func NewProcessManager() *ProcessManager
func (*ProcessManager) CreateProcess ¶
func (m *ProcessManager) CreateProcess(spec, cmd string) *Process
func (*ProcessManager) NextPID ¶
func (m *ProcessManager) NextPID() int64
type Scheduler ¶
type Scheduler struct {
// contains filtered or unexported fields
}
func NewScheduler ¶
func NewScheduler() *Scheduler
func (*Scheduler) CreateCronTask ¶
func (*Scheduler) CreateFSListenTask ¶
func (*Scheduler) CreateImmediateCronTask ¶
func (*Scheduler) CreateTimingImmediateCronTask ¶
func (*Scheduler) ProcessState ¶
Click to show internal directories.
Click to hide internal directories.