kube

package
v1.15.0 Latest Latest
Warning

This package is not in the latest version of its module.

 Go to latest Published: Sep 4, 2024 License: LGPL-3.0 Imports: 49 Imported by: 0

Documentation

Index

Constants

This section is empty.

Variables

This section is empty.

Functions

func CreateKubevirtVM 

func CreateKubevirtVM(dynamicClient dynamic.Interface, vm *kubevirtcorev1.VirtualMachine) (*kubevirtcorev1.VirtualMachine, error)

func DeleteKubeVirtVM 

func DeleteKubeVirtVM(dynamicClient dynamic.Interface, namespace, name string) error

func DeleteKubeVirtVMI 

func DeleteKubeVirtVMI(dynamicClient dynamic.Interface, namespace, name string) error

func GetClusterCPURequest 

func GetClusterCPURequest() int64

func GetClusterMemoryRequest 

func GetClusterMemoryRequest() int64

func GetClusterPodCount 

func GetClusterPodCount() int64

func GetDefaultStorageClass 

func GetDefaultStorageClass(clientset kubernetes.Interface) string

func GetKubeVirtVM 

func GetKubeVirtVM(dynamicClient dynamic.Interface, namespace, name string) (*kubevirtcorev1.VirtualMachine, error)

func GetKubeVirtVMI 

func GetKubeVirtVMI(dynamicClient dynamic.Interface, namespace, name string) (*kubevirtcorev1.VirtualMachineInstance, error)

func GetNodeCPURequest 

func GetNodeCPURequest(node string) int64

func GetNodeMemoryRequest 

func GetNodeMemoryRequest(node string) int64

func GetNodePodCount 

func GetNodePodCount(node string) int64

func GetResourcesYamlFormat 

func GetResourcesYamlFormat(clientset kubernetes.Interface, namespace string, selectors []labels.Selector, customSetting *api_model.KubeResourceCustomSetting) string

GetResourcesYamlFormat

func GetWTChannelSSHPubKey 

func GetWTChannelSSHPubKey(kubeClient kubernetes.Interface) (string, error)

func IsKubevirtInstalled 

func IsKubevirtInstalled(kubeClient kubernetes.Interface, apiextClient apiextclient.Interface) bool

func IsVeleroInstalled 

func IsVeleroInstalled(kubeClient kubernetes.Interface, apiextClient apiextclient.Interface) bool

func ListKubeVirtVMs 

func ListKubeVirtVMs(dynamicClient dynamic.Interface, namespace string) ([]*kubevirtcorev1.VirtualMachine, error)

func NodeRoles 

func NodeRoles(clientset kubernetes.Interface, node *corev1.Node) []string

func RegionAPIExtClientset 

func RegionAPIExtClientset() apiext.Interface

func RegionClientset 

func RegionClientset() kubernetes.Interface

func RegionDynamicClient 

func RegionDynamicClient() dynamic.Interface

func RegionRESTConfig 

func RegionRESTConfig() *rest.Config

func RegionRuntimeClient 

func RegionRuntimeClient() runtimeclient.Client

func RegionVeleroClientset 

func RegionVeleroClientset() veleroversioned.Interface

func RegionWutongClientset 

func RegionWutongClientset() wutongversioned.Interface

func UnDynamicObject 

func UnDynamicObject[O runtime.Object](obj runtime.Object) (O, error)

func UnDynamicObjectList 

func UnDynamicObjectList[O runtime.Object](objs []runtime.Object) ([]O, error)

func UpdateKubeVirtVM 

func UpdateKubeVirtVM(dynamicClient dynamic.Interface, vm *kubevirtcorev1.VirtualMachine) (*kubevirtcorev1.VirtualMachine, error)

Types

type CachedResources 

