fix: refresh talos token

Due to the failover process, we also need to refresh the Talos token. Signed-off-by: Serge Logvinov <[email protected]>
siderolabs · May 6, 2024 · 0faf0ae · 0faf0ae
1 parent 85e2022
commit 0faf0ae
Show file tree

Hide file tree

Showing 3 changed files with 3 additions and 3 deletions.
diff --git a/pkg/talos/client.go b/pkg/talos/client.go
@@ -47,7 +47,7 @@ func newClient(ctx context.Context, config *cloudConfig) (*client, error) {
 	}, nil
 }
 
-func (c *client) refreshClient(ctx context.Context) error {
+func (c *client) refreshTalosClient(ctx context.Context) error {
 	if _, err := c.talos.Version(ctx); err != nil {
 		talos, err := newClient(ctx, c.config)
 		if err != nil {

diff --git a/pkg/talos/cloud.go b/pkg/talos/cloud.go
@@ -75,7 +75,7 @@ func (c *cloud) Initialize(clientBuilder cloudprovider.ControllerClientBuilder,
 	c.ctx = ctx
 	c.stop = cancel
 
-	if _, err := c.client.talos.Version(c.ctx); err != nil {
+	if err := c.client.refreshTalosClient(c.ctx); err != nil {
 		klog.Errorf("failed to initialized talos client: %v", err)
 
 		return

diff --git a/pkg/talos/instances.go b/pkg/talos/instances.go
@@ -60,7 +60,7 @@ func (i *instances) InstanceMetadata(ctx context.Context, node *v1.Node) (*cloud
 			nodeIP string
 		)
 
-		if err = i.c.refreshClient(ctx); err != nil {
+		if err = i.c.refreshTalosClient(ctx); err != nil {
 			return nil, fmt.Errorf("error refreshing client connection: %w", err)
 		}