clusterinfo

Apr 12, 2024

Changes in this version

+ func Dump(option DumpOption) error

+ type ChanData struct

+ Data interface{}

+ FilePath string

+ type ClientSet struct

+ Client *kubernetes.Clientset

+ func NewDumpOption(client *kubernetes.Clientset) *ClientSet

+ func (c *ClientSet) GetCRD() []interface{}

+ func (c *ClientSet) GetClusterResources(namespace string) map[string]map[string]map[string][]interface{}

+ func (c *ClientSet) GetConfigMap(namespace string) []corev1.ConfigMap

+ func (c *ClientSet) GetCronJobs(namespace string) []batchv1.CronJob

+ func (c *ClientSet) GetDeployment(namespace string) []appsv1.Deployment

+ func (c *ClientSet) GetJobs(namespace string) []batchv1.Job

+ func (c *ClientSet) GetMultiCluster() ([]v1alpha2.MultiCluster, error)

+ func (c *ClientSet) GetNamespaces() []corev1.Namespace

+ func (c *ClientSet) GetNodes() []corev1.Node

+ func (c *ClientSet) GetPersistentVolumeClaims(namespace string) []corev1.PersistentVolumeClaim

+ func (c *ClientSet) GetPersistentVolumes() []corev1.PersistentVolume

+ func (c *ClientSet) GetPods(namespace string) []corev1.Pod

+ func (c *ClientSet) GetSecrets(namespace string) []corev1.Secret

+ func (c *ClientSet) GetServices(namespace string) []corev1.Service

+ func (c *ClientSet) GetStatefulSets(namespace string) []appsv1.StatefulSet

+ func (c *ClientSet) GetStorageClasses() []interface{}

+ type DumpFile interface

+ CreateFile func(string) (*os.File, error)

+ GetWireData func(ChanData) []byte

+ ReadData func(*ClientSet, string)

+ SendData func(ChanData, bool)

+ WriteFile func() error

+ type DumpFileChan struct

+ Excel *excelize.File

+ OutFileChan chan ChanData

+ WaitGroup sync.WaitGroup

+ func NewFileChan(option DumpOption, excel *excelize.File) *DumpFileChan

+ func (c *DumpFileChan) CreateFile(path string) (*os.File, error)

+ func (c *DumpFileChan) GetWireData(o ChanData) []byte

+ func (c *DumpFileChan) ReadData(client *ClientSet, clusterName string)

+ func (c *DumpFileChan) SendData(data ChanData, isContinue bool)

+ func (c *DumpFileChan) WriteFile() error

+ type DumpOption struct

+ AllNamespaces bool

+ KubeConfig string

+ Logger bool

+ Namespace []string

+ OutputDir string

+ Queue int

+ Tar bool

+ Type string

+ func (c *DumpOption) GetOutputDir() string

+ type DumpResources interface

+ GetCRD func() []interface{}

+ GetClusterResources func(namespace string) map[string]map[string]map[string][]interface{}

+ GetConfigMap func(namespace string) []corev1.ConfigMap

+ GetCronJobs func(namespace string) []batchv1.CronJob

+ GetDeployment func(namespace string) []appsv1.Deployment

+ GetJobs func(namespace string) []batchv1.Job

+ GetMultiCluster func() ([]v1alpha2.MultiCluster, error)

+ GetNamespaces func() []corev1.Namespace

+ GetNodes func() []corev1.Node

+ GetPersistentVolumeClaims func(namespace string) []corev1.PersistentVolumeClaim

+ GetPersistentVolumes func() []corev1.PersistentVolume

+ GetPods func(namespace string) []corev1.Pod

+ GetSecrets func(namespace string) []corev1.Secret

+ GetServices func(namespace string) []corev1.Service

+ GetStatefulSets func(namespace string) []appsv1.StatefulSet

+ GetStorageClasses func() []interface{}

+ type TarOptions struct

+ func NewTar(option DumpOption) *TarOptions

+ func (t TarOptions) Run() error