controller

Documentation

Index

• Constants
• Variables
• func RunController(configFilename string) error
• type Controller
  • func NewController(conf *config.Config) (*Controller, error)
  • func (c *Controller) NewLocalScheduler() (Scheduler, error)
  • func (c *Controller) Start() error
• type DataStore
  • func NewDataStoreFromConfig(conf *config.DataStore) (DataStore, error)
• type DataStoreJob
• type DeviceStore
  • func NewDeviceStoreFromConfig(conf *config.DeviceStore, jobStore JobStore) (DeviceStore, error)
• type JobStore
  • func NewJobStoreFromConfig(conf *config.JobStore) (JobStore, error)
• type Scheduler

Constants

const (
	GitStructureByDevice = "by_device"
	GitStructureByJob    = "by_job"
	GitDirPerm           = 0755
	GitFilePerm          = 0644
)

const MaxJobBytes int64 = 524288000

500 meg

Variables

var Verbose bool

TODO: maybe remove this as a global var

Functions

func RunController

func RunController(configFilename string) error

configFileName can be empty which means default config

Types

type Controller

type Controller struct {
	JobStore
	DeviceStore
	DataStore
	Scheduler
	// contains filtered or unexported fields
}

func NewController

func NewController(conf *config.Config) (*Controller, error)

func (*Controller) NewLocalScheduler

func (c *Controller) NewLocalScheduler() (Scheduler, error)

func (*Controller) Start

func (c *Controller) Start() error

type DataStore

type DataStore interface {
	Store(job *DataStoreJob)
}

func NewDataStoreFromConfig

func NewDataStoreFromConfig(conf *config.DataStore) (DataStore, error)

type DataStoreJob

type DataStoreJob struct {
	DeviceName string
	JobName    string
	JobTime    time.Time
	StartTime  time.Time
	EndTime    time.Time
	Failure    string
	// TODO: worries about this eating too much mem?
	// Problem is we can't store reader because HTTP request is long gone
	Contents []byte
}

type DeviceStore

type DeviceStore interface {
	AllDevices() map[string]*model.Device
}

func NewDeviceStoreFromConfig

func NewDeviceStoreFromConfig(conf *config.DeviceStore, jobStore JobStore) (DeviceStore, error)

type JobStore

type JobStore interface {
	AllJobs() map[string]*model.Job
}

func NewJobStoreFromConfig

func NewJobStoreFromConfig(conf *config.JobStore) (JobStore, error)

type Scheduler

type Scheduler interface {
	NextExecution(tags []string, before time.Time) *model.Execution
}