jobkickqd

type DaemonConfig struct {
	ProjectID     string
	JobQueueTopic string
	LogTopic      string
	App           string
	WorkDir       string
}

type DefaultJobMessage struct {
	JobID          string   `json:"jobID"`
	JobExecutionID string   `json:"jobExecutionID"`
	Command        string   `json:"command"`
	Environment    []string `json:"environment"`
	Timeout        int      `json:"timeout"`
}

type Job struct {
	JobID          string
	JobExecutionID string
	CommandString  string
	Environment    []string
	JobExitCode    int
	ExecutionLog   string
	SentAt         time.Time
	SubmittedAt    time.Time
	StartedAt      time.Time
	FinishedAt     time.Time
	Timeout        time.Duration
	Cmd            exec.Cmd
}

type JobQueueExecutor interface {
	Run()
}

type MessageDriver interface {
	Write()
}

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

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