feat(v2/salvage): get snapshots from runtime replicas

longhorn/longhorn-8430 Signed-off-by: Chin-Ya Huang <chin-ya.huang@suse.com>
longhorn · Sep 27, 2024 · 479e276 · 479e276
1 parent 5890742
commit 479e276
Show file tree

Hide file tree

Showing 4 changed files with 5 additions and 5 deletions.
diff --git a/pkg/instance/instance.go b/pkg/instance/instance.go
@@ -270,7 +270,7 @@ func (ops V2DataEngineInstanceOps) InstanceGet(req *rpc.InstanceGetRequest) (*rp
 
 	switch req.Type {
 	case types.InstanceTypeEngine:
-		engine, err := c.EngineGet(req.Name)
+		engine, err := c.EngineGet(req.Name, false)
 		if err != nil {
 			return nil, err
 		}

diff --git a/pkg/proxy/replica.go b/pkg/proxy/replica.go
@@ -151,7 +151,7 @@ func (ops V2DataEngineProxyOps) ReplicaList(ctx context.Context, req *rpc.ProxyE
 	}
 	defer c.Close()
 
-	recv, err := c.EngineGet(req.EngineName)
+	recv, err := c.EngineGet(req.EngineName, false)
 	if err != nil {
 		return nil, grpcstatus.Error(grpccodes.Internal, errors.Wrapf(err, "failed to get engine %v", req.EngineName).Error())
 	}
@@ -228,7 +228,7 @@ func (ops V2DataEngineProxyOps) ReplicaRebuildingStatus(ctx context.Context, req
 	}
 	defer engineCli.Close()
 
-	e, err := engineCli.EngineGet(req.EngineName)
+	e, err := engineCli.EngineGet(req.EngineName, false)
 	if err != nil {
 		return nil, grpcstatus.Errorf(grpccodes.Internal, "failed to get engine %v: %v", req.EngineName, err)
 	}

diff --git a/pkg/proxy/snapshot.go b/pkg/proxy/snapshot.go
@@ -135,7 +135,7 @@ func (ops V2DataEngineProxyOps) SnapshotList(ctx context.Context, req *rpc.Proxy
 	}
 	defer c.Close()
 
-	engine, err := c.EngineGet(req.EngineName)
+	engine, err := c.EngineGet(req.EngineName, true)
 	if err != nil {
 		return nil, errors.Wrapf(err, "failed to get engine %v", req.EngineName)
 	}

diff --git a/pkg/proxy/volume.go b/pkg/proxy/volume.go
@@ -71,7 +71,7 @@ func (ops V2DataEngineProxyOps) VolumeGet(ctx context.Context, req *rpc.ProxyEng
 	}
 	defer c.Close()
 
-	recv, err := c.EngineGet(req.EngineName)
+	recv, err := c.EngineGet(req.EngineName, false)
 	if err != nil {
 		return nil, grpcstatus.Errorf(grpccodes.Internal, "failed to get engine %v: %v", req.EngineName, err)
 	}