route_operator

Documentation

Overview

Licensed under the Apache License, Version 2.0 (the "License"); you may not use this file except in compliance with the License. You may obtain a copy of the License at

http://www.apache.org/licenses/LICENSE-2.0

Unless required by applicable law or agreed to in writing, software distributed under the License is distributed on an "AS IS" BASIS, WITHOUT WARRANTIES OR CONDITIONS OF ANY KIND, either express or implied. See the License for the specific language governing permissions and limitations under the License.

Index

• Variables
• type RouteController
  • func NewRouteController(mgr ctrl.Manager, wgc wireguard.Client, nl wireguard.Netlinker) (*RouteController, error)
  • func (r *RouteController) Reconcile(req ctrl.Request) (ctrl.Result, error)
  • func (r *RouteController) SetupSignalHandlerForRouteOperator() (stopCh <-chan struct{})
  • func (r *RouteController) SetupWithManager(mgr ctrl.Manager) error
  • func (r *RouteController) StartPodWatcher()
  • func (r *RouteController) StartServiceWatcher()
  • func (r *RouteController) Watcher(sharedDynFactory dynamicinformer.DynamicSharedInformerFactory, ...)

Variables

var (
	PodRouteLabelKey   = "app.kubernetes.io/name"
	PodRouteLabelValue = "route"
)

var (
	OperatorName = "liqo-route"
)

Types

type RouteController

type RouteController struct {
	client.Client
	record.EventRecorder
	utils.NetLink

	DynClient dynamic.Interface
	// contains filtered or unexported fields
}

RouteController reconciles a TunnelEndpoint object

func NewRouteController

func NewRouteController(mgr ctrl.Manager, wgc wireguard.Client, nl wireguard.Netlinker) (*RouteController, error)

func (*RouteController) Reconcile

func (r *RouteController) Reconcile(req ctrl.Request) (ctrl.Result, error)

func (*RouteController) SetupSignalHandlerForRouteOperator

func (r *RouteController) SetupSignalHandlerForRouteOperator() (stopCh <-chan struct{})

SetupSignalHandlerForRouteOperator registers for SIGTERM, SIGINT. A stop channel is returned which is closed on one of these signals.

func (*RouteController) SetupWithManager

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

func (*RouteController) StartPodWatcher

func (r *RouteController) StartPodWatcher()

func (*RouteController) StartServiceWatcher

func (r *RouteController) StartServiceWatcher()

func (*RouteController) Watcher

func (r *RouteController) Watcher(sharedDynFactory dynamicinformer.DynamicSharedInformerFactory, resourceType schema.GroupVersionResource, handlerFuncs cache.ResourceEventHandlerFuncs, stopCh chan struct{})