ADHOC: add read needle meta grpc (#3581)

* ADHOC: add read needle meta grpc

* add test

* nit

Co-authored-by: root <root@HQ-10MSTD3EY.roblox.local>

1 files changed, 29 insertions, 0 deletions

diff --git a/weed/server/volume_grpc_read_write.go b/weed/server/volume_grpc_read_write.go
index 9a4b6b072..75b2e38fa 100644
--- a/weed/server/volume_grpc_read_write.go
+++ b/weed/server/volume_grpc_read_write.go
@@ -23,6 +23,35 @@ func (vs *VolumeServer) ReadNeedleBlob(ctx context.Context, req *volume_server_p
 	return resp, nil
 }
 
+func (vs *VolumeServer) ReadNeedleMeta(ctx context.Context, req *volume_server_pb.ReadNeedleMetaRequest) (resp *volume_server_pb.ReadNeedleMetaResponse, err error) {
+	resp = &volume_server_pb.ReadNeedleMetaResponse{}
+	volumeId := needle.VolumeId(req.VolumeId)
+
+	n := &needle.Needle{
+		Id:    types.NeedleId(req.NeedleId),
+		Flags: 0x08,
+	}
+	size := req.Size
+	offset := req.Offset
+
+	hasVolume := vs.store.HasVolume(volumeId)
+	if !hasVolume {
+		return nil, fmt.Errorf("not found volume id %d and read needle metadata at ec shards is not supported", req.VolumeId)
+	}
+	err = vs.store.ReadVolumeNeedleMetaAt(volumeId, n, offset, size)
+	if err != nil {
+		return nil, err
+	}
+
+	resp.Cookie = uint32(n.Cookie)
+	resp.LastModified = n.LastModified
+	resp.Crc = n.Checksum.Value()
+	if n.HasTtl() {
+		resp.Ttl = n.Ttl.String()
+	}
+	return resp, nil
+}
+
 func (vs *VolumeServer) WriteNeedleBlob(ctx context.Context, req *volume_server_pb.WriteNeedleBlobRequest) (resp *volume_server_pb.WriteNeedleBlobResponse, err error) {
 	resp = &volume_server_pb.WriteNeedleBlobResponse{}
 	v := vs.store.GetVolume(needle.VolumeId(req.VolumeId))