controllers

package
v0.60.0 Latest Latest
Warning

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

 Go to latest Published: Sep 18, 2024 License: Apache-2.0 Imports: 35 Imported by: 0

README

There are two sets of controllers here. The first set belongs to the controller-manager and the second set belongs to the node agent. The controller manager controllers do things that need to be done once per cluster, such as notifying EPIC of new services and endpoints. The agent controllers do per-node setup, such as configuring the True Ingress components.

Documentation

Index

Constants

This section is empty.

Variables

This section is empty.

Functions

func AddFinalizer 

func AddFinalizer(ctx context.Context, cl client.Client, obj client.Object, finalizerName string) error

AddFinalizer safely adds "finalizerName" to the finalizers list of "obj". See https://pkg.go.dev/k8s.io/client-go/util/retry#RetryOnConflict for more info.

func RemoveFinalizer 

func RemoveFinalizer(ctx context.Context, cl client.Client, obj client.Object, finalizerName string) error

RemoveFinalizer safely removes "finalizerName" from the finalizers list of "obj". See https://pkg.go.dev/k8s.io/client-go/util/retry#RetryOnConflict for more info.

Types

type EPICAgentReconciler 

type EPICAgentReconciler struct {
	client.Client
	RuntimeScheme *runtime.Scheme
}

EPICAgentReconciler reconciles a EPIC object

func (*EPICAgentReconciler) Reconcile 

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

Reconcile takes a Request and makes the system reflect what the Request is asking for.

func (*EPICAgentReconciler) Scheme 

func (r *EPICAgentReconciler) Scheme() *runtime.Scheme

Scheme returns this reconciler's scheme.

func (*EPICAgentReconciler) SetupWithManager 

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

SetupWithManager sets up this controller to work with the mgr.

type GWEndpointSliceReconciler 

type GWEndpointSliceReconciler struct {
	client.Client
	Scheme *runtime.Scheme
}

GWEndpointSliceReconciler reconciles a GWEndpointSlice object

func (*GWEndpointSliceReconciler) Reconcile 

func (r *GWEndpointSliceReconciler) 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. TODO(user): Modify the Reconcile function to compare the state specified by the GWEndpointSlice 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.6.4/pkg/reconcile

func (*GWEndpointSliceReconciler) SetupWithManager 

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

SetupWithManager sets up the controller with the Manager.

type GWProxyAdhocReconciler 

type GWProxyAdhocReconciler struct {
	client.Client
	RuntimeScheme *runtime.Scheme
	NodeAddress   string
}

GWProxyAdhocReconciler reconciles a GWProxy object by performing the per-node networking setup needed to enable True Ingress tunnels.

func (*GWProxyAdhocReconciler) Reconcile 

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

Reconcile takes a Request and makes the system reflect what the Request is asking for.

func (*GWProxyAdhocReconciler) Scheme 

func (r *GWProxyAdhocReconciler) Scheme() *runtime.Scheme

Scheme returns this reconciler's scheme.

func (*GWProxyAdhocReconciler) SetupWithManager 

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

SetupWithManager sets up this controller to work with the mgr.

type GWProxyAgentReconciler 

type GWProxyAgentReconciler struct {
	client.Client
	RuntimeScheme *runtime.Scheme
}

GWProxyAgentReconciler reconciles a GWProxy object by performing the per-node networking setup needed to enable True Ingress tunnels.

func (*GWProxyAgentReconciler) Reconcile 

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

Reconcile takes a Request and makes the system reflect what the Request is asking for.

func (*GWProxyAgentReconciler) Scheme 

func (r *GWProxyAgentReconciler) Scheme() *runtime.Scheme

Scheme returns this reconciler's scheme.

func (*GWProxyAgentReconciler) SetupWithManager 

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

SetupWithManager sets up this controller to work with the mgr.

type GWProxyReconciler 

type GWProxyReconciler struct {
	client.Client
	Allocator     *allocator.Allocator
	RuntimeScheme *runtime.Scheme
}

GWProxyReconciler reconciles a GWProxy object

func (*GWProxyReconciler) Reconcile 

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

Reconcile takes a Request and makes the system reflect what the Request is asking for.

func (*GWProxyReconciler) Scheme 

func (r *GWProxyReconciler) Scheme() *runtime.Scheme

Scheme returns this reconciler's scheme.

func (*GWProxyReconciler) SetupWithManager 

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

SetupWithManager sets up this controller to work with the mgr.

type GWRouteReconciler 

type GWRouteReconciler struct {
	client.Client
	Scheme *runtime.Scheme
}

GWRouteReconciler reconciles a GWRoute object

func (*GWRouteReconciler) Reconcile 

func (r *GWRouteReconciler) 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. TODO(user): Modify the Reconcile function to compare the state specified by the GWRoute 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.6.4/pkg/reconcile

func (*GWRouteReconciler) SetupWithManager 

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

SetupWithManager sets up the controller with the Manager.

type LoadBalancerAgentReconciler 

type LoadBalancerAgentReconciler struct {
	client.Client
	RuntimeScheme *runtime.Scheme
}

