netcfgcreator

Documentation

Overview

Package netcfgcreator implements the logic to react to ForeignClusters status changes, in order to enforce/remove the related NetworkConfig resources for network establishment.

Index

• func GetLocalNetworkConfig(ctx context.Context, c client.Client, labels client.MatchingLabels, ...) (*netv1alpha1.NetworkConfig, error)
• func GetRemoteNetworkConfig(ctx context.Context, c client.Client, clusterID, namespace string) (*netv1alpha1.NetworkConfig, error)
• type NetworkConfigCreator
  • func (ncc *NetworkConfigCreator) EnforceNetworkConfigAbsence(ctx context.Context, fc *discoveryv1alpha1.ForeignCluster) error
  • func (ncc *NetworkConfigCreator) EnforceNetworkConfigPresence(ctx context.Context, fc *discoveryv1alpha1.ForeignCluster) error
  • func (ncc *NetworkConfigCreator) Reconcile(ctx context.Context, req ctrl.Request) (ctrl.Result, error)
  • func (ncc *NetworkConfigCreator) SetupWithManager(mgr ctrl.Manager) error
• type SecretWatcher
  • func NewSecretWatcher(enqueuefn func(workqueue.RateLimitingInterface)) *SecretWatcher
  • func (sw *SecretWatcher) Handlers() handler.EventHandler
  • func (sw *SecretWatcher) Predicates() predicate.Predicate
  • func (sw *SecretWatcher) WaitForConfigured(ctx context.Context) bool
  • func (sw *SecretWatcher) WiregardPublicKey() string
• type ServiceWatcher
  • func NewServiceWatcher(enqueuefn func(workqueue.RateLimitingInterface)) *ServiceWatcher
  • func (sw *ServiceWatcher) Handlers() handler.EventHandler
  • func (sw *ServiceWatcher) Predicates() predicate.Predicate
  • func (sw *ServiceWatcher) WaitForConfigured(ctx context.Context) bool
  • func (sw *ServiceWatcher) WiregardEndpoint() (ip, port string)

Functions

func GetLocalNetworkConfig

func GetLocalNetworkConfig(ctx context.Context, c client.Client, labels client.MatchingLabels,
	clusterID, namespace string) (*netv1alpha1.NetworkConfig, error)

GetLocalNetworkConfig returns the local NetworkConfig associated with a given label selector and a clusterID. In case more than one NetworkConfig is found, all but the oldest are deleted.

func GetRemoteNetworkConfig

func GetRemoteNetworkConfig(ctx context.Context, c client.Client, clusterID, namespace string) (*netv1alpha1.NetworkConfig, error)

GetRemoteNetworkConfig returns the remote NetworkConfig associated with a given cluster ID.

Types

type NetworkConfigCreator

type NetworkConfigCreator struct {
	client.Client
	Scheme *runtime.Scheme

	PodCIDR      string
	ExternalCIDR string
	// contains filtered or unexported fields
}

NetworkConfigCreator reconciles ForeignCluster objects to enforce the respective NetworkConfigs.

func (*NetworkConfigCreator) EnforceNetworkConfigAbsence

func (ncc *NetworkConfigCreator) EnforceNetworkConfigAbsence(ctx context.Context, fc *discoveryv1alpha1.ForeignCluster) error

EnforceNetworkConfigAbsence ensures the absence of local NetworkConfigs associated with the given ForeignCluster.

func (*NetworkConfigCreator) EnforceNetworkConfigPresence

func (ncc *NetworkConfigCreator) EnforceNetworkConfigPresence(ctx context.Context, fc *discoveryv1alpha1.ForeignCluster) error

EnforceNetworkConfigPresence ensures the presence of a local NetworkConfig associated with the given ForeignCluster.

func (*NetworkConfigCreator) Reconcile

func (ncc *NetworkConfigCreator) Reconcile(ctx context.Context, req ctrl.Request) (ctrl.Result, error)

Reconcile reconciles the state of ForeignCluster resources to enforce the respective NetworkConfigs.

func (*NetworkConfigCreator) SetupWithManager

func (ncc *NetworkConfigCreator) SetupWithManager(mgr ctrl.Manager) error

SetupWithManager registers a new controller for ForeignCluster resources.

type SecretWatcher

type SecretWatcher struct {
	sync.RWMutex
	// contains filtered or unexported fields
}

SecretWatcher reconciles Secret objects to retrieve the Wireguard public key.

func NewSecretWatcher

func NewSecretWatcher(enqueuefn func(workqueue.RateLimitingInterface)) *SecretWatcher

NewSecretWatcher returns a new initialized SecretWatcher instance.

func (*SecretWatcher) Handlers

func (sw *SecretWatcher) Handlers() handler.EventHandler

Handlers returns the set of handlers used for the Watch configuration.

func (*SecretWatcher) Predicates

func (sw *SecretWatcher) Predicates() predicate.Predicate

Predicates returns the set of predicates used for the Watch configuration.

func (*SecretWatcher) WaitForConfigured

func (sw *SecretWatcher) WaitForConfigured(ctx context.Context) bool

WaitForConfigured waits until a valid key is retrieved for the first time.

func (*SecretWatcher) WiregardPublicKey

func (sw *SecretWatcher) WiregardPublicKey() string

WiregardPublicKey returns the retrieved Wireguard public key.

type ServiceWatcher

type ServiceWatcher struct {
	sync.RWMutex
	// contains filtered or unexported fields
}

ServiceWatcher reconciles Service objects to retrieve the Wireguard endpoint.

func NewServiceWatcher

func NewServiceWatcher(enqueuefn func(workqueue.RateLimitingInterface)) *ServiceWatcher

NewServiceWatcher returns a new initialized ServiceWatcher instance.

func (*ServiceWatcher) Handlers

func (sw *ServiceWatcher) Handlers() handler.EventHandler

Handlers returns the set of handlers used for the Watch configuration.

func (*ServiceWatcher) Predicates

func (sw *ServiceWatcher) Predicates() predicate.Predicate

Predicates returns the set of predicates used for the Watch configuration.

func (*ServiceWatcher) WaitForConfigured

func (sw *ServiceWatcher) WaitForConfigured(ctx context.Context) bool

WaitForConfigured waits until a valid key is retrieved for the first time.

func (*ServiceWatcher) WiregardEndpoint

func (sw *ServiceWatcher) WiregardEndpoint() (ip, port string)

WiregardEndpoint returns the retrieved Wireguard endpoint information (IP/port).