controller

Jun 20, 2025

Changes in this version

+ type Buildable interface

May 27, 2025

Changes in this version

+ const Debug

+ const Info

+ func ConduitInitContainers(cc []*v1alpha.ConduitConnector) []corev1.Container

+ func ConduitPipelineVol(refName string) corev1.Volume

+ func ConduitRuntimeContainer(image, version string, envVars []corev1.EnvVar, flags *conduit.Flags) (corev1.Container, error)

+ func ConduitVolume(claimName string) corev1.Volume

+ func ConduitVolumeClaim(nn types.NamespacedName, size string) *corev1.PersistentVolumeClaim

+ func EnvVars(c *v1alpha.Conduit) []corev1.EnvVar

+ func PipelineConfigYAML(ctx context.Context, client client.Client, conduit *v1alpha.Conduit) (string, error)

+ func SchemaRegistryConfig(ctx context.Context, cl client.Client, c *v1alpha.Conduit) (map[string][]byte, error)

+ type ConduitReconciler struct

+ func NewConduitReconciler(meta *v1.ConduitInstanceMetadata, c client.Client, logger logr.Logger, ...) *ConduitReconciler

+ func (r *ConduitReconciler) CreateOrUpdateConfig(ctx context.Context, c *v1.Conduit) error

+ func (r *ConduitReconciler) CreateOrUpdateDeployment(ctx context.Context, c *v1.Conduit) error

+ func (r *ConduitReconciler) CreateOrUpdateSecret(ctx context.Context, c *v1.Conduit) error

+ func (r *ConduitReconciler) CreateOrUpdateService(ctx context.Context, c *v1.Conduit) error

+ func (r *ConduitReconciler) CreateOrUpdateVolume(ctx context.Context, c *v1.Conduit) error

+ func (r *ConduitReconciler) Reconcile(ctx context.Context, req ctrl.Request) (ctrl.Result, error)

+ func (r *ConduitReconciler) SetupWithManager(mgr ctrl.Manager) error

+ func (r *ConduitReconciler) UpdateStatus(ctx context.Context, c *v1.Conduit) error