cronicle

type Config struct {
	// Repo repository containing version controlled cronicle.hcl
	Repo *Repo `hcl:"repo,block"`
	// Cron expression that specifies the cronicle heartbeat and cronicle.hcl refresh
	Heartbeat string `hcl:"heartbeat,optional"`
	// Repos points at external dependent repos that maintain their own schedules remotly.
	Repos []string `hcl:"repos,optional"`
	// Timezone Location to run cron in. i.e. "America/New_York" [IANA Time Zone database]
	// https://en.wikipedia.org/wiki/List_of_tz_database_time_zones
	Timezone string `hcl:"timezone,optional"`
	// GitRemote *GitRemote `hcl:"git,block"`
	Queue     *Queue     `hcl:"queue,block"`
	Schedules []Schedule `hcl:"schedule,block"`
}

type Git struct {
	Worktree      *git.Worktree
	Repository    *git.Repository
	Head          *plumbing.Reference
	Hash          *plumbing.Hash
	Commit        *object.Commit
	ReferenceName plumbing.ReferenceName
	// contains filtered or unexported fields
}

type HclWriteFile struct {
	// File is the hclwrite.File encoded by gohcl.EncodeIntoBody
	File hclwrite.File

	// Bytes is the byte array with deduped $$
	Bytes []byte
}

type Queue struct {
	//Type names the message queue technology to be used
	//options are nsq and redis
	Type string `hcl:"type,optional"`
	//host:port of nsqd/nsqlookupd/redis queue service
	Addr string `hcl:"addr,optional"`
}

type Repo struct {
	// URL is the remote git repository, a local path to git repository
	URL string `hcl:"url,optional"`
	// DeployKey is the path to the rsa private key that enables pull access to a
	// private remote repository.
	DeployKey string `hcl:"key,optional"`
	Commit    string `hcl:"branch,optional"`
	Branch    string `hcl:"commit,optional"`
}

type Retry struct {
	//Count: Number of retry attemts to make after first attempt
	Count int `hcl:"count,optional"`
	//Seconds: Number of seconds to wait between retry attempts
	Seconds int `hcl:"seconds,optional"`
	//Minutes: Number of minutes to wait between retry attempts
	Minutes int `hcl:"minutes,optional"`
	//Hours: Number of hours to wait between retry attempts
	Hours int `hcl:"hours,optional"`
}

type RunOptions struct {
	RunWorker bool
	QueueType string
	QueueName string
	Addr      string
	LogToFile bool
}

type Schedule struct {
	// Cron is the schedule interval. The field accepts standard cron
	// and other configurations listed here https://godoc.org/gopkg.in/robfig/cron.v2
	// i.e. ["@hourly", "@every 1h30m", "0 30 * * * *", "TZ=Asia/Tokyo 30 04 * * * *"]
	Name string `hcl:"name,label"`
	Cron string `hcl:"cron,optional"`
	// Timezone Location to run cron in. i.e. "America/New_York" [IANA Time Zone database]
	// https://en.wikipedia.org/wiki/List_of_tz_database_time_zones
	Timezone  string `hcl:"timezone,optional"`
	StartDate string `hcl:"start_date,optional"`
	EndDate   string `hcl:"end_date,optional"`
	Repo      *Repo  `hcl:"repo,block"`
	Tasks     []Task `hcl:"task,block"`
	//Now is the execution time of the given schedule that will be used to
	//fill variable task command ${datetime}. The cron scheduler generally provides
	//the value.
	Now time.Time
	//repo given at the config level, will be overridden by repo given at schedule or task level.
	CronicleRepo *Repo
}

type ScheduleMap map[string]Schedule

type TZFormatter struct {
	log.Formatter
	// contains filtered or unexported fields
}

type Task struct {
	Name         string   `hcl:"name,label"`
	Command      []string `hcl:"command,optional"`
	Depends      []string `hcl:"depends,optional"`
	Repo         *Repo    `hcl:"repo,block"`
	Retry        *Retry   `hcl:"retry,block"`
	Env          []string `hcl:"env,optional"`
	Path         string
	CronicleRepo *Repo
	CroniclePath string
	Git          Git
	ScheduleName string
}

type TaskArray []Task

type TaskMap map[string]Task