utils

package
v0.2.0 Latest Latest
Warning

This package is not in the latest version of its module.

Go to latest
Published: Sep 27, 2019 License: Apache-2.0 Imports: 29 Imported by: 0

Documentation

Index

Constants

This section is empty.

Variables

This section is empty.

Functions

func CustomizeAffinity

func CustomizeAffinity(a *corev1.Affinity, cr *appsodyv1beta1.AppsodyApplication)

CustomizeAffinity ...

func CustomizeDeployment added in v0.2.0

func CustomizeDeployment(deploy *appsv1.Deployment, cr *appsodyv1beta1.AppsodyApplication)

CustomizeDeployment ...

func CustomizeHPA

CustomizeHPA ...

func CustomizeKnativeService

func CustomizeKnativeService(ksvc *servingv1alpha1.Service, cr *appsodyv1beta1.AppsodyApplication)

CustomizeKnativeService ...

func CustomizePersistence

func CustomizePersistence(statefulSet *appsv1.StatefulSet, cr *appsodyv1beta1.AppsodyApplication)

CustomizePersistence ...

func CustomizePodSpec

func CustomizePodSpec(pts *corev1.PodTemplateSpec, cr *appsodyv1beta1.AppsodyApplication)

CustomizePodSpec ...

func CustomizeRoute

func CustomizeRoute(route *routev1.Route, cr *appsodyv1beta1.AppsodyApplication)

CustomizeRoute ...

func CustomizeService

func CustomizeService(svc *corev1.Service, cr *appsodyv1beta1.AppsodyApplication)

CustomizeService ...

func CustomizeServiceAccount

func CustomizeServiceAccount(sa *corev1.ServiceAccount, cr *appsodyv1beta1.AppsodyApplication)

CustomizeServiceAccount ...

func CustomizeServiceMonitor added in v0.2.0

func CustomizeServiceMonitor(sm *prometheusv1.ServiceMonitor, cr *appsodyv1beta1.AppsodyApplication)

CustomizeServiceMonitor ...

func CustomizeStatefulSet added in v0.2.0

func CustomizeStatefulSet(statefulSet *appsv1.StatefulSet, cr *appsodyv1beta1.AppsodyApplication)

CustomizeStatefulSet ...

func ErrorIsNoMatchesForKind

func ErrorIsNoMatchesForKind(err error, kind string, version string) bool

ErrorIsNoMatchesForKind ...

func GetLabels

GetLabels ...

func GetWatchNamespaces added in v0.2.0

func GetWatchNamespaces() ([]string, error)

GetWatchNamespaces returns a slice of namespaces the operator should watch based on WATCH_NAMESPSCE value WATCH_NAMESPSCE value could be empty for watching the whole cluster or a comma-separated list of namespaces

func Initialize added in v0.2.0

Initialize the AppsodyApplication instance with values from the default and constant ConfigMap

func SetCondition

SetCondition ...

func UpdateAppDefinition added in v0.2.0

func UpdateAppDefinition(labels map[string]string, annotations map[string]string, cr *appsodyv1beta1.AppsodyApplication)

UpdateAppDefinition ...

func Validate added in v0.2.0

Validate if the AppsodyApplication is valid

Types

type ReconcilerBase

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

ReconcilerBase base reconciler with some common behaviour

func NewReconcilerBase

func NewReconcilerBase(client client.Client, scheme *runtime.Scheme, restConfig *rest.Config, recorder record.EventRecorder) ReconcilerBase

NewReconcilerBase creates a new ReconcilerBase

func (*ReconcilerBase) CreateOrUpdate

func (r *ReconcilerBase) CreateOrUpdate(obj metav1.Object, owner metav1.Object, reconcile func() error) error

CreateOrUpdate ...

func (*ReconcilerBase) DeleteResource

func (r *ReconcilerBase) DeleteResource(obj runtime.Object) error

DeleteResource deletes kubernetes resource

func (*ReconcilerBase) DeleteResources

func (r *ReconcilerBase) DeleteResources(resources []runtime.Object) error

DeleteResources ...

func (*ReconcilerBase) GetAppsodyOpConfigMap

func (r *ReconcilerBase) GetAppsodyOpConfigMap(name string, ns string) (*corev1.ConfigMap, error)

GetAppsodyOpConfigMap ...

func (*ReconcilerBase) GetClient

func (r *ReconcilerBase) GetClient() client.Client

GetClient returns client

func (*ReconcilerBase) GetDiscoveryClient

func (r *ReconcilerBase) GetDiscoveryClient() (discovery.DiscoveryInterface, error)

GetDiscoveryClient ...

func (*ReconcilerBase) GetRecorder

func (r *ReconcilerBase) GetRecorder() record.EventRecorder

GetRecorder returns the underlying recorder

func (*ReconcilerBase) IsGroupVersionSupported

func (r *ReconcilerBase) IsGroupVersionSupported(groupVersion string) (bool, error)

IsGroupVersionSupported ...

func (*ReconcilerBase) ManageError

ManageError ...

func (*ReconcilerBase) ManageSuccess

ManageSuccess ...

func (*ReconcilerBase) SetDiscoveryClient

func (r *ReconcilerBase) SetDiscoveryClient(discovery discovery.DiscoveryInterface)

SetDiscoveryClient ...

Jump to

Keyboard shortcuts

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