forge

Documentation

Overview

Package forge groups the methods used to forge the Kubernetes object definitions for the reflection logic.

Index

• Constants
• Variables
• func ApplyOptions() metav1.ApplyOptions
• func EndpointSliceLabels() labels.Set
• func EndpointToBeReflected(endpoint *discoveryv1beta1.Endpoint) bool
• func ForeignReplicasetDeleted(pod *corev1.Pod) *corev1.Pod
• func ForeignToHome(foreignObj, homeObj runtime.Object, reflectionType string) (runtime.Object, error)
• func ForeignToHomeStatus(foreignObj, homeObj runtime.Object) (runtime.Object, error)
• func HomeToForeign(homeObj, foreignObj runtime.Object, reflectionType string) (runtime.Object, error)
• func IPAMClient() liqonetIpam.IpamClient
• func InitForger(nattingTable namespacesmapping.NamespaceNatter, opts ...options.ReadOnlyOption)
• func IsEndpointSliceManagedByReflection(obj metav1.Object) bool
• func IsReflected(obj metav1.Object) bool
• func ReflectedLabelSelector() labels.Selector
• func ReflectionLabels() labels.Set
• func RemoteEndpointSlice(local *discoveryv1beta1.EndpointSlice, targetNamespace string, ...) *discoveryv1beta1apply.EndpointSliceApplyConfiguration
• func RemoteEndpointSliceEndpoints(locals []discoveryv1beta1.Endpoint, translator EndpointTranslator) []*discoveryv1beta1apply.EndpointApplyConfiguration
• func RemoteEndpointSlicePorts(locals []discoveryv1beta1.EndpointPort) []*discoveryv1beta1apply.EndpointPortApplyConfiguration
• func RemoteKind(kind string) string
• func RemoteObjectReference(ref *corev1.ObjectReference) *corev1apply.ObjectReferenceApplyConfiguration
• func RemoteService(local *corev1.Service, targetNamespace string) *corev1apply.ServiceApplyConfiguration
• func RemoteServicePorts(locals []corev1.ServicePort) []*corev1apply.ServicePortApplyConfiguration
• func RemoteServiceSpec(local *corev1.ServiceSpec) *corev1apply.ServiceSpecApplyConfiguration
• func ReplicasetFromPod(pod *corev1.Pod) *appsv1.ReplicaSet
• func Tolerations(inputTolerations []corev1.Toleration) []corev1.Toleration
• type EndpointTranslator

Constants

const (
	// LiqoOutgoingKey is a label to set on all offloaded resources (deprecated).
	LiqoOutgoingKey = "virtualkubelet.liqo.io/outgoing"
	// LiqoOriginClusterIDKey is the key of a label identifying the origin cluster of a reflected resource.
	LiqoOriginClusterIDKey = "virtualkubelet.liqo.io/origin"
	// LiqoDestinationClusterIDKey is the key of a label identifying the destination cluster of a reflected resource.
	LiqoDestinationClusterIDKey = "virtualkubelet.liqo.io/destination"
)

const EndpointSliceManagedBy = "endpointslice.reflection.liqo.io"

EndpointSliceManagedBy -> The manager associated with the reflected EndpointSlices.

const ReflectionFieldManager = "reflection.liqo.io"

ReflectionFieldManager -> The name associated with the fields modified by virtual kubelet reflection.

Variables

var (
	// LocalClusterID -> the cluster ID associated with the local cluster.
	LocalClusterID string
	// RemoteClusterID -> the cluster ID associated with the remote cluster.
	RemoteClusterID string
)

var (
	LiqoNodeName = func() string {
		if forger.virtualNodeName == nil {
			return ""
		}
		return forger.virtualNodeName.Value().ToString()
	}
)

Functions

func ApplyOptions

func ApplyOptions() metav1.ApplyOptions

ApplyOptions returns the apply options configured for object reflection.

func EndpointSliceLabels

func EndpointSliceLabels() labels.Set

EndpointSliceLabels returns the labels assigned to the reflected EndpointSlices.

func EndpointToBeReflected

func EndpointToBeReflected(endpoint *discoveryv1beta1.Endpoint) bool

