diff --git a/pkg/cluster/bootstrap.go b/pkg/cluster/bootstrap.go index ebf2c73b2d..6523349d88 100644 --- a/pkg/cluster/bootstrap.go +++ b/pkg/cluster/bootstrap.go @@ -393,6 +393,7 @@ func (c *Cluster) ReconcileBootstrapData(ctx context.Context, buf io.ReadSeeker, if err != nil { return err } + defer storageClient.Close() ticker := time.NewTicker(5 * time.Second) defer ticker.Stop() diff --git a/pkg/cluster/storage.go b/pkg/cluster/storage.go index 55196f8387..bc4049ac52 100644 --- a/pkg/cluster/storage.go +++ b/pkg/cluster/storage.go @@ -48,6 +48,7 @@ func Save(ctx context.Context, config *config.Control, etcdConfig endpoint.ETCDC if err != nil { return err } + defer storageClient.Close() if _, _, err = getBootstrapKeyFromStorage(ctx, storageClient, normalizedToken, token); err != nil { return err @@ -102,6 +103,7 @@ func (c *Cluster) storageBootstrap(ctx context.Context) error { if err != nil { return err } + defer storageClient.Close() token := c.config.Token if token == "" {