usecases

Documentation

Index

• Constants
• type AllNodesInventoryData
• type NodepoolsInfo
• type Usecases
  • func (u *Usecases) InstallNodeRequirements(request *pb.InstallRequest) (*pb.InstallResponse, error)
  • func (u *Usecases) InstallVPN(request *pb.InstallRequest) (*pb.InstallResponse, error)
  • func (u *Usecases) RemoveUtilities(req *pb.RemoveClaudieUtilitiesRequest) (*pb.RemoveClaudieUtilitiesResponse, error)
  • func (u *Usecases) SetUpLoadbalancers(request *pb.SetUpLBRequest) (*pb.SetUpLBResponse, error)
  • func (u *Usecases) TeardownLoadBalancers(ctx context.Context, request *pb.TeardownLBRequest) (*pb.TeardownLBResponse, error)
  • func (u *Usecases) UpdateAPIEndpoint(request *pb.UpdateAPIEndpointRequest) (*pb.UpdateAPIEndpointResponse, error)
  • func (u *Usecases) UpdateNoProxyEnvsInKubernetes(request *pb.UpdateNoProxyEnvsInKubernetesRequest) (*pb.UpdateNoProxyEnvsInKubernetesResponse, error)
  • func (u *Usecases) UpdateProxyEnvsOnNodes(request *pb.UpdateProxyEnvsOnNodesRequest) (*pb.UpdateProxyEnvsOnNodesResponse, error)
• type VPNInfo

Constants

const (

	// SpawnProcessLimit is the number of processes concurrently executing ansible.
	SpawnProcessLimit = 5
)

Types

type AllNodesInventoryData

type AllNodesInventoryData struct {
	NodepoolsInfo []*NodepoolsInfo
}

type NodepoolsInfo

type NodepoolsInfo struct {
	Nodepools      utils.NodePools
	ClusterID      string
	ClusterNetwork string
}

type Usecases

type Usecases struct {
	// SpawnProcessLimit limits the number of spawned ansible processes.
	SpawnProcessLimit *semaphore.Weighted
}

func (*Usecases) InstallNodeRequirements

func (u *Usecases) InstallNodeRequirements(request *pb.InstallRequest) (*pb.InstallResponse, error)

InstallNodeRequirements installs pre-requisite tools (currently only for LongHorn) on all the nodes

func (*Usecases) InstallVPN

func (u *Usecases) InstallVPN(request *pb.InstallRequest) (*pb.InstallResponse, error)

InstallVPN installs VPN between nodes in the k8s cluster and lb clusters

func (*Usecases) RemoveUtilities

func (u *Usecases) RemoveUtilities(req *pb.RemoveClaudieUtilitiesRequest) (*pb.RemoveClaudieUtilitiesResponse, error)

func (*Usecases) SetUpLoadbalancers

func (u *Usecases) SetUpLoadbalancers(request *pb.SetUpLBRequest) (*pb.SetUpLBResponse, error)

func (*Usecases) TeardownLoadBalancers

func (u *Usecases) TeardownLoadBalancers(ctx context.Context, request *pb.TeardownLBRequest) (*pb.TeardownLBResponse, error)

TeardownLoadBalancers correctly destroys loadbalancers by selecting the new ApiServer endpoint.

func (*Usecases) UpdateAPIEndpoint

func (u *Usecases) UpdateAPIEndpoint(request *pb.UpdateAPIEndpointRequest) (*pb.UpdateAPIEndpointResponse, error)

func (*Usecases) UpdateNoProxyEnvsInKubernetes

func (u *Usecases) UpdateNoProxyEnvsInKubernetes(request *pb.UpdateNoProxyEnvsInKubernetesRequest) (*pb.UpdateNoProxyEnvsInKubernetesResponse, error)

func (*Usecases) UpdateProxyEnvsOnNodes

func (u *Usecases) UpdateProxyEnvsOnNodes(request *pb.UpdateProxyEnvsOnNodesRequest) (*pb.UpdateProxyEnvsOnNodesResponse, error)

type VPNInfo

type VPNInfo struct {
	ClusterNetwork string
	// NodepoolsInfos is a slice with each element of type *DesiredClusterNodepoolsInfo.
	// Each element corresponds to a cluster (either a Kubernetes cluster or attached LB clusters).
	NodepoolsInfos []*NodepoolsInfo
}