Versions in this module Expand all Collapse all v1 v1.16.3 Oct 23, 2019 Changes in this version + func CreateOrMutateConfigMap(client clientset.Interface, cm *v1.ConfigMap, mutator ConfigMapMutator) error + func CreateOrRetainConfigMap(client clientset.Interface, cm *v1.ConfigMap, configMapName string) error + func CreateOrUpdateClusterRole(client clientset.Interface, clusterRole *rbac.ClusterRole) error + func CreateOrUpdateClusterRoleBinding(client clientset.Interface, clusterRoleBinding *rbac.ClusterRoleBinding) error + func CreateOrUpdateConfigMap(client clientset.Interface, cm *v1.ConfigMap) error + func CreateOrUpdateDaemonSet(client clientset.Interface, ds *apps.DaemonSet) error + func CreateOrUpdateDeployment(client clientset.Interface, deploy *apps.Deployment) error + func CreateOrUpdateRole(client clientset.Interface, role *rbac.Role) error + func CreateOrUpdateRoleBinding(client clientset.Interface, roleBinding *rbac.RoleBinding) error + func CreateOrUpdateSecret(client clientset.Interface, secret *v1.Secret) error + func CreateOrUpdateServiceAccount(client clientset.Interface, sa *v1.ServiceAccount) error + func DefaultMarshalFunc(obj runtime.Object, gv schema.GroupVersion) ([]byte, error) + func DeleteDaemonSetForeground(client clientset.Interface, namespace, name string) error + func DeleteDeploymentForeground(client clientset.Interface, namespace, name string) error + func GetConfigMapWithRetry(client clientset.Interface, namespace, name string) (*v1.ConfigMap, error) + func MutateConfigMap(client clientset.Interface, meta metav1.ObjectMeta, mutator ConfigMapMutator) error + func NewDryRunClient(drg DryRunGetter, w io.Writer) clientset.Interface + func NewDryRunClientWithOpts(opts DryRunClientOptions) clientset.Interface + func PatchNode(client clientset.Interface, nodeName string, patchFn func(*v1.Node)) error + func PatchNodeOnce(client clientset.Interface, nodeName string, patchFn func(*v1.Node)) func() (bool, error) + func PrintBytesWithLinePrefix(w io.Writer, objBytes []byte, linePrefix string) + func TryRunCommand(f func() error, failureThreshold int) error + type ClientBackedDryRunGetter struct + func NewClientBackedDryRunGetter(config *rest.Config) (*ClientBackedDryRunGetter, error) + func NewClientBackedDryRunGetterFromKubeconfig(file string) (*ClientBackedDryRunGetter, error) + func (clg *ClientBackedDryRunGetter) Client() clientset.Interface + func (clg *ClientBackedDryRunGetter) HandleGetAction(action core.GetAction) (bool, runtime.Object, error) + func (clg *ClientBackedDryRunGetter) HandleListAction(action core.ListAction) (bool, runtime.Object, error) + type ConfigMapMutator func(*v1.ConfigMap) error + type DryRunClientOptions struct + AppendReactors []core.Reactor + Getter DryRunGetter + MarshalFunc MarshalFunc + PrependReactors []core.Reactor + PrintGETAndLIST bool + Writer io.Writer + func GetDefaultDryRunClientOptions(drg DryRunGetter, w io.Writer) DryRunClientOptions + type DryRunGetter interface + HandleGetAction func(core.GetAction) (bool, runtime.Object, error) + HandleListAction func(core.ListAction) (bool, runtime.Object, error) + type InitDryRunGetter struct + func NewInitDryRunGetter(controlPlaneName string, serviceSubnet string) *InitDryRunGetter + func (idr *InitDryRunGetter) HandleGetAction(action core.GetAction) (bool, runtime.Object, error) + func (idr *InitDryRunGetter) HandleListAction(action core.ListAction) (bool, runtime.Object, error) + type KubeWaiter struct + func (w *KubeWaiter) SetTimeout(timeout time.Duration) + func (w *KubeWaiter) WaitForAPI() error + func (w *KubeWaiter) WaitForHealthyKubelet(initalTimeout time.Duration, healthzEndpoint string) error + func (w *KubeWaiter) WaitForKubeletAndFunc(f func() error) error + func (w *KubeWaiter) WaitForPodToDisappear(podName string) error + func (w *KubeWaiter) WaitForPodsWithLabel(kvLabel string) error + func (w *KubeWaiter) WaitForStaticPodControlPlaneHashes(nodeName string) (map[string]string, error) + func (w *KubeWaiter) WaitForStaticPodHashChange(nodeName, component, previousHash string) error + func (w *KubeWaiter) WaitForStaticPodSingleHash(nodeName string, component string) (string, error) + type MarshalFunc func(runtime.Object, schema.GroupVersion) ([]byte, error) + type Waiter interface + SetTimeout func(timeout time.Duration) + WaitForAPI func() error + WaitForHealthyKubelet func(initalTimeout time.Duration, healthzEndpoint string) error + WaitForKubeletAndFunc func(f func() error) error + WaitForPodToDisappear func(staticPodName string) error + WaitForPodsWithLabel func(kvLabel string) error + WaitForStaticPodControlPlaneHashes func(nodeName string) (map[string]string, error) + WaitForStaticPodHashChange func(nodeName, component, previousHash string) error + WaitForStaticPodSingleHash func(nodeName string, component string) (string, error) + func NewKubeWaiter(client clientset.Interface, timeout time.Duration, writer io.Writer) Waiter