LoadBalancerAgentReconciler reconciles a LoadBalancer object by performing the per-node networking setup needed to enable True Ingress tunnels.

func (*LoadBalancerAgentReconciler) Reconcile 

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

Reconcile takes a Request and makes the system reflect what the Request is asking for.

func (*LoadBalancerAgentReconciler) Scheme 

func (r *LoadBalancerAgentReconciler) Scheme() *runtime.Scheme

Scheme returns this reconciler's scheme.

func (*LoadBalancerAgentReconciler) SetupWithManager 

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

SetupWithManager sets up this controller to work with the mgr.

type LoadBalancerReconciler 

type LoadBalancerReconciler struct {
	client.Client
	Allocator     *allocator.Allocator
	RuntimeScheme *runtime.Scheme
}

LoadBalancerReconciler reconciles a LoadBalancer object

func (*LoadBalancerReconciler) Reconcile 

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

Reconcile takes a Request and makes the system reflect what the Request is asking for.

func (*LoadBalancerReconciler) Scheme 

func (r *LoadBalancerReconciler) Scheme() *runtime.Scheme

Scheme returns this reconciler's scheme.

func (*LoadBalancerReconciler) SetupWithManager 

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

SetupWithManager sets up this controller to work with the mgr.

type NamespaceReconciler 

type NamespaceReconciler struct {
	client.Client
	RuntimeScheme *runtime.Scheme
}

NamespaceReconciler reconciles a Namespace object

func (*NamespaceReconciler) Reconcile 

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

Reconcile takes a Request and makes the system reflect what the Request is asking for.

func (*NamespaceReconciler) Scheme 

func (r *NamespaceReconciler) Scheme() *runtime.Scheme

Scheme returns this reconciler's scheme.

func (*NamespaceReconciler) SetupWithManager 

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

SetupWithManager sets up this controller to work with the mgr.

type PodAgentReconciler 

type PodAgentReconciler struct {
	client.Client
	RuntimeScheme *runtime.Scheme
}

PodAgentReconciler reconciles a Pod object

func (*PodAgentReconciler) Reconcile 

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

Reconcile takes a Request and makes the system reflect what the Request is asking for.

func (*PodAgentReconciler) Scheme 

func (r *PodAgentReconciler) Scheme() *runtime.Scheme

Scheme returns this reconciler's scheme.

func (*PodAgentReconciler) SetupWithManager 

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

SetupWithManager sets up this controller to work with the mgr.

type PodReconciler 

type PodReconciler struct {
	client.Client
	RuntimeScheme *runtime.Scheme
}

PodReconciler reconciles a Pod object

func (*PodReconciler) Reconcile 

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

Reconcile takes a Request and makes the system reflect what the Request is asking for.

func (*PodReconciler) Scheme 

func (r *PodReconciler) Scheme() *runtime.Scheme

Scheme returns this reconciler's scheme.

func (*PodReconciler) SetupWithManager 

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

SetupWithManager sets up this controller to work with the mgr.

type RemoteEndpointReconciler 

type RemoteEndpointReconciler struct {
	client.Client
	RuntimeScheme *runtime.Scheme
}

RemoteEndpointReconciler reconciles RemoteEndpoint objects.

func (*RemoteEndpointReconciler) Reconcile 

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

Reconcile takes a Request and makes the system reflect what the Request is asking for. In this case the request indicates that an endpoint has changed so we need to update the LB's tunnel map.

func (*RemoteEndpointReconciler) Scheme 

func (r *RemoteEndpointReconciler) Scheme() *runtime.Scheme

Scheme returns this reconciler's scheme.

func (*RemoteEndpointReconciler) SetupWithManager 

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

SetupWithManager sets up this controller to work with the mgr.

type ServicePrefixAgentReconciler 

type ServicePrefixAgentReconciler struct {
	client.Client
	NetClient     netclient.K8sCniCncfIoV1Interface
	RuntimeScheme *runtime.Scheme
}

ServicePrefixAgentReconciler reconciles a ServicePrefix object

func (*ServicePrefixAgentReconciler) Reconcile 

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

Reconcile takes a Request and makes the system reflect what the Request is asking for.

func (*ServicePrefixAgentReconciler) Scheme 

func (r *ServicePrefixAgentReconciler) Scheme() *runtime.Scheme

Scheme returns this reconciler's scheme.

func (*ServicePrefixAgentReconciler) SetupWithManager 

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

SetupWithManager sets up this controller to work with the mgr.

type ServicePrefixReconciler 

type ServicePrefixReconciler struct {
	client.Client
	NetClient     netclient.K8sCniCncfIoV1Interface
	Allocator     *allocator.Allocator
	RuntimeScheme *runtime.Scheme
}

ServicePrefixReconciler reconciles a ServicePrefix object

func (*ServicePrefixReconciler) Reconcile 

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

Reconcile takes a Request and makes the system reflect what the Request is asking for.

func (*ServicePrefixReconciler) Scheme 

func (r *ServicePrefixReconciler) Scheme() *runtime.Scheme

Scheme returns this reconciler's scheme.

func (*ServicePrefixReconciler) SetupWithManager 

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

SetupWithManager sets up this controller to work with the mgr.

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.