Versions in this module Expand all Collapse all v1 v1.5.0 Jan 30, 2026 v1.4.2 Jan 19, 2026 Changes in this version + func BuildClusterMetadata(cluster *kafscalev1alpha1.KafscaleCluster, ...) metadata.ClusterMetadata + func PublishMetadataSnapshot(ctx context.Context, endpoints []string, snapshot metadata.ClusterMetadata) error + type ClusterReconciler struct + Client client.Client + Publisher *SnapshotPublisher + Scheme *runtime.Scheme + func NewClusterReconciler(mgr ctrl.Manager, publisher *SnapshotPublisher) *ClusterReconciler + func (r *ClusterReconciler) Reconcile(ctx context.Context, req ctrl.Request) (ctrl.Result, error) + func (r *ClusterReconciler) SetupWithManager(mgr ctrl.Manager) error + type EtcdResolution struct + Endpoints []string + Managed bool + func EnsureEtcd(ctx context.Context, c client.Client, scheme *runtime.Scheme, ...) (EtcdResolution, error) + type SnapshotPublisher struct + Client client.Client + func NewSnapshotPublisher(c client.Client) *SnapshotPublisher + func (p *SnapshotPublisher) Publish(ctx context.Context, cluster *kafscalev1alpha1.KafscaleCluster, ...) error + type TopicReconciler struct + Publisher *SnapshotPublisher + Scheme *runtime.Scheme + func NewTopicReconciler(mgr ctrl.Manager, publisher *SnapshotPublisher) *TopicReconciler + func (r *TopicReconciler) Reconcile(ctx context.Context, req ctrl.Request) (ctrl.Result, error) + func (r *TopicReconciler) SetupWithManager(mgr ctrl.Manager) error
Go to main page