server

Documentation

Overview

Package server implements the gRPC server for the upgrade agent.

The server is responsible for using kubeadm to upgrade the Kubernetes release of a Constellation node.

Index

• type Server
  • func New(log *slog.Logger, fileHandler file.Handler) (*Server, error)
  • func (s *Server) ExecuteUpdate(ctx context.Context, updateRequest *upgradeproto.ExecuteUpdateRequest) (*upgradeproto.ExecuteUpdateResponse, error)
  • func (s *Server) Run(protocol string, sockAddr string) error
  • func (s *Server) Stop()

Types

type Server

type Server struct {
	upgradeproto.UnimplementedUpdateServer
	// contains filtered or unexported fields
}

Server is the upgrade-agent server.

func New

func New(log *slog.Logger, fileHandler file.Handler) (*Server, error)

New creates a new upgrade-agent server.

func (*Server) ExecuteUpdate

func (s *Server) ExecuteUpdate(ctx context.Context, updateRequest *upgradeproto.ExecuteUpdateRequest) (*upgradeproto.ExecuteUpdateResponse, error)

ExecuteUpdate installs & verifies the provided kubeadm, then executes `kubeadm upgrade plan` & `kubeadm upgrade apply {wanted_Kubernetes_Version}` to upgrade to the specified version.

func (*Server) Run

func (s *Server) Run(protocol string, sockAddr string) error

Run starts the upgrade-agent server on the given port, using the provided protocol and socket address.

func (*Server) Stop

func (s *Server) Stop()

Stop stops the upgrade-agent server gracefully.