models

type JobActionRequest struct {
	Action string `json:"action"`
}

type JobData struct {
	Name       string       `json:"name"`
	Parameters Parameters   `json:"parameters"`
	Metadata   *JobMetadata `json:"metadata"`
	StatusHook string       `json:"status_hook"`
}

type JobMetadata struct {
	JobKind       string `json:"kind"`
	ScheduleDelay uint64 `json:"schedule_delay,omitempty"`
	Cron          string `json:"cron_spec,omitempty"`
	IsUnique      bool   `json:"unique"`
}

type JobPoolStats struct {
	Pools []*JobPoolStatsData `json:"worker_pools"`
}

type JobPoolStatsData struct {
	WorkerPoolID string   `json:"worker_pool_id"`
	StartedAt    int64    `json:"started_at"`
	HeartbeatAt  int64    `json:"heartbeat_at"`
	JobNames     []string `json:"job_names"`
	Concurrency  uint     `json:"concurrency"`
	Status       string   `json:"status"`
}

type JobRequest struct {
	Job *JobData `json:"job"`
}

type JobStatData struct {
	JobID       string `json:"id"`
	Status      string `json:"status"`
	JobName     string `json:"name"`
	JobKind     string `json:"kind"`
	IsUnique    bool   `json:"unique"`
	RefLink     string `json:"ref_link,omitempty"`
	CronSpec    string `json:"cron_spec,omitempty"`
	EnqueueTime int64  `json:"enqueue_time"`
	UpdateTime  int64  `json:"update_time"`
	RunAt       int64  `json:"run_at,omitempty"`
	CheckIn     string `json:"check_in,omitempty"`
	CheckInAt   int64  `json:"check_in_at,omitempty"`
	DieAt       int64  `json:"die_at,omitempty"`
	HookStatus  string `json:"hook_status,omitempty"`
}

type JobStats struct {
	Stats *JobStatData `json:"job"`
}

type JobStatusChange struct {
	JobID   string `json:"job_id"`
	Status  string `json:"status"`
	CheckIn string `json:"check_in,omitempty"`
}

type Message struct {
	Event string
	Data  interface{} //generic format
}

type Parameters map[string]interface{}