cron

Jun 5, 2019

Changes in this version

+ var DefaultCheckInterval = time.Minute

+ var ErrUnreachable = fmt.Errorf("cannot establish a connection to the server")

+ type Cron struct

+ func NewCron(schedule, log JobStore, factory RunJobFactory) *Cron

+ func NewCronInterval(schedule, log JobStore, factory RunJobFactory, checkInterval time.Duration) *Cron

+ func (c *Cron) Job(ctx context.Context, name string) (*Job, error)

+ func (c *Cron) ListJobs(ctx context.Context, offset, limit int) ([]*Job, error)

+ func (c *Cron) ListLogs(ctx context.Context, offset, limit int) ([]*Job, error)

+ func (c *Cron) Log(ctx context.Context, logName string) (*Job, error)

+ func (c *Cron) LogFile(ctx context.Context, logName string) (io.ReadCloser, error)

+ func (c *Cron) Schedule(ctx context.Context, job *Job) error

+ func (c *Cron) ServeHTTP(addr string) error

+ func (c *Cron) Start(ctx context.Context) error

+ func (c *Cron) Unschedule(ctx context.Context, name string) error

+ type DatasetOptions struct

+ BodyPath string

+ Config map[string]string

+ ConvertFormatToPrev bool

+ FilePaths []string

+ Force bool

+ Message string

+ Publish bool

+ Recall string

+ Secrets map[string]string

+ ShouldRender bool

+ Strict bool

+ Title string

+ func (o *DatasetOptions) MarshalFlatbuffer(builder *flatbuffers.Builder) flatbuffers.UOffsetT

+ func (o *DatasetOptions) UnmarshalFlatbuffer(fbo *cronfb.DatasetOptions)

+ type FlatbufferJobStore struct

+ func (s *FlatbufferJobStore) CreateLogFile(j *Job) (f io.WriteCloser, path string, err error)

+ func (s *FlatbufferJobStore) DeleteJob(ctx context.Context, name string) error

+ func (s *FlatbufferJobStore) Destroy() error

+ func (s *FlatbufferJobStore) Job(ctx context.Context, name string) (*Job, error)

+ func (s *FlatbufferJobStore) ListJobs(ctx context.Context, offset, limit int) ([]*Job, error)

+ func (s *FlatbufferJobStore) PutJob(ctx context.Context, job *Job) error

+ func (s *FlatbufferJobStore) PutJobs(ctx context.Context, add ...*Job) error

+ type HTTPClient struct

+ Addr string

+ func (c HTTPClient) Job(ctx context.Context, name string) (*Job, error)

+ func (c HTTPClient) ListJobs(ctx context.Context, offset, limit int) ([]*Job, error)

+ func (c HTTPClient) ListLogs(ctx context.Context, offset, limit int) ([]*Job, error)

+ func (c HTTPClient) Log(ctx context.Context, logName string) (*Job, error)

+ func (c HTTPClient) LogFile(ctx context.Context, logName string) (io.ReadCloser, error)

+ func (c HTTPClient) Ping() error

+ func (c HTTPClient) Schedule(ctx context.Context, job *Job) error

+ func (c HTTPClient) Unschedule(ctx context.Context, name string) error

+ type Job struct

+ Alias string

+ LogFilePath string

+ Name string

+ Options Options

+ Periodicity iso8601.RepeatingInterval

+ PrevRunStart time.Time

+ RepoPath string

+ RunError string

+ RunNumber int64

+ RunStart time.Time

+ RunStop time.Time

+ Type JobType

+ func (job *Job) Copy() *Job

+ func (job *Job) FlatbufferBytes() []byte

+ func (job *Job) LogName() string

+ func (job *Job) MarshalFlatbuffer(builder *flatbuffers.Builder) flatbuffers.UOffsetT

+ func (job *Job) NextExec() time.Time

+ func (job *Job) UnmarshalFlatbuffer(j *cronfb.Job) error

+ func (job *Job) Validate() error

+ type JobStore interface

+ DeleteJob func(ctx context.Context, name string) error

+ PutJob func(context.Context, *Job) error

+ PutJobs func(context.Context, ...*Job) error

+ func NewFlatbufferJobStore(path string) JobStore

+ type JobType string

+ const JTDataset

+ const JTShellScript

+ func (jt JobType) Enum() int8

+ type LogFileCreator interface

+ CreateLogFile func(job *Job) (f io.WriteCloser, path string, err error)

+ type MemJobStore struct

+ func (s *MemJobStore) DeleteJob(ctx context.Context, name string) error

+ func (s *MemJobStore) Job(ctx context.Context, name string) (*Job, error)

+ func (s *MemJobStore) ListJobs(ctx context.Context, offset, limit int) ([]*Job, error)

+ func (s *MemJobStore) PutJob(ctx context.Context, job *Job) error

+ func (s *MemJobStore) PutJobs(ctx context.Context, js ...*Job) error

+ type Options interface

+ MarshalFlatbuffer func(builder *flatbuffers.Builder) flatbuffers.UOffsetT

+ type ReadJobs interface

+ Job func(ctx context.Context, name string) (*Job, error)

+ ListJobs func(ctx context.Context, offset, limit int) ([]*Job, error)

+ type RunJobFactory func(ctx context.Context) (runner RunJobFunc)

+ type RunJobFunc func(ctx context.Context, streams ioes.IOStreams, job *Job) error

+ type Scheduler interface

+ Job func(ctx context.Context, name string) (*Job, error)

+ ListJobs func(ctx context.Context, offset, limit int) ([]*Job, error)

+ ListLogs func(ctx context.Context, offset, limit int) ([]*Job, error)

+ Log func(ctx context.Context, logName string) (*Job, error)

+ LogFile func(ctx context.Context, logName string) (io.ReadCloser, error)

+ Schedule func(ctx context.Context, job *Job) error

+ Unschedule func(ctx context.Context, name string) error

+ type ShellScriptOptions struct

+ func (o *ShellScriptOptions) MarshalFlatbuffer(builder *flatbuffers.Builder) flatbuffers.UOffsetT