controllers

Documentation

Index

• Constants
• type IntentsReconciler
  • func NewIntentsReconciler(client client.Client, scheme *runtime.Scheme, ...) *IntentsReconciler
  • func (r *IntentsReconciler) InitEndpointsPodNamesIndex(mgr ctrl.Manager) error
  • func (r *IntentsReconciler) InitIntentsServerIndices(mgr ctrl.Manager) error
  • func (r *IntentsReconciler) Reconcile(ctx context.Context, req ctrl.Request) (ctrl.Result, error)
  • func (r *IntentsReconciler) SetupWithManager(mgr ctrl.Manager) error
• type KafkaServerConfigReconciler
  • func NewKafkaServerConfigReconciler(client client.Client, scheme *runtime.Scheme, ...) *KafkaServerConfigReconciler
  • func (r *KafkaServerConfigReconciler) Reconcile(ctx context.Context, req ctrl.Request) (ctrl.Result, error)
  • func (r *KafkaServerConfigReconciler) SetupWithManager(mgr ctrl.Manager) error

Constants

const (
	ReasonIntentsOperatorIdentityResolveFailed = "IntentsOperatorIdentityResolveFailed"
	ReasonApplyingKafkaServerConfigFailed      = "ApplyingKafkaServerConfigFailed"
	ReasonAppliedKafkaServerConfigFailed       = "AppliedKafkaServerConfigFailed"
	IntentsOperatorSource                      = "intents-operator"
)

Types

type IntentsReconciler

type IntentsReconciler struct {
	// contains filtered or unexported fields
}

IntentsReconciler reconciles a Intents object

func NewIntentsReconciler

func NewIntentsReconciler(
	client client.Client,
	scheme *runtime.Scheme,
	kafkaServerStore kafkaacls.ServersStore,
	endpointsReconciler *external_traffic.EndpointsReconciler,
	restrictToNamespaces []string,
	enforcementEnabledGlobally bool,
	enableNetworkPolicyCreation, enableKafkaACLCreation bool,
	otterizeClient otterizecloud.CloudClient) *IntentsReconciler

func (*IntentsReconciler) InitEndpointsPodNamesIndex

func (r *IntentsReconciler) InitEndpointsPodNamesIndex(mgr ctrl.Manager) error

func (*IntentsReconciler) InitIntentsServerIndices

func (r *IntentsReconciler) InitIntentsServerIndices(mgr ctrl.Manager) error

InitIntentsServerIndices indexes intents by target server name This is used in finalizers to determine whether a network policy should be removed from the target namespace

func (*IntentsReconciler) Reconcile

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

Reconcile is part of the main kubernetes reconciliation loop which aims to move the current state of the cluster closer to the desired state.

func (*IntentsReconciler) SetupWithManager

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

SetupWithManager sets up the controller with the Manager.

type KafkaServerConfigReconciler

type KafkaServerConfigReconciler struct {
	client.Client
	Scheme       *runtime.Scheme
	ServersStore kafkaacls.ServersStore

	injectablerecorder.InjectableRecorder
	// contains filtered or unexported fields
}

KafkaServerConfigReconciler reconciles a KafkaServerConfig object

func NewKafkaServerConfigReconciler

func NewKafkaServerConfigReconciler(
	client client.Client,
	scheme *runtime.Scheme,
	serversStore kafkaacls.ServersStore,
	operatorPodName string,
	operatorPodNameSpace string,
	cloudClient otterizecloud.CloudClient,
) *KafkaServerConfigReconciler

func (*KafkaServerConfigReconciler) Reconcile

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

func (*KafkaServerConfigReconciler) SetupWithManager

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

SetupWithManager sets up the controller with the Manager.