read ec volume shards locations from master

5 files changed, 291 insertions, 106 deletions

diff --git a/weed/pb/master.proto b/weed/pb/master.proto
index 6f7db5d96..1cf78276a 100644
--- a/weed/pb/master.proto
+++ b/weed/pb/master.proto
@@ -21,6 +21,8 @@ service Seaweed {
     }
     rpc VolumeList (VolumeListRequest) returns (VolumeListResponse) {
     }
+    rpc LookupEcVolume (LookupEcVolumeRequest) returns (LookupEcVolumeResponse) {
+    }
 }
 
 //////////////////////////////////////////////////
@@ -218,3 +220,15 @@ message VolumeListResponse {
     TopologyInfo topology_info = 1;
     uint64 volume_size_limit_mb = 2;
 }
+
+message LookupEcVolumeRequest {
+    uint32 volume_id = 1;
+}
+message LookupEcVolumeResponse {
+    uint32 volume_id = 1;
+    message EcShardIdLocation {
+        uint32 shard_id = 1;
+        repeated Location locations = 2;
+    }
+    repeated EcShardIdLocation shard_id_locations = 2;
+}
diff --git a/weed/pb/master_pb/master.pb.go b/weed/pb/master_pb/master.pb.go
index 70326384e..db39880bc 100644
--- a/weed/pb/master_pb/master.pb.go
+++ b/weed/pb/master_pb/master.pb.go
@@ -37,6 +37,8 @@ It has these top-level messages:
 	TopologyInfo
 	VolumeListRequest
 	VolumeListResponse
+	LookupEcVolumeRequest
+	LookupEcVolumeResponse
 */
 package master_pb
 
@@ -1158,6 +1160,74 @@ func (m *VolumeListResponse) GetVolumeSizeLimitMb() uint64 {
 	return 0
 }
 
