controllers

Documentation

Index

• Constants
• type StreamReconcileResult
• type StreamReconciler
  • func (r *StreamReconciler) Process(stream kafka_nais_io_v1.Stream, logger log.FieldLogger) StreamReconcileResult
  • func (r *StreamReconciler) Reconcile(ctx context.Context, req ctrl.Request) (ctrl.Result, error)
  • func (r *StreamReconciler) SetupWithManager(mgr ctrl.Manager) error
• type SyncResult
• type Synchronizer
  • func NewSynchronizer(a kafkarator_aiven.Interfaces, t kafka_nais_io_v1.Topic, logger *log.Entry) (*Synchronizer, error)
  • func (c *Synchronizer) Synchronize() error
• type TopicReconcileResult
• type TopicReconciler
  • func (r *TopicReconciler) Process(topic kafka_nais_io_v1.Topic, logger *log.Entry) TopicReconcileResult
  • func (r *TopicReconciler) Reconcile(ctx context.Context, req ctrl.Request) (ctrl.Result, error)
  • func (r *TopicReconciler) SetupWithManager(mgr ctrl.Manager) error

Constants

const Finalizer = "kafkarator.kafka.nais.io"

const (
	LogFieldSynchronizationState = "synchronization_state"
)

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

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

+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

type Synchronizer struct {
	ACLs   acl.Manager
	Topics topic.Manager
	Logger *log.Entry
}

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 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
}

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) Reconcile

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

func (*TopicReconciler) SetupWithManager

func (r *TopicReconciler) SetupWithManager(mgr ctrl.Manager) error