Versions in this module Expand all Collapse all v0 v0.13.1 May 8, 2020 v0.13.0 May 8, 2020 Changes in this version + func CreateKubeConfig(clusterName string, ca certs.CertificateAuthority, endpoint string, ...) ([]byte, error) + func CreateOIDCKubeConfig(clusterName string, ca certs.CertificateAuthority, ...) ([]byte, error) + func GetNodeStatus(node v1.Node) string + func GetUnstructuredObjects(data []byte) ([]unstructured.Unstructured, error) + func GetValidName(name string) string + func IsDeleted(object metav1.Object) bool + func IsMasterNode(node v1.Node) bool + func IsPodCrashLoopBackoff(pod v1.Pod) bool + func IsPodDaemonSet(pod v1.Pod) bool + func IsPodFinished(pod v1.Pod) bool + func IsPodHealthy(pod v1.Pod) bool + func IsPodPending(pod v1.Pod) bool + func LowResourceRequirements() v1.ResourceRequirements + func NewCommandJob(node, command string) v1.PodSpec + func NewDeployment(ns, name, image string, labels map[string]string, port int32, args ...string) *apps.Deployment + func NewObjectMeta(ns, name string) metav1.ObjectMeta + func TestNamespace(client kubernetes.Interface, ns string, t *console.TestResults) + func WaitForNamespace(client kubernetes.Interface, ns string, timeout time.Duration) + type Builder struct + Annotations map[string]string + Labels map[string]string + Namespace string + Objects []runtime.Object + func (b *Builder) AddAnnotations(annotations map[string]string) *Builder + func (b *Builder) AddLabels(labels map[string]string) *Builder + func (b *Builder) Append(objects ...runtime.Object) *Builder + func (b *Builder) ConfigMap(name string, data map[string]string) *Builder + func (b *Builder) Deployment(name, image string) *DeploymentBuilder + func (b *Builder) ObjectMeta(name string) metav1.ObjectMeta + func (b *Builder) Secret(name string, data map[string][]byte) *Builder + func (b *Builder) ServiceAccount(name string) *ServiceAccountBuilder + func (b *Builder) SetNamespace(namespace string) *Builder + type CRD struct + APIVersion string + Kind string + Metadata Metadata + Spec map[string]interface{} + type Client struct + ApplyDryRun bool + GetKubeConfigBytes func() ([]byte, error) + GetKustomizePatches func() ([]string, error) + Trace bool + func (c *Client) Annotate(obj runtime.Object, annotations map[string]string) error + func (c *Client) Apply(namespace string, objects ...runtime.Object) error + func (c *Client) ApplyUnstructured(namespace string, objects ...*unstructured.Unstructured) error + func (c *Client) Cordon(nodeName string) error + func (c *Client) CreateOrUpdateConfigMap(name, ns string, data map[string]string) error + func (c *Client) CreateOrUpdateNamespace(name string, labels map[string]string, annotations map[string]string) error + func (c *Client) CreateOrUpdateSecret(name, ns string, data map[string][]byte) error + func (c *Client) Drain(nodeName string, timeout time.Duration) error + func (c *Client) EvictNode(nodeName string) error + func (c *Client) EvictPod(pod v1.Pod) error + func (c *Client) ExecutePodf(namespace, pod, container string, command ...string) (string, string, error) + func (c *Client) Executef(node string, timeout time.Duration, command string, args ...interface{}) (string, error) + func (c *Client) ExposeIngress(namespace, service string, domain string, port int, ...) error + func (c *Client) Get(namespace string, name string, obj runtime.Object) error + func (c *Client) GetClientset() (*kubernetes.Clientset, error) + func (c *Client) GetConditionsForNode(name string) (map[v1.NodeConditionType]v1.ConditionStatus, error) + func (c *Client) GetConfigMap(namespace, name string) *map[string]string + func (c *Client) GetDynamicClient() (dynamic.Interface, error) + func (c *Client) GetDynamicClientFor(namespace string, obj runtime.Object) (dynamic.ResourceInterface, *schema.GroupVersionResource, ...) + func (c *Client) GetEtcdClientGenerator(ca *certs.Certificate) (*etcd.EtcdClientGenerator, error) + func (c *Client) GetFirstPodByLabelSelector(namespace string, labelSelector string) (*v1.Pod, error) + func (c *Client) GetHealth() Health + func (c *Client) GetKustomize() (*kustomize.Manager, error) + func (c *Client) GetMasterNode() (string, error) + func (c *Client) GetOrCreatePVC(namespace, name, size, class string) error + func (c *Client) GetOrCreateSecret(name, ns string, data map[string][]byte) error + func (c *Client) GetPodReplicas(pod v1.Pod) (int, error) + func (c *Client) GetProxyDialer(p proxy.Proxy) (*proxy.Dialer, error) + func (c *Client) GetRESTConfig() (*rest.Config, error) + func (c *Client) GetRestClient(obj unstructured.Unstructured) (*cliresource.Helper, error) + func (c *Client) GetRestMapper() (meta.RESTMapper, error) + func (c *Client) GetSecret(namespace, name string) *map[string][]byte + func (c *Client) HasConfigMap(ns, name string) bool + func (c *Client) HasSecret(ns, name string) bool + func (c *Client) Label(obj runtime.Object, labels map[string]string) error + func (c *Client) PingMaster() bool + func (c *Client) ResetConnection() + func (c *Client) ScalePod(pod v1.Pod, replicas int32) error + func (c *Client) StreamLogs(namespace, name string) error + func (c *Client) Uncordon(nodeName string) error + func (c *Client) WaitForNode(name string, timeout time.Duration, condition v1.NodeConditionType, ...) (map[v1.NodeConditionType]v1.ConditionStatus, error) + func (c *Client) WaitForPod(ns, name string, timeout time.Duration, phases ...v1.PodPhase) error + func (c *Client) WaitForPodCommand(ns, name string, container string, timeout time.Duration, command ...string) error + type DeploymentBuilder struct + Builder *Builder + Image string + Name string + func Deployment(name, image string) *DeploymentBuilder + func (d *DeploymentBuilder) Annotations(annotations map[string]string) *DeploymentBuilder + func (d *DeploymentBuilder) Args(args ...string) *DeploymentBuilder + func (d *DeploymentBuilder) AsCronJob(schedule string) *batchv1beta1.CronJob + func (d *DeploymentBuilder) AsOneShotJob() *v1.Pod + func (d *DeploymentBuilder) Build() *Builder + func (d *DeploymentBuilder) Command(cmd ...string) *DeploymentBuilder + func (d *DeploymentBuilder) EnvVarFromConfigMap(env, configmap, key string) *DeploymentBuilder + func (d *DeploymentBuilder) EnvVarFromField(env, field string) *DeploymentBuilder + func (d *DeploymentBuilder) EnvVarFromSecret(env, secret, key string) *DeploymentBuilder + func (d *DeploymentBuilder) EnvVars(env map[string]string) *DeploymentBuilder + func (d *DeploymentBuilder) Expose(ports ...int32) *DeploymentBuilder + func (d *DeploymentBuilder) GetLabels() map[string]string + func (d *DeploymentBuilder) Labels(labels map[string]string) *DeploymentBuilder + func (d *DeploymentBuilder) MountConfigMap(cm, path string) *DeploymentBuilder + func (d *DeploymentBuilder) MountSecret(secret, path string, mode int32) *DeploymentBuilder + func (d *DeploymentBuilder) NodeAffinity(nodeReadinessLabel map[string]string) *DeploymentBuilder + func (d *DeploymentBuilder) ObjectMeta() metav1.ObjectMeta + func (d *DeploymentBuilder) PodAffinity(labels map[string]string, topologyKey string) *DeploymentBuilder + func (d *DeploymentBuilder) PodSpec() v1.PodSpec + func (d *DeploymentBuilder) PodTemplate() v1.PodTemplateSpec + func (d *DeploymentBuilder) Ports(ports ...int32) *DeploymentBuilder + func (d *DeploymentBuilder) Replicas(replicas int) *DeploymentBuilder + func (d *DeploymentBuilder) Resources(resources v1.ResourceRequirements) *DeploymentBuilder + func (d *DeploymentBuilder) ServiceAccount(name string) *DeploymentBuilder + type DynamicKind struct + APIVersion string + Kind string + func (dk DynamicKind) GroupVersionKind() schema.GroupVersionKind + func (dk DynamicKind) SetGroupVersionKind(gvk schema.GroupVersionKind) + type Health struct + CrashLoopBackOff int + Error error + ErrorPods int + PendingPods int + ReadyNodes int + RunningPods int + UnreadyNodes int + func (h Health) IsDegradedComparedTo(h2 Health) bool + func (h Health) String() string + type Metadata struct + Annotations map[string]string + Labels map[string]string + Name string + Namespace string + type ServiceAccountBuilder struct + Name string + func (s *ServiceAccountBuilder) AddClusterRole(role string) *ServiceAccountBuilder + func (s *ServiceAccountBuilder) AddRole(role string) *ServiceAccountBuilder + type Spec struct + Items []unstructured.Unstructured + Path string + type Specs []Spec + func Walk(path string) (Specs, error) + func (specs Specs) FilterBy(kind string) []unstructured.Unstructured