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
DryRun bool
}
func (*StreamReconciler) Process ¶
func (r *StreamReconciler) Process(ctx context.Context, 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 Synchronizer ¶
func NewSynchronizer ¶
func (*Synchronizer) Synchronize ¶
func (c *Synchronizer) Synchronize(ctx context.Context) error
type TopicReconcileResult ¶
type TopicReconcileResult struct {
DeleteFinalized bool
Skipped bool
Requeue bool
Status kafka_nais_io_v1.TopicStatus
Error error
}
type TopicReconciler ¶
type TopicReconciler struct {
client.Client
Aiven kafkarator_aiven.Interfaces
Logger *log.Logger
Projects []string
RequeueInterval time.Duration
DryRun bool
}
func (*TopicReconciler) Process ¶
func (r *TopicReconciler) Process(ctx context.Context, 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.