intents_reconcilers

package

v0.1.15 Latest Latest Go to latest Published: Feb 5, 2023 License: Apache-2.0 Imports: 21 Imported by: 0

Details

Valid go.mod file

The Go module system was introduced in Go 1.11 and is the official dependency management solution for Go.
Redistributable license

Redistributable licenses place minimal restrictions on how software can be used, modified, and redistributed.
Tagged version

Modules with tagged versions give importers more predictable builds.
Stable version

When a project reaches major version v1 it is considered stable.
Learn more about best practices

Repository

github.com/otterize/intents-operator

Documentation ¶

Index ¶

Constants
func MatchSaramaResource(s SaramaResource) gomock.Matcher
type KafkaACLReconciler
- func NewKafkaACLReconciler(client client.Client, scheme *runtime.Scheme, ...) *KafkaACLReconciler
- func (r *KafkaACLReconciler) Reconcile(ctx context.Context, req ctrl.Request) (ctrl.Result, error)
- func (r *KafkaACLReconciler) RemoveACLs(intents *otterizev1alpha2.ClientIntents) error
type NetworkPolicyReconciler
- func NewNetworkPolicyReconciler(c client.Client, s *runtime.Scheme, ...) *NetworkPolicyReconciler
- func (r *NetworkPolicyReconciler) Reconcile(ctx context.Context, req ctrl.Request) (ctrl.Result, error)
type PodLabelReconciler
- func NewPodLabelReconciler(c client.Client, s *runtime.Scheme) *PodLabelReconciler
- func (r *PodLabelReconciler) Reconcile(ctx context.Context, req ctrl.Request) (ctrl.Result, error)
type SaramaResource
- func (s *SaramaResource) Matches(arg interface{}) bool
- func (s *SaramaResource) String() string

Constants ¶

View Source

const (
	KafkaACLsFinalizerName                  = "intents.otterize.com/kafka-finalizer"
	ReasonCouldNotConnectToKafkaServer      = "CouldNotConnectToKafkaServer"
	ReasonCouldNotApplyIntentsOnKafkaServer = "CouldNotApplyIntentsOnKafkaServer"
	ReasonKafkaACLCreationDisabled          = "KafkaACLCreationDisabled"
	ReasonKafkaServerNotConfigured          = "KafkaServerNotConfigured"
	ReasonRemovingKafkaACLsFailed           = "RemovingKafkaACLsFailed"
	ReasonApplyingKafkaACLsFailed           = "ApplyingKafkaACLsFailed"
	ReasonAppliedKafkaACLs                  = "AppliedKafkaACLs"
)

View Source

const (
	ReasonEnforcementGloballyDisabled   = "EnforcementGloballyDisabled"
	ReasonNetworkPolicyCreationDisabled = "NetworkPolicyCreationDisabled"
	ReasonGettingNetworkPolicyFailed    = "GettingNetworkPolicyFailed"
	ReasonRemovingNetworkPolicyFailed   = "RemovingNetworkPolicyFailed"
	ReasonNamespaceNotAllowed           = "NamespaceNotAllowed"
	ReasonCreatingNetworkPoliciesFailed = "CreatingNetworkPoliciesFailed"
	ReasonCreatedNetworkPolicies        = "CreatedNetworkPolicies"
)

View Source

const (
	ReasonRemovingPodLabelsFailed = "RemovingPodLabelsFailed"
	ReasonUpdatePodFailed         = "UpdatePodFailed"
	ReasonListPodsFailed          = "ListPodsFailed"
)

View Source

const PodLabelFinalizerName = "intents.otterize.com/pods-finalizer"

Variables ¶

This section is empty.

Functions ¶

func MatchSaramaResource ¶

func MatchSaramaResource(s SaramaResource) gomock.Matcher

Types ¶

type KafkaACLReconciler ¶

type KafkaACLReconciler struct {
	KafkaServersStore kafkaacls.ServersStore

	injectablerecorder.InjectableRecorder
	// contains filtered or unexported fields
}

func NewKafkaACLReconciler ¶

func NewKafkaACLReconciler(client client.Client, scheme *runtime.Scheme, serversStore kafkaacls.ServersStore, enableKafkaACLCreation bool, factoryFunc kafkaacls.IntentsAdminFactoryFunction, enforcementEnabledGlobally bool) *KafkaACLReconciler

func (*KafkaACLReconciler) Reconcile ¶

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

func (*KafkaACLReconciler) RemoveACLs ¶

func (r *KafkaACLReconciler) RemoveACLs(intents *otterizev1alpha2.ClientIntents) error

type NetworkPolicyReconciler ¶

type NetworkPolicyReconciler struct {
	client.Client
	Scheme *runtime.Scheme

	RestrictToNamespaces []string

	injectablerecorder.InjectableRecorder
	// contains filtered or unexported fields
}

func NewNetworkPolicyReconciler ¶

func NewNetworkPolicyReconciler(
	c client.Client,
	s *runtime.Scheme,
	endpointsReconciler *external_traffic.EndpointsReconciler,
	restrictToNamespaces []string,
	enableNetworkPolicyCreation bool,
	enforcementEnabledGlobally bool) *NetworkPolicyReconciler

func (*NetworkPolicyReconciler) Reconcile ¶

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

type PodLabelReconciler ¶

type PodLabelReconciler struct {
	client.Client
	Scheme *runtime.Scheme
	injectablerecorder.InjectableRecorder
}

func NewPodLabelReconciler ¶

func NewPodLabelReconciler(c client.Client, s *runtime.Scheme) *PodLabelReconciler

func (*PodLabelReconciler) Reconcile ¶

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

type SaramaResource ¶

type SaramaResource []*sarama.ResourceAcls

func (*SaramaResource) Matches ¶

func (s *SaramaResource) Matches(arg interface{}) bool

func (*SaramaResource) String ¶

func (s *SaramaResource) String() string

Source Files ¶

View all Source files

Directories ¶

Path	Synopsis
otterizecloud

?	: This menu
/	: Search site
f or F	: Jump to
y or Y	: Canonical URL