kubernetes

type ApiObject struct {
	resource.Resource
	Kind     string   `yaml:"kind"`
	Metadata metadata `yaml:"metadata"`
}

type Applier interface {
	Apply(namespace string, cs ChangeSet) SyncError
}

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

type Cluster struct {
	Client    extendedClient
	Mgrs      *operatorutil.MgrList
	Applier   Applier
	Describer Describer
	Mu        sync.Mutex
	Scaler    Scaler
}

type Describer interface {
	Describe(namespace, sourceKind, sourceName string) string
}

type K8sObject interface {
	GetName() string
	GetNamespace() string
	GetLabels() map[string]string
	GetAnnotations() map[string]string
}

type K8sResource struct {
	K8sObject
	ApiVersion string
	Kind       string
	Name       string
}

type Manifests struct {
}

type ResourceError struct {
	resource.Resource
	Error error
}

type ResourceKind interface {
	GetResources(c *Cluster, namespace string) ([]K8sResource, error)
}

type Scaler interface {
	Scaler(namespace, sourceKind, sourceName, replicas string) error
}

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

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

type SyncError []ResourceError