outbound

package
v0.7.0 Latest Latest
Warning

This package is not in the latest version of its module.

 Go to latest Published: Feb 23, 2024 License: Apache-2.0 Imports: 10 Imported by: 0

Documentation

Index

Constants

This section is empty.

Variables

This section is empty.

Functions

This section is empty.

Types

type AnsiblerConnector 

type AnsiblerConnector struct {
	Connection *grpc.ClientConn
}

func (*AnsiblerConnector) Connect 

func (a *AnsiblerConnector) Connect() error

Connect establishes a gRPC connection with the ansibler microservice.

func (*AnsiblerConnector) Disconnect 

func (a *AnsiblerConnector) Disconnect()

Disconnect closes the underlying gRPC connection to ansibler microservice

func (*AnsiblerConnector) GetClient 

func (a *AnsiblerConnector) GetClient() pb.AnsiblerServiceClient

GetClient returns a ansibler gRPC client.

func (*AnsiblerConnector) InstallNodeRequirements 

func (a *AnsiblerConnector) InstallNodeRequirements(builderCtx *utils.BuilderContext, ansiblerGrpcClient pb.AnsiblerServiceClient) (*pb.InstallResponse, error)

InstallNodeRequirements installs node requirements on all nodes.

func (*AnsiblerConnector) InstallVPN 

func (a *AnsiblerConnector) InstallVPN(builderCtx *utils.BuilderContext, ansiblerGrpcClient pb.AnsiblerServiceClient) (*pb.InstallResponse, error)

InstallVPN installs VPN on all nodes of the infrastructure.

func (*AnsiblerConnector) PerformHealthCheck 

func (a *AnsiblerConnector) PerformHealthCheck() error

PerformHealthCheck checks health of the underlying gRPC connection to ansibler microservice

func (*AnsiblerConnector) RemoveClaudieUtilities added in v0.6.2 

func (a *AnsiblerConnector) RemoveClaudieUtilities(builderCtx *utils.BuilderContext, ansiblerGrpcClient pb.AnsiblerServiceClient) (*pb.RemoveClaudieUtilitiesResponse, error)

RemoveClaudieUtilities removes claudie installed utilities from the nodes of the cluster.

func (*AnsiblerConnector) SetUpLoadbalancers 

func (a *AnsiblerConnector) SetUpLoadbalancers(builderCtx *utils.BuilderContext, apiEndpoint string, ansiblerGrpcClient pb.AnsiblerServiceClient) (*pb.SetUpLBResponse, error)

SetUpLoadbalancers configures loadbalancers for the infrastructure.

func (*AnsiblerConnector) TeardownLoadBalancers 

func (a *AnsiblerConnector) TeardownLoadBalancers(builderCtx *utils.BuilderContext, ansiblerGrpcClient pb.AnsiblerServiceClient) (*pb.TeardownLBResponse, error)

TeardownLoadBalancers destroys loadbalancers for the infrastructure.

func (*AnsiblerConnector) UpdateAPIEndpoint 

func (a *AnsiblerConnector) UpdateAPIEndpoint(builderCtx *utils.BuilderContext, ansiblerGrpcClient pb.AnsiblerServiceClient) (*pb.UpdateAPIEndpointResponse, error)

UpdateAPIEndpoint updates kube API endpoint of the cluster.

type ContextBoxConnector 

type ContextBoxConnector struct {
	Connection *grpc.ClientConn
}

func (*ContextBoxConnector) Connect 

func (c *ContextBoxConnector) Connect() error

Connect establishes a gRPC connection with the context-box microservice

func (*ContextBoxConnector) DeleteConfig 

func (c *ContextBoxConnector) DeleteConfig(config *pb.Config, contextBoxGrpcClient pb.ContextBoxServiceClient) error

DeleteConfig removes config from Claudie database via context-box.

func (*ContextBoxConnector) Disconnect 

func (c *ContextBoxConnector) Disconnect()

Disconnect closes the underlying gRPC connection to context-box microservice

func (*ContextBoxConnector) GetClient 

func (c *ContextBoxConnector) GetClient() pb.ContextBoxServiceClient

GetClient returns a context-box gRPC client.

func (*ContextBoxConnector) GetConfigBuilder 

func (c *ContextBoxConnector) GetConfigBuilder(contextBoxGrpcClient pb.ContextBoxServiceClient) (*pb.GetConfigResponse, error)

