const defaultPollIntervalSeconds … const defaultPollTimeoutSeconds … type TestPod … func (pod TestPod) PodString() PodString { … } type kubeManager … // newKubeManager is a utility function that wraps creation of the kubeManager instance. func newKubeManager(framework *framework.Framework, dnsDomain string) *kubeManager { … } // initializeCluster initialized the cluster, creating namespaces pods and services as needed. func (k *kubeManager) initializeClusterFromModel(ctx context.Context, model *Model) error { … } func (k *kubeManager) AllPods() []TestPod { … } func (k *kubeManager) AllPodStrings() []PodString { … } func (k *kubeManager) DNSDomain() string { … } func (k *kubeManager) NamespaceNames() []string { … } // getPod gets a pod by namespace and name. func (k *kubeManager) getPod(ctx context.Context, ns string, name string) (*v1.Pod, error) { … } // probeConnectivity execs into a pod and checks its connectivity to another pod. // Implements the Prober interface. func (k *kubeManager) probeConnectivity(args *probeConnectivityArgs) (bool, string, error) { … } // executeRemoteCommand executes a remote shell command on the given pod. func (k *kubeManager) executeRemoteCommand(namespace string, pod string, containerName string, command []string) (string, string, error) { … } // createService is a convenience function for service setup. func (k *kubeManager) createService(ctx context.Context, service *v1.Service) (*v1.Service, error) { … } // createPod is a convenience function for pod setup. func (k *kubeManager) createPod(ctx context.Context, pod *v1.Pod) (*v1.Pod, error) { … } // cleanNetworkPolicies is a convenience function for deleting network policies before startup of any new test. func (k *kubeManager) cleanNetworkPolicies(ctx context.Context) error { … } // createNetworkPolicy is a convenience function for creating network policies. func (k *kubeManager) createNetworkPolicy(ctx context.Context, ns string, netpol *networkingv1.NetworkPolicy) (*networkingv1.NetworkPolicy, error) { … } // updateNetworkPolicy is a convenience function for updating network policies. func (k *kubeManager) updateNetworkPolicy(ctx context.Context, ns string, netpol *networkingv1.NetworkPolicy) (*networkingv1.NetworkPolicy, error) { … } // getNamespace gets a namespace object from kubernetes. func (k *kubeManager) getNamespace(ctx context.Context, ns string) (*v1.Namespace, error) { … } // getProbeTimeoutSeconds returns a timeout for how long the probe should work before failing a check, and takes windows heuristics into account, where requests can take longer sometimes. func getProbeTimeoutSeconds() int { … } // getWorkers returns the number of workers suggested to run when testing. func getWorkers() int { … } // getPollInterval returns the value for which the Prober will wait before attempting next attempt. func getPollIntervalSeconds() int { … } // getPollTimeout returns the timeout for polling on probes, and takes windows heuristics into account, where requests can take longer sometimes. func getPollTimeoutSeconds() int { … }
Codebase Browser
kubernetes