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)
• 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
	PrivateKey     string
	ClusterID      string
	ClusterNetwork string
}

type Usecases

type Usecases struct {
	// SpawnProcessLimit represents a synchronization channel which limits the number of spawned ansible
	// processes. This values should always be non-nil and be buffered, where the capacity indicates
	// the limit.
	SpawnProcessLimit chan struct{}
}

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)

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
}