hajobs

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

type JobInfo struct {
	Name     string `json:"name"`
	Checksec int    `json:"checksec"`
	Enabled  bool   `json:"enabled"`
	//owner      string
	Lockttlsec  int `json:"lockttlsec"`
	Schedule    *cronexpr.Expression
	Cronexpr    string
	LastUpdated time.Time
	State       []byte
}

type JobsRepo interface {
	GetJobinfo(ctx context.Context, name string) (*JobInfo, error)
	SaveState(ctx context.Context, name string, state []byte) error
	Commit(ctx context.Context, name string, state []byte) error
	CreateJob(ctx context.Context, name string, jobCfg JobCfg) error
}

type Lock interface {
	Unlock(context context.Context) error
}

type LockRepo interface {
	// Lock - name is the lock Name
	// owner is used to indicate the current holder of a lock (eg the hostname)
	// interval is the lock TTL
	// returns lock object that is a handle for unlocking a lock
	Lock(context context.Context, name string, owner string, interval time.Duration) (Lock, error, <-chan error)
}

type Manager interface {
	Register(name string, schedule string, run func(ctx context.Context, commitFunc func(state []byte) error, state []byte) ([]byte, error))
	StartAll()
}