runtime

package
v1.2.9 Latest Latest
Warning

This package is not in the latest version of its module.

 Go to latest Published: Mar 10, 2023 License: MPL-2.0 Imports: 96 Imported by: 0

Documentation

Index

Constants

View Source 
const MinimumEtcdUpgradeLeaseLockSeconds = 60

MinimumEtcdUpgradeLeaseLockSeconds indicates the minimum number of seconds for which we open a lease lock for upgrading Etcd nodes. This is not intended to lock for the duration of an upgrade. Rather, it is intended to make sure only one node processes the various pre-upgrade checks at a time. Thus, this timeout should be reflective of the expected time for the pre-upgrade checks, NOT the time to perform the upgrade itself.

View Source 
const OSPathSeparator = string(os.PathSeparator)

OSPathSeparator is the string version of the os.PathSeparator.

Variables

This section is empty.

Functions

This section is empty.

Types

type ConfigProvider added in v0.10.0 

type ConfigProvider interface {
	Config() config.Provider
}

ConfigProvider defines an interface sufficient for the TimeServer.

type InspectServer added in v0.9.0 

type InspectServer struct {
	inspectapi.UnimplementedInspectServiceServer
	// contains filtered or unexported fields
}

InspectServer implements InspectService API.

func (*InspectServer) ControllerRuntimeDependencies added in v0.9.0 

func (s *InspectServer) ControllerRuntimeDependencies(ctx context.Context, in *emptypb.Empty) (*inspectapi.ControllerRuntimeDependenciesResponse, error)

ControllerRuntimeDependencies implements inspect.InspectService interface.

type ResetOptions added in v0.8.0 

type ResetOptions struct {
	*machine.ResetRequest
	// contains filtered or unexported fields
}

ResetOptions implements runtime.ResetOptions interface.

func (*ResetOptions) GetSystemDiskTargets added in v0.8.0 

func (opt *ResetOptions) GetSystemDiskTargets() []runtime.PartitionTarget

GetSystemDiskTargets implements runtime.ResetOptions interface.

type Server 

type Server struct {
	cluster.UnimplementedClusterServiceServer
	machine.UnimplementedMachineServiceServer

	Controller runtime.Controller
	// breaking the import loop cycle between services/ package and v1alpha1_server.go
	EtcdBootstrapper func(context.Context, runtime.Runtime, *machine.BootstrapRequest) error

	// ShutdownCtx signals that the server is shutting down.
	ShutdownCtx context.Context //nolint:containedctx
	// contains filtered or unexported fields
}

Server implements ClusterService and MachineService APIs and is also responsible for registering ResourceServer and InspectServer.

func (*Server) ApplyConfiguration added in v0.7.0 

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

ApplyConfiguration implements machine.MachineService.

func (*Server) Bootstrap 

func (s *Server) Bootstrap(ctx context.Context, in *machine.BootstrapRequest) (reply *machine.BootstrapResponse, err error)

Bootstrap implements the machine.MachineServer interface.

func (*Server) CPUInfo added in v0.6.0 

func (s *Server) CPUInfo(ctx context.Context, in *emptypb.Empty) (*machine.CPUInfoResponse, error)

CPUInfo implements the machine.MachineServer interface.

func (*Server) Containers added in v0.6.0 

func (s *Server) Containers(ctx context.Context, in *machine.ContainersRequest) (reply *machine.ContainersResponse, err error)

Containers implements the machine.MachineServer interface.

func (*Server) Copy 

func (s *Server) Copy(req *machine.CopyRequest, obj machine.MachineService_CopyServer) error

Copy implements the machine.MachineServer interface and copies data out of Talos node.

func (*Server) DiskStats added in v0.6.0 

func (s *Server) DiskStats(ctx context.Context, in *emptypb.Empty) (*machine.DiskStatsResponse, error)

DiskStats implements the machine.MachineServer interface.

func (*Server) DiskUsage added in v0.7.0 

func (s *Server) DiskUsage(req *machine.DiskUsageRequest, obj machine.MachineService_DiskUsageServer) error

DiskUsage implements the machine.MachineServer interface.

func (*Server) Dmesg added in v0.6.0 

