manager

type BaseCluster interface {
	GetOriginKubeCli(clusterNames ...string) (kubernetes.Interface, error)
	GetPod(opts types.NamespacedName, clusterNames ...string) (*corev1.Pod, error)
	GetPods(opts *client.ListOptions, clusterNames ...string) ([]*corev1.Pod, error)
	GetNodes(opts *client.ListOptions, clusterNames ...string) ([]*corev1.Node, error)
	GetDeployment(opts *client.ListOptions, clusterNames ...string) ([]*appv1.Deployment, error)
	GetStatefulsets(opts *client.ListOptions, clusternames ...string) ([]*appv1.StatefulSet, error)
	GetService(opts *client.ListOptions, clusterNames ...string) ([]*corev1.Service, error)
	GetEndpoints(opts *client.ListOptions, clusterNames ...string) ([]*corev1.Endpoints, error)
	GetEvent(opts *client.ListOptions, clusterNames ...string) ([]*corev1.Event, error)
	DeletePods(opts *client.ListOptions, clusterNames ...string) error
	DeletePod(opts types.NamespacedName, clusterNames ...string) error
}

type Cluster struct {
	Name          string
	AliasName     string
	RawKubeconfig []byte
	Meta          map[string]string
	RestConfig    *rest.Config
	Client        client.Client
	KubeCli       kubernetes.Interface

	Log        logr.Logger
	Mgr        manager.Manager
	Cache      cache.Cache
	SyncPeriod time.Duration

	Status ClusterStatusType
	// Started is true if the Informers has been Started
	Started bool
	// contains filtered or unexported fields
}

type ClusterManager struct {
	MasterClient

	Opt *ClusterManagerOption

	PreInit        func()
	Started        bool
	ClusterAddInfo chan map[string]string
	// contains filtered or unexported fields
}

type ClusterManagerOption struct {
	Namespace     string
	LabelSelector map[string]string
}

type ClusterStatusType string

type CustomeCluster interface {
	BaseCluster
	GetHelmRelease(opts map[string]string, clusterNames ...string) ([]*rlsv2.Release, error)
}

type MasterClient struct {
	KubeCli kubernetes.Interface
	manager.Manager
}