cluster

package

Go to main page

Versions in this module

v0

v0.9.0

Aug 4, 2026

Changes in this version

type BaseClusterClient

+ func (c *BaseClusterClient) UpgradeNodes(ctx context.Context, nodeAddresses []string, image string, powercycle bool) error

+ func (c *BaseClusterClient) WaitForControlPlaneAPIReady(ctx context.Context, nodeAddress string, outputFunc func(string)) error

+ func (c *BaseClusterClient) WaitForNodesReboot(ctx context.Context, nodeAddresses []string, expectedVersion string, ...) error

type ClusterClient

+ UpgradeNodes func(ctx context.Context, nodeAddresses []string, image string, powercycle bool) error

+ WaitForControlPlaneAPIReady func(ctx context.Context, nodeAddress string, outputFunc func(string)) error

+ WaitForNodesReboot func(ctx context.Context, nodeAddresses []string, expectedVersion string, ...) error

type MockClusterClient

+ UpgradeNodesFunc func(ctx context.Context, nodeAddresses []string, image string, powercycle bool) error

+ WaitForControlPlaneAPIReadyFunc func(ctx context.Context, nodeAddress string, outputFunc func(string)) error

+ WaitForNodesRebootFunc func(ctx context.Context, nodeAddresses []string, expectedVersion string, ...) error

+ func (m *MockClusterClient) UpgradeNodes(ctx context.Context, nodeAddresses []string, image string, powercycle bool) error

+ func (m *MockClusterClient) WaitForControlPlaneAPIReady(ctx context.Context, nodeAddress string, outputFunc func(string)) error

+ func (m *MockClusterClient) WaitForNodesReboot(ctx context.Context, nodeAddresses []string, expectedVersion string, ...) error

type Shims

+ NetDialTimeout func(network, address string, timeout time.Duration) (net.Conn, error)

+ TalosUpgrade func(ctx context.Context, client *client.Client, image string, powercycle bool) error

type TalosClusterClient

+ func (c *TalosClusterClient) UpgradeNodes(ctx context.Context, nodeAddresses []string, image string, powercycle bool) error

+ func (c *TalosClusterClient) WaitForControlPlaneAPIReady(ctx context.Context, nodeAddress string, outputFunc func(string)) error

+ func (c *TalosClusterClient) WaitForNodesReboot(ctx context.Context, nodeAddresses []string, expectedVersion string, ...) error

v0.8.1

Dec 12, 2025

v0.8.0

Dec 2, 2025

Changes in this version

+ type BaseClusterClient struct

+ func NewBaseClusterClient() *BaseClusterClient

+ func (c *BaseClusterClient) Close()

+ func (c *BaseClusterClient) WaitForNodesHealthy(ctx context.Context, nodeAddresses []string, expectedVersion string) error

+ type ClusterClient interface

+ Close func()

+ WaitForNodesHealthy func(ctx context.Context, nodeAddresses []string, expectedVersion string) error

+ type MockClusterClient struct

+ CloseFunc func()

+ WaitForNodesHealthyFunc func(ctx context.Context, nodeAddresses []string, expectedVersion string) error

+ func NewMockClusterClient() *MockClusterClient

+ func (m *MockClusterClient) Close()

+ func (m *MockClusterClient) WaitForNodesHealthy(ctx context.Context, nodeAddresses []string, expectedVersion string) error

+ type Shims struct

+ TalosClose func(client *client.Client)

+ TalosConfigOpen func(configPath string) (*clientconfig.Config, error)

+ TalosNewClient func(ctx context.Context, opts ...client.OptionFunc) (*client.Client, error)

+ TalosServiceList func(ctx context.Context, client *client.Client) (*machine.ServiceListResponse, error)

+ TalosVersion func(ctx context.Context, client *client.Client) (*machine.VersionResponse, error)

+ TalosWithNodes func(ctx context.Context, nodes ...string) context.Context

+ func NewShims() *Shims

+ type TalosClusterClient struct

+ func NewTalosClusterClient() *TalosClusterClient

+ func (c *TalosClusterClient) Close()

+ func (c *TalosClusterClient) WaitForNodesHealthy(ctx context.Context, nodeAddresses []string, expectedVersion string) error

?	: This menu
/	: Search site
f or F	: Jump to
y or Y	: Canonical URL