k8sutil

package

v1.11.0 Latest Latest Go to latest Published: Mar 15, 2024 License: MIT Imports: 27 Imported by: 5

Details

Valid go.mod file

The Go module system was introduced in Go 1.11 and is the official dependency management solution for Go.
Redistributable license

Redistributable licenses place minimal restrictions on how software can be used, modified, and redistributed.
Tagged version

Modules with tagged versions give importers more predictable builds.
Stable version

When a project reaches major version v1 it is considered stable.
Learn more about best practices

Repository

github.com/zalando/postgres-operator

Links

Open Source Insights

Documentation ¶

Index ¶

func Int32ToPointer(value int32) *int32
func ResourceAlreadyExists(err error) bool
func ResourceNotFound(err error) bool
func RestConfig(kubeConfig string, outOfCluster bool) (*rest.Config, error)
func SameLogicalBackupJob(cur, new *batchv1.CronJob) (match bool, reason string)
func SamePDB(cur, new *apipolicyv1.PodDisruptionBudget) (match bool, reason string)
func StringToPointer(str string) *string
func UInt32ToPointer(value uint32) *uint32
type KubernetesClient
- func ClientMissingObjects() KubernetesClient
- func NewFromConfig(cfg *rest.Config) (KubernetesClient, error)
- func NewMockKubernetesClient() KubernetesClient
- func (client *KubernetesClient) SetFinalizer(clusterName spec.NamespacedName, pg *apiacidv1.Postgresql, finalizers []string) (*apiacidv1.Postgresql, error)
- func (client *KubernetesClient) SetPostgresCRDStatus(clusterName spec.NamespacedName, status string) (*apiacidv1.Postgresql, error)
type MockConfigMapsGetter
- func (mock *MockConfigMapsGetter) ConfigMaps(namespace string) corev1.ConfigMapInterface
type MockDeploymentGetter
- func (mock *MockDeploymentGetter) Deployments(namespace string) appsv1.DeploymentInterface
type MockDeploymentNotExistGetter
- func (mock *MockDeploymentNotExistGetter) Deployments(namespace string) appsv1.DeploymentInterface
type MockSecretGetter
- func (mock *MockSecretGetter) Secrets(namespace string) corev1.SecretInterface
type MockServiceGetter
- func (mock *MockServiceGetter) Services(namespace string) corev1.ServiceInterface
type MockServiceNotExistGetter
- func (mock *MockServiceNotExistGetter) Services(namespace string) corev1.ServiceInterface

Constants ¶

This section is empty.

Variables ¶

This section is empty.

Functions ¶

func Int32ToPointer ¶ added in v1.5.0

func Int32ToPointer(value int32) *int32

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 ¶ added in v1.2.0

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

SameLogicalBackupJob compares Specs of logical backup cron jobs

func SamePDB ¶

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

SamePDB compares the PodDisruptionBudgets

func StringToPointer ¶ added in v1.8.0

func StringToPointer(str string) *string

func UInt32ToPointer ¶ added in v1.8.0

func UInt32ToPointer(value uint32) *uint32

Types ¶

type KubernetesClient ¶

type KubernetesClient struct {
	corev1.SecretsGetter
	corev1.ServicesGetter
	corev1.EndpointsGetter
	corev1.PodsGetter
	corev1.PersistentVolumesGetter
	corev1.PersistentVolumeClaimsGetter
	corev1.ConfigMapsGetter
	corev1.NodesGetter
	corev1.NamespacesGetter
	corev1.ServiceAccountsGetter
	corev1.EventsGetter
	appsv1.StatefulSetsGetter
	appsv1.DeploymentsGetter
	rbacv1.RoleBindingsGetter
	policyv1.PodDisruptionBudgetsGetter
	apiextv1.CustomResourceDefinitionsGetter
	clientbatchv1.CronJobsGetter
	acidv1.OperatorConfigurationsGetter
	acidv1.PostgresTeamsGetter
	acidv1.PostgresqlsGetter
	zalandov1.FabricEventStreamsGetter

	RESTClient         rest.Interface
	AcidV1ClientSet    *zalandoclient.Clientset
	Zalandov1ClientSet *zalandoclient.Clientset
}

KubernetesClient describes getters for Kubernetes objects

func ClientMissingObjects ¶ added in v1.5.0

func ClientMissingObjects() KubernetesClient

func NewFromConfig ¶

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

NewFromConfig create Kubernetes Interface using REST config

func NewMockKubernetesClient ¶ added in v1.2.0

func NewMockKubernetesClient() KubernetesClient

NewMockKubernetesClient for other tests

func (*KubernetesClient) SetFinalizer ¶ added in v1.11.0

func (client *KubernetesClient) SetFinalizer(clusterName spec.NamespacedName, pg *apiacidv1.Postgresql, finalizers []string) (*apiacidv1.Postgresql, error)

SetFinalizer of Postgres cluster

func (*KubernetesClient) SetPostgresCRDStatus ¶ added in v1.6.0

func (client *KubernetesClient) SetPostgresCRDStatus(clusterName spec.NamespacedName, status string) (*apiacidv1.Postgresql, error)

SetPostgresCRDStatus of Postgres cluster

type MockConfigMapsGetter ¶ added in v1.2.0

type MockConfigMapsGetter struct {
}

func (*MockConfigMapsGetter) ConfigMaps ¶ added in v1.2.0

func (mock *MockConfigMapsGetter) ConfigMaps(namespace string) corev1.ConfigMapInterface

ConfigMaps to be mocked

type MockDeploymentGetter ¶ added in v1.5.0

type MockDeploymentGetter struct {
}

func (*MockDeploymentGetter) Deployments ¶ added in v1.5.0

func (mock *MockDeploymentGetter) Deployments(namespace string) appsv1.DeploymentInterface

type MockDeploymentNotExistGetter ¶ added in v1.5.0

type MockDeploymentNotExistGetter struct {
}

func (*MockDeploymentNotExistGetter) Deployments ¶ added in v1.5.0

func (mock *MockDeploymentNotExistGetter) Deployments(namespace string) appsv1.DeploymentInterface

type MockSecretGetter ¶ added in v1.2.0

type MockSecretGetter struct {
}

func (*MockSecretGetter) Secrets ¶ added in v1.2.0

func (mock *MockSecretGetter) Secrets(namespace string) corev1.SecretInterface

Secrets to be mocked

type MockServiceGetter ¶ added in v1.5.0

type MockServiceGetter struct {
}

func (*MockServiceGetter) Services ¶ added in v1.5.0

func (mock *MockServiceGetter) Services(namespace string) corev1.ServiceInterface

type MockServiceNotExistGetter ¶ added in v1.5.0

type MockServiceNotExistGetter struct {
}

func (*MockServiceNotExistGetter) Services ¶ added in v1.5.0

func (mock *MockServiceNotExistGetter) Services(namespace string) corev1.ServiceInterface

Source Files ¶

View all Source files

k8sutil.go

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