machinestatus

Documentation

Overview

Package machinestatus provides functionality to poll the state of machines, i.e., power, connectivity, etc.

Index

• func Get(ctx context.Context, st state.State, id resource.ID) (*baremetal.MachineStatus, error)
• func Modify(ctx context.Context, st state.State, id resource.ID, ...) (*baremetal.MachineStatus, error)
• type AgentService
• type Poller
  • func NewPoller(agentService AgentService, powerClientFactory PowerClientFactory, ...) *Poller
  • func (m *Poller) Run(ctx context.Context) error
• type PowerClientFactory

Functions

func Get

func Get(ctx context.Context, st state.State, id resource.ID) (*baremetal.MachineStatus, error)

Get gets the baremetal.MachineStatus resource from the state.

func Modify

func Modify(ctx context.Context, st state.State, id resource.ID, updateFn func(status *baremetal.MachineStatus) error) (*baremetal.MachineStatus, error)

Modify modifies the baremetal.MachineStatus resource in the state.

Types

type AgentService

type AgentService interface {
	AllConnectedMachines() map[string]struct{}
	IsAccessible(ctx context.Context, machineID string) (bool, error)
}

AgentService is the interface for controlling Talos agent.

type Poller

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

Poller polls the machines periodically and updates their statuses.

func NewPoller

func NewPoller(agentService AgentService, powerClientFactory PowerClientFactory, state state.State, logger *zap.Logger) *Poller

NewPoller creates a new Poller.

func (*Poller) Run

func (m *Poller) Run(ctx context.Context) error

Run starts the Poller.

type PowerClientFactory

type PowerClientFactory interface {
	GetClient(powerManagement *specs.PowerManagement) (power.Client, error)
}

PowerClientFactory is the interface for creating power clients.