controller

package
v0.10.0 Latest Latest
Warning

This package is not in the latest version of its module.

 Go to latest Published: Nov 19, 2025 License: AGPL-3.0 Imports: 65 Imported by: 0

Documentation

Index

Constants

View Source 
const (
	SchemeHTTP  = "http"
	SchemeHTTPS = "https"

	DefaultHTTPPort  = 80
	DefaultHTTPSPort = 443
)
View Source 
const KindEndpointSlice = "EndpointSlice"
View Source 
const KindGateway = "Gateway"
View Source 
const KindHTTPRoute = "HTTPRoute"
View Source 
const KindService = "Service"

Variables

View Source 
var EnqueueRequestForObjectNamespace = mchandler.TypedEnqueueRequestsFromMapFunc(func(ctx context.Context, obj client.Object) []NamespaceReconcileRequest {
	return []NamespaceReconcileRequest{{
		Namespace: obj.GetNamespace(),
	}}
})

Functions

func AddCertManagerIndexers added in v0.10.0 

func AddCertManagerIndexers(ctx context.Context, cl cluster.Cluster) error

TODO(jreese): I can't seem to get these indexers to function on the downstream cluster. From tracing the code, the indexers get invoked, but I still get an error that the index does not exist when trying to list resources.

func AddIndexers added in v0.3.0 

func AddIndexers(ctx context.Context, mgr mcmanager.Manager) error

func TypedEnqueueRequestForObjectWithGVK added in v0.3.0 

func TypedEnqueueRequestForObjectWithGVK(
	obj client.Object,
) mchandler.TypedEventHandlerFunc[client.Object, GVKRequest]

Types

type DomainReconciler added in v0.3.0 

type DomainReconciler struct {
	Config config.NetworkServicesOperator
	// contains filtered or unexported fields
}

DomainReconciler reconciles a Domain object

func (*DomainReconciler) Reconcile added in v0.3.0 