GetConfigBuilder requests a new config for builder from context-box.

func (*ContextBoxConnector) PerformHealthCheck 

func (c *ContextBoxConnector) PerformHealthCheck() error

PerformHealthCheck checks health of the underlying gRPC connection to context-box microservice.

func (*ContextBoxConnector) SaveConfigBuilder 

func (c *ContextBoxConnector) SaveConfigBuilder(config *pb.Config, contextBoxGrpcClient pb.ContextBoxServiceClient) error

SaveConfigBuilder saves a config from builder to Claudie database via context-box.

func (*ContextBoxConnector) SaveWorkflowState 

func (c *ContextBoxConnector) SaveWorkflowState(configName, clusterName string, wf *pb.Workflow, contextBoxGrpcClient pb.ContextBoxServiceClient) error

SaveWorkflowState saves workflow state for a particular cluster.

type KubeElevenConnector 

type KubeElevenConnector struct {
	Connection *grpc.ClientConn
}

func (*KubeElevenConnector) BuildCluster 

func (k *KubeElevenConnector) BuildCluster(builderCtx *utils.BuilderContext, kubeElevenGrpcClient pb.KubeElevenServiceClient) (*pb.BuildClusterResponse, error)

BuildCluster builds/reconciles given k8s cluster via kube-eleven.

func (*KubeElevenConnector) Connect 

func (k *KubeElevenConnector) Connect() error

Connect establishes a gRPC connection with the kube-eleven microservice

func (*KubeElevenConnector) DestroyCluster added in v0.6.2 

func (k *KubeElevenConnector) DestroyCluster(builderCtx *utils.BuilderContext, kubeElevenGrpcClient pb.KubeElevenServiceClient) (*pb.DestroyClusterResponse, error)

DestroyCluster destroys k8s cluster.

func (*KubeElevenConnector) Disconnect 

func (k *KubeElevenConnector) Disconnect()

Disconnect closes the underlying gRPC connection to kube-eleven microservice

func (*KubeElevenConnector) GetClient 

func (k *KubeElevenConnector) GetClient() pb.KubeElevenServiceClient

GetClient returns a kube-eleven gRPC client.

func (*KubeElevenConnector) PerformHealthCheck 

func (k *KubeElevenConnector) PerformHealthCheck() error

PerformHealthCheck checks health of the underlying gRPC connection to kube-eleven microservice

type KuberConnector 

type KuberConnector struct {
	Connection *grpc.ClientConn
}

func (*KuberConnector) CiliumRolloutRestart added in v0.5.0 

func (k *KuberConnector) CiliumRolloutRestart(cluster *pb.K8Scluster, kuberGrpcClient pb.KuberServiceClient) error

func (*KuberConnector) Connect 

func (k *KuberConnector) Connect() error

Connect establishes a gRPC connection with the kuber microservice.

func (*KuberConnector) DeleteClusterMetadata 

func (k *KuberConnector) DeleteClusterMetadata(builderCtx *utils.BuilderContext, kuberGrpcClient pb.KuberServiceClient) error

DeleteClusterMetadata removes cluster metadata from management k8s cluster.

func (*KuberConnector) DeleteKubeconfig 

func (k *KuberConnector) DeleteKubeconfig(builderCtx *utils.BuilderContext, kuberGrpcClient pb.KuberServiceClient) error

DeleteKubeconfig removes cluster kubeconfig from management k8s cluster.

func (*KuberConnector) DeleteNodes 

func (k *KuberConnector) DeleteNodes(cluster *pb.K8Scluster, masterNodes, workerNodes []string, kuberGrpcClient pb.KuberServiceClient) (*pb.DeleteNodesResponse, error)

DeleteNodes gracefully removes nodes from a given k8s cluster.

func (*KuberConnector) DestroyClusterAutoscaler 

func (k *KuberConnector) DestroyClusterAutoscaler(builderCtx *utils.BuilderContext, kuberGrpcClient pb.KuberServiceClient) error

DestroyClusterAutoscaler deletes cluster autoscaler from a management k8s cluster for a given k8s cluster.

func (*KuberConnector) Disconnect 

func (k *KuberConnector) Disconnect()

Disconnect closes the underlying gRPC connection to kuber microservice.

func (*KuberConnector) GetClient 

func (k *KuberConnector) GetClient() pb.KuberServiceClient

