hub

package

v0.2.4 Latest Latest Go to latest Published: May 24, 2022 License: Apache-2.0 Imports: 16 Imported by: 0

Details

Valid go.mod file
Redistributable license
Tagged version
Stable version
Learn more about best practices

Repository

github.com/kubeslice/worker-operator

Links

Open Source Insights

Documentation ¶

Index ¶

Variables
func PostClusterInfoToHub(ctx context.Context, spokeclient client.Client, hubClient client.Client, ...) error
type HubClientConfig
- func NewHubClientConfig() (*HubClientConfig, error)
type HubClientRpc

Constants ¶

This section is empty.

Variables ¶

View Source

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")
)

Functions ¶

func PostClusterInfoToHub ¶

func PostClusterInfoToHub(ctx context.Context, spokeclient client.Client, hubClient client.Client, clusterName, nodeIP string, namespace 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) UpdateAppPodsList ¶

func (hubClient *HubClientConfig) UpdateAppPodsList(ctx context.Context, sliceConfigName string, appPods []kubeslicev1beta1.AppPod) 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
}

Source Files ¶

View all Source files

?	: This menu
/	: Search site
f or F	: Jump to
y or Y	: Canonical URL