kommons

package module

Go to main page

Versions in this module

v0

v0.31.6

Nov 5, 2024

v0.31.5

Oct 22, 2024

v0.31.4

Sep 27, 2023

v0.31.3

Jul 20, 2023

v0.31.2

Jun 20, 2023

v0.31.1

Oct 2, 2022

v0.31.0

Oct 2, 2022

v0.30.2

Apr 29, 2022

Changes in this version

+ func IsPod(obj *unstructured.Unstructured) bool

+ func IsPodReadyAndRunning(item *unstructured.Unstructured) (bool, string)

v0.30.1

Apr 28, 2022

v0.30.0

Apr 4, 2022

Changes in this version

+ func TestStatefulSet(client kubernetes.Interface, ns string, name string, t *console.TestResults)

v0.29.1

Mar 10, 2022

v0.29.0

Feb 27, 2022

Changes in this version

type Client

+ func (c *Client) GetConfigMapV2(ctx context.Context, namespace, name string) (*map[string]string, error)

+ func (c *Client) GetEnvValueFromCache(input EnvVar, namespace string, expiry time.Duration) (string, string, error)

+ func (c *Client) GetSecretV2(ctx context.Context, namespace, name string) (*map[string][]byte, error)

type EnvVar

+ func (e EnvVar) GetCacheKey() string

+ func (e EnvVar) GetKey() string

v0.28.0

Feb 22, 2022

v0.27.0

Jan 4, 2022

Changes in this version

+ func IsNode(obj *unstructured.Unstructured) bool

+ func IsNodeReady(item *unstructured.Unstructured) (bool, string)

v0.26.0

Oct 20, 2021

v0.25.2

Sep 19, 2021

v0.25.1

Sep 17, 2021

v0.25.0

Sep 6, 2021

Changes in this version

type Client

+ func (c *Client) StreamLogsV2(namespace, name string, timeout time.Duration, containerNames ...string) error

+ func (c *Client) WaitForContainerStart(ns, name string, timeout time.Duration, containerNames ...string) error

v0.24.0

Sep 5, 2021

Changes in this version

type EnvVar

+ func (e EnvVar) IsEmpty() bool

v0.23.0

Sep 1, 2021

v0.22.0

Aug 12, 2021

v0.21.2

Aug 10, 2021

v0.21.1

Aug 4, 2021

v0.21.0

Jul 25, 2021

Changes in this version

+ func GetDNS1192Name(s string) string

v0.20.2

Jul 25, 2021

v0.20.1

Jul 20, 2021

Changes in this version

+ func GetUnstructuredObjectsFromJson(data []byte) ([]*unstructured.Unstructured, error)

v0.20.0

Jul 1, 2021

v0.19.0

Jun 28, 2021

v0.18.3

Jun 22, 2021

v0.18.2

Jun 16, 2021

v0.18.1

Jun 15, 2021

v0.18.0

Jun 3, 2021

Changes in this version

+ var CoreAPIGroups = []string

type Client

+ func (c *Client) IsCoreType(object *unstructured.Unstructured) bool

v0.17.2

Jun 3, 2021

v0.17.1

Jun 1, 2021

v0.17.0

May 29, 2021

Changes in this version

+ var APIServerDefaultArgs = []string

+ func InstallTestBin(version string) (string, error)

+ func StartTestEnv(version string) (*rest.Config, string, error)

v0.16.0

May 21, 2021

v0.15.0

May 20, 2021

Changes in this version

type Client

+ func (c *Client) ResetRestMapper() error

v0.14.0

May 13, 2021

Changes in this version

+ func IsDataContainerReady(item *unstructured.Unstructured) (bool, string)

+ func IsKafka(obj *unstructured.Unstructured) bool

+ func IsServiceReady(item *unstructured.Unstructured, client *Client) (bool, string)

type Client

+ func (c *Client) IsConditionReadyTrue(item *unstructured.Unstructured) (bool, string)

v0.13.0

May 12, 2021

v0.12.0

May 3, 2021

Changes in this version

