kubernetes

Documentation

Index

• func CreateIfNotExistsConfigMap(ctx context.Context, c client.Client, desired *corev1.ConfigMap) error
• func CreateOrUpdateClusterRole(ctx context.Context, c client.Client, desired *rbacv1.ClusterRole) error
• func CreateOrUpdateClusterRoleBinding(ctx context.Context, c client.Client, desired *rbacv1.ClusterRoleBinding) error
• func CreateOrUpdateConfigMap(ctx context.Context, c client.Client, desired *corev1.ConfigMap) error
• func CreateOrUpdateDaemonSet(ctx context.Context, c client.Client, desired *appsv1.DaemonSet) error
• func CreateOrUpdateDeployment(ctx context.Context, c client.Client, desired *appsv1.Deployment) error
• func CreateOrUpdateSecret(ctx context.Context, c client.Client, desired *corev1.Secret) error
• func CreateOrUpdateService(ctx context.Context, c client.Client, desired *corev1.Service) error
• func CreateOrUpdateServiceAccount(ctx context.Context, c client.Client, desired *corev1.ServiceAccount) error
• func CreateOrUpdateValidatingWebhookConfiguration(ctx context.Context, c client.Client, ...) error
• func GetOrCreateConfigMap(ctx context.Context, c client.Client, name types.NamespacedName) (corev1.ConfigMap, error)
• func GetOrCreateSecret(ctx context.Context, c client.Client, name types.NamespacedName) (corev1.Secret, error)
• type ConfigmapProber
  • func (cmp *ConfigmapProber) ReadConfigMapOrEmpty(ctx context.Context, name types.NamespacedName) (string, error)
• type DaemonSetAnnotator
  • func (dsa *DaemonSetAnnotator) SetAnnotation(ctx context.Context, name types.NamespacedName, key, value string) error
• type DaemonSetProber
  • func (dsp *DaemonSetProber) IsReady(ctx context.Context, name types.NamespacedName) (bool, error)
• type DeploymentProber
  • func (dp *DeploymentProber) IsReady(ctx context.Context, name types.NamespacedName) (bool, error)
• type ResourceCountLock
  • func NewResourceCountLock(client client.Client, lockName types.NamespacedName, maxOwners int) *ResourceCountLock
  • func (l *ResourceCountLock) TryAcquireLock(ctx context.Context, owner metav1.Object) error

Functions

func CreateIfNotExistsConfigMap

func CreateIfNotExistsConfigMap(ctx context.Context, c client.Client, desired *corev1.ConfigMap) error

func CreateOrUpdateClusterRole

func CreateOrUpdateClusterRole(ctx context.Context, c client.Client, desired *rbacv1.ClusterRole) error

func CreateOrUpdateClusterRoleBinding

func CreateOrUpdateClusterRoleBinding(ctx context.Context, c client.Client, desired *rbacv1.ClusterRoleBinding) error

func CreateOrUpdateConfigMap

func CreateOrUpdateConfigMap(ctx context.Context, c client.Client, desired *corev1.ConfigMap) error

func CreateOrUpdateDaemonSet

func CreateOrUpdateDaemonSet(ctx context.Context, c client.Client, desired *appsv1.DaemonSet) error

func CreateOrUpdateDeployment

func CreateOrUpdateDeployment(ctx context.Context, c client.Client, desired *appsv1.Deployment) error

func CreateOrUpdateSecret

func CreateOrUpdateSecret(ctx context.Context, c client.Client, desired *corev1.Secret) error

func CreateOrUpdateService

func CreateOrUpdateService(ctx context.Context, c client.Client, desired *corev1.Service) error

func CreateOrUpdateServiceAccount

func CreateOrUpdateServiceAccount(ctx context.Context, c client.Client, desired *corev1.ServiceAccount) error

func CreateOrUpdateValidatingWebhookConfiguration

func CreateOrUpdateValidatingWebhookConfiguration(ctx context.Context, c client.Client, desired *admissionregistrationv1.ValidatingWebhookConfiguration) error

func GetOrCreateConfigMap

func GetOrCreateConfigMap(ctx context.Context, c client.Client, name types.NamespacedName) (corev1.ConfigMap, error)

func GetOrCreateSecret

func GetOrCreateSecret(ctx context.Context, c client.Client, name types.NamespacedName) (corev1.Secret, error)

Types

type ConfigmapProber

type ConfigmapProber struct {
	client.Client
}

func (*ConfigmapProber) ReadConfigMapOrEmpty

func (cmp *ConfigmapProber) ReadConfigMapOrEmpty(ctx context.Context, name types.NamespacedName) (string, error)

type DaemonSetAnnotator

type DaemonSetAnnotator struct {
	client.Client
}

func (*DaemonSetAnnotator) SetAnnotation

func (dsa *DaemonSetAnnotator) SetAnnotation(ctx context.Context, name types.NamespacedName, key, value string) error

type DaemonSetProber

type DaemonSetProber struct {
	client.Client
}

func (*DaemonSetProber) IsReady

func (dsp *DaemonSetProber) IsReady(ctx context.Context, name types.NamespacedName) (bool, error)

type DeploymentProber

type DeploymentProber struct {
	client.Client
}

func (*DeploymentProber) IsReady

func (dp *DeploymentProber) IsReady(ctx context.Context, name types.NamespacedName) (bool, error)

type ResourceCountLock

type ResourceCountLock struct {
	// contains filtered or unexported fields
}

func NewResourceCountLock

func NewResourceCountLock(client client.Client, lockName types.NamespacedName, maxOwners int) *ResourceCountLock

func (*ResourceCountLock) TryAcquireLock

func (l *ResourceCountLock) TryAcquireLock(ctx context.Context, owner metav1.Object) error