type CachedResources struct {
	DeploymentLister            appsv1.DeploymentLister
	StatefuleSetLister          appsv1.StatefulSetLister
	PodLister                   corev1.PodLister
	ConfigMapLister             corev1.ConfigMapLister
	SecretLister                corev1.SecretLister
	ServiceLister               corev1.ServiceLister
	IngressV1Lister             networkingv1.IngressLister
	HPAV1Lister                 autoscalingv1.HorizontalPodAutoscalerLister
	EventLister                 corev1.EventLister
	StorageClassLister          storagev1.StorageClassLister
	NodeLister                  corev1.NodeLister
	PersistentVolumeClaimLister corev1.PersistentVolumeClaimLister
}

func GetCachedResources 

func GetCachedResources(clientset kubernetes.Interface) *CachedResources

type ClusterMetrics 

type ClusterMetrics struct {
	NodeMetricsMap map[string]*NodeMetrics `json:"node_metrics_map"`
}

type ConfigMaps 

type ConfigMaps struct {
	kubernetes.Interface
	ConfigMaps []*corev1.ConfigMap `json:"configmaps"`
}

func (*ConfigMaps) AppendTo 

func (c *ConfigMaps) AppendTo(objs []interface{}) []interface{}

func (*ConfigMaps) Decorate 

func (c *ConfigMaps) Decorate(setting *api_model.KubeResourceCustomSetting)

func (*ConfigMaps) Migrate 

func (c *ConfigMaps) Migrate(namespace string, seletcor labels.Selector)

func (*ConfigMaps) SetClientset 

func (c *ConfigMaps) SetClientset(clientset kubernetes.Interface)

type Deployments 

type Deployments struct {
	kubernetes.Interface
	Deployments []*appsv1.Deployment `json:"deployments"`
}

func (*Deployments) AppendTo 

func (d *Deployments) AppendTo(objs []interface{}) []interface{}

func (*Deployments) Decorate 

func (d *Deployments) Decorate(setting *api_model.KubeResourceCustomSetting)

func (*Deployments) Migrate 

func (d *Deployments) Migrate(namespace string, seletcor labels.Selector)

func (*Deployments) SetClientset 

func (d *Deployments) SetClientset(clientset kubernetes.Interface)

type DynamicCachedResources 

type DynamicCachedResources struct {
	VMLister  cache.GenericLister
	VMILister cache.GenericLister
}

func GetDynamicCachedResources 

func GetDynamicCachedResources(dynamicClient dynamic.Interface) *DynamicCachedResources

func (*DynamicCachedResources) GetVMILister 

func (d *DynamicCachedResources) GetVMILister() cache.GenericLister

func (*DynamicCachedResources) GetVMLister 

func (d *DynamicCachedResources) GetVMLister() cache.GenericLister

type HorizontalPodAutoscalers 

type HorizontalPodAutoscalers struct {
	kubernetes.Interface
	HorizontalPodAutoscalers []*autoscalingv1.HorizontalPodAutoscaler `json:"horizontalpodautoscalers"`
}

func (*HorizontalPodAutoscalers) AppendTo 

func (h *HorizontalPodAutoscalers) AppendTo(objs []interface{}) []interface{}

func (*HorizontalPodAutoscalers) Decorate 

func (h *HorizontalPodAutoscalers) Decorate(setting *api_model.KubeResourceCustomSetting)

func (*HorizontalPodAutoscalers) Migrate 

func (h *HorizontalPodAutoscalers) Migrate(namespace string, seletcor labels.Selector)

func (*HorizontalPodAutoscalers) SetClientset 

func (h *HorizontalPodAutoscalers) SetClientset(clientset kubernetes.Interface)

type Ingresses 

type Ingresses struct {
	kubernetes.Interface
	Ingresses []*networkingv1.Ingress `json:"ingresses"`
}

func (*Ingresses) AppendTo 

func (i *Ingresses) AppendTo(objs []interface{}) []interface{}

func (*Ingresses) Decorate 

func (i *Ingresses) Decorate(setting *api_model.KubeResourceCustomSetting)

func (*Ingresses) Migrate 

func (i *Ingresses) Migrate(namespace string, seletcor labels.Selector)

func (*Ingresses) SetClientset 

func (i *Ingresses) SetClientset(clientset kubernetes.Interface)

