tunnelEndpointCreator

Documentation

Index

• Variables
• type TunnelEndpointCreator
  • func (tec *TunnelEndpointCreator) ForeignClusterHandlerAdd(obj interface{})
  • func (tec *TunnelEndpointCreator) ForeignClusterHandlerDelete(obj interface{})
  • func (tec *TunnelEndpointCreator) ForeignClusterHandlerUpdate(oldObj interface{}, newObj interface{})
  • func (tec *TunnelEndpointCreator) GetNetworkConfig(destinationClusterID, namespace string) (*netv1alpha1.NetworkConfig, bool, error)
  • func (tec *TunnelEndpointCreator) GetTunnelEndpoint(destinationClusterID, namespace string) (*netv1alpha1.TunnelEndpoint, bool, error)
  • func (tec *TunnelEndpointCreator) Reconcile(ctx context.Context, req ctrl.Request) (ctrl.Result, error)
  • func (tec *TunnelEndpointCreator) SetupSignalHandlerForTunEndCreator() context.Context
  • func (tec *TunnelEndpointCreator) SetupWithManager(mgr ctrl.Manager) error
  • func (tec *TunnelEndpointCreator) StartForeignClusterWatcher()
  • func (tec *TunnelEndpointCreator) StartSecretWatcher()
  • func (tec *TunnelEndpointCreator) StartServiceWatcher()
  • func (tec *TunnelEndpointCreator) WatchConfiguration(config *rest.Config, gv *schema.GroupVersion)
  • func (tec *TunnelEndpointCreator) Watcher(sharedDynFactory dynamicinformer.DynamicSharedInformerFactory, ...)

Variables

var (
	// ResyncPeriod for watchers.
	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       liqonetIpam.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
}

TunnelEndpointCreator manages the most of liqo networking.

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) GetNetworkConfig

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

GetNetworkConfig returns the network config for a specific cluster.

func (*TunnelEndpointCreator) GetTunnelEndpoint

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

GetTunnelEndpoint retrieves the tunnelEndpoint resource related to a cluster.

func (*TunnelEndpointCreator) Reconcile

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

Reconciler method.

func (*TunnelEndpointCreator) SetupSignalHandlerForTunEndCreator

func (tec *TunnelEndpointCreator) SetupSignalHandlerForTunEndCreator() context.Context

SetupSignalHandlerForTunEndCreator 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

SetupWithManager informs the manager that the tunnelEndpointCreator will deal with networkconfigs.

func (*TunnelEndpointCreator) StartForeignClusterWatcher

func (tec *TunnelEndpointCreator) StartForeignClusterWatcher()

func (*TunnelEndpointCreator) StartSecretWatcher

func (tec *TunnelEndpointCreator) StartSecretWatcher()

func (*TunnelEndpointCreator) StartServiceWatcher

func (tec *TunnelEndpointCreator) StartServiceWatcher()

func (*TunnelEndpointCreator) WatchConfiguration

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

WatchConfiguration start watcher of clusterconfig resource.

func (*TunnelEndpointCreator) Watcher

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

Watcher for resources.