common

Documentation

Index

• Constants
• func FilterEndpointSubsets(subsets []corev1.EndpointSubset) []corev1.EndpointSubset
• func GetServiceEndpointPorts(ports []corev1.ServicePort) []corev1.EndpointPort
• func GetServiceEndpointSubset(svc *corev1.Service) corev1.EndpointSubset
• func HashLabelIdentity(l string) string
• func NamespacedName(namespace, name string) string
• func RemoveStringFromSlice(slice []string, s string) (result []string)
• func StringExistsInSlice(slice []string, s string) bool
• type ClusterID
• type ClusterSetID

Constants

const (
	AntreaMCServiceAnnotation = "multicluster.antrea.io/imported-service"
	AntreaMCACNPAnnotation    = "multicluster.antrea.io/imported-acnp"
	GatewayAnnotation         = "multicluster.antrea.io/gateway"
	GatewayIPAnnotation       = "multicluster.antrea.io/gateway-ip"

	AntreaMCSPrefix                = "antrea-mc-"
	ServiceKind                    = "Service"
	EndpointsKind                  = "Endpoints"
	AntreaClusterNetworkPolicyKind = "AntreaClusterNetworkPolicy"
	LabelIdentityKind              = "LabelIdentity"
	ServiceImportKind              = "ServiceImport"
	ClusterInfoKind                = "ClusterInfo"

	SourceName      = "sourceName"
	SourceNamespace = "sourceNamespace"
	SourceClusterID = "sourceClusterID"
	SourceKind      = "sourceKind"

	DefaultWorkerCount = 5

	ResourceExportFinalizer = "resourceexport.finalizers.antrea.io"
)

const (
	InvalidClusterID    = ClusterID("invalid")
	InvalidClusterSetID = ClusterSetID("invalid")
)

Functions

func FilterEndpointSubsets

func FilterEndpointSubsets(subsets []corev1.EndpointSubset) []corev1.EndpointSubset

FilterEndpointSubsets keeps IPs only and removes other fields from EndpointSubset which are unnecessary information for other member clusters.

func GetServiceEndpointPorts

func GetServiceEndpointPorts(ports []corev1.ServicePort) []corev1.EndpointPort

GetServiceEndpointPorts converts Service's port to EndpointPort

func GetServiceEndpointSubset

func GetServiceEndpointSubset(svc *corev1.Service) corev1.EndpointSubset

func HashLabelIdentity

func HashLabelIdentity(l string) string

HashLabelIdentity generates a hash value for label identity string.

func NamespacedName

func NamespacedName(namespace, name string) string

TODO: Use NamespacedName stringer method instead of this. e.g. nsName.String()

func RemoveStringFromSlice

func RemoveStringFromSlice(slice []string, s string) (result []string)

func StringExistsInSlice

func StringExistsInSlice(slice []string, s string) bool

Types

type ClusterID

type ClusterID string

type ClusterSetID

type ClusterSetID string