+ func IsBuilder(obj *unstructured.Unstructured) bool

+ func IsBuilderReady(item *unstructured.Unstructured) (bool, string)

+ func IsImage(obj *unstructured.Unstructured) bool

+ func IsImageReady(item *unstructured.Unstructured) (bool, string)

v0.11.4

May 2, 2021

v0.11.3

Apr 29, 2021

v0.11.2

Apr 27, 2021

Changes in this version

+ func IsPostgresqlDB(obj *unstructured.Unstructured) bool

type Client

+ func (c *Client) IsPostgresqlDBReady(item *unstructured.Unstructured) (bool, string)

+ func (c *Client) WaitForPodByLabel(ns, label string, timeout time.Duration, phases ...v1.PodPhase) (*v1.Pod, error)

v0.11.1

Apr 23, 2021

v0.11.0

Apr 19, 2021

Changes in this version

type Client

+ func (c *Client) TriggerCronJobManually(namespace, cronJobName string) (string, error)

+ func (c *Client) WaitForJob(ns, name string, timeout time.Duration) error

v0.10.0

Mar 31, 2021

Changes in this version

type Client

+ func (c *Client) GetPodLogs(namespace, podName, container string) (string, error)

v0.9.0

Mar 31, 2021

Changes in this version

type Client

+ func (c *Client) GetJobPod(namespace, jobName string) (string, error)

type DeploymentBuilder

+ func (d *DeploymentBuilder) AsOneShotPod() *v1.Pod

+ func (d *DeploymentBuilder) EnvFromConfigMap(name string) *DeploymentBuilder

+ func (d *DeploymentBuilder) EnvFromSecret(name string) *DeploymentBuilder

v0.8.1

Mar 22, 2021

Changes in this version

type Client

+ func (c *Client) IsReadyWithConditions(item *unstructured.Unstructured) (bool, string)

v0.8.0

Mar 21, 2021

Changes in this version

+ func IsMongoDB(obj *unstructured.Unstructured) bool

type Client

+ func (c *Client) IsMongoDBReady(item *unstructured.Unstructured) (bool, string)

v0.7.2

Mar 18, 2021

Changes in this version

+ func IsCanary(obj *unstructured.Unstructured) bool

+ func IsCronJob(obj *unstructured.Unstructured) bool

+ func IsDeploymentReady(d *appsv1.Deployment) (bool, string)

+ func IsElasticsearch(obj *unstructured.Unstructured) bool

+ func IsKibana(obj *unstructured.Unstructured) bool

+ func IsPostgresql(obj *unstructured.Unstructured) bool

+ func IsRedisFailover(obj *unstructured.Unstructured) bool

+ func IsStatefulSetReady(sts *appsv1.StatefulSet) (bool, string)

type Client

+ func (c *Client) IsElasticsearchReady(item *unstructured.Unstructured) (bool, string)

+ func (c *Client) IsKibanaReady(item *unstructured.Unstructured) (bool, string)

+ func (c *Client) IsPostgresqlReady(item *unstructured.Unstructured) (bool, string)

+ func (c *Client) IsRedisFailoverReady(item *unstructured.Unstructured) (bool, string)

v0.7.1

Mar 17, 2021

v0.7.0

Mar 16, 2021

Changes in this version

type Client

+ func (c *Client) GetEnvValue(input EnvVar, namespace string) (string, string, error)

+ type ConfigMapKeySelector struct

+ Key string

+ Optional *bool

+ func (in *ConfigMapKeySelector) DeepCopy() *ConfigMapKeySelector

+ func (in *ConfigMapKeySelector) DeepCopyInto(out *ConfigMapKeySelector)

+ type EnvVar struct

+ Name string

+ Value string

+ ValueFrom *EnvVarSource

+ func (in *EnvVar) DeepCopy() *EnvVar

+ func (in *EnvVar) DeepCopyInto(out *EnvVar)

+ type EnvVarSource struct

+ ConfigMapKeyRef *ConfigMapKeySelector