func (s *Server) Dmesg(req *machine.DmesgRequest, srv machine.MachineService_DmesgServer) error

Dmesg implements the machine.MachineServer interface.

func (*Server) EtcdForfeitLeadership added in v0.7.0 

func (s *Server) EtcdForfeitLeadership(ctx context.Context, in *machine.EtcdForfeitLeadershipRequest) (reply *machine.EtcdForfeitLeadershipResponse, err error)

EtcdForfeitLeadership implements the machine.MachineServer interface.

func (*Server) EtcdLeaveCluster added in v0.7.0 

func (s *Server) EtcdLeaveCluster(ctx context.Context, in *machine.EtcdLeaveClusterRequest) (reply *machine.EtcdLeaveClusterResponse, err error)

EtcdLeaveCluster implements the machine.MachineServer interface.

func (*Server) EtcdMemberList added in v0.7.0 

func (s *Server) EtcdMemberList(ctx context.Context, in *machine.EtcdMemberListRequest) (reply *machine.EtcdMemberListResponse, err error)

EtcdMemberList implements the machine.MachineServer interface.

func (*Server) EtcdRecover added in v0.10.0 

func (s *Server) EtcdRecover(srv machine.MachineService_EtcdRecoverServer) error

EtcdRecover implements the machine.MachineServer interface.

func (*Server) EtcdRemoveMember added in v0.9.0 

func (s *Server) EtcdRemoveMember(ctx context.Context, in *machine.EtcdRemoveMemberRequest) (reply *machine.EtcdRemoveMemberResponse, err error)

EtcdRemoveMember implements the machine.MachineServer interface.

func (*Server) EtcdSnapshot added in v0.10.0 

func (s *Server) EtcdSnapshot(in *machine.EtcdSnapshotRequest, srv machine.MachineService_EtcdSnapshotServer) error

EtcdSnapshot implements the machine.MachineServer interface.

func (*Server) Events 

func (s *Server) Events(req *machine.EventsRequest, l machine.MachineService_EventsServer) error

Events streams runtime events.

func (*Server) GenerateClientConfiguration added in v0.11.0 

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

GenerateClientConfiguration implements the machine.MachineServer interface.

func (*Server) GenerateConfiguration added in v0.8.0 

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

GenerateConfiguration implements the machine.MachineServer interface.

func (*Server) HealthCheck added in v0.6.0 

func (s *Server) HealthCheck(in *clusterapi.HealthCheckRequest, srv clusterapi.ClusterService_HealthCheckServer) error

HealthCheck implements the cluster.ClusterServer interface.

func (*Server) Hostname added in v0.6.0 

func (s *Server) Hostname(ctx context.Context, in *emptypb.Empty) (*machine.HostnameResponse, error)

Hostname implements the machine.MachineServer interface.

func (*Server) Kubeconfig 

func (s *Server) Kubeconfig(empty *emptypb.Empty, obj machine.MachineService_KubeconfigServer) error

Kubeconfig implements the machine.MachineServer interface.

func (*Server) List 

func (s *Server) List(req *machine.ListRequest, obj machine.MachineService_ListServer) error

List implements the machine.MachineServer interface.

func (*Server) LoadAvg added in v0.6.0 

func (s *Server) LoadAvg(ctx context.Context, in *emptypb.Empty) (*machine.LoadAvgResponse, error)

LoadAvg implements the machine.MachineServer interface.

func (*Server) Logs 

func (s *Server) Logs(req *machine.LogsRequest, l machine.MachineService_LogsServer) (err error)

Logs provides a service or container logs can be requested and the contents of the log file are streamed in chunks.

func (*Server) Memory added in v0.6.0 

func (s *Server) Memory(ctx context.Context, in *emptypb.Empty) (reply *machine.MemoryResponse, err error)

Memory implements the machine.MachineServer interface.

func (*Server) Mounts 

func (s *Server) Mounts(ctx context.Context, in *emptypb.Empty) (reply *machine.MountsResponse, err error)

Mounts implements the machine.MachineServer interface.

func (*Server) NetworkDeviceStats added in v0.6.0 

func (s *Server) NetworkDeviceStats(ctx context.Context, in *emptypb.Empty) (*machine.NetworkDeviceStatsResponse, error)

