cluster

type Cluster interface {
	// Get all of the services (optionally, from a specific namespace), excluding those
	AllControllers(maybeNamespace string) ([]Controller, error)
	SomeControllers([]flux.ResourceID) ([]Controller, error)
	Ping() error
	Export() ([]byte, error)
	Sync(SyncDef) error
	PublicSSHKey(regenerate bool) (ssh.PublicKey, error)
}

type ContainersOrExcuse struct {
	Excuse     string
	Containers []resource.Container
}

type Controller struct {
	ID     flux.ResourceID
	Status string // A status summary for display
	// Is the controller considered read-only because it's under the
	// control of the platform. In the case of Kubernetes, we simply
	// omit these controllers; but this may not always be the case.
	IsSystem bool
	// If this workload was created _because_ of another, antecedent
	// resource through some mechanism (like an operator, or custom
	// resource controller), we try to record the ID of that resource
	// in this field.
	Antecedent flux.ResourceID
	Labels     map[string]string
	Policies   policy.Set
	Rollout    RolloutStatus
	// Errors during the recurring sync from the Git repository to the
	// cluster will surface here.
	SyncError error

	Containers ContainersOrExcuse
}

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

type Manifests interface {
	// Update the image in a manifest's bytes to that given
	UpdateImage(def []byte, resourceID flux.ResourceID, container string, newImageID image.Ref) ([]byte, error)
	// Load all the resource manifests under the paths
	// given. `baseDir` is used to relativise the paths, which are
	// supplied as absolute paths to directories or files; at least
	// one path should be supplied, even if it is the same as `baseDir`.
	LoadManifests(baseDir string, paths []string) (map[string]resource.Resource, error)
	// Parse the manifests given in an exported blob
	ParseManifests([]byte) (map[string]resource.Resource, error)
	// UpdatePolicies modifies a manifest to apply the policy update specified
	UpdatePolicies([]byte, flux.ResourceID, policy.Update) ([]byte, error)
}

type Mock struct {
	AllServicesFunc    func(maybeNamespace string) ([]Controller, error)
	SomeServicesFunc   func([]flux.ResourceID) ([]Controller, error)
	PingFunc           func() error
	ExportFunc         func() ([]byte, error)
	SyncFunc           func(SyncDef) error
	PublicSSHKeyFunc   func(regenerate bool) (ssh.PublicKey, error)
	UpdateImageFunc    func(def []byte, id flux.ResourceID, container string, newImageID image.Ref) ([]byte, error)
	LoadManifestsFunc  func(base string, paths []string) (map[string]resource.Resource, error)
	ParseManifestsFunc func([]byte) (map[string]resource.Resource, error)
	UpdateManifestFunc func(path, resourceID string, f func(def []byte) ([]byte, error)) error
	UpdatePoliciesFunc func([]byte, flux.ResourceID, policy.Update) ([]byte, error)
}

type ResourceError struct {
	resource.Resource
	Error error
}

type RolloutStatus struct {
	// Desired number of pods as defined in spec.
	Desired int32
	// Updated number of pods that are on the desired pod spec.
	Updated int32
	// Ready number of pods targeted by this deployment.
	Ready int32
	// Available number of available pods (ready for at least minReadySeconds) targeted by this deployment.
	Available int32
	// Outdated number of pods that are on a different pod spec.
	Outdated int32
	// Messages about unexpected rollout progress
	// if there's a message here, the rollout will not make progress without intervention
	Messages []string
}

type SyncAction struct {
	Delete resource.Resource // ) one of these
	Apply  resource.Resource // )
}

type SyncDef struct {
	// The actions to undertake
	Actions []SyncAction
}

type SyncError []ResourceError