+ SecretKeyRef *SecretKeySelector

+ func (in *EnvVarSource) DeepCopy() *EnvVarSource

+ func (in *EnvVarSource) DeepCopyInto(out *EnvVarSource)

+ type LocalObjectReference struct

+ Name string

+ func (in *LocalObjectReference) DeepCopy() *LocalObjectReference

+ func (in *LocalObjectReference) DeepCopyInto(out *LocalObjectReference)

+ type SecretKeySelector struct

+ Key string

+ Optional *bool

+ func (in *SecretKeySelector) DeepCopy() *SecretKeySelector

+ func (in *SecretKeySelector) DeepCopyInto(out *SecretKeySelector)

v0.6.1

Mar 16, 2021

Changes in this version

type Client

+ func (c *Client) Update(namespace string, item runtime.Object) error

v0.6.0

Mar 16, 2021

Changes in this version

type Client

+ func (c *Client) UpdateCRD(namespace string, item *unstructured.Unstructured) error

v0.5.2

Mar 16, 2021

v0.5.1

Mar 15, 2021

Changes in this version

type Client

+ func (c *Client) WaitForRestMapping(obj runtime.Object, timeout time.Duration) (*meta.RESTMapping, error)

v0.5.0

Mar 15, 2021

v0.4.11

Mar 15, 2021

v0.4.10

Mar 15, 2021

v0.4.9

Mar 15, 2021

Changes in this version

+ func IsAPIResourceMissing(err error) bool

+ func UnwrapError(err error) string

v0.4.8

Mar 15, 2021

Changes in this version

+ var KustomizedLabel = "kustomize/patched"

+ var TrivialTypes = map[string]IsType

+ func AsClusterRoleBinding(obj *unstructured.Unstructured) (*rbac.ClusterRoleBinding, error)

+ func AsCustomResourceDefinition(obj *unstructured.Unstructured) (*apiextensions.CustomResourceDefinition, error)

+ func AsCustomResourceDefinitionV1Beta1(obj *unstructured.Unstructured) (*apiextensionsv1beta1.CustomResourceDefinition, error)

+ func AsDaemonSet(obj *unstructured.Unstructured) (*appsv1.DaemonSet, error)

+ func AsDeployment(obj *unstructured.Unstructured) (*appsv1.Deployment, error)

+ func AsIngress(obj *unstructured.Unstructured) (*networking.Ingress, error)

+ func AsPodTemplate(obj *unstructured.Unstructured) (*v1.PodTemplateSpec, error)

+ func AsRoleBinding(obj *unstructured.Unstructured) (*rbac.RoleBinding, error)

+ func AsSecret(obj *unstructured.Unstructured) (*v1.Secret, error)

+ func AsService(obj *unstructured.Unstructured) (*v1.Service, error)

+ func AsStatefulSet(obj *unstructured.Unstructured) (*appsv1.StatefulSet, error)

+ func CreateKubeConfig(clusterName string, ca certs.CertificateAuthority, endpoint string, ...) ([]byte, error)

+ func CreateMultiKubeConfig(ca certs.CertificateAuthority, clusters map[string]string, group string, ...) ([]byte, error)

+ func CreateOIDCKubeConfig(clusterName string, ca certs.CertificateAuthority, ...) ([]byte, error)

+ func DefaultSubjects(subjects []rbac.Subject) []rbac.Subject

+ func Defaults(obj *unstructured.Unstructured) (*unstructured.Unstructured, error)

+ func DefaultsClusterRoleBinding(rb *rbac.ClusterRoleBinding) *rbac.ClusterRoleBinding

+ func DefaultsContainer(container v1.Container) v1.Container

+ func DefaultsContainers(containers []v1.Container) []v1.Container

+ func DefaultsCustomResourceDefinition(crd *apiextensions.CustomResourceDefinition) *apiextensions.CustomResourceDefinition

+ func DefaultsCustomResourceDefinitionV1Beta1(crd *apiextensionsv1beta1.CustomResourceDefinition) *apiextensionsv1beta1.CustomResourceDefinition

