initserver

Documentation

Index

• type ClusterInitializer
• type IssuerWrapper
  • func NewIssuerWrapper(issuer atls.Issuer, vmType vmtype.VMType, idkeydigest []byte) IssuerWrapper
  • func (i *IssuerWrapper) IDKeyDigest() []byte
  • func (i *IssuerWrapper) VMType() vmtype.VMType
• type Server
  • func New(lock locker, kube ClusterInitializer, issuerWrapper IssuerWrapper, ...) *Server
  • func (s *Server) Init(ctx context.Context, req *initproto.InitRequest) (*initproto.InitResponse, error)
  • func (s *Server) Serve(ip, port string, cleaner cleaner) error
  • func (s *Server) Stop()

Types

type ClusterInitializer

type ClusterInitializer interface {
	// InitCluster initializes a new Kubernetes cluster.
	InitCluster(
		ctx context.Context,
		cloudServiceAccountURI string,
		k8sVersion string,
		measurementSalt []byte,
		enforcedPcrs []uint32,
		enforceIDKeyDigest bool,
		idKeyDigest []byte,
		azureCVM bool,
		kmsConfig resources.KMSConfig,
		sshUserKeys map[string]string,
		helmDeployments []byte,
		conformanceMode bool,
		log *logger.Logger,
	) ([]byte, error)
}

ClusterInitializer has the ability to initialize a cluster.

type IssuerWrapper

type IssuerWrapper struct {
	atls.Issuer
	// contains filtered or unexported fields
}

func NewIssuerWrapper

func NewIssuerWrapper(issuer atls.Issuer, vmType vmtype.VMType, idkeydigest []byte) IssuerWrapper

func (*IssuerWrapper) IDKeyDigest

func (i *IssuerWrapper) IDKeyDigest() []byte

func (*IssuerWrapper) VMType

func (i *IssuerWrapper) VMType() vmtype.VMType

type Server

type Server struct {
	initproto.UnimplementedAPIServer
	// contains filtered or unexported fields
}

Server is the initialization server, which is started on each node. The server handles initialization calls from the CLI and initializes the Kubernetes cluster.

func New

func New(lock locker, kube ClusterInitializer, issuerWrapper IssuerWrapper, fh file.Handler, log *logger.Logger) *Server

New creates a new initialization server.

func (*Server) Init

func (s *Server) Init(ctx context.Context, req *initproto.InitRequest) (*initproto.InitResponse, error)

Init initializes the cluster.

func (*Server) Serve

func (s *Server) Serve(ip, port string, cleaner cleaner) error

Serve starts the initialization server.

func (*Server) Stop

func (s *Server) Stop()

Stop stops the initialization server gracefully.