controllers

Documentation

Index

• Constants
• Variables
• func ContructNetworkPolicyObject(ctx context.Context, slice *kubeslicev1beta1.Slice, appNs string) *networkingv1.NetworkPolicy
• func GetSlice(ctx context.Context, c client.Client, slice string) (*kubeslicev1beta1.Slice, error)
• func GetSliceGatewayEdgeServices(ctx context.Context, c client.Client, sliceName string) (*corev1.ServiceList, error)
• func GetSliceGatewayList(ctx context.Context, c client.Client, sliceName string) (*kubeslicev1beta1.SliceGatewayList, error)
• func GetSliceGatewayServers(ctx context.Context, c client.Client, sliceName string) ([]*kubeslicev1beta1.SliceGateway, error)
• func GetSliceGwServices(ctx context.Context, c client.Client, sliceName string) (*corev1.ServiceList, error)
• func GetSliceIngressGwPod(ctx context.Context, c client.Client, sliceName string) (bool, *kubeslicev1beta1.AppPod, error)
• func GetSliceOverlayNetworkType(ctx context.Context, c client.Client, sliceName string) (string, error)
• func GetSliceRouterPodNameAndIP(ctx context.Context, c client.Client, sliceName string) (string, string, error)
• func SliceAppNamespaceConfigured(ctx context.Context, slice string, namespace string) (bool, error)

Constants

const (
	ApplicationNamespaceSelectorLabelKey = "kubeslice.io/slice"
	SliceGatewaySelectorLabelKey         = "kubeslice.io/slice-gw"
	SliceGatewayEdgeTypeLabelKey         = "kubeslice.io/slice-gw-edge-type"
	NodeTypeSelectorLabelKey             = "kubeslice.io/node-type"
	PodTypeSelectorLabelKey              = "kubeslice.io/pod-type"
	TopologyKeySelector                  = "topology.kubeslice.io/gateway"
)

const (
	AllowedNamespaceSelectorLabelKey = "kubeslice.io/namespace"
)

Variables

var (
	// ControlPlaneNamespace is the namespace where slice operator is running
	ControlPlaneNamespace = "kubeslice-system"
	// DNSDeploymentName is the name of coredns deployment running in the cluster
	DNSDeploymentName            = "kubeslice-dns"
	NSMIPLabelSelectorKey string = "kubeslice.io/nsmIP"

	ClusterName = os.Getenv("CLUSTER_NAME")

	ImagePullSecretName = utils.GetEnvOrDefault("IMAGE_PULL_SECRET_NAME", "kubeslice-nexus")

	ReconcileInterval = 10 * time.Second
)

Functions

func ContructNetworkPolicyObject

func ContructNetworkPolicyObject(ctx context.Context, slice *kubeslicev1beta1.Slice, appNs string) *networkingv1.NetworkPolicy

func GetSlice

func GetSlice(ctx context.Context, c client.Client, slice string) (*kubeslicev1beta1.Slice, error)

GetSlice returns slice object by slice name

func GetSliceGatewayEdgeServices

func GetSliceGatewayEdgeServices(ctx context.Context, c client.Client, sliceName string) (*corev1.ServiceList, error)

Returns the list of slice gateway edge service objects. By default there will be only one service object. There could be multiple in future enhancements.

func GetSliceGatewayList

func GetSliceGatewayList(ctx context.Context, c client.Client, sliceName string) (*kubeslicev1beta1.SliceGatewayList, error)

GetSliceGatewayList returns a list of slice gateway objects by slice name

func GetSliceGatewayServers

func GetSliceGatewayServers(ctx context.Context, c client.Client, sliceName string) ([]*kubeslicev1beta1.SliceGateway, error)

GetSliceGatewayServers returns a list of slice gateways that run as VPN servers

func GetSliceGwServices

func GetSliceGwServices(ctx context.Context, c client.Client, sliceName string) (*corev1.ServiceList, error)

GetSliceGwServices returns a list of slice gateway service objects by slice name

func GetSliceIngressGwPod

func GetSliceIngressGwPod(ctx context.Context, c client.Client, sliceName string) (bool, *kubeslicev1beta1.AppPod, error)

GetSliceIngressGwPod returns a bool to indicate if ingress gateway is enabled for the slice, a struct of type AppPod that contains info on the ingress gw pod and an error var to indicate if an error was encountered while executing the func.

func GetSliceOverlayNetworkType

func GetSliceOverlayNetworkType(ctx context.Context, c client.Client, sliceName string) (string, error)

func GetSliceRouterPodNameAndIP

func GetSliceRouterPodNameAndIP(ctx context.Context, c client.Client, sliceName string) (string, string, error)

func SliceAppNamespaceConfigured

func SliceAppNamespaceConfigured(ctx context.Context, slice string, namespace string) (bool, error)

SliceAppNamespaceConfigured returns true if the namespace is present in the application namespace list configured for the slice