+ func DefaultsDaemonSet(daemeonset *appsv1.DaemonSet) *appsv1.DaemonSet

+ func DefaultsDeployment(deploy *appsv1.Deployment) *appsv1.Deployment

+ func DefaultsIngress(ing *networking.Ingress) *networking.Ingress

+ func DefaultsPod(pod v1.PodTemplateSpec) v1.PodTemplateSpec

+ func DefaultsProbe(probe *v1.Probe) *v1.Probe

+ func DefaultsRoleBinding(rb *rbac.RoleBinding) *rbac.RoleBinding

+ func DefaultsService(svc *v1.Service) *v1.Service

+ func DefaultsStatefulSet(sts *appsv1.StatefulSet) *appsv1.StatefulSet

+ func Diff(from, to *unstructured.Unstructured) string

+ func GetContainerStatus(pod v1.Pod) string

+ func GetCurrentClusterNameFrom(kubeConfigPath string) string

+ func GetLastRestartTime(pod v1.Pod) *time.Time

+ func GetNodeStatus(node v1.Node) string

+ func GetOwner(pod v1.Pod) string

+ func GetPodStatus(pod v1.Pod) string

+ func GetUnstructuredObjects(data []byte) ([]*unstructured.Unstructured, error)

+ func GetValidName(name string) string

+ func HasTaint(node v1.Node, name string) bool

+ func IsAnyRoleBinding(obj *unstructured.Unstructured) bool

+ func IsApp(obj *unstructured.Unstructured) bool

+ func IsAppReady(item *unstructured.Unstructured) (bool, string)

+ func IsClusterRole(obj *unstructured.Unstructured) bool

+ func IsClusterRoleBinding(obj *unstructured.Unstructured) bool

+ func IsConfigMap(obj *unstructured.Unstructured) bool

+ func IsConstraintTemplate(obj *unstructured.Unstructured) bool

+ func IsCustomResourceDefinition(obj *unstructured.Unstructured) bool

+ func IsCustomResourceDefinitionV1Beta1(obj *unstructured.Unstructured) bool

+ func IsDaemonSet(obj *unstructured.Unstructured) bool

+ func IsDeleted(object metav1.Object) bool

+ func IsDeployment(obj *unstructured.Unstructured) bool

+ func IsDiffable(obj *unstructured.Unstructured) bool

+ func IsElasticReady(item *unstructured.Unstructured) (bool, string)

+ func IsIngress(obj *unstructured.Unstructured) bool

+ func IsKustomized(to *unstructured.Unstructured) bool

+ func IsMasterNode(node v1.Node) bool

+ func IsNil(object runtime.Object) bool

+ func IsPVC(obj *unstructured.Unstructured) 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 IsPodReady(pod v1.Pod) bool

+ func IsRole(obj *unstructured.Unstructured) bool

+ func IsRoleBinding(obj *unstructured.Unstructured) bool

+ func IsSecret(obj *unstructured.Unstructured) bool

+ func IsService(obj *unstructured.Unstructured) bool

+ func IsServiceAccount(obj *unstructured.Unstructured) bool

+ func IsStatefulSet(obj *unstructured.Unstructured) bool

