Versions in this module Expand all Collapse all v1 v1.0.0 Oct 15, 2021 Changes in this version + var ClientForTest corev1.CoreV1Interface = nil + func CheckPodReady(name, namespace string, logger logr.Logger) bool + func CheckPolicyIsReload(policy *GetControllerConfigPolicy) bool + func CreatePod(pod *v1.Pod, logger logr.Logger) error + func DeleteConfigmap(cm *corev1.ConfigMap, logger logr.Logger) error + func DeletePod(name, namespace string, ctx context.Context, logger logr.Logger) error + func ExecInPod(command []string, containerName, podName, namespace string, logger logr.Logger) (string, string, error) + func ExecInPodWithTimeout(ctx context.Context, command []string, ...) (string, string, error) + func GetClientIP(hostIP string, logger logr.Logger) (string, error) + func GetConfigMap(name, namespace string, logger logr.Logger) (*corev1.ConfigMap, error) + func GetCorev1Client() (corev1.CoreV1Interface, error) + func GetDynamicClient(group, version, resource string) (dynamic.NamespaceableResourceInterface, error) + func GetHostIP(clientIP string, logger logr.Logger) (string, error) + func GetKubeClient() (*kubernetes.Clientset, *rest.Config, error) + func GetKubeConfig() (*rest.Config, error) + func GetNode(nodeName string, logger logr.Logger) (*v1.Node, error) + func GetNodeCondition(node *corev1.Node, conditionType corev1.NodeConditionType) *corev1.NodeCondition + func GetNodes(logger logr.Logger) ([]v1.Node, error) + func GetPod(name, namespace string, logger logr.Logger) (*v1.Pod, error) + func GetPodContainerInfo(pod *corev1.Pod, logger logr.Logger) string + func GetPodWatchResourceVersion(name string, namespace string, client corev1client.CoreV1Interface, ...) string + func GetPodWatcher(pod *corev1.Pod, client corev1client.CoreV1Interface, timeout int64, ...) (watch.Interface, error) + func GetPodsByLabel(labelStr, namespace string, logger logr.Logger) (*v1.PodList, error) + func GetService(name string, namespace string, logger logr.Logger) (*corev1.Service, error) + func GetServiceByLabel(labelStr string, namespace string, logger logr.Logger) (*corev1.ServiceList, error) + func IsNodeReady(node *v1.Node) bool + func IsPodSchedulerFailed(cond *corev1.PodCondition) bool + func SetWatchOption(object metav1.ObjectMeta, timeout int64) *metav1.ListOptions + func StringOfCondition(condition *corev1.NodeCondition) string + func StringOfPodCondition(condition *corev1.PodCondition) string + func UpdateConfigMap(configMap *corev1.ConfigMap) error + func WaitForContainerReady(pod *corev1.Pod, containerName string, ctx context.Context, logger logr.Logger) (*corev1.Pod, error) + func WaitForPodDeleted(namespace, name string, ctx context.Context, logger logr.Logger) error + func WaitForPodReady(pod *corev1.Pod, isNewPod bool, ctx context.Context, logger logr.Logger) (*corev1.Pod, error) + type ControllerConfig struct + CanUpdateNotChangeableParams bool + CmHybridDeployment bool + ControllerNodeLabel string + CowSnapshotSupport bool + DegradeDaemonSet []string + DegradeDeployment []string + DisableSanCmd bool + DisabledWfEvents []string + EnableCheckSum bool + EnableDegrade bool + EnableOnlinePromote bool + EnablePodGc bool + EnableRedline bool + EnableVip bool + HybridDeployment bool + SshPassword string + SshUser string + func GetControllerConfig(logger logr.Logger) (*ControllerConfig, error) + func GetControllerConfigWithPolicy(policy *GetControllerConfigPolicy, logger logr.Logger) (*ControllerConfig, error) + type GetControllerConfigPolicy struct + IsInited bool + LastQueryTime *time.Time + LastValue *ControllerConfig + MaxQueryStepTime *time.Duration + var ControllerConfigPolicy *GetControllerConfigPolicy + type NodeClientIP struct + ClientIP string + HostIP string + NodeName string + func GetNodeClientIPList(logger logr.Logger) ([]*NodeClientIP, error)
Go to main page