kube

package
v1.12.0 Latest Latest
Warning

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

 Go to latest Published: Apr 17, 2024 License: LGPL-3.0 Imports: 46 Imported by: 0

Documentation

Index

Constants

This section is empty.

Variables

This section is empty.

Functions

func CreateKubevirtVM added in v1.7.0 

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

func DeleteKubeVirtVM added in v1.7.0 

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

func DeleteKubeVirtVMI added in v1.7.0 

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

func GetClusterCPURequest added in v1.11.0 

func GetClusterCPURequest() int64

func GetClusterMemoryRequest added in v1.11.0 

func GetClusterMemoryRequest() int64

func GetClusterPodCount added in v1.11.0 

func GetClusterPodCount() int64

func GetDefaultStorageClass added in v1.7.0 

func GetDefaultStorageClass(clientset kubernetes.Interface) string

func GetKubeVirtVM added in v1.7.0 

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

func GetKubeVirtVMI added in v1.7.0 

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

func GetNodeCPURequest added in v1.11.0 

func GetNodeCPURequest(node string) int64

func GetNodeMemoryRequest added in v1.11.0 

func GetNodeMemoryRequest(node string) int64

func GetNodePodCount added in v1.11.0 

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 added in v1.7.0 

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

func IsKubevirtInstalled added in v1.7.0 

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

func IsVeleroInstalled added in v1.6.0 

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

func ListKubeVirtVMs added in v1.7.0 

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

func NodeRoles added in v1.10.0 

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

func RegionAPIExtClientset added in v1.9.0 

func RegionAPIExtClientset() apiext.Interface

func RegionClientset added in v1.9.0 

func RegionClientset() kubernetes.Interface

func RegionDynamicClient added in v1.9.0 

func RegionDynamicClient() dynamic.Interface

func RegionRESTConfig added in v1.9.0 

func RegionRESTConfig() *rest.Config

func RegionRuntimeClient added in v1.9.0 

func RegionRuntimeClient() runtimeclient.Client

func RegionVeleroClientset added in v1.9.0 

func RegionVeleroClientset() veleroversioned.Interface

func RegionWutongClientset added in v1.9.0 

func RegionWutongClientset() wutongversioned.Interface

func UnDynamicObject added in v1.7.0 

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

func UnDynamicObjectList added in v1.7.0 

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

func UpdateKubeVirtVM added in v1.7.0 

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 added in v1.11.0 

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 added in v1.7.0 

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

func GetDynamicCachedResources added in v1.7.0 

func GetDynamicCachedResources(dynamicClient dynamic.Interface) *DynamicCachedResources

func (*DynamicCachedResources) GetVMILister added in v1.7.0 

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

func (*DynamicCachedResources) GetVMLister added in v1.7.0 

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 added in v1.11.0 

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

type PodMetrics added in v1.11.0 

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 added in v1.6.0 

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 added in v1.6.0 

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

type VeleroStatus added in v1.6.0 

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

func GetVeleroStatus added in v1.6.0 

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.