+ func IsStaticPod(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 RemoveTaint(taints []v1.Taint, name string) []v1.Taint

+ func RequiresReplacement(obj *unstructured.Unstructured, err error) bool

+ func Sanitize(objects ...*unstructured.Unstructured)

+ func SetAnnotation(obj *unstructured.Unstructured, key string, value string)

+ func StripIdentifiers(object *unstructured.Unstructured) *unstructured.Unstructured

+ func TestDaemonSet(client kubernetes.Interface, ns string, name string, t *console.TestResults)

+ func TestDeploy(client kubernetes.Interface, ns string, deploymentName string, ...)

+ func TestNamespace(client kubernetes.Interface, ns string, t *console.TestResults)

+ func TestPod(testName string, client kubernetes.Interface, events typedv1.EventInterface, ...) error

+ func TestPodsByLabels(client kubernetes.Interface, testName string, ns string, ...)

+ func ToJson(to *unstructured.Unstructured) string

+ func ToUnstructured(unstructuredObj *unstructured.Unstructured, obj interface{}) (*unstructured.Unstructured, error)

+ func ToYaml(to *unstructured.Unstructured) string

+ func Unwrap(list []*unstructured.Unstructured) ([]*unstructured.Unstructured, error)

+ func Validate(object runtime.Object) error

+ type ApplyHook func(namespace string, obj unstructured.Unstructured)

+ 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

+ ApplyHook ApplyHook

+ GetKubeConfigBytes func() ([]byte, error)

+ GetKustomizePatches func() ([]string, error)

+ GetRESTConfig func() (*rest.Config, error)

+ ImmutableAnnotations []string

+ Trace bool

+ func NewClient(config *rest.Config, logger logger.Logger) *Client

+ func NewClientFromBytes(kubeconfig []byte) (*Client, error)

+ func NewClientFromDefaults(log logger.Logger) (*Client, error)

+ 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) ApplyText(namespace string, specs ...string) 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, annotations map[string]string) error

+ func (c *Client) CreateOrUpdateSecret(name, ns string, data map[string][]byte) error

+ func (c *Client) DeleteByKind(kind, namespace, name string) error

+ func (c *Client) DeleteUnstructured(namespace string, objects ...*unstructured.Unstructured) 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) ForceDeleteNamespace(ns string, timeout time.Duration) error

+ func (c *Client) Get(namespace string, name string, obj runtime.Object) error

+ func (c *Client) GetAPIResource(name string) (*metav1.APIResource, error)

+ func (c *Client) GetByKind(kind, namespace, name string) (*unstructured.Unstructured, error)

+ func (c *Client) GetClientByKind(kind string) (dynamic.NamespaceableResourceInterface, error)

+ func (c *Client) GetClientset() (*kubernetes.Clientset, error)

+ func (c *Client) GetConditions(item *unstructured.Unstructured) ([]kommonsv1.CommonCondition, 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) GetDynamicClientForUser(namespace string, obj runtime.Object, user string) (dynamic.ResourceInterface, *schema.GroupVersionResource, ...)

+ func (c *Client) GetEtcdClient(ctx context.Context) (*etcd.Client, error)

+ func (c *Client) GetEtcdClientGenerator(ca *certs.Certificate) (*etcd.EtcdClientGenerator, error)

+ func (c *Client) GetEventsFor(kind string, object metav1.Object) ([]v1.Event, 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) GetMasterNodes() ([]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) GetRESTConfigFromKubeconfig() (*rest.Config, error)

+ func (c *Client) GetRESTConfigInCluster() (*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) HasChanges(from, to *unstructured.Unstructured) bool

+ func (c *Client) HasConfigMap(ns, name string) bool

+ func (c *Client) HasSecret(ns, name string) bool

+ func (c *Client) IsCRDReady(group, name string) (bool, string)

+ func (c *Client) IsConstraintTemplateReady(item *unstructured.Unstructured) (bool, string)

+ func (c *Client) IsNamespaceReady(ns string) (bool, string)

+ func (c *Client) IsReady(item *unstructured.Unstructured) (bool, string)

+ func (c *Client) IsTrivialType(item *unstructured.Unstructured) bool

+ func (c *Client) Label(obj runtime.Object, labels map[string]string) error

+ func (c *Client) Orphan(kind, name, namespace string, object RuntimeObjectWithMetadata) error

+ func (c *Client) OrphanCRD(kind, name, namespace string) error

+ func (c *Client) PingMaster() bool

+ func (c *Client) Refresh(item *unstructured.Unstructured) (*unstructured.Unstructured, error)

+ func (c *Client) RemoveVolumeAttachment(va storagev1.VolumeAttachment) error

+ func (c *Client) ResetConnection()

+ func (c *Client) ScalePod(pod v1.Pod, replicas int32) error

+ func (c *Client) SetCondition(item *unstructured.Unstructured, kind, status string) error