GetClient returns a kuber gRPC client.

func (*KuberConnector) PatchClusterInfoConfigMap 

func (k *KuberConnector) PatchClusterInfoConfigMap(builderCtx *utils.BuilderContext, kuberGrpcClient pb.KuberServiceClient) error

PatchClusterInfoConfigMap updates certificates in a cluster-info config map for a given cluster.

func (*KuberConnector) PatchNodes 

func (k *KuberConnector) PatchNodes(builderCtx *utils.BuilderContext, kuberGrpcClient pb.KuberServiceClient) error

PatchNodes updates k8s cluster node metadata.

func (*KuberConnector) PerformHealthCheck 

func (k *KuberConnector) PerformHealthCheck() error

PerformHealthCheck checks health of the underlying gRPC connection to kuber microservice.

func (*KuberConnector) RemoveLBScrapeConfig 

func (k *KuberConnector) RemoveLBScrapeConfig(builderCtx *utils.BuilderContext, kuberGrpcClient pb.KuberServiceClient) error

RemoveLBScrapeConfig removes LB scrape config from a given k8s cluster.

func (*KuberConnector) SetUpClusterAutoscaler 

func (k *KuberConnector) SetUpClusterAutoscaler(builderCtx *utils.BuilderContext, kuberGrpcClient pb.KuberServiceClient) error

SetUpClusterAutoscaler deploys cluster autoscaler on a management k8s cluster for a given k8s cluster.

func (*KuberConnector) SetUpStorage 

func (k *KuberConnector) SetUpStorage(builderCtx *utils.BuilderContext, kuberGrpcClient pb.KuberServiceClient) (*pb.SetUpStorageResponse, error)

SetUpStorage configures storage solution on given k8s cluster.

func (*KuberConnector) StoreClusterMetadata 

func (k *KuberConnector) StoreClusterMetadata(builderCtx *utils.BuilderContext, kuberGrpcClient pb.KuberServiceClient) error

StoreClusterMetadata stores cluster metadata on a management k8s cluster.

func (*KuberConnector) StoreKubeconfig 

func (k *KuberConnector) StoreKubeconfig(builderCtx *utils.BuilderContext, kuberGrpcClient pb.KuberServiceClient) error

StoreKubeconfig stores cluster kubeconfig on a management k8s cluster.

func (*KuberConnector) StoreLBScrapeConfig 

func (k *KuberConnector) StoreLBScrapeConfig(builderCtx *utils.BuilderContext, kuberGrpcClient pb.KuberServiceClient) error

StoreLBScrapeConfig stores LB scrape config on a given k8s cluster.

type TerraformerConnector 

type TerraformerConnector struct {
	Connection *grpc.ClientConn
}

func (*TerraformerConnector) BuildInfrastructure 

func (t *TerraformerConnector) BuildInfrastructure(builderCtx *utils.BuilderContext, terraformerGrpcClient pb.TerraformerServiceClient) (*pb.BuildInfrastructureResponse, error)

BuildInfrastructure builds/reconciles the infrastructure for given k8s cluster via terraformer.

func (*TerraformerConnector) Connect 

func (t *TerraformerConnector) Connect() error

Connect establishes a gRPC connection with the terraformer microservice.

func (*TerraformerConnector) DestroyInfrastructure 

func (t *TerraformerConnector) DestroyInfrastructure(builderCtx *utils.BuilderContext, terraformerGrpcClient pb.TerraformerServiceClient) (*pb.DestroyInfrastructureResponse, error)

DestroyInfrastructure destroys the infrastructure for given k8s cluster via terraformer.

func (*TerraformerConnector) Disconnect 

func (t *TerraformerConnector) Disconnect()

Disconnect closes the underlying gRPC connection to terraformer microservice.

func (*TerraformerConnector) GetClient 

func (t *TerraformerConnector) GetClient() pb.TerraformerServiceClient

GetClient returns a terraformer gRPC client.

func (*TerraformerConnector) PerformHealthCheck 

func (t *TerraformerConnector) PerformHealthCheck() error

PerformHealthCheck checks health of the underlying gRPC connection to terraformer microservice.

Source Files

View all Source files

Jump to

Keyboard shortcuts

? : This menu
/ : Search site
f or F : Jump to
y or Y : Canonical URL
go.dev uses cookies from Google to deliver and enhance the quality of its services and to analyze traffic. Learn more.