Documentation ¶
Index ¶
Constants ¶
View Source
const Finalizer = "kafkarator.kafka.nais.io"
View Source
const (
LogFieldSynchronizationState = "synchronization_state"
)
Variables ¶
This section is empty.
Functions ¶
This section is empty.
Types ¶
type StreamReconcileResult ¶
type StreamReconcileResult struct { DeleteFinalized bool Skipped bool Requeue bool Status kafka_nais_io_v1.StreamStatus Error error }
type StreamReconciler ¶
type StreamReconciler struct { client.Client Aiven kafkarator_aiven.Interfaces Logger log.FieldLogger Projects []string RequeueInterval time.Duration }
func (*StreamReconciler) Process ¶
func (r *StreamReconciler) Process(stream kafka_nais_io_v1.Stream, logger log.FieldLogger) StreamReconcileResult
func (*StreamReconciler) Reconcile ¶
+kubebuilder:rbac:groups=kafka.nais.io,resources=streams,verbs=get;list;watch;create;update;patch;delete +kubebuilder:rbac:groups=kafka.nais.io,resources=streams/status,verbs=get;update;patch
func (*StreamReconciler) SetupWithManager ¶
func (r *StreamReconciler) SetupWithManager(mgr ctrl.Manager) error
type SyncResult ¶
type SyncResult struct {
// contains filtered or unexported fields
}
type Synchronizer ¶
func NewSynchronizer ¶
func NewSynchronizer(a kafkarator_aiven.Interfaces, t kafka_nais_io_v1.Topic, logger *log.Entry) (*Synchronizer, error)
func (*Synchronizer) Synchronize ¶
func (c *Synchronizer) Synchronize() error
type TopicReconcileResult ¶
type TopicReconciler ¶
type TopicReconciler struct { client.Client Aiven kafkarator_aiven.Interfaces Logger *log.Logger Projects []string RequeueInterval time.Duration }
func (*TopicReconciler) Process ¶
func (r *TopicReconciler) Process(topic kafka_nais_io_v1.Topic, logger *log.Entry) TopicReconcileResult
Process changes in Aiven and return a topic processing status
func (*TopicReconciler) SetupWithManager ¶
func (r *TopicReconciler) SetupWithManager(mgr ctrl.Manager) error
Click to show internal directories.
Click to hide internal directories.