vmapi

Documentation

Index

• type API
  • func New(logger *zap.Logger, core Core, dialer Dialer) *API
  • func (a *API) GetJoinDataKube(_ context.Context, _ *vmproto.GetJoinDataKubeRequest) (*vmproto.GetJoinDataKubeResponse, error)
  • func (a *API) InitFirstMaster(in *vmproto.InitFirstMasterRequest, srv vmproto.API_InitFirstMasterServer) error
• type Core
• type Dialer

Types

type API

type API struct {
	// contains filtered or unexported fields
}

API is the API.

func New

func New(logger *zap.Logger, core Core, dialer Dialer) *API

New creates a new API.

func (*API) GetJoinDataKube

func (a *API) GetJoinDataKube(_ context.Context, _ *vmproto.GetJoinDataKubeRequest) (*vmproto.GetJoinDataKubeResponse, error)

GetJoinDataKube returns the join data for the kubernetes cluster. This function will be used by all master nodes except the first one and all worker nodes.

func (*API) InitFirstMaster

func (a *API) InitFirstMaster(in *vmproto.InitFirstMasterRequest, srv vmproto.API_InitFirstMasterServer) error

InitFirstMaster executes the kubeadm init command on the first master node. The subsequent master nodes will join the cluster automatically.

type Core

type Core interface {
	ConnectToKubernetes() error
	GetJoinToken(time.Duration) (*kubeadm.BootstrapTokenDiscovery, error)
	GetControlPlaneCertificatesAndKeys() (map[string][]byte, error)
	IsInReadyState() bool
	IsReadyForInit() bool
	SetJoiningCluster()
	SetInitialized()
}

Core interface contains functions to access the state Core data.

type Dialer

type Dialer interface {
	DialContext(ctx context.Context, network, address string) (net.Conn, error)
}

Dialer is the dial interface. Necessary to stub network connections for local testing with bufconns.