k8sutil

Documentation

Index

• func ResourceAlreadyExists(err error) bool
• func ResourceNotFound(err error) bool
• func RestConfig(kubeConfig string, outOfCluster bool) (*rest.Config, error)
• func SameLogicalBackupJob(cur, new *batchv1beta1.CronJob) (match bool, reason string)
• func SamePDB(cur, new *policybeta1.PodDisruptionBudget) (match bool, reason string)
• func SameService(cur, new *v1.Service) (match bool, reason string)
• type KubernetesClient
  • func NewFromConfig(cfg *rest.Config) (KubernetesClient, error)
  • func NewMockKubernetesClient() KubernetesClient
• type MockConfigMapsGetter
  • func (c *MockConfigMapsGetter) ConfigMaps(namespace string) v1core.ConfigMapInterface
• type MockSecretGetter
  • func (c *MockSecretGetter) Secrets(namespace string) v1core.SecretInterface

Functions

func ResourceAlreadyExists

func ResourceAlreadyExists(err error) bool

ResourceAlreadyExists checks if error corresponds to Already exists error

func ResourceNotFound

func ResourceNotFound(err error) bool

ResourceNotFound checks if error corresponds to Not found error

func RestConfig

func RestConfig(kubeConfig string, outOfCluster bool) (*rest.Config, error)

RestConfig creates REST config

func SameLogicalBackupJob

func SameLogicalBackupJob(cur, new *batchv1beta1.CronJob) (match bool, reason string)

SameLogicalBackupJob compares Specs of logical backup cron jobs

func SamePDB

func SamePDB(cur, new *policybeta1.PodDisruptionBudget) (match bool, reason string)

SamePDB compares the PodDisruptionBudgets

func SameService

func SameService(cur, new *v1.Service) (match bool, reason string)

SameService compares the Services

Types

type KubernetesClient

type KubernetesClient struct {
	v1core.SecretsGetter
	v1core.ServicesGetter
	v1core.EndpointsGetter
	v1core.PodsGetter
	v1core.PersistentVolumesGetter
	v1core.PersistentVolumeClaimsGetter
	v1core.ConfigMapsGetter
	v1core.NodesGetter
	v1core.NamespacesGetter
	v1core.ServiceAccountsGetter
	v1beta1.StatefulSetsGetter
	rbacv1beta1.RoleBindingsGetter
	policyv1beta1.PodDisruptionBudgetsGetter
	apiextbeta1.CustomResourceDefinitionsGetter
	clientbatchv1beta1.CronJobsGetter

	RESTClient      rest.Interface
	AcidV1ClientSet *acidv1client.Clientset
}

KubernetesClient describes getters for Kubernetes objects

func NewFromConfig

func NewFromConfig(cfg *rest.Config) (KubernetesClient, error)

NewFromConfig create Kubernets Interface using REST config

func NewMockKubernetesClient

func NewMockKubernetesClient() KubernetesClient

NewMockKubernetesClient for other tests

type MockConfigMapsGetter

type MockConfigMapsGetter struct {
}

func (*MockConfigMapsGetter) ConfigMaps

func (c *MockConfigMapsGetter) ConfigMaps(namespace string) v1core.ConfigMapInterface

ConfigMaps to be mocked

type MockSecretGetter

type MockSecretGetter struct {
}

func (*MockSecretGetter) Secrets

func (c *MockSecretGetter) Secrets(namespace string) v1core.SecretInterface

Secrets to be mocked