cron

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

type DatasetOptions struct {
	Title     string
	Message   string
	Recall    string
	BodyPath  string
	FilePaths []string

	Publish             bool
	Strict              bool
	Force               bool
	ConvertFormatToPrev bool
	ShouldRender        bool

	Config  map[string]string
	Secrets map[string]string
}

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

type HTTPClient struct {
	Addr string
}

type Job struct {
	Name         string                    `json:"name"`
	Alias        string                    `json:"alias"`
	Type         JobType                   `json:"type"`
	Periodicity  iso8601.RepeatingInterval `json:"periodicity"`
	PrevRunStart time.Time                 `json:"lastRunStart,omitempty"`

	RunNumber   int64     `json:"runNumber,omitempty"`
	RunStart    time.Time `json:"runStart,omitempty"`
	RunStop     time.Time `json:"runStop,omitempty"`
	RunError    string    `json:"runError,omitempty"`
	LogFilePath string    `json:"logFilePath,omitempty"`

	RepoPath string `json:"repoPath,omitempty"`

	Options Options `json:"options,omitempty"`
}

type JobStore interface {
	// JobStores must implement the ReadJobs interface for fetching stored jobs
	ReadJobs
	// PutJob places one or more jobs in the store. Putting a job who's name
	// already exists must overwrite the previous job, making all job names unique
	PutJobs(context.Context, ...*Job) error
	// PutJob places a job in the store. Putting a job who's name already exists
	// must overwrite the previous job, making all job names unique
	PutJob(context.Context, *Job) error
	// DeleteJob removes a job from the store
	DeleteJob(ctx context.Context, name string) error
}

type JobType string

type LogFileCreator interface {
	// CreateLogFile returns a file to write output to
	CreateLogFile(job *Job) (f io.WriteCloser, path string, err error)
}

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

type Options interface {
	MarshalFlatbuffer(builder *flatbuffers.Builder) flatbuffers.UOffsetT
}

type ReadJobs interface {
	// ListJobs should return the set of jobs sorted in reverse-chronological order
	// (newest first order) of the last time they were run. When two LastRun times
	// are equal, Jobs should alpha sort the names
	// passing a limit and offset of 0 must return the entire list of stored jobs
	ListJobs(ctx context.Context, offset, limit int) ([]*Job, error)
	// Job gets a job by it's name. All job names in a set must be unique. It's
	// the job of the set backing ReadJobs functions to enforce uniqueness
	Job(ctx context.Context, name string) (*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 {
	// ListJobs lists currently scheduled jobs
	ListJobs(ctx context.Context, offset, limit int) ([]*Job, error)
	// Job gets a single scheduled job by name
	Job(ctx context.Context, name string) (*Job, error)

	// Schedule adds a job to the scheduler for execution once every period
	Schedule(ctx context.Context, job *Job) error
	// Unschedule removes a job from the scheduler
	Unschedule(ctx context.Context, name string) error

	// ListLogs gives a log of executed jobs
	ListLogs(ctx context.Context, offset, limit int) ([]*Job, error)
	// Log returns a single executed job by job.LogName
	Log(ctx context.Context, logName string) (*Job, error)
	// JobLogFile returns a reader for a file at the given name
	LogFile(ctx context.Context, logName string) (io.ReadCloser, error)
}

type ShellScriptOptions struct {
}