EndpointToBeReflected filters out the endpoints targeting pods already running on the remote cluster.

func ForeignReplicasetDeleted

func ForeignReplicasetDeleted(pod *corev1.Pod) *corev1.Pod

func ForeignToHome

func ForeignToHome(foreignObj, homeObj runtime.Object, reflectionType string) (runtime.Object, error)

func ForeignToHomeStatus

func ForeignToHomeStatus(foreignObj, homeObj runtime.Object) (runtime.Object, error)

func HomeToForeign

func HomeToForeign(homeObj, foreignObj runtime.Object, reflectionType string) (runtime.Object, error)

func IPAMClient

func IPAMClient() liqonetIpam.IpamClient

IPAMClient returns the initialized IPAM client.

func InitForger

func InitForger(nattingTable namespacesmapping.NamespaceNatter, opts ...options.ReadOnlyOption)

InitForger initialize forger component to set all necessary fields of offloaded resources.

func IsEndpointSliceManagedByReflection

func IsEndpointSliceManagedByReflection(obj metav1.Object) bool

IsEndpointSliceManagedByReflection returns whether the EndpointSlice is managed by the reflection logic.

func IsReflected

func IsReflected(obj metav1.Object) bool

IsReflected returns whether the current object has been reflected from the local to the remote cluster.

func ReflectedLabelSelector

func ReflectedLabelSelector() labels.Selector

ReflectedLabelSelector returns a label selector matching the objects reflected from the local to the remote cluster.

func ReflectionLabels

func ReflectionLabels() labels.Set

ReflectionLabels returns the labels assigned to the objects reflected from the local to the remote cluster.

func RemoteEndpointSlice

func RemoteEndpointSlice(local *discoveryv1beta1.EndpointSlice, targetNamespace string,
	translator EndpointTranslator) *discoveryv1beta1apply.EndpointSliceApplyConfiguration

RemoteEndpointSlice forges the apply patch for the reflected endpointslice, given the local one.

func RemoteEndpointSliceEndpoints

func RemoteEndpointSliceEndpoints(locals []discoveryv1beta1.Endpoint,
	translator EndpointTranslator) []*discoveryv1beta1apply.EndpointApplyConfiguration

RemoteEndpointSliceEndpoints forges the apply patch for the endpoints of the reflected endpointslice, given the local ones.

func RemoteEndpointSlicePorts

func RemoteEndpointSlicePorts(locals []discoveryv1beta1.EndpointPort) []*discoveryv1beta1apply.EndpointPortApplyConfiguration

RemoteEndpointSlicePorts forges the apply patch for the ports of the reflected endpointslice, given the local ones.

func RemoteKind

func RemoteKind(kind string) string

RemoteKind prepends "Remote" to a kind name, to identify remote objects.

func RemoteObjectReference

func RemoteObjectReference(ref *corev1.ObjectReference) *corev1apply.ObjectReferenceApplyConfiguration

RemoteObjectReference forges the apply patch for a reflected RemoteObjectReference.

func RemoteService

func RemoteService(local *corev1.Service, targetNamespace string) *corev1apply.ServiceApplyConfiguration

RemoteService forges the apply patch for the reflected service, given the local one.

func RemoteServicePorts

func RemoteServicePorts(locals []corev1.ServicePort) []*corev1apply.ServicePortApplyConfiguration

RemoteServicePorts forges the apply patch for the ports of the reflected service, given the local ones.

func RemoteServiceSpec

func RemoteServiceSpec(local *corev1.ServiceSpec) *corev1apply.ServiceSpecApplyConfiguration

RemoteServiceSpec forges the apply patch for the specs of the reflected service, given the local ones. It expects the local object to be a deepcopy, as it is mutated.

func ReplicasetFromPod

func ReplicasetFromPod(pod *corev1.Pod) *appsv1.ReplicaSet

func Tolerations

func Tolerations(inputTolerations []corev1.Toleration) []corev1.Toleration

Tolerations forges the tolerations for a reflected pod.

Types

type EndpointTranslator

type EndpointTranslator func([]string) []string

EndpointTranslator defines the function to translate between local and remote endpoint addresses.