kubefate

type ChartListResponse struct {
	Data []*modules.HelmChart
	Msg  string
}

type Client interface {
	// CheckVersion returns the version of the KubeFATE service
	CheckVersion() (string, error)
	// EnsureChartExist makes sure the specified chart is downloaded and managed by kubefate
	EnsureChartExist(name, version string, content []byte) error
	// ListClusterByNamespace returns clusters list in the specified namespace
	ListClusterByNamespace(namespace string) ([]*modules.Cluster, error)

	SubmitClusterInstallationJob(yamlStr string) (string, error)
	SubmitClusterUpdateJob(yamlStr string) (string, error)
	SubmitClusterDeletionJob(clusterUUID string) (string, error)
	GetJobInfo(jobUUID string) (*modules.Job, error)
	WaitJob(jobUUID string) (*modules.Job, error)
	WaitClusterUUID(jobUUID string) (string, error)
	StopJob(jobUUID string) error

	IngressAddress() string
	IngressRuleHost() string
}

type ClientManager interface {
	// K8sClient returns the embedded K8s client
	K8sClient() kubernetes.Client
	// BuildClient retrieve the KubeFATE access info from the underlying K8s cluster and return a client instance
	BuildClient() (Client, error)
	// BuildPFClient build a KubeFATE client based on internal port-forwarding routine, caller must call the returned closerFn when no longer needs it
	BuildPFClient() (client Client, closerFn func(), err error)
}

type ClusterArgs struct {
	Name         string `json:"name"`
	Namespace    string `json:"namespace"`
	ChartName    string `json:"chart_name"`
	ChartVersion string `json:"chart_version"`
	Cover        bool   `json:"cover"`
	Data         []byte `json:"data"`
}

type ClusterInfoResponse struct {
	Data *modules.Cluster
	Msg  string
}

type ClusterJobResponse struct {
	Data *modules.Job
	Msg  string
}

type ClusterListResponse struct {
	Data []*modules.Cluster
	Msg  string
}

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

type Manager interface {
	ClientManager
	// Install installs a KubeFATE deployment
	Install(bool) error
	// Uninstall uninstalls a KubeFATE installation
	Uninstall() error
	// InstallIngressNginxController installs a default ingress nginx controller
	InstallIngressNginxController() error
	// GetKubeFATEDeployment returns the Deployment object of KubeFATE
	GetKubeFATEDeployment() (*appv1.Deployment, error)
}