managerclient

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

type ClientAPI interface {
	io.Closer
	healthcheck.HealthChecker

	TaskAPI
	ManifestAPI
	CrudAPI
	StateAPI
}

type CrudAPI interface {
	// GetConfig will query the config with the specified name. If the requested
	// config is not found the ErrNotFound error is returned.
	GetConfig(ctx context.Context, request *GetConfigRequest) (*GetConfigResponse, error)
	// ListConfigs will query all the configs the manager handles.
	ListConfigs(ctx context.Context, request *ListConfigRequest) (*ListConfigResponse, error)
}

type GetConfigRequest struct{ Name string }

type GetConfigResponse struct{ Config *spec.Config }

type KubernetesContext struct{ Name, Namespace string }

type ListConfigRequest struct{}

type ListConfigResponse struct{ Config []*spec.Config }

type Manifest struct{ Raw string }

type ManifestAPI interface {
	// UpsertManifest will update the [store.Manifest] and [store.KubernetesContext] of an existing
	// config or will create a new config (if not present) from the passed in values.
	// The function will return the ErrVersionMismatch error indicating a Dirty write,
	// the application code should execute the Read/Update/Write cycle again, to resolve the merge conflicts.
	UpsertManifest(ctx context.Context, request *UpsertManifestRequest) error

	// MarkForDeletion will mark the Infrastructure of the specified Config to be deleted.
	// If the requested config with the specific version is not found the ErrVersionMismatch error is
	// returned indicating a Dirty write. On a Dirty write the application code should execute
	// the Read/Update/Write cycle again. If the config is not present an error will be returned
	// along with other errors. If the requested config for deletion is not found the ErrNotFound error
	// is returned.
	MarkForDeletion(ctx context.Context, request *MarkForDeletionRequest) error
}

type MarkForDeletionRequest struct{ Name string }

type NextTaskResponse struct {
	Config  string
	Cluster string
	TTL     int32
	Current *spec.Clusters
	Event   *spec.TaskEvent
	State   *spec.Workflow
}

type StateAPI interface {
	// UpdateNodePool will update the nodepool of a cluster within a config. If during an update a dirty
	// write occurs the ErrVersionMismatch error is returned. On a dirty write the application code should execute
	// the Read/Update/Write cycle again. If either one of nodepool, cluster, config is not found the ErrNotFound
	// error is returned.
	UpdateNodePool(ctx context.Context, request *UpdateNodePoolRequest) error
}

type TaskAPI interface {
	// NextTask will fetch the next task from the queue of tasks available at the Manager service.
	// If no tasks are available a nil response and a nil error is returned. If at any point an error
	// occurred an error is returned describing the cause. The API on server performs validation before
	// and initialization before returning the task, thus the error ErrVersionMismatch will be returned in
	// case a dirty write occurred on the server side. On the Client it is simply enough to call the
	// NextTask function again. Once new tasks are scheduled a non-nil response is returned.
	// If no tasks are scheduled or the Config for which the task was scheduled was deleted in the
	// meantime, the ErrNotFound error is returned.
	NextTask(ctx context.Context) (*NextTaskResponse, error)

	// TaskUpdate will update the state of the cluster within the specified config and version. If the requested config version is not
	// found the ErrVersionMismatch error is returned indicating a Dirty write. On a dirty write the application code
	// should execute the Read/Update/Write cycle again. If either the config or the cluster within the config or
	// the task for which the state should be updated is not found the ErrNotFound error is returned.
	TaskUpdate(ctx context.Context, request *TaskUpdateRequest) error

	// TaskComplete will mark the given task as completed either with status "DONE" or "ERROR. Further, it will update
	// the current state of the cluster within the specified config and version. If the requested config version is not
	// found the ErrVersionMismatch error is returned indicating a Dirty write. On a dirty write the application code
	// should execute the Read/Update/Write cycle again. If either the (cluster, config, task) triple is not found the
	// ErrNotFound error is returned.
	TaskComplete(ctx context.Context, request *TaskCompleteRequest) error
}

type TaskCompleteRequest struct {
	Config   string
	Cluster  string
	TaskId   string
	Workflow *spec.Workflow
	State    *spec.Clusters
}

type TaskUpdateRequest struct {
	Config  string
	Cluster string
	TaskId  string
	State   *spec.Workflow
}

type UpdateNodePoolRequest struct {
	Config   string
	Cluster  string
	NodePool *spec.NodePool
}

type UpsertManifestRequest struct {
	Name     string
	Manifest *Manifest
	K8sCtx   *KubernetesContext
}