NetworkDeviceStats implements the machine.MachineServer interface.

func (*Server) PacketCapture added in v1.2.0 

func (s *Server) PacketCapture(in *machine.PacketCaptureRequest, srv machine.MachineService_PacketCaptureServer) error

PacketCapture performs packet capture and streams the pcap file.

func (*Server) Processes added in v0.6.0 

func (s *Server) Processes(ctx context.Context, in *emptypb.Empty) (reply *machine.ProcessesResponse, err error)

Processes implements the machine.MachineServer interface.

func (*Server) Read 

func (s *Server) Read(in *machine.ReadRequest, srv machine.MachineService_ReadServer) (err error)

Read implements the read API.

func (*Server) Reboot 

func (s *Server) Reboot(ctx context.Context, in *machine.RebootRequest) (reply *machine.RebootResponse, err error)

Reboot implements the machine.MachineServer 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) Restart added in v0.6.0 

func (s *Server) Restart(ctx context.Context, in *machine.RestartRequest) (*machine.RestartResponse, error)

Restart implements the machine.MachineServer interface.

func (*Server) Rollback added in v0.6.0 

func (s *Server) Rollback(ctx context.Context, in *machine.RollbackRequest) (*machine.RollbackResponse, error)

Rollback implements the machine.MachineServer interface.

func (*Server) ServiceList 

func (s *Server) ServiceList(ctx context.Context, in *emptypb.Empty) (result *machine.ServiceListResponse, err error)

ServiceList returns list of the registered services and their status.

func (*Server) ServiceRestart 

func (s *Server) ServiceRestart(ctx context.Context, in *machine.ServiceRestartRequest) (reply *machine.ServiceRestartResponse, err error)

ServiceRestart implements the machine.MachineServer interface and stops a service running on Talos.

func (*Server) ServiceStart 

func (s *Server) ServiceStart(ctx context.Context, in *machine.ServiceStartRequest) (reply *machine.ServiceStartResponse, err error)

ServiceStart implements the machine.MachineServer interface and starts a service running on Talos.

func (*Server) ServiceStop 

func (s *Server) ServiceStop(ctx context.Context, in *machine.ServiceStopRequest) (reply *machine.ServiceStopResponse, err error)

ServiceStop implements the machine.MachineServer interface and stops a service running on Talos.

func (*Server) Shutdown 

func (s *Server) Shutdown(ctx context.Context, in *machine.ShutdownRequest) (reply *machine.ShutdownResponse, err error)

Shutdown implements the machine.MachineServer interface.

func (*Server) Stats added in v0.6.0 

func (s *Server) Stats(ctx context.Context, in *machine.StatsRequest) (reply *machine.StatsResponse, err error)

Stats implements the machine.MachineServer interface.

func (*Server) SystemStat added in v0.6.0 

func (s *Server) SystemStat(ctx context.Context, in *emptypb.Empty) (*machine.SystemStatResponse, error)

SystemStat implements the machine.MachineServer interface.

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, in *emptypb.Empty) (reply *machine.VersionResponse, err error)

Version implements the machine.MachineServer interface.

type TimeServer added in v0.10.0 

type TimeServer struct {
	timeapi.UnimplementedTimeServiceServer

	ConfigProvider ConfigProvider
}

TimeServer implements TimeService API.

func (*TimeServer) Register added in v0.10.0 

func (r *TimeServer) Register(s *grpc.Server)

Register implements the factory.Registrator interface.

func (*TimeServer) Time added in v0.10.0 

func (r *TimeServer) Time(ctx context.Context, in *emptypb.Empty) (reply *timeapi.TimeResponse, err error)

Time issues a query to the configured ntp server and displays the results.

func (*TimeServer) TimeCheck added in v0.10.0 

func (r *TimeServer) TimeCheck(ctx context.Context, in *timeapi.TimeRequest) (reply *timeapi.TimeResponse, err error)

TimeCheck issues a query to the specified ntp server and displays the results.

Source Files

View all Source files

Jump to

Keyboard shortcuts

? : This menu
/ : Search site
f or F : Jump to
y or Y : Canonical URL
go.dev uses cookies from Google to deliver and enhance the quality of its services and to analyze traffic. Learn more.