tunnelEndpointCreator

Documentation

Index

• Constants
• Variables
• type TunnelEndpointCreator
  • func (tec *TunnelEndpointCreator) CreateTunnelEndpoint(param networkParam, owner *metav1.OwnerReference) error
  • func (tec *TunnelEndpointCreator) ForeignClusterHandlerAdd(obj interface{})
  • func (tec *TunnelEndpointCreator) ForeignClusterHandlerDelete(obj interface{})
  • func (tec *TunnelEndpointCreator) ForeignClusterHandlerUpdate(oldObj interface{}, newObj interface{})
  • func (tec *TunnelEndpointCreator) GetAdditionalPools(config *configv1alpha1.ClusterConfig) []string
  • func (tec *TunnelEndpointCreator) GetNetworkConfig(destinationClusterID string) (*netv1alpha1.NetworkConfig, bool, error)
  • func (tec *TunnelEndpointCreator) GetReservedSubnets(config *configv1alpha1.ClusterConfig) []string
  • func (tec *TunnelEndpointCreator) GetTunnelEndpoint(destinationClusterID string) (*netv1alpha1.TunnelEndpoint, bool, error)
  • func (tec *TunnelEndpointCreator) ProcessTunnelEndpoint(param networkParam, owner *metav1.OwnerReference) error
  • func (tec *TunnelEndpointCreator) Reconcile(req ctrl.Request) (ctrl.Result, error)
  • func (tec *TunnelEndpointCreator) SetNetParameters(config *configv1alpha1.ClusterConfig)
  • func (tec *TunnelEndpointCreator) SetupSignalHandlerForTunEndCreator() (stopCh <-chan struct{})
  • func (tec *TunnelEndpointCreator) SetupWithManager(mgr ctrl.Manager) error
  • func (tec *TunnelEndpointCreator) StartForeignClusterWatcher()
  • func (tec *TunnelEndpointCreator) StartGWPodWatcher()
  • func (tec *TunnelEndpointCreator) StartSecretWatcher()
  • func (tec *TunnelEndpointCreator) StartServiceWatcher()
  • func (tec *TunnelEndpointCreator) UpdatePools(additionalPools []string) error
  • func (tec *TunnelEndpointCreator) UpdateReservedSubnets(reservedSubnets []string) error
  • func (tec *TunnelEndpointCreator) UpdateSpecTunnelEndpoint(param networkParam) error
  • func (tec *TunnelEndpointCreator) UpdateStatusTunnelEndpoint(param networkParam) error
  • func (tec *TunnelEndpointCreator) WatchConfiguration(config *rest.Config, gv *schema.GroupVersion)
  • func (tec *TunnelEndpointCreator) Watcher(sharedDynFactory dynamicinformer.DynamicSharedInformerFactory, ...)

Constants

const (
	TunEndpointNamePrefix    = "tun-endpoint-"
	NetConfigNamePrefix      = "net-config-"
	DefaultPodCIDRValue      = "None"
	DefaultExternalCIDRValue = "None"
)

Variables

var (
	GwPodLabelKey   = "net.liqo.io/gatewayPod"
	GwPodLabelValue = "true"
)

var (
	ResyncPeriod = 30 * time.Second
)

Types

type TunnelEndpointCreator

type TunnelEndpointCreator struct {
	client.Client
	ClientSet    *k8s.Clientset
	Scheme       *runtime.Scheme
	Manager      ctrl.Manager
	DynClient    dynamic.Interface
	EndpointIP   string
	EndpointPort string
	PodCIDR      string
	ServiceCIDR  string
	ExternalCIDR string

	ReservedSubnets []string
	AdditionalPools []string
	IPManager       liqonet.Ipam
	Mutex           sync.Mutex
	WaitConfig      *sync.WaitGroup
	IpamConfigured  bool

	IsConfigured               bool
	Configured                 chan bool
	ForeignClusterStartWatcher chan bool
	ForeignClusterStopWatcher  chan struct{}

	SecretStopWatcher chan struct{}
	RunningWatchers   bool
	Namespace         string

	RetryTimeout time.Duration
	// contains filtered or unexported fields
}

