hub

Documentation

Index

• Variables
• func DeleteNamespaceInfoFromHub(ctx context.Context, hubClient client.Client, onboardNamespace string) error
• func PostClusterInfoToHub(ctx context.Context, spokeclient client.Client, hubClient client.Client, ...) error
• func PostCredsToHub(ctx context.Context, spokeclient client.Client, hubClient client.Client, ...) error
• func PostDashboardCredsToHub(ctx context.Context, spokeclient, hubClient client.Client) error
• func UpdateNamespaceInfoToHub(ctx context.Context, hubClient client.Client, ...) error
• type HubClientConfig
  • func NewHubClientConfig() (*HubClientConfig, error)
  • func (hubClient *HubClientConfig) DeleteServiceExport(ctx context.Context, serviceexport *kubeslicev1beta1.ServiceExport) error
  • func (hubClient *HubClientConfig) GetClusterNodeIP(ctx context.Context, clusterName, namespace string) (string, error)
  • func (hubClient *HubClientConfig) UpdateAppNamespaces(ctx context.Context, sliceConfigName string, onboardedNamespaces []string) error
  • func (hubClient *HubClientConfig) UpdateAppPodsList(ctx context.Context, sliceConfigName string, appPods []kubeslicev1beta1.AppPod) error
  • func (hubClient *HubClientConfig) UpdateNodeIpInCluster(ctx context.Context, clusterName, nodeIP, namespace string) error
  • func (hubClient *HubClientConfig) UpdateNodePortForSliceGwServer(ctx context.Context, sliceGwNodePort int32, sliceGwName string) error
  • func (hubClient *HubClientConfig) UpdateServiceExport(ctx context.Context, serviceexport *kubeslicev1beta1.ServiceExport) error
  • func (hubClient *HubClientConfig) UpdateServiceExportEndpointForIngressGw(ctx context.Context, serviceexport *kubeslicev1beta1.ServiceExport, ...) error
• type HubClientRpc

Variables

var (
	ProjectNamespace     = os.Getenv("HUB_PROJECT_NAMESPACE")
	HubEndpoint          = os.Getenv("HUB_HOST_ENDPOINT")
	ClusterName          = os.Getenv("CLUSTER_NAME")
	HubTokenFile         = utils.GetEnvOrDefault("HUB_TOKEN_FILE", "/var/run/secrets/kubernetes.io/hub-serviceaccount/token")
	HubCAFile            = utils.GetEnvOrDefault("HUB_CA_FILE", "/var/run/secrets/kubernetes.io/hub-serviceaccount/ca.crt")
	KubeSliceDashboardSA = "kubeslice-kubernetes-dashboard"
	HubSecretSuffix      = "-kubernetes-dashboard"
)

Functions

func DeleteNamespaceInfoFromHub

func DeleteNamespaceInfoFromHub(ctx context.Context, hubClient client.Client, onboardNamespace string) error

func PostClusterInfoToHub

func PostClusterInfoToHub(ctx context.Context, spokeclient client.Client, hubClient client.Client, clusterName, nodeIP string, namespace string) error

func PostCredsToHub

func PostCredsToHub(ctx context.Context, spokeclient client.Client, hubClient client.Client, secret *corev1.Secret) error

func PostDashboardCredsToHub

func PostDashboardCredsToHub(ctx context.Context, spokeclient, hubClient client.Client) error

func UpdateNamespaceInfoToHub

func UpdateNamespaceInfoToHub(ctx context.Context, hubClient client.Client, onboardNamespace, sliceName string) error

Types

type HubClientConfig

type HubClientConfig struct {
	client.Client
}

func NewHubClientConfig

func NewHubClientConfig() (*HubClientConfig, error)

func (*HubClientConfig) DeleteServiceExport

func (hubClient *HubClientConfig) DeleteServiceExport(ctx context.Context, serviceexport *kubeslicev1beta1.ServiceExport) error

func (*HubClientConfig) GetClusterNodeIP

func (hubClient *HubClientConfig) GetClusterNodeIP(ctx context.Context, clusterName, namespace string) (string, error)

func (*HubClientConfig) UpdateAppNamespaces

func (hubClient *HubClientConfig) UpdateAppNamespaces(ctx context.Context, sliceConfigName string, onboardedNamespaces []string) error

func (*HubClientConfig) UpdateAppPodsList

func (hubClient *HubClientConfig) UpdateAppPodsList(ctx context.Context, sliceConfigName string, appPods []kubeslicev1beta1.AppPod) error

func (*HubClientConfig) UpdateNodeIpInCluster

func (hubClient *HubClientConfig) UpdateNodeIpInCluster(ctx context.Context, clusterName, nodeIP, namespace string) error

func (*HubClientConfig) UpdateNodePortForSliceGwServer

func (hubClient *HubClientConfig) UpdateNodePortForSliceGwServer(ctx context.Context, sliceGwNodePort int32, sliceGwName string) error

func (*HubClientConfig) UpdateServiceExport

func (hubClient *HubClientConfig) UpdateServiceExport(ctx context.Context, serviceexport *kubeslicev1beta1.ServiceExport) error

func (*HubClientConfig) UpdateServiceExportEndpointForIngressGw

func (hubClient *HubClientConfig) UpdateServiceExportEndpointForIngressGw(ctx context.Context, serviceexport *kubeslicev1beta1.ServiceExport,
	ep *kubeslicev1beta1.ServicePod) error

type HubClientRpc

type HubClientRpc interface {
	UpdateNodePortForSliceGwServer(ctx context.Context, sliceGwNodePort int32, sliceGwName string) error
	UpdateServiceExport(ctx context.Context, serviceexport *kubeslicev1beta1.ServiceExport) error
	UpdateServiceExportEndpointForIngressGw(ctx context.Context, serviceexport *kubeslicev1beta1.ServiceExport,
		ep *kubeslicev1beta1.ServicePod) error
	UpdateAppNamespaces(ctx context.Context, sliceConfigName string, onboardedNamespaces []string) error
	UpdateNodeIpInCluster(ctx context.Context, clusterName, nodeIP, namespace string) error
}