manager

package

v0.0.0-...-281381b Latest Latest Go to latest Published: Feb 10, 2019 License: GPL-2.0 Imports: 9 Imported by: 0

Details

Valid go.mod file

The Go module system was introduced in Go 1.11 and is the official dependency management solution for Go.
Redistributable license

Redistributable licenses place minimal restrictions on how software can be used, modified, and redistributed.
Tagged version

Modules with tagged versions give importers more predictable builds.
Stable version

When a project reaches major version v1 it is considered stable.
Learn more about best practices

Repository

github.com/apsl/apcron

Links

Open Source Insights

Documentation ¶

Index ¶

Constants
type Job
type JobStats
- func (js *JobStats) AddRss(maxRss int64)
type Manager
- func New() *Manager

Constants ¶

View Source

const MaxJobs int = 100

Variables ¶

This section is empty.

Functions ¶

This section is empty.

Types ¶

type Job ¶

type Job struct {
	sync.RWMutex

	Spec string //not used in manager, only for showing info

	Stats JobStats
	// contains filtered or unexported fields
}

func (*Job) GetCmd ¶

func (j *Job) GetCmd() string

GetCmd returns job cmd

func (*Job) GetID ¶

func (j *Job) GetID() int

GetID returns job ID

func (*Job) Run ¶

func (j *Job) Run()

Run runs a Job on the manager and returns not waiting for process fininsh We could wait, but seems that external scheduler do not need this by now.

type JobStats ¶

type JobStats struct {
	MeanRss  float64
	MaxRss   float64
	RssCount float64
}

JobStats represents Job execution stats

func (*JobStats) AddRss ¶

func (js *JobStats) AddRss(maxRss int64)

func NewJobStats() *JobStats {
	return &JobStats{0, 0, 0}
}

AddRss calculates mean and max of the job, given Maxrss from a process

type Manager ¶

type Manager struct {
	sync.RWMutex

	Jobs [MaxJobs]*Job
	// contains filtered or unexported fields
}

Manager represent a process Manager

func New ¶

func New() *Manager

New return a new process manager

func (*Manager) CreateJob ¶

func (m *Manager) CreateJob(cmd, spec, shell string) (j *Job, err error)

CreateJob creates a new manager.Job from a command string

func (*Manager) PrintStats ¶

func (m *Manager) PrintStats()

func (*Manager) Start ¶

func (m *Manager) Start()

Start manager service. Receives Jobs on channel Receiver

Source Files ¶

View all Source files

?	: This menu
/	: Search site
f or F	: Jump to
y or Y	: Canonical URL