func (*TunnelEndpointCreator) CreateTunnelEndpoint

func (tec *TunnelEndpointCreator) CreateTunnelEndpoint(param networkParam, owner *metav1.OwnerReference) error

func (*TunnelEndpointCreator) ForeignClusterHandlerAdd

func (tec *TunnelEndpointCreator) ForeignClusterHandlerAdd(obj interface{})

func (*TunnelEndpointCreator) ForeignClusterHandlerDelete

func (tec *TunnelEndpointCreator) ForeignClusterHandlerDelete(obj interface{})

func (*TunnelEndpointCreator) ForeignClusterHandlerUpdate

func (tec *TunnelEndpointCreator) ForeignClusterHandlerUpdate(oldObj interface{}, newObj interface{})

func (*TunnelEndpointCreator) GetAdditionalPools

func (tec *TunnelEndpointCreator) GetAdditionalPools(config *configv1alpha1.ClusterConfig) []string

func (*TunnelEndpointCreator) GetNetworkConfig

func (tec *TunnelEndpointCreator) GetNetworkConfig(destinationClusterID string) (*netv1alpha1.NetworkConfig, bool, error)

func (*TunnelEndpointCreator) GetReservedSubnets

func (tec *TunnelEndpointCreator) GetReservedSubnets(config *configv1alpha1.ClusterConfig) []string

func (*TunnelEndpointCreator) GetTunnelEndpoint

func (tec *TunnelEndpointCreator) GetTunnelEndpoint(destinationClusterID string) (*netv1alpha1.TunnelEndpoint, bool, error)

func (*TunnelEndpointCreator) ProcessTunnelEndpoint

func (tec *TunnelEndpointCreator) ProcessTunnelEndpoint(param networkParam, owner *metav1.OwnerReference) error

func (*TunnelEndpointCreator) Reconcile

func (tec *TunnelEndpointCreator) Reconcile(req ctrl.Request) (ctrl.Result, error)

func (*TunnelEndpointCreator) SetNetParameters

func (tec *TunnelEndpointCreator) SetNetParameters(config *configv1alpha1.ClusterConfig)

func (*TunnelEndpointCreator) SetupSignalHandlerForTunEndCreator

func (tec *TunnelEndpointCreator) SetupSignalHandlerForTunEndCreator() (stopCh <-chan struct{})

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

func (*TunnelEndpointCreator) SetupWithManager

func (tec *TunnelEndpointCreator) SetupWithManager(mgr ctrl.Manager) error

func (*TunnelEndpointCreator) StartForeignClusterWatcher

func (tec *TunnelEndpointCreator) StartForeignClusterWatcher()

func (*TunnelEndpointCreator) StartGWPodWatcher

func (tec *TunnelEndpointCreator) StartGWPodWatcher()

func (*TunnelEndpointCreator) StartSecretWatcher

func (tec *TunnelEndpointCreator) StartSecretWatcher()

func (*TunnelEndpointCreator) StartServiceWatcher

func (tec *TunnelEndpointCreator) StartServiceWatcher()

func (*TunnelEndpointCreator) UpdatePools

func (tec *TunnelEndpointCreator) UpdatePools(additionalPools []string) error

func (*TunnelEndpointCreator) UpdateReservedSubnets

func (tec *TunnelEndpointCreator) UpdateReservedSubnets(reservedSubnets []string) error

func (*TunnelEndpointCreator) UpdateSpecTunnelEndpoint

func (tec *TunnelEndpointCreator) UpdateSpecTunnelEndpoint(param networkParam) error

func (*TunnelEndpointCreator) UpdateStatusTunnelEndpoint

func (tec *TunnelEndpointCreator) UpdateStatusTunnelEndpoint(param networkParam) error

func (*TunnelEndpointCreator) WatchConfiguration

func (tec *TunnelEndpointCreator) WatchConfiguration(config *rest.Config, gv *schema.GroupVersion)

func (*TunnelEndpointCreator) Watcher

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