+ func (c *Client) StreamLogs(namespace, name string) error

+ func (c *Client) Uncordon(nodeName string) error

+ func (c *Client) Undelete(kind, name, namespace string, object RuntimeObjectWithMetadata) error

+ func (c *Client) UndeleteCRD(kind, name, namespace string) error

+ func (c *Client) WaitFor(obj runtime.Object, timeout time.Duration) (*unstructured.Unstructured, error)

+ func (c *Client) WaitForAPIResource(group, name string, timeout time.Duration) error

+ func (c *Client) WaitForCRD(kind, namespace, name string, timeout time.Duration, waitFN WaitFN) (*unstructured.Unstructured, error)

+ func (c *Client) WaitForDaemonSet(ns, name string, timeout time.Duration) error

+ func (c *Client) WaitForDeployment(ns, name string, timeout time.Duration) error

+ func (c *Client) WaitForNamespace(ns string, timeout time.Duration) 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

+ func (c *Client) WaitForResource(kind, namespace, name string, timeout time.Duration) (*unstructured.Unstructured, error)

+ func (c *Client) WaitForStatefulSet(ns, name string, timeout time.Duration) error

+ func (c *Client) WaitForTaintRemoval(name string, timeout time.Duration, taintKey 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) GetNonReadyPods() int

+ func (h Health) IsDegradedComparedTo(h2 Health, tolerance int) bool

+ func (h Health) String() string

+ type IsType func(*unstructured.Unstructured) bool

+ type Kindable interface

+ GetKind func() string

+ type Metadata struct

+ Annotations map[string]string

+ Labels map[string]string

+ Name string

+ Namespace string

+ type Name struct

+ Kind string

+ Name string

+ Namespace string

+ func GetName(obj interface{}) Name

+ func (n Name) GetKind() string

+ func (n Name) GetName() string

+ func (n Name) GetNamespace() string

+ func (n Name) String() string

+ type Nameable interface

+ GetName func() string

+ GetNamespace func() string

+ type RuntimeObjectWithMetadata interface

+ DeepCopyObject func() runtime.Object

+ GetObjectKind func() schema.ObjectKind

+ GetObjectMeta func() metav1.Object

+ 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

+ type WaitFN func(*unstructured.Unstructured) (bool, string)

+ type WebhookBuilder struct

+ CA []byte

+ Path string

+ Service string

+ func (b WebhookBuilder) Add() *WebhookConfigBuilder

+ func (b WebhookBuilder) Fail() WebhookBuilder

+ func (b WebhookBuilder) Match(groups, versions, resources []string) WebhookBuilder

+ func (b WebhookBuilder) MatchAny() WebhookBuilder

+ func (b WebhookBuilder) MatchKinds(resources ...string) WebhookBuilder

+ func (b WebhookBuilder) TimeoutSeconds(timeout int32) WebhookBuilder

+ func (b WebhookBuilder) WithNamespaceLabel(label string, values ...string) WebhookBuilder

+ func (b WebhookBuilder) WithoutNamespaceLabel(label string, values ...string) WebhookBuilder

+ type WebhookConfigBuilder struct

+ CA []byte

+ Service string

+ func (b *WebhookConfigBuilder) NewHook(Name, Path string) *WebhookBuilder

+ func (b WebhookConfigBuilder) Build() *admission.ValidatingWebhookConfiguration

+ func (b WebhookConfigBuilder) BuildMutating() *admission.MutatingWebhookConfiguration

v0.4.7

Mar 14, 2021

v0.4.6

Mar 14, 2021

v0.4.5

Mar 14, 2021

v0.4.3

Mar 7, 2021

v0.4.2

Mar 7, 2021

v0.4.0

Mar 4, 2021

v0.3.5

Mar 2, 2021

v0.3.4

Feb 28, 2021

v0.3.2

Feb 27, 2021

v0.1.6

Nov 18, 2020

?	: This menu
/	: Search site
f or F	: Jump to
y or Y	: Canonical URL