type NodeMetrics 

type NodeMetrics struct {
	PodMetricsMap map[string]*PodMetrics `json:"pod_metrics_map"`
}

type PodMetrics 

type PodMetrics struct {
	CPURequest    int64 `json:"cpu_request"`
	MemoryRequest int64 `json:"memory_request"`
}

type ResourceListInterface 

type ResourceListInterface interface {
	SetClientset(clientset kubernetes.Interface)
	Migrate(namespace string, seletcor labels.Selector)
	Decorate(setting *api_model.KubeResourceCustomSetting)
	AppendTo([]interface{}) []interface{}
}

type Secrets 

type Secrets struct {
	kubernetes.Interface
	Secrets []*corev1.Secret `json:"secrets"`
}

func (*Secrets) AppendTo 

func (s *Secrets) AppendTo(objs []interface{}) []interface{}

func (*Secrets) Decorate 

func (s *Secrets) Decorate(setting *api_model.KubeResourceCustomSetting)

func (*Secrets) Migrate 

func (s *Secrets) Migrate(namespace string, seletcor labels.Selector)

func (*Secrets) SetClientset 

func (s *Secrets) SetClientset(clientset kubernetes.Interface)

type Services 

type Services struct {
	kubernetes.Interface
	Services []*corev1.Service `json:"services"`
}

func (*Services) AppendTo 

func (s *Services) AppendTo(objs []interface{}) []interface{}

func (*Services) Decorate 

func (s *Services) Decorate(setting *api_model.KubeResourceCustomSetting)

func (*Services) Migrate 

func (s *Services) Migrate(namespace string, seletcor labels.Selector)

func (*Services) SetClientset 

func (s *Services) SetClientset(clientset kubernetes.Interface)

type Statefulsets 

type Statefulsets struct {
	kubernetes.Interface
	StatefulSets []*appsv1.StatefulSet `json:"statefulsets"`
}

func (*Statefulsets) AppendTo 

func (s *Statefulsets) AppendTo(objs []interface{}) []interface{}

func (*Statefulsets) Decorate 

func (s *Statefulsets) Decorate(setting *api_model.KubeResourceCustomSetting)

func (*Statefulsets) Migrate 

func (s *Statefulsets) Migrate(namespace string, seletcor labels.Selector)

func (*Statefulsets) SetClientset 

func (s *Statefulsets) SetClientset(clientset kubernetes.Interface)

type VeleroCachedResources 

type VeleroCachedResources struct {
	BackupLister                velerov1.BackupLister
	BackupRepositoryLister      velerov1.BackupRepositoryLister
	BackupStorageLocationLister velerov1.BackupStorageLocationLister
	RestoreLister               velerov1.RestoreLister
	PodVolumeBackupLister       velerov1.PodVolumeBackupLister
	PodVolumeRestoreLister      velerov1.PodVolumeRestoreLister
	DeleteBackupRequestLister   velerov1.DeleteBackupRequestLister
	ScheduleLister              velerov1.ScheduleLister
	DownloadRequestLister       velerov1.DownloadRequestLister
}

func GetVeleroCachedResources 

func GetVeleroCachedResources(kubeClient kubernetes.Interface, veleroClient versioned.Interface, apiextClientset apiextclient.Interface) *VeleroCachedResources

type VeleroStatus 

type VeleroStatus struct {
	S3Url             string
	S3UrlScheme       string
	S3Host            string
	S3Region          string
	S3Bucket          string
	S3AccessKeyID     string
	S3SecretAccessKey string
	ResticPassword    string
}

func GetVeleroStatus 

func GetVeleroStatus(kubeClient kubernetes.Interface, veleroClient versioned.Interface, apiextClient apiextclient.Interface) *VeleroStatus

Source Files

View all Source files

Jump to

Keyboard shortcuts

? : This menu
/ : Search site
f or F : Jump to
y or Y : Canonical URL
go.dev uses cookies from Google to deliver and enhance the quality of its services and to analyze traffic. Learn more.