workflows

type Client struct {
	Jobs     JobClient
	Clusters ClusterClient
	// contains filtered or unexported fields
}

type ClientOption func(*clientConfig)

type Cluster struct {
	// Slug is the unique identifier of the cluster within the namespace.
	Slug string
	// Name is the display name of the cluster.
	Name string
}

type ClusterClient interface {
	Create(ctx context.Context, name string) (*Cluster, error)
	Get(ctx context.Context, slug string) (*Cluster, error)
	Delete(ctx context.Context, slug string) error
	List(ctx context.Context) ([]*Cluster, error)
}

type ExecutableTask interface {
	Execute(ctx context.Context) error
}

type ExplicitlyIdentifiableTask interface {
	Identifier() TaskIdentifier
}

type Job struct {
	// ID is the unique identifier of the job.
	ID uuid.UUID
	// Name is the name of the job.
	Name string
	// Canceled indicates whether the job has been canceled.
	Canceled bool
	// State is the current state of the job.
	State JobState
	// SubmittedAt is the time the job was submitted.
	SubmittedAt time.Time
	// StartedAt is the time the job started running.
	StartedAt time.Time
	// TaskSummaries is the task summaries of the job.
	TaskSummaries []*TaskSummary
	// AutomationID is the ID of the automation that submitted the job.
	AutomationID uuid.UUID
}

type JobClient interface {
	Submit(ctx context.Context, jobName string, cluster *Cluster, tasks []Task, options ...job.SubmitOption) (*Job, error)
	Get(ctx context.Context, jobID uuid.UUID) (*Job, error)
	Retry(ctx context.Context, jobID uuid.UUID) (int64, error)
	Cancel(ctx context.Context, jobID uuid.UUID) error
	List(ctx context.Context, interval query.TemporalExtent) iter.Seq2[*Job, error]
}

type JobService interface {
	SubmitJob(ctx context.Context, req *workflowsv1.SubmitJobRequest) (*workflowsv1.Job, error)
	GetJob(ctx context.Context, jobID uuid.UUID) (*workflowsv1.Job, error)
	RetryJob(ctx context.Context, jobID uuid.UUID) (*workflowsv1.RetryJobResponse, error)
	CancelJob(ctx context.Context, jobID uuid.UUID) error
	ListJobs(ctx context.Context, idInterval *workflowsv1.IDInterval, page *workflowsv1.Pagination) (*workflowsv1.ListJobsResponse, error)
}

type JobState int32

type Task interface{}

type TaskIdentifier interface {
	Name() string
	Version() string
	Display() string
}

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

type TaskService interface {
	NextTask(ctx context.Context, computedTask *workflowsv1.ComputedTask, nextTaskToRun *workflowsv1.NextTaskToRun) (*workflowsv1.NextTaskResponse, error)
	TaskFailed(ctx context.Context, taskID uuid.UUID, display string, cancelJob bool) (*workflowsv1.TaskStateResponse, error)
	ExtendTaskLease(ctx context.Context, taskID uuid.UUID, requestedLease time.Duration) (*workflowsv1.TaskLease, error)
}

type TaskState int32

type TaskSummary struct {
	// ID is the unique identifier of the task.
	ID uuid.UUID
	// Display is the display message of the task.
	Display string
	// State is the state of the task.
	State TaskState
	// ParentID is the ID of the parent task.
	ParentID uuid.UUID
	// DependsOn is the list of task IDs that this task depends on.
	DependsOn []uuid.UUID
	// StartedAt is the time the task started.
	StartedAt time.Time
	// StoppedAt is the time the task stopped.
	StoppedAt time.Time
}

type WorkflowService interface {
	CreateCluster(ctx context.Context, name string) (*workflowsv1.Cluster, error)
	GetCluster(ctx context.Context, slug string) (*workflowsv1.Cluster, error)
	DeleteCluster(ctx context.Context, slug string) error
	ListClusters(ctx context.Context) (*workflowsv1.ListClustersResponse, error)
}