maintenance

Documentation

Index

• func InjectController(c runtime.Controller)
• type Server
  • func New(cfgCh chan<- config.Provider) *Server
  • func (s *Server) ApplyConfiguration(_ context.Context, in *machine.ApplyConfigurationRequest) (*machine.ApplyConfigurationResponse, error)
  • func (s *Server) GenerateClientConfiguration(context.Context, *machine.GenerateClientConfigurationRequest) (*machine.GenerateClientConfigurationResponse, error)
  • func (s *Server) GenerateConfiguration(ctx context.Context, in *machine.GenerateConfigurationRequest) (*machine.GenerateConfigurationResponse, error)
  • func (s *Server) MetaDelete(ctx context.Context, req *machine.MetaDeleteRequest) (*machine.MetaDeleteResponse, error)
  • func (s *Server) MetaWrite(ctx context.Context, req *machine.MetaWriteRequest) (*machine.MetaWriteResponse, error)
  • func (s *Server) Register(obj *grpc.Server)
  • func (s *Server) Reset(ctx context.Context, in *machine.ResetRequest) (reply *machine.ResetResponse, err error)
  • func (s *Server) Upgrade(ctx context.Context, in *machine.UpgradeRequest) (reply *machine.UpgradeResponse, err error)
  • func (s *Server) Version(ctx context.Context, _ *emptypb.Empty) (*machine.VersionResponse, error)
• type TLSProvider
  • func NewTLSProvider() *TLSProvider
  • func (provider *TLSProvider) GetCA() ([]byte, error)
  • func (provider *TLSProvider) GetCACertPool() (*x509.CertPool, error)
  • func (provider *TLSProvider) GetCertificate(h *stdlibtls.ClientHelloInfo) (*stdlibtls.Certificate, error)
  • func (provider *TLSProvider) GetClientCertificate(*stdlibtls.CertificateRequestInfo) (*stdlibtls.Certificate, error)
  • func (provider *TLSProvider) TLSConfig() (*stdlibtls.Config, error)
  • func (provider *TLSProvider) Update(maintenanceCerts *secrets.MaintenanceServiceCerts) error

Functions

func InjectController

func InjectController(c runtime.Controller)

InjectController is used to pass the controller into the maintenance service.

Types

type Server

type Server struct {
	machine.UnimplementedMachineServiceServer
	// contains filtered or unexported fields
}

Server implements machine.MachineServiceServer, network.NetworkService, and storage.StorageServiceServer.

func New

func New(cfgCh chan<- config.Provider) *Server

New initializes and returns a Server.

func (*Server) ApplyConfiguration

func (s *Server) ApplyConfiguration(_ context.Context, in *machine.ApplyConfigurationRequest) (*machine.ApplyConfigurationResponse, error)

ApplyConfiguration implements machine.MachineServiceServer.

func (*Server) GenerateClientConfiguration

func (s *Server) GenerateClientConfiguration(context.Context, *machine.GenerateClientConfigurationRequest) (*machine.GenerateClientConfigurationResponse, error)

GenerateClientConfiguration implements the machine.MachineServiceServer interface.

func (*Server) GenerateConfiguration

func (s *Server) GenerateConfiguration(ctx context.Context, in *machine.GenerateConfigurationRequest) (*machine.GenerateConfigurationResponse, error)

GenerateConfiguration implements the machine.MachineServiceServer interface.

func (*Server) MetaDelete

func (s *Server) MetaDelete(ctx context.Context, req *machine.MetaDeleteRequest) (*machine.MetaDeleteResponse, error)

MetaDelete implements the machine.MachineServiceServer interface.

func (*Server) MetaWrite

func (s *Server) MetaWrite(ctx context.Context, req *machine.MetaWriteRequest) (*machine.MetaWriteResponse, error)

MetaWrite implements the machine.MachineServiceServer interface.

func (*Server) Register

func (s *Server) Register(obj *grpc.Server)

Register implements the factory.Registrator interface.

func (*Server) Reset

func (s *Server) Reset(ctx context.Context, in *machine.ResetRequest) (reply *machine.ResetResponse, err error)

Reset resets the node.

func (*Server) Upgrade

func (s *Server) Upgrade(ctx context.Context, in *machine.UpgradeRequest) (reply *machine.UpgradeResponse, err error)

Upgrade initiates an upgrade.

func (*Server) Version

func (s *Server) Version(ctx context.Context, _ *emptypb.Empty) (*machine.VersionResponse, error)

Version implements the machine.MachineServer interface.

type TLSProvider

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

TLSProvider provides TLS configuration for maintenance service.

func NewTLSProvider

func NewTLSProvider() *TLSProvider

NewTLSProvider creates a new TLS provider for maintenance service.

The provider expects that the certificates are pushed to it.

func (*TLSProvider) GetCA

func (provider *TLSProvider) GetCA() ([]byte, error)

GetCA implements tls.CertificateProvider interface.

func (*TLSProvider) GetCACertPool

func (provider *TLSProvider) GetCACertPool() (*x509.CertPool, error)

GetCACertPool implements tls.CertificateProvider interface.

func (*TLSProvider) GetCertificate

func (provider *TLSProvider) GetCertificate(h *stdlibtls.ClientHelloInfo) (*stdlibtls.Certificate, error)

GetCertificate implements tls.CertificateProvider interface.

func (*TLSProvider) GetClientCertificate

func (provider *TLSProvider) GetClientCertificate(*stdlibtls.CertificateRequestInfo) (*stdlibtls.Certificate, error)

GetClientCertificate implements tls.CertificateProvider interface.

func (*TLSProvider) TLSConfig

func (provider *TLSProvider) TLSConfig() (*stdlibtls.Config, error)

TLSConfig generates server-side tls.Config.

func (*TLSProvider) Update

func (provider *TLSProvider) Update(maintenanceCerts *secrets.MaintenanceServiceCerts) error

Update the certificate in the provider.