Documentation ¶
Index ¶
- Constants
- type 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
Constants ¶
View Source
const ( ReasonIntentsOperatorIdentityResolveFailed = "IntentsOperatorIdentityResolveFailed" ReasonApplyingKafkaServerConfigFailed = "ApplyingKafkaServerConfigFailed" ReasonAppliedKafkaServerConfigFailed = "AppliedKafkaServerConfigFailed" IntentsOperatorSource = "intents-operator" )
Variables ¶
This section is empty.
Functions ¶
This section is empty.
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 ¶
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) SetupWithManager ¶
func (r *KafkaServerConfigReconciler) SetupWithManager(mgr ctrl.Manager) error
SetupWithManager sets up the controller with the Manager.
Click to show internal directories.
Click to hide internal directories.