k8s

Documentation

Index

• func EnsureDeployment(ctx context.Context, cl client.Client, store *v1.Store, ...) error
• func EnsureHPA(ctx context.Context, cl client.Client, store *v1.Store, ...) error
• func EnsureIngress(ctx context.Context, cl client.Client, store *v1.Store, ...) error
• func EnsureJob(ctx context.Context, cl client.Client, store *v1.Store, job *batchv1.Job, ...) error
• func EnsureObjectWithHash(ctx context.Context, cl client.Client, owner metav1.Object, obj client.Object, ...) error
• func EnsureService(ctx context.Context, cl client.Client, store *v1.Store, svc *corev1.Service, ...) error
• func GetOperatorNamespace() (string, error)
• func GetSecret(ctx context.Context, cl client.Client, nn types.NamespacedName) (*corev1.Secret, error)
• func GetStore(ctx context.Context, cl client.Client, nn types.NamespacedName) (*v1.Store, error)
• func GetWatchNamespace() (string, error)
• func HasObjectChanged(ctx context.Context, cl client.Client, obj client.Object) (bool, error)
• func ObjectExists(ctx context.Context, cl client.Reader, nn types.NamespacedName, ...) (bool, error)
• func ObjectHash(obj runtime.Object) (string, error)

Functions

func EnsureDeployment

func EnsureDeployment(
	ctx context.Context,
	cl client.Client,
	store *v1.Store,
	deployment *appsv1.Deployment,
	s *runtime.Scheme,
	saveOldMeta bool,
) error

func EnsureHPA

func EnsureHPA(
	ctx context.Context,
	cl client.Client,
	store *v1.Store,
	svc *autoscalingv2.HorizontalPodAutoscaler,
	s *runtime.Scheme,
	saveOldMeta bool,
) error

func EnsureIngress

func EnsureIngress(
	ctx context.Context,
	cl client.Client,
	store *v1.Store,
	ingress *networkingv1.Ingress,
	s *runtime.Scheme,
	saveOldMeta bool,
) error

func EnsureJob

func EnsureJob(
	ctx context.Context,
	cl client.Client,
	store *v1.Store,
	job *batchv1.Job,
	s *runtime.Scheme,
	saveOldMeta bool,
) error

func EnsureObjectWithHash

func EnsureObjectWithHash(
	ctx context.Context,
	cl client.Client,
	owner metav1.Object,
	obj client.Object,
	s *runtime.Scheme,
) error

func EnsureService

func EnsureService(
	ctx context.Context,
	cl client.Client,
	store *v1.Store,
	svc *corev1.Service,
	s *runtime.Scheme,
	saveOldMeta bool,
) error

func GetOperatorNamespace

func GetOperatorNamespace() (string, error)

func GetSecret

func GetSecret(
	ctx context.Context,
	cl client.Client,
	nn types.NamespacedName,
) (*corev1.Secret, error)

func GetStore

func GetStore(
	ctx context.Context,
	cl client.Client,
	nn types.NamespacedName,
) (*v1.Store, error)

func GetWatchNamespace

func GetWatchNamespace() (string, error)

func HasObjectChanged

func HasObjectChanged(
	ctx context.Context,
	cl client.Client,
	obj client.Object,
) (bool, error)

func ObjectExists

func ObjectExists(
	ctx context.Context,
	cl client.Reader,
	nn types.NamespacedName,
	o client.Object,
) (bool, error)

func ObjectHash

func ObjectHash(obj runtime.Object) (string, error)