github-personal/talos-cloud-controller-manager
1
0
Fork 0
mirror of https://github.com/outbackdingo/talos-cloud-controller-manager.git synced 2026-01-27 18:20:23 +00:00
Code Issues Packages Projects Releases Wiki Activity

fix: refresh talos token

Browse Source 
Due to the failover process, we also need to refresh the Talos token.

Signed-off-by: Serge Logvinov <serge.logvinov@sinextra.dev>
This commit is contained in:
Serge Logvinov
2024-04-25 20:23:17 +03:00
parent 85e2022f1e
commit 0faf0ae2b4
3 changed files with 3 additions and 3 deletions
Download Patch File Download Diff File Expand all files Collapse all files

2
pkg/talos/client.go
View File

@@ -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 {

2
pkg/talos/cloud.go
View File

@@ -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

2
pkg/talos/instances.go
View File

@@ -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)
}