reconcile

Documentation

Index

• func EnsureAstarteDashboard(cr *apiv1alpha1.Astarte, dashboard commontypes.AstarteDashboardSpec, ...) error
• func EnsureAstarteDataUpdaterPlant(cr *apiv1alpha1.Astarte, dup commontypes.AstarteDataUpdaterPlantSpec, ...) error
• func EnsureAstarteGenericAPI(cr *apiv1alpha1.Astarte, api commontypes.AstarteGenericAPISpec, ...) error
• func EnsureAstarteGenericAPIWithCustomProbe(cr *apiv1alpha1.Astarte, api commontypes.AstarteGenericAPISpec, ...) error
• func EnsureAstarteGenericBackend(cr *apiv1alpha1.Astarte, backend commontypes.AstarteGenericClusteredResource, ...) error
• func EnsureAstarteGenericBackendWithCustomProbe(cr *apiv1alpha1.Astarte, backend commontypes.AstarteGenericClusteredResource, ...) error
• func EnsureCFSSL(cr *apiv1alpha1.Astarte, c client.Client, scheme *runtime.Scheme) error
• func EnsureCFSSLCASecret(cr *apiv1alpha1.Astarte, c client.Client, scheme *runtime.Scheme) error
• func EnsureCassandra(cr *apiv1alpha1.Astarte, c client.Client, scheme *runtime.Scheme) error
• func EnsureGenericErlangConfiguration(cr *apiv1alpha1.Astarte, c client.Client, scheme *runtime.Scheme) error
• func EnsureHousekeepingKey(cr *apiv1alpha1.Astarte, c client.Client, scheme *runtime.Scheme) error
• func EnsureRabbitMQ(cr *apiv1alpha1.Astarte, c client.Client, scheme *runtime.Scheme) error
• func EnsureVerneMQ(cr *apiv1alpha1.Astarte, c client.Client, scheme *runtime.Scheme) error
• type Options

Functions

func EnsureAstarteDashboard

func EnsureAstarteDashboard(cr *apiv1alpha1.Astarte, dashboard commontypes.AstarteDashboardSpec, c client.Client, scheme *runtime.Scheme) error

EnsureAstarteDashboard reconciles Astarte Dashboard

func EnsureAstarteDataUpdaterPlant

func EnsureAstarteDataUpdaterPlant(cr *apiv1alpha1.Astarte, dup commontypes.AstarteDataUpdaterPlantSpec, c client.Client, scheme *runtime.Scheme) error

EnsureAstarteDataUpdaterPlant manages multiple deployments for Astarte Data Updater Plant based on scalability requirements

func EnsureAstarteGenericAPI

func EnsureAstarteGenericAPI(cr *apiv1alpha1.Astarte, api commontypes.AstarteGenericAPISpec, component commontypes.AstarteComponent,
	c client.Client, scheme *runtime.Scheme) error

EnsureAstarteGenericAPI reconciles any component compatible with AstarteGenericAPISpec with a custom Probe

func EnsureAstarteGenericAPIWithCustomProbe

func EnsureAstarteGenericAPIWithCustomProbe(cr *apiv1alpha1.Astarte, api commontypes.AstarteGenericAPISpec, component commontypes.AstarteComponent,
	c client.Client, scheme *runtime.Scheme, customProbe *v1.Probe) error

EnsureAstarteGenericAPIWithCustomProbe reconciles any component compatible with AstarteGenericAPISpec with a custom Probe

func EnsureAstarteGenericBackend

func EnsureAstarteGenericBackend(cr *apiv1alpha1.Astarte, backend commontypes.AstarteGenericClusteredResource, component commontypes.AstarteComponent,
	c client.Client, scheme *runtime.Scheme) error

EnsureAstarteGenericBackend reconciles any component compatible with AstarteGenericClusteredResource

func EnsureAstarteGenericBackendWithCustomProbe

func EnsureAstarteGenericBackendWithCustomProbe(cr *apiv1alpha1.Astarte, backend commontypes.AstarteGenericClusteredResource,
	component commontypes.AstarteComponent, c client.Client, scheme *runtime.Scheme, customProbe *v1.Probe) error

EnsureAstarteGenericBackendWithCustomProbe reconciles any component compatible with AstarteGenericClusteredResource adding a custom probe

func EnsureCFSSL

func EnsureCFSSL(cr *apiv1alpha1.Astarte, c client.Client, scheme *runtime.Scheme) error

EnsureCFSSL reconciles CFSSL

func EnsureCFSSLCASecret

func EnsureCFSSLCASecret(cr *apiv1alpha1.Astarte, c client.Client, scheme *runtime.Scheme) error

EnsureCFSSLCASecret reconciles CFSSL's CA Secret

func EnsureCassandra

func EnsureCassandra(cr *apiv1alpha1.Astarte, c client.Client, scheme *runtime.Scheme) error

EnsureCassandra reconciles Cassandra

func EnsureGenericErlangConfiguration

func EnsureGenericErlangConfiguration(cr *apiv1alpha1.Astarte, c client.Client, scheme *runtime.Scheme) error

EnsureGenericErlangConfiguration reconciles the generic Erlang Configuration for Astarte services

func EnsureHousekeepingKey

func EnsureHousekeepingKey(cr *apiv1alpha1.Astarte, c client.Client, scheme *runtime.Scheme) error

EnsureHousekeepingKey makes sure that a valid Housekeeping key is available

func EnsureRabbitMQ

func EnsureRabbitMQ(cr *apiv1alpha1.Astarte, c client.Client, scheme *runtime.Scheme) error

EnsureRabbitMQ reconciles the state of RabbitMQ

func EnsureVerneMQ

func EnsureVerneMQ(cr *apiv1alpha1.Astarte, c client.Client, scheme *runtime.Scheme) error

EnsureVerneMQ reconciles VerneMQ

Types

type Options

type Options struct {
	// CustomLivenessProbe adds a custom Liveness Probe to the reconciliation.
	// This is usually useful when wanting to wait forever for a component to be Ready.
	CustomLivenessProbe *v1.Probe

	// CustomReadinessProbe adds a custom Readiness Probe to the reconciliation.
	// This is usually useful when wanting to wait forever for a component to be Ready.
	CustomReadinessProbe *v1.Probe
}

Options represents a set of options which can be given when reconciling