+type LookupEcVolumeRequest struct {
+	VolumeId uint32 `protobuf:"varint,1,opt,name=volume_id,json=volumeId" json:"volume_id,omitempty"`
+}
+
+func (m *LookupEcVolumeRequest) Reset()                    { *m = LookupEcVolumeRequest{} }
+func (m *LookupEcVolumeRequest) String() string            { return proto.CompactTextString(m) }
+func (*LookupEcVolumeRequest) ProtoMessage()               {}
+func (*LookupEcVolumeRequest) Descriptor() ([]byte, []int) { return fileDescriptor0, []int{28} }
+
+func (m *LookupEcVolumeRequest) GetVolumeId() uint32 {
+	if m != nil {
+		return m.VolumeId
+	}
+	return 0
+}
+
+type LookupEcVolumeResponse struct {
+	VolumeId         uint32                                      `protobuf:"varint,1,opt,name=volume_id,json=volumeId" json:"volume_id,omitempty"`
+	ShardIdLocations []*LookupEcVolumeResponse_EcShardIdLocation `protobuf:"bytes,2,rep,name=shard_id_locations,json=shardIdLocations" json:"shard_id_locations,omitempty"`
+}
+
+func (m *LookupEcVolumeResponse) Reset()                    { *m = LookupEcVolumeResponse{} }
+func (m *LookupEcVolumeResponse) String() string            { return proto.CompactTextString(m) }
+func (*LookupEcVolumeResponse) ProtoMessage()               {}
+func (*LookupEcVolumeResponse) Descriptor() ([]byte, []int) { return fileDescriptor0, []int{29} }
+
+func (m *LookupEcVolumeResponse) GetVolumeId() uint32 {
+	if m != nil {
+		return m.VolumeId
+	}
+	return 0
+}
+
+func (m *LookupEcVolumeResponse) GetShardIdLocations() []*LookupEcVolumeResponse_EcShardIdLocation {
+	if m != nil {
+		return m.ShardIdLocations
+	}
+	return nil
+}
+
+type LookupEcVolumeResponse_EcShardIdLocation struct {
+	ShardId   uint32      `protobuf:"varint,1,opt,name=shard_id,json=shardId" json:"shard_id,omitempty"`
+	Locations []*Location `protobuf:"bytes,2,rep,name=locations" json:"locations,omitempty"`
+}
+
+func (m *LookupEcVolumeResponse_EcShardIdLocation) Reset() {
+	*m = LookupEcVolumeResponse_EcShardIdLocation{}
+}
+func (m *LookupEcVolumeResponse_EcShardIdLocation) String() string { return proto.CompactTextString(m) }
+func (*LookupEcVolumeResponse_EcShardIdLocation) ProtoMessage()    {}
+func (*LookupEcVolumeResponse_EcShardIdLocation) Descriptor() ([]byte, []int) {
+	return fileDescriptor0, []int{29, 0}
+}
+
+func (m *LookupEcVolumeResponse_EcShardIdLocation) GetShardId() uint32 {
+	if m != nil {
+		return m.ShardId
+	}
+	return 0
+}
+
+func (m *LookupEcVolumeResponse_EcShardIdLocation) GetLocations() []*Location {
+	if m != nil {
+		return m.Locations
+	}
+	return nil
+}
+
 func init() {
 	proto.RegisterType((*Heartbeat)(nil), "master_pb.Heartbeat")
 	proto.RegisterType((*HeartbeatResponse)(nil), "master_pb.HeartbeatResponse")
@@ -1189,6 +1259,9 @@ func init() {
 	proto.RegisterType((*TopologyInfo)(nil), "master_pb.TopologyInfo")
 	proto.RegisterType((*VolumeListRequest)(nil), "master_pb.VolumeListRequest")
 	proto.RegisterType((*VolumeListResponse)(nil), "master_pb.VolumeListResponse")
+	proto.RegisterType((*LookupEcVolumeRequest)(nil), "master_pb.LookupEcVolumeRequest")
+	proto.RegisterType((*LookupEcVolumeResponse)(nil), "master_pb.LookupEcVolumeResponse")
+	proto.RegisterType((*LookupEcVolumeResponse_EcShardIdLocation)(nil), "master_pb.LookupEcVolumeResponse.EcShardIdLocation")
 }
 
 // Reference imports to suppress errors if they are not otherwise used.
@@ -1210,6 +1283,7 @@ type SeaweedClient interface {
 	CollectionList(ctx context.Context, in *CollectionListRequest, opts ...grpc.CallOption) (*CollectionListResponse, error)
 	CollectionDelete(ctx context.Context, in *CollectionDeleteRequest, opts ...grpc.CallOption) (*CollectionDeleteResponse, error)
 	VolumeList(ctx context.Context, in *VolumeListRequest, opts ...grpc.CallOption) (*VolumeListResponse, error)
+	LookupEcVolume(ctx context.Context, in *LookupEcVolumeRequest, opts ...grpc.CallOption) (*LookupEcVolumeResponse, error)
 }
 
 type seaweedClient struct {
@@ -1336,6 +1410,15 @@ func (c *seaweedClient) VolumeList(ctx context.Context, in *VolumeListRequest, o
 	return out, nil
 }
 
+func (c *seaweedClient) LookupEcVolume(ctx context.Context, in *LookupEcVolumeRequest, opts ...grpc.CallOption) (*LookupEcVolumeResponse, error) {
+	out := new(LookupEcVolumeResponse)
+	err := grpc.Invoke(ctx, "/master_pb.Seaweed/LookupEcVolume", in, out, c.cc, opts...)
+	if err != nil {
+		return nil, err
+	}
+	return out, nil
+}
+
 // Server API for Seaweed service
 
 type SeaweedServer interface {
@@ -1347,6 +1430,7 @@ type SeaweedServer interface {
 	CollectionList(context.Context, *CollectionListRequest) (*CollectionListResponse, error)
 	CollectionDelete(context.Context, *CollectionDeleteRequest) (*CollectionDeleteResponse, error)
 	VolumeList(context.Context, *VolumeListRequest) (*VolumeListResponse, error)
+	LookupEcVolume(context.Context, *LookupEcVolumeRequest) (*LookupEcVolumeResponse, error)
 }
 
 func RegisterSeaweedServer(s *grpc.Server, srv SeaweedServer) {
@@ -1513,6 +1597,24 @@ func _Seaweed_VolumeList_Handler(srv interface{}, ctx context.Context, dec func(
 	return interceptor(ctx, in, info, handler)
 }
 
+func _Seaweed_LookupEcVolume_Handler(srv interface{}, ctx context.Context, dec func(interface{}) error, interceptor grpc.UnaryServerInterceptor) (interface{}, error) {
+	in := new(LookupEcVolumeRequest)
+	if err := dec(in); err != nil {
+		return nil, err
+	}
+	if interceptor == nil {
+		return srv.(SeaweedServer).LookupEcVolume(ctx, in)
+	}
+	info := &grpc.UnaryServerInfo{
+		Server:     srv,
+		FullMethod: "/master_pb.Seaweed/LookupEcVolume",
+	}
+	handler := func(ctx context.Context, req interface{}) (interface{}, error) {
+		return srv.(SeaweedServer).LookupEcVolume(ctx, req.(*LookupEcVolumeRequest))
+	}
+	return interceptor(ctx, in, info, handler)
+}
+
 var _Seaweed_serviceDesc = grpc.ServiceDesc{
 	ServiceName: "master_pb.Seaweed",
 	HandlerType: (*SeaweedServer)(nil),
@@ -1541,6 +1643,10 @@ var _Seaweed_serviceDesc = grpc.ServiceDesc{
 			MethodName: "VolumeList",
 			Handler:    _Seaweed_VolumeList_Handler,
 		},
+		{
+			MethodName: "LookupEcVolume",
+			Handler:    _Seaweed_LookupEcVolume_Handler,
+		},
 	},
 	Streams: []grpc.StreamDesc{
 		{
@@ -1562,105 +1668,110 @@ var _Seaweed_serviceDesc = grpc.ServiceDesc{
 func init() { proto.RegisterFile("master.proto", fileDescriptor0) }
 
 var fileDescriptor0 = []byte{
-	// 1594 bytes of a gzipped FileDescriptorProto
-	0x1f, 0x8b, 0x08, 0x00, 0x00, 0x09, 0x6e, 0x88, 0x02, 0xff, 0xd4, 0x58, 0x4f, 0x6f, 0xdb, 0xc6,
-	0x12, 0x37, 0xf5, 0xcf, 0xd2, 0xe8, 0x8f, 0xa5, 0xb5, 0x93, 0x30, 0xca, 0x4b, 0xa2, 0x30, 0x17,
-	0x25, 0xef, 0x3d, 0xbf, 0x3c, 0xf7, 0xd0, 0x43, 0x5b, 0x04, 0x89, 0xe3, 0xb4, 0x46, 0x9c, 0xc4,
-	0xa1, 0x92, 0x14, 0x28, 0x50, 0xb0, 0x14, 0xb9, 0x76, 0x08, 0x53, 0x24, 0xcb, 0x5d, 0x39, 0x56,
-	0x2e, 0x3d, 0xb4, 0xc7, 0xa2, 0x97, 0x7e, 0x89, 0x7e, 0x88, 0xa2, 0x97, 0x1e, 0xfb, 0x29, 0xfa,
-	0x09, 0x0a, 0xf4, 0x5e, 0xa0, 0xd8, 0x3f, 0x24, 0x97, 0x94, 0x6c, 0xc5, 0x05, 0x72, 0xc8, 0x6d,
-	0x77, 0x66, 0xf6, 0xb7, 0xb3, 0xbf, 0x9d, 0x9d, 0x19, 0x12, 0x5a, 0x13, 0x9b, 0x50, 0x1c, 0x6f,
-	0x46, 0x71, 0x48, 0x43, 0xd4, 0x10, 0x33, 0x2b, 0x1a, 0x1b, 0x3f, 0x57, 0xa1, 0xf1, 0x19, 0xb6,
-	0x63, 0x3a, 0xc6, 0x36, 0x45, 0x1d, 0x28, 0x79, 0x91, 0xae, 0x0d, 0xb4, 0x61, 0xc3, 0x2c, 0x79,
-	0x11, 0x42, 0x50, 0x89, 0xc2, 0x98, 0xea, 0xa5, 0x81, 0x36, 0x6c, 0x9b, 0x7c, 0x8c, 0xae, 0x02,
-	0x44, 0xd3, 0xb1, 0xef, 0x39, 0xd6, 0x34, 0xf6, 0xf5, 0x32, 0xb7, 0x6d, 0x08, 0xc9, 0x8b, 0xd8,
-	0x47, 0x43, 0xe8, 0x4e, 0xec, 0x13, 0xeb, 0x38, 0xf4, 0xa7, 0x13, 0x6c, 0x39, 0xe1, 0x34, 0xa0,
-	0x7a, 0x85, 0x2f, 0xef, 0x4c, 0xec, 0x93, 0x97, 0x5c, 0xbc, 0xcd, 0xa4, 0x68, 0xc0, 0xbc, 0x3a,
-	0xb1, 0x0e, 0x3c, 0x1f, 0x5b, 0x47, 0x78, 0xa6, 0x57, 0x07, 0xda, 0xb0, 0x62, 0xc2, 0xc4, 0x3e,
-	0x79, 0xe8, 0xf9, 0xf8, 0x11, 0x9e, 0xa1, 0xeb, 0xd0, 0x74, 0x6d, 0x6a, 0x5b, 0x0e, 0x0e, 0x28,
-	0x8e, 0xf5, 0x1a, 0xdf, 0x0b, 0x98, 0x68, 0x9b, 0x4b, 0x98, 0x7f, 0xb1, 0xed, 0x1c, 0xe9, 0xab,
-	0x5c, 0xc3, 0xc7, 0xcc, 0x3f, 0xdb, 0x9d, 0x78, 0x81, 0xc5, 0x3d, 0xaf, 0xf3, 0xad, 0x1b, 0x5c,
-	0xb2, 0xcf, 0xdc, 0xff, 0x04, 0x56, 0x85, 0x6f, 0x44, 0x6f, 0x0c, 0xca, 0xc3, 0xe6, 0xd6, 0xcd,
-	0xcd, 0x94, 0x8d, 0x4d, 0xe1, 0xde, 0x6e, 0x70, 0x10, 0xc6, 0x13, 0x9b, 0x7a, 0x61, 0xf0, 0x18,
-	0x13, 0x62, 0x1f, 0x62, 0x33, 0x59, 0x83, 0x76, 0xa1, 0x19, 0xe0, 0xd7, 0x56, 0x02, 0x01, 0x1c,
-	0x62, 0x38, 0x07, 0x31, 0x7a, 0x15, 0xc6, 0x74, 0x01, 0x0e, 0x04, 0xf8, 0xf5, 0x4b, 0x09, 0xf5,
-	0x0c, 0xd6, 0x5c, 0xec, 0x63, 0x8a, 0xdd, 0x14, 0xae, 0x79, 0x4e, 0xb8, 0x8e, 0x04, 0x48, 0x20,
-	0x3f, 0x85, 0x06, 0x76, 0x2c, 0xf2, 0xca, 0x8e, 0x5d, 0xa2, 0x77, 0x39, 0xd8, 0xed, 0x39, 0xb0,
-	0x1d, 0x67, 0xc4, 0x0c, 0x16, 0xc0, 0xd5, 0xb1, 0x50, 0x11, 0xf4, 0x04, 0xda, 0xec, 0x98, 0x19,
-	0x58, 0xef, 0xdc, 0x60, 0x8c, 0xa7, 0x9d, 0x04, 0xef, 0x25, 0xf4, 0x92, 0xb3, 0x66, 0x98, 0xe8,
-	0xdc, 0x98, 0x09, 0x61, 0x09, 0xae, 0xf1, 0x02, 0x7a, 0x69, 0xf4, 0x9a, 0x98, 0x44, 0x61, 0x40,
-	0x30, 0x1a, 0xc2, 0x9a, 0x20, 0x74, 0xe4, 0xbd, 0xc1, 0x7b, 0xde, 0xc4, 0xa3, 0x3c, 0xa4, 0x2b,
-	0x66, 0x51, 0x8c, 0x2e, 0x42, 0xcd, 0xc7, 0xb6, 0x8b, 0x63, 0x19, 0xc7, 0x72, 0x66, 0xfc, 0x51,
-	0x02, 0xfd, 0xb4, 0x58, 0xe0, 0x8f, 0xc4, 0xe5, 0x88, 0x6d, 0xb3, 0xe4, 0xb9, 0x2c, 0x08, 0x89,
-	0xf7, 0x06, 0xf3, 0x47, 0x52, 0x31, 0xf9, 0x18, 0x5d, 0x03, 0x70, 0x42, 0xdf, 0xc7, 0x0e, 0x5b,
-	0x28, 0xc1, 0x15, 0x09, 0x0b, 0x52, 0x1e, 0xf7, 0xd9, 0xfb, 0xa8, 0x98, 0x0d, 0x26, 0x11, 0x4f,
-	0xe3, 0x06, 0xb4, 0xc4, 0x49, 0xa5, 0x81, 0x78, 0x1a, 0x4d, 0x21, 0x13, 0x26, 0xff, 0x01, 0x94,
-	0x30, 0x3a, 0x9e, 0xa5, 0x86, 0x35, 0x6e, 0xd8, 0x95, 0x9a, 0xfb, 0xb3, 0xc4, 0xfa, 0x0a, 0x34,
-	0x62, 0x6c, 0xbb, 0x56, 0x18, 0xf8, 0x33, 0xfe, 0x5a, 0xea, 0x66, 0x9d, 0x09, 0x9e, 0x06, 0xfe,
-	0x0c, 0xfd, 0x1b, 0x7a, 0x31, 0x8e, 0x7c, 0xcf, 0xb1, 0xad, 0xc8, 0xb7, 0x1d, 0x3c, 0xc1, 0x41,
-	0xf2, 0x70, 0xba, 0x52, 0xb1, 0x9f, 0xc8, 0x91, 0x0e, 0xab, 0xc7, 0x38, 0x26, 0xec, 0x58, 0x0d,
-	0x6e, 0x92, 0x4c, 0x51, 0x17, 0xca, 0x94, 0xfa, 0x3a, 0x70, 0x29, 0x1b, 0xa2, 0x5b, 0xd0, 0x75,
-	0xc2, 0x49, 0x64, 0x3b, 0xd4, 0x8a, 0xf1, 0xb1, 0xc7, 0x17, 0x35, 0xb9, 0x7a, 0x4d, 0xca, 0x4d,
-	0x29, 0x36, 0x7e, 0xd2, 0xe0, 0xea, 0x99, 0xb1, 0x3e, 0x47, 0xfb, 0x32, 0x8a, 0xdf, 0xd5, 0xa9,
-	0x8c, 0x29, 0x5c, 0x5f, 0x12, 0xa7, 0x4b, 0x7c, 0x2d, 0xcd, 0xf9, 0x6a, 0x40, 0x1b, 0x3b, 0x96,
-	0x17, 0xb8, 0xf8, 0xc4, 0x1a, 0x7b, 0x94, 0xf0, 0xe3, 0xb4, 0xcd, 0x26, 0x76, 0x76, 0x99, 0xec,
-	0xbe, 0x47, 0x89, 0xb1, 0x0a, 0xd5, 0x9d, 0x49, 0x44, 0x67, 0xc6, 0x2f, 0x1a, 0xac, 0x8d, 0xa6,
-	0x11, 0x8e, 0xef, 0xfb, 0xa1, 0x73, 0xb4, 0x73, 0x42, 0x63, 0x1b, 0x3d, 0x85, 0x0e, 0x8e, 0x6d,
-	0x32, 0x8d, 0x59, 0x20, 0xb8, 0x5e, 0x70, 0xc8, 0x37, 0xcf, 0xa7, 0x92, 0xc2, 0x9a, 0xcd, 0x1d,
-	0xb1, 0x60, 0x9b, 0xdb, 0x9b, 0x6d, 0xac, 0x4e, 0xfb, 0x5f, 0x40, 0x3b, 0xa7, 0x67, 0x51, 0xce,
-	0x12, 0xaf, 0x3c, 0x14, 0x1f, 0xb3, 0xe7, 0x13, 0xd9, 0xb1, 0x47, 0x67, 0xb2, 0x40, 0xc8, 0x19,
-	0x8b, 0x6e, 0x99, 0xff, 0x3d, 0x97, 0x9d, 0xa5, 0xcc, 0x52, 0xb0, 0x90, 0xec, 0xba, 0xc4, 0xb8,
-	0x05, 0xeb, 0xdb, 0xbe, 0x87, 0x03, 0xba, 0xe7, 0x11, 0x8a, 0x03, 0x13, 0x7f, 0x3d, 0xc5, 0x84,
-	0xb2, 0x1d, 0x02, 0x7b, 0x82, 0x65, 0xf9, 0xe1, 0x63, 0xe3, 0x1b, 0xe8, 0x08, 0xae, 0xf7, 0x42,
-	0x87, 0x33, 0xcc, 0xee, 0x83, 0xd5, 0x1d, 0x61, 0xc4, 0x86, 0x85, 0x82, 0x54, 0x2a, 0x16, 0xa4,
-	0xcb, 0x50, 0xe7, 0x19, 0x3b, 0x73, 0x65, 0x95, 0x25, 0x61, 0xcf, 0x25, 0xd9, 0x33, 0x73, 0x85,
-	0xba, 0xc2, 0xd5, 0xcd, 0x24, 0xa9, 0x7a, 0x2e, 0x31, 0x9e, 0xc3, 0xfa, 0x5e, 0x18, 0x1e, 0x4d,
-	0x23, 0xe1, 0x46, 0xe2, 0x6b, 0xfe, 0x84, 0xda, 0xa0, 0xcc, 0xf6, 0x4c, 0x4f, 0xb8, 0xec, 0xbe,
-	0x8d, 0x3f, 0x35, 0xd8, 0xc8, 0xc3, 0xca, 0xd4, 0xf5, 0x15, 0xac, 0xa7, 0xb8, 0x96, 0x2f, 0xcf,
-	0x2c, 0x36, 0x68, 0x6e, 0xdd, 0x51, 0x2e, 0x73, 0xd1, 0xea, 0xa4, 0x7c, 0xb9, 0x09, 0x59, 0x66,
-	0xef, 0xb8, 0x20, 0x21, 0xfd, 0x13, 0xe8, 0x16, 0xcd, 0x58, 0x76, 0x48, 0x77, 0x95, 0xcc, 0xd6,
-	0x93, 0x95, 0xe8, 0xff, 0xd0, 0xc8, 0x1c, 0x29, 0x71, 0x47, 0xd6, 0x73, 0x8e, 0xc8, 0xbd, 0x32,
-	0x2b, 0xb4, 0x01, 0x55, 0x1c, 0xc7, 0x61, 0x92, 0x55, 0xc5, 0xc4, 0xf8, 0x08, 0xea, 0xff, 0xf8,
-	0x16, 0x8d, 0xdf, 0x34, 0x68, 0xdf, 0x23, 0xc4, 0x3b, 0x4c, 0xc3, 0x65, 0x03, 0xaa, 0x22, 0xe7,
-	0x89, 0xdc, 0x2e, 0x26, 0x68, 0x00, 0x4d, 0xf9, 0xb8, 0x15, 0xea, 0x55, 0xd1, 0xd2, 0xbc, 0x21,
-	0x1f, 0x7c, 0x45, 0xb8, 0xc6, 0xd2, 0x58, 0xa1, 0x0d, 0xa9, 0x9e, 0xda, 0x86, 0xd4, 0x94, 0x36,
-	0xe4, 0x0a, 0x34, 0xf8, 0xa2, 0x20, 0x74, 0xb1, 0xec, 0x4f, 0xea, 0x4c, 0xf0, 0x24, 0x74, 0xb1,
-	0xf1, 0xa3, 0x06, 0x9d, 0xe4, 0x34, 0xf2, 0xe6, 0xbb, 0x50, 0x3e, 0x48, 0xd9, 0x67, 0xc3, 0x84,
-	0xa3, 0xd2, 0x69, 0x1c, 0xcd, 0xb5, 0x5e, 0x29, 0x23, 0x15, 0x95, 0x91, 0xf4, 0x32, 0xaa, 0xca,
-	0x65, 0x30, 0x97, 0xed, 0x29, 0x7d, 0x95, 0xb8, 0xcc, 0xc6, 0xc6, 0x21, 0xf4, 0x46, 0xd4, 0xa6,
-	0x1e, 0xa1, 0x9e, 0x43, 0x12, 0x9a, 0x0b, 0x84, 0x6a, 0xcb, 0x08, 0x2d, 0x9d, 0x46, 0x68, 0x39,
-	0x25, 0xd4, 0xf8, 0x55, 0x03, 0xa4, 0xee, 0x24, 0x29, 0x78, 0x07, 0x5b, 0x31, 0xca, 0x68, 0x48,
-	0x6d, 0xdf, 0xe2, 0x25, 0x5a, 0x16, 0x5a, 0x2e, 0x61, 0x5d, 0x00, 0xbb, 0xa5, 0x29, 0xc1, 0xae,
-	0xd0, 0x8a, 0x2a, 0x5b, 0x67, 0x02, 0xae, 0xcc, 0x17, 0xe9, 0x5a, 0xa1, 0x48, 0x1b, 0xf7, 0xa0,
-	0x39, 0xa2, 0x61, 0x6c, 0x1f, 0xe2, 0xe7, 0xb3, 0xe8, 0x6d, 0xbc, 0x97, 0xde, 0x95, 0x32, 0x22,
-	0x06, 0x00, 0xdb, 0x99, 0xf7, 0x8b, 0x12, 0xe0, 0x25, 0xb8, 0x90, 0x59, 0xb0, 0x7c, 0x29, 0xef,
-	0xc5, 0x78, 0x06, 0x17, 0x8b, 0x0a, 0x49, 0xe3, 0x87, 0xd0, 0xcc, 0x28, 0x49, 0x72, 0xc7, 0x05,
-	0xe5, 0xc9, 0x66, 0xeb, 0x4c, 0xd5, 0xd2, 0xf8, 0x2f, 0x5c, 0xca, 0x54, 0x0f, 0x78, 0x12, 0x3c,
-	0x2b, 0x37, 0xf7, 0x41, 0x9f, 0x37, 0x17, 0x3e, 0x18, 0xbf, 0x97, 0xa0, 0xf5, 0x40, 0x46, 0x3b,
-	0xab, 0x8f, 0x4a, 0x45, 0x6c, 0xf0, 0x8a, 0x78, 0x03, 0x5a, 0xb9, 0x4f, 0x04, 0xd1, 0x3c, 0x35,
-	0x8f, 0x95, 0xef, 0x83, 0x45, 0x5f, 0x12, 0x65, 0x6e, 0x56, 0xfc, 0x92, 0xb8, 0x0d, 0xbd, 0x83,
-	0x18, 0xe3, 0xf9, 0x8f, 0x8e, 0x8a, 0xb9, 0xc6, 0x14, 0xaa, 0xed, 0x26, 0xac, 0xdb, 0x0e, 0xf5,
-	0x8e, 0x0b, 0xd6, 0xe2, 0xee, 0x7b, 0x42, 0xa5, 0xda, 0x3f, 0x4c, 0x1d, 0xf5, 0x82, 0x83, 0x90,
-	0xe8, 0xb5, 0xb7, 0xff, 0x68, 0x90, 0xa7, 0x61, 0x1a, 0x82, 0xf6, 0xa1, 0x93, 0x74, 0xbe, 0x12,
-	0x69, 0xf5, 0xdc, 0xed, 0x6f, 0x0b, 0x67, 0x2a, 0x62, 0x7c, 0x57, 0x82, 0xba, 0x69, 0x3b, 0x47,
-	0xef, 0x37, 0xbf, 0x77, 0x61, 0x2d, 0xcd, 0x93, 0x39, 0x8a, 0x2f, 0x29, 0xc4, 0xa8, 0xa1, 0x64,
-	0xb6, 0x5d, 0x65, 0x46, 0x8c, 0xbf, 0x34, 0xe8, 0x3c, 0x48, 0x73, 0xf1, 0xfb, 0x4d, 0xc6, 0x16,
-	0x00, 0x2b, 0x1e, 0x39, 0x1e, 0xd4, 0x62, 0x9b, 0x5c, 0xb7, 0xd9, 0x88, 0xe5, 0x88, 0x18, 0x3f,
-	0x94, 0xa0, 0xf5, 0x3c, 0x8c, 0x42, 0x3f, 0x3c, 0x9c, 0xbd, 0xdf, 0xa7, 0xdf, 0x81, 0x9e, 0x52,
-	0x67, 0x73, 0x24, 0x5c, 0x2e, 0x04, 0x43, 0x76, 0xd9, 0xe6, 0x9a, 0x9b, 0x9b, 0x13, 0x63, 0x1d,
-	0x7a, 0xb2, 0x67, 0x54, 0xd2, 0xe5, 0xb7, 0x1a, 0x20, 0x55, 0x2a, 0x73, 0xe5, 0xc7, 0xd0, 0xa6,
-	0x92, 0x3b, 0xbe, 0x9f, 0x6c, 0x9b, 0xd5, 0xd8, 0x53, 0xb9, 0x35, 0x5b, 0x54, 0x65, 0xfa, 0x7f,
-	0xb0, 0x21, 0x4f, 0xc6, 0xea, 0x87, 0xe5, 0xb3, 0x6f, 0x4a, 0x6b, 0x32, 0x96, 0x0c, 0xf7, 0x0a,
-	0x5f, 0x9b, 0x8f, 0xc7, 0x5b, 0xdf, 0x57, 0x61, 0x75, 0x84, 0xed, 0xd7, 0x18, 0xbb, 0x68, 0x17,
-	0xda, 0x23, 0x1c, 0xb8, 0xd9, 0xcf, 0x97, 0x0d, 0x65, 0xd3, 0x54, 0xda, 0xff, 0xd7, 0x22, 0x69,
-	0x9a, 0x67, 0x57, 0x86, 0xda, 0x1d, 0x0d, 0xed, 0x43, 0xfb, 0x11, 0xc6, 0xd1, 0x76, 0x18, 0x04,
-	0xd8, 0xa1, 0xd8, 0x45, 0xd7, 0xd4, 0x6c, 0x3f, 0xdf, 0x6a, 0xf7, 0x2f, 0xcf, 0x25, 0x9d, 0xa4,
-	0x33, 0x93, 0x88, 0xcf, 0xa0, 0xa5, 0x76, 0x98, 0x39, 0xc0, 0x05, 0xfd, 0x70, 0xff, 0xfa, 0x92,
-	0xd6, 0xd4, 0x58, 0x41, 0x77, 0xa1, 0x26, 0x5a, 0x1e, 0xa4, 0x2b, 0xc6, 0xb9, 0x9e, 0x2e, 0xe7,
-	0x57, 0xbe, 0x3f, 0x32, 0x56, 0xd0, 0x23, 0x80, 0xac, 0x69, 0x40, 0x2a, 0x2f, 0x73, 0x5d, 0x4b,
-	0xff, 0xea, 0x29, 0xda, 0x14, 0xec, 0x73, 0xe8, 0xe4, 0xcb, 0x27, 0x1a, 0x2c, 0xac, 0x90, 0x4a,
-	0x0c, 0xf5, 0x6f, 0x9c, 0x61, 0x91, 0x02, 0x7f, 0x09, 0xdd, 0x62, 0x55, 0x44, 0xc6, 0xc2, 0x85,
-	0xb9, 0x0a, 0xdb, 0xbf, 0x79, 0xa6, 0x8d, 0x4a, 0x42, 0x16, 0xc6, 0x39, 0x12, 0xe6, 0x62, 0x3e,
-	0x47, 0xc2, 0x7c, 0xec, 0x1b, 0x2b, 0xe3, 0x1a, 0xff, 0x1d, 0xf8, 0xc1, 0xdf, 0x01, 0x00, 0x00,
-	0xff, 0xff, 0xf2, 0x26, 0x88, 0x39, 0x1e, 0x14, 0x00, 0x00,
+	// 1677 bytes of a gzipped FileDescriptorProto
+	0x1f, 0x8b, 0x08, 0x00, 0x00, 0x09, 0x6e, 0x88, 0x02, 0xff, 0xd4, 0x58, 0x4b, 0x6f, 0xdb, 0xca,
+	0x15, 0x36, 0xf5, 0xd6, 0xd1, 0xc3, 0xd2, 0xd8, 0x49, 0x14, 0xa5, 0x49, 0x14, 0x66, 0xa3, 0xa4,
+	0xad, 0x9b, 0x3a, 0x05, 0xba, 0x68, 0x8b, 0x20, 0x71, 0x9c, 0xd6, 0x88, 0x93, 0x38, 0x54, 0x92,
+	0x02, 0x05, 0x0a, 0x76, 0x44, 0x8e, 0x1d, 0xc2, 0x14, 0xc9, 0x72, 0x46, 0x8e, 0x95, 0x4d, 0x17,
+	0xed, 0xba, 0x9b, 0xfe, 0x89, 0xfe, 0x88, 0xa2, 0x9b, 0x2e, 0xfb, 0x2b, 0xba, 0xe8, 0xfa, 0x02,
+	0x77, 0x7b, 0x71, 0x81, 0x8b, 0x79, 0x90, 0x1c, 0x52, 0xb2, 0x1d, 0x07, 0xc8, 0x22, 0xbb, 0xe1,
+	0x99, 0x33, 0x67, 0xce, 0x7c, 0x73, 0x1e, 0xdf, 0x10, 0xda, 0x33, 0x4c, 0x19, 0x89, 0xb7, 0xa2,
+	0x38, 0x64, 0x21, 0x6a, 0xca, 0x2f, 0x3b, 0x9a, 0x9a, 0xff, 0xaa, 0x42, 0xf3, 0x77, 0x04, 0xc7,
+	0x6c, 0x4a, 0x30, 0x43, 0x5d, 0x28, 0x79, 0xd1, 0xc0, 0x18, 0x19, 0xe3, 0xa6, 0x55, 0xf2, 0x22,
+	0x84, 0xa0, 0x12, 0x85, 0x31, 0x1b, 0x94, 0x46, 0xc6, 0xb8, 0x63, 0x89, 0x31, 0xba, 0x09, 0x10,
+	0xcd, 0xa7, 0xbe, 0xe7, 0xd8, 0xf3, 0xd8, 0x1f, 0x94, 0x85, 0x6e, 0x53, 0x4a, 0xde, 0xc6, 0x3e,
+	0x1a, 0x43, 0x6f, 0x86, 0x4f, 0xed, 0x93, 0xd0, 0x9f, 0xcf, 0x88, 0xed, 0x84, 0xf3, 0x80, 0x0d,
+	0x2a, 0x62, 0x79, 0x77, 0x86, 0x4f, 0xdf, 0x09, 0xf1, 0x0e, 0x97, 0xa2, 0x11, 0xf7, 0xea, 0xd4,
+	0x3e, 0xf4, 0x7c, 0x62, 0x1f, 0x93, 0xc5, 0xa0, 0x3a, 0x32, 0xc6, 0x15, 0x0b, 0x66, 0xf8, 0xf4,
+	0x99, 0xe7, 0x93, 0xe7, 0x64, 0x81, 0x6e, 0x43, 0xcb, 0xc5, 0x0c, 0xdb, 0x0e, 0x09, 0x18, 0x89,
+	0x07, 0x35, 0xb1, 0x17, 0x70, 0xd1, 0x8e, 0x90, 0x70, 0xff, 0x62, 0xec, 0x1c, 0x0f, 0xea, 0x62,
+	0x46, 0x8c, 0xb9, 0x7f, 0xd8, 0x9d, 0x79, 0x81, 0x2d, 0x3c, 0x6f, 0x88, 0xad, 0x9b, 0x42, 0x72,
+	0xc0, 0xdd, 0xff, 0x0d, 0xd4, 0xa5, 0x6f, 0x74, 0xd0, 0x1c, 0x95, 0xc7, 0xad, 0xed, 0xbb, 0x5b,
+	0x29, 0x1a, 0x5b, 0xd2, 0xbd, 0xbd, 0xe0, 0x30, 0x8c, 0x67, 0x98, 0x79, 0x61, 0xf0, 0x82, 0x50,
+	0x8a, 0x8f, 0x88, 0x95, 0xac, 0x41, 0x7b, 0xd0, 0x0a, 0xc8, 0x07, 0x3b, 0x31, 0x01, 0xc2, 0xc4,
+	0x78, 0xc9, 0xc4, 0xe4, 0x7d, 0x18, 0xb3, 0x15, 0x76, 0x20, 0x20, 0x1f, 0xde, 0x29, 0x53, 0xaf,
+	0x61, 0xdd, 0x25, 0x3e, 0x61, 0xc4, 0x4d, 0xcd, 0xb5, 0x2e, 0x69, 0xae, 0xab, 0x0c, 0x24, 0x26,
+	0x7f, 0x0b, 0x4d, 0xe2, 0xd8, 0xf4, 0x3d, 0x8e, 0x5d, 0x3a, 0xe8, 0x09, 0x63, 0xf7, 0x97, 0x8c,
+	0xed, 0x3a, 0x13, 0xae, 0xb0, 0xc2, 0x5c, 0x83, 0xc8, 0x29, 0x8a, 0x5e, 0x42, 0x87, 0x1f, 0x33,
+	0x33, 0xd6, 0xbf, 0xb4, 0x31, 0x8e, 0xd3, 0x6e, 0x62, 0xef, 0x1d, 0xf4, 0x93, 0xb3, 0x66, 0x36,
+	0xd1, 0xa5, 0x6d, 0x26, 0x80, 0x25, 0x76, 0xcd, 0xb7, 0xd0, 0x4f, 0xa3, 0xd7, 0x22, 0x34, 0x0a,
+	0x03, 0x4a, 0xd0, 0x18, 0xd6, 0x25, 0xa0, 0x13, 0xef, 0x23, 0xd9, 0xf7, 0x66, 0x1e, 0x13, 0x21,
+	0x5d, 0xb1, 0x8a, 0x62, 0x74, 0x15, 0x6a, 0x3e, 0xc1, 0x2e, 0x89, 0x55, 0x1c, 0xab, 0x2f, 0xf3,
+	0x9b, 0x12, 0x0c, 0xce, 0x8a, 0x05, 0x91, 0x24, 0xae, 0xb0, 0xd8, 0xb1, 0x4a, 0x9e, 0xcb, 0x83,
+	0x90, 0x7a, 0x1f, 0x89, 0x48, 0x92, 0x8a, 0x25, 0xc6, 0xe8, 0x16, 0x80, 0x13, 0xfa, 0x3e, 0x71,
+	0xf8, 0x42, 0x65, 0x5c, 0x93, 0xf0, 0x20, 0x15, 0x71, 0x9f, 0xe5, 0x47, 0xc5, 0x6a, 0x72, 0x89,
+	0x4c, 0x8d, 0x3b, 0xd0, 0x96, 0x27, 0x55, 0x0a, 0x32, 0x35, 0x5a, 0x52, 0x26, 0x55, 0x7e, 0x02,
+	0x28, 0x41, 0x74, 0xba, 0x48, 0x15, 0x6b, 0x42, 0xb1, 0xa7, 0x66, 0x9e, 0x2c, 0x12, 0xed, 0x1b,
+	0xd0, 0x8c, 0x09, 0x76, 0xed, 0x30, 0xf0, 0x17, 0x22, 0x5b, 0x1a, 0x56, 0x83, 0x0b, 0x5e, 0x05,
+	0xfe, 0x02, 0xfd, 0x18, 0xfa, 0x31, 0x89, 0x7c, 0xcf, 0xc1, 0x76, 0xe4, 0x63, 0x87, 0xcc, 0x48,
+	0x90, 0x24, 0x4e, 0x4f, 0x4d, 0x1c, 0x24, 0x72, 0x34, 0x80, 0xfa, 0x09, 0x89, 0x29, 0x3f, 0x56,
+	0x53, 0xa8, 0x24, 0x9f, 0xa8, 0x07, 0x65, 0xc6, 0xfc, 0x01, 0x08, 0x29, 0x1f, 0xa2, 0x7b, 0xd0,
+	0x73, 0xc2, 0x59, 0x84, 0x1d, 0x66, 0xc7, 0xe4, 0xc4, 0x13, 0x8b, 0x5a, 0x62, 0x7a, 0x5d, 0xc9,
+	0x2d, 0x25, 0x36, 0xff, 0x69, 0xc0, 0xcd, 0x73, 0x63, 0x7d, 0x09, 0xf6, 0x8b, 0x20, 0xfe, 0x52,
+	0xa7, 0x32, 0xe7, 0x70, 0xfb, 0x82, 0x38, 0xbd, 0xc0, 0xd7, 0xd2, 0x92, 0xaf, 0x26, 0x74, 0x88,
+	0x63, 0x7b, 0x81, 0x4b, 0x4e, 0xed, 0xa9, 0xc7, 0xa8, 0x38, 0x4e, 0xc7, 0x6a, 0x11, 0x67, 0x8f,
+	0xcb, 0x9e, 0x78, 0x8c, 0x9a, 0x75, 0xa8, 0xee, 0xce, 0x22, 0xb6, 0x30, 0xff, 0x6d, 0xc0, 0xfa,
+	0x64, 0x1e, 0x91, 0xf8, 0x89, 0x1f, 0x3a, 0xc7, 0xbb, 0xa7, 0x2c, 0xc6, 0xe8, 0x15, 0x74, 0x49,
+	0x8c, 0xe9, 0x3c, 0xe6, 0x81, 0xe0, 0x7a, 0xc1, 0x91, 0xd8, 0x3c, 0x5f, 0x4a, 0x0a, 0x6b, 0xb6,
+	0x76, 0xe5, 0x82, 0x1d, 0xa1, 0x6f, 0x75, 0x88, 0xfe, 0x39, 0xfc, 0x03, 0x74, 0x72, 0xf3, 0x3c,
+	0xca, 0x79, 0xe1, 0x55, 0x87, 0x12, 0x63, 0x9e, 0x3e, 0x11, 0x8e, 0x3d, 0xb6, 0x50, 0x0d, 0x42,
+	0x7d, 0xf1, 0xe8, 0x56, 0xf5, 0xdf, 0x73, 0xf9, 0x59, 0xca, 0xbc, 0x04, 0x4b, 0xc9, 0x9e, 0x4b,
+	0xcd, 0x7b, 0xb0, 0xb1, 0xe3, 0x7b, 0x24, 0x60, 0xfb, 0x1e, 0x65, 0x24, 0xb0, 0xc8, 0x9f, 0xe7,
+	0x84, 0x32, 0xbe, 0x43, 0x80, 0x67, 0x44, 0xb5, 0x1f, 0x31, 0x36, 0xff, 0x02, 0x5d, 0x89, 0xf5,
+	0x7e, 0xe8, 0x08, 0x84, 0xf9, 0x7d, 0xf0, 0xbe, 0x23, 0x95, 0xf8, 0xb0, 0xd0, 0x90, 0x4a, 0xc5,
+	0x86, 0x74, 0x1d, 0x1a, 0xa2, 0x62, 0x67, 0xae, 0xd4, 0x79, 0x11, 0xf6, 0x5c, 0x9a, 0xa5, 0x99,
+	0x2b, 0xa7, 0x2b, 0x62, 0xba, 0x95, 0x14, 0x55, 0xcf, 0xa5, 0xe6, 0x1b, 0xd8, 0xd8, 0x0f, 0xc3,
+	0xe3, 0x79, 0x24, 0xdd, 0x48, 0x7c, 0xcd, 0x9f, 0xd0, 0x18, 0x95, 0xf9, 0x9e, 0xe9, 0x09, 0x2f,
+	0xba, 0x6f, 0xf3, 0x5b, 0x03, 0x36, 0xf3, 0x66, 0x55, 0xe9, 0xfa, 0x13, 0x6c, 0xa4, 0x76, 0x6d,
+	0x5f, 0x9d, 0x59, 0x6e, 0xd0, 0xda, 0x7e, 0xa0, 0x5d, 0xe6, 0xaa, 0xd5, 0x49, 0xfb, 0x72, 0x13,
+	0xb0, 0xac, 0xfe, 0x49, 0x41, 0x42, 0x87, 0xa7, 0xd0, 0x2b, 0xaa, 0xf1, 0xea, 0x90, 0xee, 0xaa,
+	0x90, 0x6d, 0x24, 0x2b, 0xd1, 0xcf, 0xa1, 0x99, 0x39, 0x52, 0x12, 0x8e, 0x6c, 0xe4, 0x1c, 0x51,
+	0x7b, 0x65, 0x5a, 0x68, 0x13, 0xaa, 0x24, 0x8e, 0xc3, 0xa4, 0xaa, 0xca, 0x0f, 0xf3, 0x57, 0xd0,
+	0xf8, 0xec, 0x5b, 0x34, 0xff, 0x6b, 0x40, 0xe7, 0x31, 0xa5, 0xde, 0x51, 0x1a, 0x2e, 0x9b, 0x50,
+	0x95, 0x35, 0x4f, 0xd6, 0x76, 0xf9, 0x81, 0x46, 0xd0, 0x52, 0xc9, 0xad, 0x41, 0xaf, 0x8b, 0x2e,
+	0xac, 0x1b, 0x2a, 0xe1, 0x2b, 0xd2, 0x35, 0x5e, 0xc6, 0x0a, 0x34, 0xa4, 0x7a, 0x26, 0x0d, 0xa9,
+	0x69, 0x34, 0xe4, 0x06, 0x34, 0xc5, 0xa2, 0x20, 0x74, 0x89, 0xe2, 0x27, 0x0d, 0x2e, 0x78, 0x19,
+	0xba, 0xc4, 0xfc, 0x87, 0x01, 0xdd, 0xe4, 0x34, 0xea, 0xe6, 0x7b, 0x50, 0x3e, 0x4c, 0xd1, 0xe7,
+	0xc3, 0x04, 0xa3, 0xd2, 0x59, 0x18, 0x2d, 0x51, 0xaf, 0x14, 0x91, 0x8a, 0x8e, 0x48, 0x7a, 0x19,
+	0x55, 0xed, 0x32, 0xb8, 0xcb, 0x78, 0xce, 0xde, 0x27, 0x2e, 0xf3, 0xb1, 0x79, 0x04, 0xfd, 0x09,
+	0xc3, 0xcc, 0xa3, 0xcc, 0x73, 0x68, 0x02, 0x73, 0x01, 0x50, 0xe3, 0x22, 0x40, 0x4b, 0x67, 0x01,
+	0x5a, 0x4e, 0x01, 0x35, 0xff, 0x63, 0x00, 0xd2, 0x77, 0x52, 0x10, 0x7c, 0x81, 0xad, 0x38, 0x64,
+	0x2c, 0x64, 0xd8, 0xb7, 0x45, 0x8b, 0x56, 0x8d, 0x56, 0x48, 0x38, 0x0b, 0xe0, 0xb7, 0x34, 0xa7,
+	0xc4, 0x95, 0xb3, 0xb2, 0xcb, 0x36, 0xb8, 0x40, 0x4c, 0xe6, 0x9b, 0x74, 0xad, 0xd0, 0xa4, 0xcd,
+	0xc7, 0xd0, 0x9a, 0xb0, 0x30, 0xc6, 0x47, 0xe4, 0xcd, 0x22, 0xfa, 0x14, 0xef, 0x95, 0x77, 0xa5,
+	0x0c, 0x88, 0x11, 0xc0, 0x4e, 0xe6, 0xfd, 0xaa, 0x02, 0x78, 0x0d, 0xae, 0x64, 0x1a, 0xbc, 0x5e,
+	0xaa, 0x7b, 0x31, 0x5f, 0xc3, 0xd5, 0xe2, 0x84, 0x82, 0xf1, 0x97, 0xd0, 0xca, 0x20, 0x49, 0x6a,
+	0xc7, 0x15, 0x2d, 0x65, 0xb3, 0x75, 0x96, 0xae, 0x69, 0xfe, 0x14, 0xae, 0x65, 0x53, 0x4f, 0x45,
+	0x11, 0x3c, 0xaf, 0x36, 0x0f, 0x61, 0xb0, 0xac, 0x2e, 0x7d, 0x30, 0xff, 0x57, 0x82, 0xf6, 0x53,
+	0x15, 0xed, 0xbc, 0x3f, 0x6a, 0x1d, 0xb1, 0x29, 0x3a, 0xe2, 0x1d, 0x68, 0xe7, 0x9e, 0x08, 0x92,
+	0x3c, 0xb5, 0x4e, 0xb4, 0xf7, 0xc1, 0xaa, 0x97, 0x44, 0x59, 0xa8, 0x15, 0x5f, 0x12, 0xf7, 0xa1,
+	0x7f, 0x18, 0x13, 0xb2, 0xfc, 0xe8, 0xa8, 0x58, 0xeb, 0x7c, 0x42, 0xd7, 0xdd, 0x82, 0x0d, 0xec,
+	0x30, 0xef, 0xa4, 0xa0, 0x2d, 0xef, 0xbe, 0x2f, 0xa7, 0x74, 0xfd, 0x67, 0xa9, 0xa3, 0x5e, 0x70,
+	0x18, 0xd2, 0x41, 0xed, 0xd3, 0x1f, 0x0d, 0xea, 0x34, 0x7c, 0x86, 0xa2, 0x03, 0xe8, 0x26, 0xcc,
+	0x57, 0x59, 0xaa, 0x5f, 0x9a, 0xfe, 0xb6, 0x49, 0x36, 0x45, 0xcd, 0xbf, 0x95, 0xa0, 0x61, 0x61,
+	0xe7, 0xf8, 0xeb, 0xc6, 0xf7, 0x11, 0xac, 0xa7, 0x75, 0x32, 0x07, 0xf1, 0x35, 0x0d, 0x18, 0x3d,
+	0x94, 0xac, 0x8e, 0xab, 0x7d, 0x51, 0xf3, 0x7b, 0x03, 0xba, 0x4f, 0xd3, 0x5a, 0xfc, 0x75, 0x83,
+	0xb1, 0x0d, 0xc0, 0x9b, 0x47, 0x0e, 0x07, 0xbd, 0xd9, 0x26, 0xd7, 0x6d, 0x35, 0x63, 0x35, 0xa2,
+	0xe6, 0xdf, 0x4b, 0xd0, 0x7e, 0x13, 0x46, 0xa1, 0x1f, 0x1e, 0x2d, 0xbe, 0xee, 0xd3, 0xef, 0x42,
+	0x5f, 0xeb, 0xb3, 0x39, 0x10, 0xae, 0x17, 0x82, 0x21, 0xbb, 0x6c, 0x6b, 0xdd, 0xcd, 0x7d, 0x53,
+	0x73, 0x03, 0xfa, 0x8a, 0x33, 0x6a, 0xe5, 0xf2, 0xaf, 0x06, 0x20, 0x5d, 0xaa, 0x6a, 0xe5, 0xaf,
+	0xa1, 0xc3, 0x14, 0x76, 0x62, 0x3f, 0x45, 0x9b, 0xf5, 0xd8, 0xd3, 0xb1, 0xb5, 0xda, 0x4c, 0x47,
+	0xfa, 0x67, 0xb0, 0xa9, 0x4e, 0xc6, 0xfb, 0x87, 0xed, 0xf3, 0x37, 0xa5, 0x3d, 0x9b, 0x2a, 0x84,
+	0xfb, 0x85, 0xd7, 0xe6, 0x8b, 0xa9, 0xf9, 0x0b, 0xb8, 0x22, 0x89, 0xdb, 0xae, 0x93, 0xe7, 0x93,
+	0x4b, 0x0c, 0xac, 0x93, 0x31, 0x30, 0xf3, 0x3b, 0x03, 0xae, 0x16, 0x97, 0x29, 0xff, 0xcf, 0x5b,
+	0x87, 0x30, 0x20, 0x55, 0x6f, 0x74, 0x2e, 0x29, 0x29, 0xdc, 0xc3, 0x25, 0x2e, 0x59, 0xb4, 0xbd,
+	0x95, 0xd4, 0xa1, 0x8c, 0x4e, 0xf6, 0x68, 0x5e, 0x40, 0x87, 0x18, 0xfa, 0x4b, 0x6a, 0x9c, 0x71,
+	0x27, 0xfb, 0x2a, 0x9f, 0xea, 0x6a, 0xe1, 0x67, 0x90, 0xc9, 0xed, 0xff, 0x57, 0xa1, 0x3e, 0x21,
+	0xf8, 0x03, 0x21, 0x2e, 0xda, 0x83, 0xce, 0x84, 0x04, 0x6e, 0xf6, 0xc3, 0x6a, 0x53, 0x5b, 0x9c,
+	0x4a, 0x87, 0x3f, 0x5a, 0x25, 0x4d, 0x7b, 0xd3, 0xda, 0xd8, 0x78, 0x60, 0xa0, 0x03, 0xe8, 0x3c,
+	0x27, 0x24, 0xda, 0x09, 0x83, 0x80, 0x38, 0x8c, 0xb8, 0xe8, 0x96, 0xde, 0x21, 0x97, 0x9f, 0x27,
+	0xc3, 0xeb, 0x4b, 0x85, 0x3a, 0xf1, 0x56, 0x59, 0x7c, 0x0d, 0x6d, 0x9d, 0x95, 0xe7, 0x0c, 0xae,
+	0x78, 0x43, 0x0c, 0x6f, 0x5f, 0x40, 0xe7, 0xcd, 0x35, 0xf4, 0x08, 0x6a, 0x92, 0x26, 0xa2, 0x81,
+	0xa6, 0x9c, 0xe3, 0xc1, 0x39, 0xbf, 0xf2, 0x9c, 0xd2, 0x5c, 0x43, 0xcf, 0x01, 0x32, 0xa2, 0x85,
+	0x74, 0x5c, 0x96, 0x98, 0xde, 0xf0, 0xe6, 0x19, 0xb3, 0xa9, 0xb1, 0xdf, 0x43, 0x37, 0x4f, 0x39,
+	0xd0, 0x68, 0x25, 0xab, 0xd0, 0xf2, 0x6e, 0x78, 0xe7, 0x1c, 0x8d, 0xd4, 0xf0, 0x1f, 0xa1, 0x57,
+	0x64, 0x12, 0xc8, 0x5c, 0xb9, 0x30, 0xc7, 0x4a, 0x86, 0x77, 0xcf, 0xd5, 0xd1, 0x41, 0xc8, 0x52,
+	0x3f, 0x07, 0xc2, 0x52, 0x9d, 0xc8, 0x81, 0xb0, 0x5c, 0x2f, 0x24, 0x08, 0xf9, 0x7c, 0xc9, 0x81,
+	0xb0, 0x32, 0xbb, 0x73, 0x20, 0xac, 0x4e, 0x36, 0x73, 0x6d, 0x5a, 0x13, 0xff, 0x66, 0x1f, 0xfe,
+	0x10, 0x00, 0x00, 0xff, 0xff, 0xac, 0x38, 0x8b, 0x89, 0xab, 0x15, 0x00, 0x00,
 }
diff --git a/weed/server/master_grpc_server_volume.go b/weed/server/master_grpc_server_volume.go
index c0ec9e91f..2aaf7b891 100644
--- a/weed/server/master_grpc_server_volume.go
+++ b/weed/server/master_grpc_server_volume.go
@@ -141,3 +141,36 @@ func (ms *MasterServer) VolumeList(ctx context.Context, req *master_pb.VolumeLis
 
 	return resp, nil
 }
+
+func (ms *MasterServer) LookupEcVolume(ctx context.Context, req *master_pb.LookupEcVolumeRequest) (*master_pb.LookupEcVolumeResponse, error) {
+
+	if !ms.Topo.IsLeader() {
+		return nil, raft.NotLeaderError
+	}
+
+	resp := &master_pb.LookupEcVolumeResponse{}
+
+	ecLocations, found := ms.Topo.LookupEcShards(needle.VolumeId(req.VolumeId))
+
+	if !found {
+		return resp, fmt.Errorf("ec volume %d not found", req.VolumeId)
+	}
+
+	resp.VolumeId = req.VolumeId
+
+	for shardId, shardLocations := range ecLocations.Locations {
+		var locations []*master_pb.Location
+		for _, dn := range shardLocations {
+			locations = append(locations, &master_pb.Location{
+				Url:       string(dn.Id()),
+				PublicUrl: dn.PublicUrl,
+			})
+		}
+		resp.ShardIdLocations = append(resp.ShardIdLocations, &master_pb.LookupEcVolumeResponse_EcShardIdLocation{
+			ShardId:   uint32(shardId),
+			Locations: locations,
+		})
+	}
+
+	return resp, nil
+}
diff --git a/weed/storage/store_ec.go b/weed/storage/store_ec.go
index daa8bbd19..41d885af1 100644
--- a/weed/storage/store_ec.go
+++ b/weed/storage/store_ec.go
@@ -172,6 +172,24 @@ func (s *Store) cachedLookupEcShardLocations(ctx context.Context, ecVolume *eras
 	defer ecVolume.ShardLocationsLock.Unlock()
 
 	err = operation.WithMasterServerClient(s.MasterAddress, s.grpcDialOption, func(masterClient master_pb.SeaweedClient) error {
+		req := &master_pb.LookupEcVolumeRequest{
+			VolumeId: uint32(ecVolume.VolumeId),
+		}
+		resp, err := masterClient.LookupEcVolume(ctx, req)
+		if err != nil {
+			return fmt.Errorf("lookup ec volume %d: %v", ecVolume.VolumeId, err)
+		}
+
+		ecVolume.ShardLocationsLock.Lock()
+		for _, shardIdLocations := range resp.ShardIdLocations {
+			shardId := erasure_coding.ShardId(shardIdLocations.ShardId)
+			ecVolume.ShardLocations[shardId] = nil
+			for _, loc := range shardIdLocations.Locations {
+				ecVolume.ShardLocations[shardId] = append(ecVolume.ShardLocations[shardId], loc.Url)
+			}
+		}
+		ecVolume.ShardLocationsLock.Unlock()
+
 		return nil
 	})
 	return
diff --git a/weed/topology/topology_ec.go b/weed/topology/topology_ec.go
index 61de86753..63cd3ce35 100644
--- a/weed/topology/topology_ec.go
+++ b/weed/topology/topology_ec.go
@@ -9,7 +9,7 @@ import (
 
 type EcShardLocations struct {
 	Collection string
-	locations  [erasure_coding.TotalShardsCount][]*DataNode
+	Locations  [erasure_coding.TotalShardsCount][]*DataNode
 }
 
 func (t *Topology) SyncDataNodeEcShards(shardInfos []*master_pb.VolumeEcShardInformationMessage, dn *DataNode) (newShards, deletedShards []*erasure_coding.EcVolumeInfo) {
@@ -69,18 +69,18 @@ func NewEcShardLocations(collection string) *EcShardLocations {
 }
 
 func (loc *EcShardLocations) AddShard(shardId erasure_coding.ShardId, dn *DataNode) (added bool) {
-	dataNodes := loc.locations[shardId]
+	dataNodes := loc.Locations[shardId]
 	for _, n := range dataNodes {
 		if n.Id() == dn.Id() {
 			return false
 		}
 	}
-	loc.locations[shardId] = append(dataNodes, dn)
+	loc.Locations[shardId] = append(dataNodes, dn)
 	return true
 }
 
 func (loc *EcShardLocations) DeleteShard(shardId erasure_coding.ShardId, dn *DataNode) (deleted bool) {
-	dataNodes := loc.locations[shardId]
+	dataNodes := loc.Locations[shardId]
 	foundIndex := -1
 	for index, n := range dataNodes {
 		if n.Id() == dn.Id() {
@@ -90,7 +90,7 @@ func (loc *EcShardLocations) DeleteShard(shardId erasure_coding.ShardId, dn *Dat
 	if foundIndex < 0 {
 		return false
 	}
-	loc.locations[shardId] = append(dataNodes[:foundIndex], dataNodes[foundIndex+1:]...)
+	loc.Locations[shardId] = append(dataNodes[:foundIndex], dataNodes[foundIndex+1:]...)
 	return true
 }
 
@@ -122,3 +122,12 @@ func (t *Topology) UnRegisterEcShards(ecShardInfos *erasure_coding.EcVolumeInfo,
 		locations.DeleteShard(shardId, dn)
 	}
 }
+
+func (t *Topology) LookupEcShards(vid needle.VolumeId)(locations *EcShardLocations, found bool) {
+	t.ecShardMapLock.RLock()
+	defer t.ecShardMapLock.RUnlock()
+
+	locations, found = t.ecShardMap[vid]
+
+	return
+}