func (r *DomainReconciler) Reconcile(ctx context.Context, req mcreconcile.Request) (_ ctrl.Result, err 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 (*DomainReconciler) SetupWithManager added in v0.3.0 

func (r *DomainReconciler) SetupWithManager(mgr mcmanager.Manager) error

SetupWithManager sets up the controller with the Manager.

type GVKRequest added in v0.3.0 

type GVKRequest struct {
	mcreconcile.Request
	GVK schema.GroupVersionKind
}

func (GVKRequest) Cluster added in v0.3.0 

func (r GVKRequest) Cluster() string

Cluster returns the name of the cluster that the request belongs to.

func (GVKRequest) WithCluster added in v0.3.0 

func (r GVKRequest) WithCluster(name string) GVKRequest

WithCluster sets the name of the cluster that the request belongs to.

type GatewayClassReconciler 

type GatewayClassReconciler struct {
	Config config.NetworkServicesOperator
	// contains filtered or unexported fields
}

GatewayClassReconciler reconciles a Network object

func (*GatewayClassReconciler) Reconcile 

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

func (*GatewayClassReconciler) SetupWithManager 

func (r *GatewayClassReconciler) SetupWithManager(mgr mcmanager.Manager) error

SetupWithManager sets up the controller with the Manager.

type GatewayDownstreamCertificateSolverReconciler added in v0.10.0 

type GatewayDownstreamCertificateSolverReconciler struct {
	Config config.NetworkServicesOperator

	DownstreamCluster cluster.Cluster
}

func (*GatewayDownstreamCertificateSolverReconciler) Reconcile added in v0.10.0 

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

func (*GatewayDownstreamCertificateSolverReconciler) SetupWithManager added in v0.10.0 

func (r *GatewayDownstreamCertificateSolverReconciler) SetupWithManager(mgr mcmanager.Manager) error

SetupWithManager sets up the controller with the Manager.

type GatewayDownstreamGCReconciler added in v0.3.0 

type GatewayDownstreamGCReconciler struct {
	Config config.NetworkServicesOperator

	DownstreamCluster cluster.Cluster
	// contains filtered or unexported fields
}

GatewayDownstreamGCReconciler reconciles a Gateway object

func (*GatewayDownstreamGCReconciler) Reconcile added in v0.3.0 

func (r *GatewayDownstreamGCReconciler) Reconcile(ctx context.Context, req GVKRequest) (ctrl.Result, error)

func (*GatewayDownstreamGCReconciler) SetupWithManager added in v0.3.0 

func (r *GatewayDownstreamGCReconciler) SetupWithManager(mgr mcmanager.Manager) error

SetupWithManager sets up the controller with the Manager.

type GatewayReconciler 

type GatewayReconciler struct {
	Config config.NetworkServicesOperator

	DownstreamCluster cluster.Cluster
	// contains filtered or unexported fields
}

GatewayReconciler reconciles a Gateway object

func (*GatewayReconciler) Reconcile 

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

func (*GatewayReconciler) SetupWithManager 

func (r *GatewayReconciler) SetupWithManager(mgr mcmanager.Manager) error

SetupWithManager sets up the controller with the Manager.

type GatewayResourceReplicatorReconciler added in v0.7.0 

type GatewayResourceReplicatorReconciler struct {
	Config config.NetworkServicesOperator

	DownstreamCluster cluster.Cluster
	// contains filtered or unexported fields
}

GatewayResourceReplicatorReconciler mirrors configured upstream resources into the downstream control plane.

func (*GatewayResourceReplicatorReconciler) Reconcile added in v0.7.0 

func (r *GatewayResourceReplicatorReconciler) Reconcile(ctx context.Context, req GVKRequest) (ctrl.Result, error)

Reconcile ensures the downstream resource mirrors the upstream resource, handling lifecycle via finalizers.

func (*GatewayResourceReplicatorReconciler) SetupWithManager added in v0.7.0 

func (r *GatewayResourceReplicatorReconciler) SetupWithManager(mgr mcmanager.Manager) error

SetupWithManager wires the controller for the configured resource types.

type HTTPProxyReconciler added in v0.3.0 

type HTTPProxyReconciler struct {
	Config config.NetworkServicesOperator
	// contains filtered or unexported fields
}

HTTPProxyReconciler reconciles a HTTPProxy object

func (*HTTPProxyReconciler) Reconcile added in v0.3.0 

func (r *HTTPProxyReconciler) Reconcile(ctx context.Context, req mcreconcile.Request) (_ ctrl.Result, err error)

func (*HTTPProxyReconciler) SetupWithManager added in v0.3.0 

func (r *HTTPProxyReconciler) SetupWithManager(mgr mcmanager.Manager) error

SetupWithManager sets up the controller with the Manager.

type NamespaceReconcileRequest added in v0.9.0 

type NamespaceReconcileRequest struct {
	Namespace string

	// ClusterName is the name of the cluster that the request belongs to.
	ClusterName string
}

func (NamespaceReconcileRequest) Cluster added in v0.9.0 

func (r NamespaceReconcileRequest) Cluster() string

Cluster returns the name of the cluster that the request belongs to.

func (NamespaceReconcileRequest) String added in v0.9.0 

func (r NamespaceReconcileRequest) String() string

String returns the general purpose string representation.

func (NamespaceReconcileRequest) WithCluster added in v0.9.0 

func (r NamespaceReconcileRequest) WithCluster(name string) NamespaceReconcileRequest

WithCluster sets the name of the cluster that the request belongs to.

type NetworkBindingReconciler 

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

NetworkBindingReconciler reconciles a NetworkBinding object

func (*NetworkBindingReconciler) Reconcile 

func (r *NetworkBindingReconciler) Reconcile(ctx context.Context, req mcreconcile.Request) (_ ctrl.Result, err error)

func (*NetworkBindingReconciler) SetupWithManager 

func (r *NetworkBindingReconciler) SetupWithManager(mgr mcmanager.Manager) error

SetupWithManager sets up the controller with the Manager.

type NetworkContextReconciler 

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

NetworkContextReconciler reconciles a NetworkContext object

func (*NetworkContextReconciler) Reconcile 

func (r *NetworkContextReconciler) Reconcile(ctx context.Context, req mcreconcile.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. TODO(user): Modify the Reconcile function to compare the state specified by the NetworkContext object against the actual cluster state, and then perform operations to make the cluster state reflect the state specified by the user.

For more details, check Reconcile and its Result here: - https://pkg.go.dev/sigs.k8s.io/controller-runtime@v0.19.1/pkg/reconcile

func (*NetworkContextReconciler) SetupWithManager 

func (r *NetworkContextReconciler) SetupWithManager(mgr mcmanager.Manager) error

SetupWithManager sets up the controller with the Manager.

type NetworkPolicyReconciler 

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

NetworkPolicyReconciler reconciles a NetworkPolicy object

func (*NetworkPolicyReconciler) Reconcile 

func (r *NetworkPolicyReconciler) Reconcile(ctx context.Context, req mcreconcile.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. TODO(user): Modify the Reconcile function to compare the state specified by the NetworkPolicy object against the actual cluster state, and then perform operations to make the cluster state reflect the state specified by the user.

For more details, check Reconcile and its Result here: - https://pkg.go.dev/sigs.k8s.io/controller-runtime@v0.19.1/pkg/reconcile

func (*NetworkPolicyReconciler) SetupWithManager 

func (r *NetworkPolicyReconciler) SetupWithManager(mgr mcmanager.Manager) error

SetupWithManager sets up the controller with the Manager.

type NetworkReconciler 

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

NetworkReconciler reconciles a Network object

func (*NetworkReconciler) Finalize added in v0.3.0 

func (r *NetworkReconciler) Finalize(ctx context.Context, obj client.Object) (finalizer.Result, error)

func (*NetworkReconciler) Reconcile 

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

func (*NetworkReconciler) SetupWithManager 

func (r *NetworkReconciler) SetupWithManager(mgr mcmanager.Manager) error

SetupWithManager sets up the controller with the Manager.

type Result 

type Result struct {
	// Result contains the result of a Reconciler invocation.
	ctrl.Result

	// Err contains an error of a Reconciler invocation
	Err error

	// StopProcessing indicates that the caller should not continue processing and
	// let the Reconciler go to sleep without an explicit requeue, expecting a
	// Watch to trigger a future reconciliation call.
	StopProcessing bool
	// contains filtered or unexported fields
}

func (*Result) AddStatusUpdate 

func (r *Result) AddStatusUpdate(c client.Client, obj client.Object)

func (Result) Complete 

func (r Result) Complete(ctx context.Context) (ctrl.Result, error)

func (*Result) Merge 

func (r *Result) Merge(other Result) Result

func (Result) ShouldReturn 

func (r Result) ShouldReturn() bool

type SubnetClaimReconciler 

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

SubnetClaimReconciler reconciles a SubnetClaim object

func (*SubnetClaimReconciler) Reconcile 

func (r *SubnetClaimReconciler) Reconcile(ctx context.Context, req mcreconcile.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. TODO(user): Modify the Reconcile function to compare the state specified by the SubnetClaim object against the actual cluster state, and then perform operations to make the cluster state reflect the state specified by the user.

For more details, check Reconcile and its Result here: - https://pkg.go.dev/sigs.k8s.io/controller-runtime@v0.19.1/pkg/reconcile

func (*SubnetClaimReconciler) SetupWithManager 

func (r *SubnetClaimReconciler) SetupWithManager(mgr mcmanager.Manager) error

SetupWithManager sets up the controller with the Manager.

type SubnetReconciler 

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

SubnetReconciler reconciles a Subnet object

func (*SubnetReconciler) Reconcile 

func (r *SubnetReconciler) Reconcile(ctx context.Context, req mcreconcile.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. TODO(user): Modify the Reconcile function to compare the state specified by the Subnet object against the actual cluster state, and then perform operations to make the cluster state reflect the state specified by the user.

For more details, check Reconcile and its Result here: - https://pkg.go.dev/sigs.k8s.io/controller-runtime@v0.19.1/pkg/reconcile

func (*SubnetReconciler) SetupWithManager 

func (r *SubnetReconciler) SetupWithManager(mgr mcmanager.Manager) error

SetupWithManager sets up the controller with the Manager.

type TrafficProtectionPolicyReconciler added in v0.9.0 

type TrafficProtectionPolicyReconciler struct {
	Config config.NetworkServicesOperator

	DownstreamCluster cluster.Cluster
	// contains filtered or unexported fields
}

TrafficProtectionPolicyReconciler reconciles a TrafficProtectionPolicy object

func (*TrafficProtectionPolicyReconciler) Reconcile added in v0.9.0 

func (r *TrafficProtectionPolicyReconciler) Reconcile(ctx context.Context, req NamespaceReconcileRequest) (ctrl.Result, error)

func (*TrafficProtectionPolicyReconciler) SetupWithManager added in v0.9.0 

func (r *TrafficProtectionPolicyReconciler) SetupWithManager(mgr mcmanager.Manager) error

SetupWithManager sets up the controller with the Manager.

Source Files

View all Source files

Jump to

Keyboard shortcuts

? : This menu
/ : Search site
f or F : Jump to
y or Y : Canonical URL
go.dev uses cookies from Google to deliver and enhance the quality of its services and to analyze traffic. Learn more.