From c2ecb52f2f04849e9053e993c78403b06e7fb241 Mon Sep 17 00:00:00 2001 From: Yu Juncen Date: Tue, 23 Nov 2021 16:43:06 +0800 Subject: [PATCH 1/2] br: undo changes for coprocessor and pdpb --- pkg/brpb/brpb.pb.go | 699 +++++++++++++++++++++++++++++++++----------- proto/brpb.proto | 33 +++ 2 files changed, 564 insertions(+), 168 deletions(-) diff --git a/pkg/brpb/brpb.pb.go b/pkg/brpb/brpb.pb.go index b516ca608..291bc7403 100644 --- a/pkg/brpb/brpb.pb.go +++ b/pkg/brpb/brpb.pb.go @@ -61,7 +61,7 @@ func (x CompressionType) String() string { return proto.EnumName(CompressionType_name, int32(x)) } func (CompressionType) EnumDescriptor() ([]byte, []int) { - return fileDescriptor_brpb_502372d4112beef5, []int{0} + return fileDescriptor_brpb_ad1bbe2886ef0925, []int{0} } // The message save the metadata of a backup. @@ -120,7 +120,7 @@ func (m *BackupMeta) Reset() { *m = BackupMeta{} } func (m *BackupMeta) String() string { return proto.CompactTextString(m) } func (*BackupMeta) ProtoMessage() {} func (*BackupMeta) Descriptor() ([]byte, []int) { - return fileDescriptor_brpb_502372d4112beef5, []int{0} + return fileDescriptor_brpb_ad1bbe2886ef0925, []int{0} } func (m *BackupMeta) XXX_Unmarshal(b []byte) error { return m.Unmarshal(b) @@ -291,7 +291,7 @@ func (m *File) Reset() { *m = File{} } func (m *File) String() string { return proto.CompactTextString(m) } func (*File) ProtoMessage() {} func (*File) Descriptor() ([]byte, []int) { - return fileDescriptor_brpb_502372d4112beef5, []int{1} + return fileDescriptor_brpb_ad1bbe2886ef0925, []int{1} } func (m *File) XXX_Unmarshal(b []byte) error { return m.Unmarshal(b) @@ -426,7 +426,7 @@ func (m *MetaFile) Reset() { *m = MetaFile{} } func (m *MetaFile) String() string { return proto.CompactTextString(m) } func (*MetaFile) ProtoMessage() {} func (*MetaFile) Descriptor() ([]byte, []int) { - return fileDescriptor_brpb_502372d4112beef5, []int{2} + return fileDescriptor_brpb_ad1bbe2886ef0925, []int{2} } func (m *MetaFile) XXX_Unmarshal(b []byte) error { return m.Unmarshal(b) @@ -509,7 +509,7 @@ func (m *Schema) Reset() { *m = Schema{} } func (m *Schema) String() string { return proto.CompactTextString(m) } func (*Schema) ProtoMessage() {} func (*Schema) Descriptor() ([]byte, []int) { - return fileDescriptor_brpb_502372d4112beef5, []int{3} + return fileDescriptor_brpb_ad1bbe2886ef0925, []int{3} } func (m *Schema) XXX_Unmarshal(b []byte) error { return m.Unmarshal(b) @@ -600,7 +600,7 @@ func (m *RawRange) Reset() { *m = RawRange{} } func (m *RawRange) String() string { return proto.CompactTextString(m) } func (*RawRange) ProtoMessage() {} func (*RawRange) Descriptor() ([]byte, []int) { - return fileDescriptor_brpb_502372d4112beef5, []int{4} + return fileDescriptor_brpb_ad1bbe2886ef0925, []int{4} } func (m *RawRange) XXX_Unmarshal(b []byte) error { return m.Unmarshal(b) @@ -662,7 +662,7 @@ func (m *ClusterIDError) Reset() { *m = ClusterIDError{} } func (m *ClusterIDError) String() string { return proto.CompactTextString(m) } func (*ClusterIDError) ProtoMessage() {} func (*ClusterIDError) Descriptor() ([]byte, []int) { - return fileDescriptor_brpb_502372d4112beef5, []int{5} + return fileDescriptor_brpb_ad1bbe2886ef0925, []int{5} } func (m *ClusterIDError) XXX_Unmarshal(b []byte) error { return m.Unmarshal(b) @@ -721,7 +721,7 @@ func (m *Error) Reset() { *m = Error{} } func (m *Error) String() string { return proto.CompactTextString(m) } func (*Error) ProtoMessage() {} func (*Error) Descriptor() ([]byte, []int) { - return fileDescriptor_brpb_502372d4112beef5, []int{6} + return fileDescriptor_brpb_ad1bbe2886ef0925, []int{6} } func (m *Error) XXX_Unmarshal(b []byte) error { return m.Unmarshal(b) @@ -910,7 +910,7 @@ func (m *CipherInfo) Reset() { *m = CipherInfo{} } func (m *CipherInfo) String() string { return proto.CompactTextString(m) } func (*CipherInfo) ProtoMessage() {} func (*CipherInfo) Descriptor() ([]byte, []int) { - return fileDescriptor_brpb_502372d4112beef5, []int{7} + return fileDescriptor_brpb_ad1bbe2886ef0925, []int{7} } func (m *CipherInfo) XXX_Unmarshal(b []byte) error { return m.Unmarshal(b) @@ -983,7 +983,7 @@ func (m *BackupRequest) Reset() { *m = BackupRequest{} } func (m *BackupRequest) String() string { return proto.CompactTextString(m) } func (*BackupRequest) ProtoMessage() {} func (*BackupRequest) Descriptor() ([]byte, []int) { - return fileDescriptor_brpb_502372d4112beef5, []int{8} + return fileDescriptor_brpb_ad1bbe2886ef0925, []int{8} } func (m *BackupRequest) XXX_Unmarshal(b []byte) error { return m.Unmarshal(b) @@ -1103,6 +1103,91 @@ func (m *BackupRequest) GetCipherInfo() *CipherInfo { return nil } +type StreamBackupTaskInfo struct { + // The storage for backup, parsed by BR. + Storage *StorageBackend `protobuf:"bytes,1,opt,name=storage" json:"storage,omitempty"` + // The time range for backing up. + StartTs uint64 `protobuf:"varint,2,opt,name=start_ts,json=startTs,proto3" json:"start_ts,omitempty"` + EndTs uint64 `protobuf:"varint,3,opt,name=end_ts,json=endTs,proto3" json:"end_ts,omitempty"` + // Misc meta datas. + // The name of the task, also the ID of the task. + Name string `protobuf:"bytes,4,opt,name=name,proto3" json:"name,omitempty"` + // The table filter of the task. + // Only for displaying the task info. + TableFilter []string `protobuf:"bytes,5,rep,name=table_filter,json=tableFilter" json:"table_filter,omitempty"` + XXX_NoUnkeyedLiteral struct{} `json:"-"` + XXX_unrecognized []byte `json:"-"` + XXX_sizecache int32 `json:"-"` +} + +func (m *StreamBackupTaskInfo) Reset() { *m = StreamBackupTaskInfo{} } +func (m *StreamBackupTaskInfo) String() string { return proto.CompactTextString(m) } +func (*StreamBackupTaskInfo) ProtoMessage() {} +func (*StreamBackupTaskInfo) Descriptor() ([]byte, []int) { + return fileDescriptor_brpb_ad1bbe2886ef0925, []int{9} +} +func (m *StreamBackupTaskInfo) XXX_Unmarshal(b []byte) error { + return m.Unmarshal(b) +} +func (m *StreamBackupTaskInfo) XXX_Marshal(b []byte, deterministic bool) ([]byte, error) { + if deterministic { + return xxx_messageInfo_StreamBackupTaskInfo.Marshal(b, m, deterministic) + } else { + b = b[:cap(b)] + n, err := m.MarshalTo(b) + if err != nil { + return nil, err + } + return b[:n], nil + } +} +func (dst *StreamBackupTaskInfo) XXX_Merge(src proto.Message) { + xxx_messageInfo_StreamBackupTaskInfo.Merge(dst, src) +} +func (m *StreamBackupTaskInfo) XXX_Size() int { + return m.Size() +} +func (m *StreamBackupTaskInfo) XXX_DiscardUnknown() { + xxx_messageInfo_StreamBackupTaskInfo.DiscardUnknown(m) +} + +var xxx_messageInfo_StreamBackupTaskInfo proto.InternalMessageInfo + +func (m *StreamBackupTaskInfo) GetStorage() *StorageBackend { + if m != nil { + return m.Storage + } + return nil +} + +func (m *StreamBackupTaskInfo) GetStartTs() uint64 { + if m != nil { + return m.StartTs + } + return 0 +} + +func (m *StreamBackupTaskInfo) GetEndTs() uint64 { + if m != nil { + return m.EndTs + } + return 0 +} + +func (m *StreamBackupTaskInfo) GetName() string { + if m != nil { + return m.Name + } + return "" +} + +func (m *StreamBackupTaskInfo) GetTableFilter() []string { + if m != nil { + return m.TableFilter + } + return nil +} + type StorageBackend struct { // Types that are valid to be assigned to Backend: // *StorageBackend_Noop @@ -1121,7 +1206,7 @@ func (m *StorageBackend) Reset() { *m = StorageBackend{} } func (m *StorageBackend) String() string { return proto.CompactTextString(m) } func (*StorageBackend) ProtoMessage() {} func (*StorageBackend) Descriptor() ([]byte, []int) { - return fileDescriptor_brpb_502372d4112beef5, []int{9} + return fileDescriptor_brpb_ad1bbe2886ef0925, []int{10} } func (m *StorageBackend) XXX_Unmarshal(b []byte) error { return m.Unmarshal(b) @@ -1392,7 +1477,7 @@ func (m *Noop) Reset() { *m = Noop{} } func (m *Noop) String() string { return proto.CompactTextString(m) } func (*Noop) ProtoMessage() {} func (*Noop) Descriptor() ([]byte, []int) { - return fileDescriptor_brpb_502372d4112beef5, []int{10} + return fileDescriptor_brpb_ad1bbe2886ef0925, []int{11} } func (m *Noop) XXX_Unmarshal(b []byte) error { return m.Unmarshal(b) @@ -1433,7 +1518,7 @@ func (m *Local) Reset() { *m = Local{} } func (m *Local) String() string { return proto.CompactTextString(m) } func (*Local) ProtoMessage() {} func (*Local) Descriptor() ([]byte, []int) { - return fileDescriptor_brpb_502372d4112beef5, []int{11} + return fileDescriptor_brpb_ad1bbe2886ef0925, []int{12} } func (m *Local) XXX_Unmarshal(b []byte) error { return m.Unmarshal(b) @@ -1493,7 +1578,7 @@ func (m *S3) Reset() { *m = S3{} } func (m *S3) String() string { return proto.CompactTextString(m) } func (*S3) ProtoMessage() {} func (*S3) Descriptor() ([]byte, []int) { - return fileDescriptor_brpb_502372d4112beef5, []int{12} + return fileDescriptor_brpb_ad1bbe2886ef0925, []int{13} } func (m *S3) XXX_Unmarshal(b []byte) error { return m.Unmarshal(b) @@ -1622,7 +1707,7 @@ func (m *GCS) Reset() { *m = GCS{} } func (m *GCS) String() string { return proto.CompactTextString(m) } func (*GCS) ProtoMessage() {} func (*GCS) Descriptor() ([]byte, []int) { - return fileDescriptor_brpb_502372d4112beef5, []int{13} + return fileDescriptor_brpb_ad1bbe2886ef0925, []int{14} } func (m *GCS) XXX_Unmarshal(b []byte) error { return m.Unmarshal(b) @@ -1708,7 +1793,7 @@ func (m *Bucket) Reset() { *m = Bucket{} } func (m *Bucket) String() string { return proto.CompactTextString(m) } func (*Bucket) ProtoMessage() {} func (*Bucket) Descriptor() ([]byte, []int) { - return fileDescriptor_brpb_502372d4112beef5, []int{14} + return fileDescriptor_brpb_ad1bbe2886ef0925, []int{15} } func (m *Bucket) XXX_Unmarshal(b []byte) error { return m.Unmarshal(b) @@ -1786,7 +1871,7 @@ func (m *CloudDynamic) Reset() { *m = CloudDynamic{} } func (m *CloudDynamic) String() string { return proto.CompactTextString(m) } func (*CloudDynamic) ProtoMessage() {} func (*CloudDynamic) Descriptor() ([]byte, []int) { - return fileDescriptor_brpb_502372d4112beef5, []int{15} + return fileDescriptor_brpb_ad1bbe2886ef0925, []int{16} } func (m *CloudDynamic) XXX_Unmarshal(b []byte) error { return m.Unmarshal(b) @@ -1849,7 +1934,7 @@ func (m *HDFS) Reset() { *m = HDFS{} } func (m *HDFS) String() string { return proto.CompactTextString(m) } func (*HDFS) ProtoMessage() {} func (*HDFS) Descriptor() ([]byte, []int) { - return fileDescriptor_brpb_502372d4112beef5, []int{16} + return fileDescriptor_brpb_ad1bbe2886ef0925, []int{17} } func (m *HDFS) XXX_Unmarshal(b []byte) error { return m.Unmarshal(b) @@ -1899,7 +1984,7 @@ func (m *BackupResponse) Reset() { *m = BackupResponse{} } func (m *BackupResponse) String() string { return proto.CompactTextString(m) } func (*BackupResponse) ProtoMessage() {} func (*BackupResponse) Descriptor() ([]byte, []int) { - return fileDescriptor_brpb_502372d4112beef5, []int{17} + return fileDescriptor_brpb_ad1bbe2886ef0925, []int{18} } func (m *BackupResponse) XXX_Unmarshal(b []byte) error { return m.Unmarshal(b) @@ -1970,7 +2055,7 @@ func (m *ExternalStorageRestoreRequest) Reset() { *m = ExternalStorageRe func (m *ExternalStorageRestoreRequest) String() string { return proto.CompactTextString(m) } func (*ExternalStorageRestoreRequest) ProtoMessage() {} func (*ExternalStorageRestoreRequest) Descriptor() ([]byte, []int) { - return fileDescriptor_brpb_502372d4112beef5, []int{18} + return fileDescriptor_brpb_ad1bbe2886ef0925, []int{19} } func (m *ExternalStorageRestoreRequest) XXX_Unmarshal(b []byte) error { return m.Unmarshal(b) @@ -2037,7 +2122,7 @@ func (m *ExternalStorageRestoreResponse) Reset() { *m = ExternalStorageR func (m *ExternalStorageRestoreResponse) String() string { return proto.CompactTextString(m) } func (*ExternalStorageRestoreResponse) ProtoMessage() {} func (*ExternalStorageRestoreResponse) Descriptor() ([]byte, []int) { - return fileDescriptor_brpb_502372d4112beef5, []int{19} + return fileDescriptor_brpb_ad1bbe2886ef0925, []int{20} } func (m *ExternalStorageRestoreResponse) XXX_Unmarshal(b []byte) error { return m.Unmarshal(b) @@ -2079,7 +2164,7 @@ func (m *ExternalStorageSaveRequest) Reset() { *m = ExternalStorageSaveR func (m *ExternalStorageSaveRequest) String() string { return proto.CompactTextString(m) } func (*ExternalStorageSaveRequest) ProtoMessage() {} func (*ExternalStorageSaveRequest) Descriptor() ([]byte, []int) { - return fileDescriptor_brpb_502372d4112beef5, []int{20} + return fileDescriptor_brpb_ad1bbe2886ef0925, []int{21} } func (m *ExternalStorageSaveRequest) XXX_Unmarshal(b []byte) error { return m.Unmarshal(b) @@ -2139,7 +2224,7 @@ func (m *ExternalStorageSaveResponse) Reset() { *m = ExternalStorageSave func (m *ExternalStorageSaveResponse) String() string { return proto.CompactTextString(m) } func (*ExternalStorageSaveResponse) ProtoMessage() {} func (*ExternalStorageSaveResponse) Descriptor() ([]byte, []int) { - return fileDescriptor_brpb_502372d4112beef5, []int{21} + return fileDescriptor_brpb_ad1bbe2886ef0925, []int{22} } func (m *ExternalStorageSaveResponse) XXX_Unmarshal(b []byte) error { return m.Unmarshal(b) @@ -2178,6 +2263,7 @@ func init() { proto.RegisterType((*Error)(nil), "backup.Error") proto.RegisterType((*CipherInfo)(nil), "backup.CipherInfo") proto.RegisterType((*BackupRequest)(nil), "backup.BackupRequest") + proto.RegisterType((*StreamBackupTaskInfo)(nil), "backup.StreamBackupTaskInfo") proto.RegisterType((*StorageBackend)(nil), "backup.StorageBackend") proto.RegisterType((*Noop)(nil), "backup.Noop") proto.RegisterType((*Local)(nil), "backup.Local") @@ -3062,6 +3148,68 @@ func (m *BackupRequest) MarshalTo(dAtA []byte) (int, error) { return i, nil } +func (m *StreamBackupTaskInfo) Marshal() (dAtA []byte, err error) { + size := m.Size() + dAtA = make([]byte, size) + n, err := m.MarshalTo(dAtA) + if err != nil { + return nil, err + } + return dAtA[:n], nil +} + +func (m *StreamBackupTaskInfo) MarshalTo(dAtA []byte) (int, error) { + var i int + _ = i + var l int + _ = l + if m.Storage != nil { + dAtA[i] = 0xa + i++ + i = encodeVarintBrpb(dAtA, i, uint64(m.Storage.Size())) + n11, err := m.Storage.MarshalTo(dAtA[i:]) + if err != nil { + return 0, err + } + i += n11 + } + if m.StartTs != 0 { + dAtA[i] = 0x10 + i++ + i = encodeVarintBrpb(dAtA, i, uint64(m.StartTs)) + } + if m.EndTs != 0 { + dAtA[i] = 0x18 + i++ + i = encodeVarintBrpb(dAtA, i, uint64(m.EndTs)) + } + if len(m.Name) > 0 { + dAtA[i] = 0x22 + i++ + i = encodeVarintBrpb(dAtA, i, uint64(len(m.Name))) + i += copy(dAtA[i:], m.Name) + } + if len(m.TableFilter) > 0 { + for _, s := range m.TableFilter { + dAtA[i] = 0x2a + i++ + l = len(s) + for l >= 1<<7 { + dAtA[i] = uint8(uint64(l)&0x7f | 0x80) + l >>= 7 + i++ + } + dAtA[i] = uint8(l) + i++ + i += copy(dAtA[i:], s) + } + } + if m.XXX_unrecognized != nil { + i += copy(dAtA[i:], m.XXX_unrecognized) + } + return i, nil +} + func (m *StorageBackend) Marshal() (dAtA []byte, err error) { size := m.Size() dAtA = make([]byte, size) @@ -3078,11 +3226,11 @@ func (m *StorageBackend) MarshalTo(dAtA []byte) (int, error) { var l int _ = l if m.Backend != nil { - nn11, err := m.Backend.MarshalTo(dAtA[i:]) + nn12, err := m.Backend.MarshalTo(dAtA[i:]) if err != nil { return 0, err } - i += nn11 + i += nn12 } if m.XXX_unrecognized != nil { i += copy(dAtA[i:], m.XXX_unrecognized) @@ -3096,11 +3244,11 @@ func (m *StorageBackend_Noop) MarshalTo(dAtA []byte) (int, error) { dAtA[i] = 0xa i++ i = encodeVarintBrpb(dAtA, i, uint64(m.Noop.Size())) - n12, err := m.Noop.MarshalTo(dAtA[i:]) + n13, err := m.Noop.MarshalTo(dAtA[i:]) if err != nil { return 0, err } - i += n12 + i += n13 } return i, nil } @@ -3110,11 +3258,11 @@ func (m *StorageBackend_Local) MarshalTo(dAtA []byte) (int, error) { dAtA[i] = 0x12 i++ i = encodeVarintBrpb(dAtA, i, uint64(m.Local.Size())) - n13, err := m.Local.MarshalTo(dAtA[i:]) + n14, err := m.Local.MarshalTo(dAtA[i:]) if err != nil { return 0, err } - i += n13 + i += n14 } return i, nil } @@ -3124,11 +3272,11 @@ func (m *StorageBackend_S3) MarshalTo(dAtA []byte) (int, error) { dAtA[i] = 0x1a i++ i = encodeVarintBrpb(dAtA, i, uint64(m.S3.Size())) - n14, err := m.S3.MarshalTo(dAtA[i:]) + n15, err := m.S3.MarshalTo(dAtA[i:]) if err != nil { return 0, err } - i += n14 + i += n15 } return i, nil } @@ -3138,11 +3286,11 @@ func (m *StorageBackend_Gcs) MarshalTo(dAtA []byte) (int, error) { dAtA[i] = 0x22 i++ i = encodeVarintBrpb(dAtA, i, uint64(m.Gcs.Size())) - n15, err := m.Gcs.MarshalTo(dAtA[i:]) + n16, err := m.Gcs.MarshalTo(dAtA[i:]) if err != nil { return 0, err } - i += n15 + i += n16 } return i, nil } @@ -3152,11 +3300,11 @@ func (m *StorageBackend_CloudDynamic) MarshalTo(dAtA []byte) (int, error) { dAtA[i] = 0x2a i++ i = encodeVarintBrpb(dAtA, i, uint64(m.CloudDynamic.Size())) - n16, err := m.CloudDynamic.MarshalTo(dAtA[i:]) + n17, err := m.CloudDynamic.MarshalTo(dAtA[i:]) if err != nil { return 0, err } - i += n16 + i += n17 } return i, nil } @@ -3166,11 +3314,11 @@ func (m *StorageBackend_Hdfs) MarshalTo(dAtA []byte) (int, error) { dAtA[i] = 0x32 i++ i = encodeVarintBrpb(dAtA, i, uint64(m.Hdfs.Size())) - n17, err := m.Hdfs.MarshalTo(dAtA[i:]) + n18, err := m.Hdfs.MarshalTo(dAtA[i:]) if err != nil { return 0, err } - i += n17 + i += n18 } return i, nil } @@ -3440,11 +3588,11 @@ func (m *CloudDynamic) MarshalTo(dAtA []byte) (int, error) { dAtA[i] = 0xa i++ i = encodeVarintBrpb(dAtA, i, uint64(m.Bucket.Size())) - n18, err := m.Bucket.MarshalTo(dAtA[i:]) + n19, err := m.Bucket.MarshalTo(dAtA[i:]) if err != nil { return 0, err } - i += n18 + i += n19 } if len(m.ProviderName) > 0 { dAtA[i] = 0x12 @@ -3521,11 +3669,11 @@ func (m *BackupResponse) MarshalTo(dAtA []byte) (int, error) { dAtA[i] = 0xa i++ i = encodeVarintBrpb(dAtA, i, uint64(m.Error.Size())) - n19, err := m.Error.MarshalTo(dAtA[i:]) + n20, err := m.Error.MarshalTo(dAtA[i:]) if err != nil { return 0, err } - i += n19 + i += n20 } if len(m.StartKey) > 0 { dAtA[i] = 0x12 @@ -3576,11 +3724,11 @@ func (m *ExternalStorageRestoreRequest) MarshalTo(dAtA []byte) (int, error) { dAtA[i] = 0xa i++ i = encodeVarintBrpb(dAtA, i, uint64(m.StorageBackend.Size())) - n20, err := m.StorageBackend.MarshalTo(dAtA[i:]) + n21, err := m.StorageBackend.MarshalTo(dAtA[i:]) if err != nil { return 0, err } - i += n20 + i += n21 } if len(m.ObjectName) > 0 { dAtA[i] = 0x12 @@ -3645,11 +3793,11 @@ func (m *ExternalStorageSaveRequest) MarshalTo(dAtA []byte) (int, error) { dAtA[i] = 0xa i++ i = encodeVarintBrpb(dAtA, i, uint64(m.StorageBackend.Size())) - n21, err := m.StorageBackend.MarshalTo(dAtA[i:]) + n22, err := m.StorageBackend.MarshalTo(dAtA[i:]) if err != nil { return 0, err } - i += n21 + i += n22 } if len(m.ObjectName) > 0 { dAtA[i] = 0x12 @@ -4046,6 +4194,35 @@ func (m *BackupRequest) Size() (n int) { return n } +func (m *StreamBackupTaskInfo) Size() (n int) { + var l int + _ = l + if m.Storage != nil { + l = m.Storage.Size() + n += 1 + l + sovBrpb(uint64(l)) + } + if m.StartTs != 0 { + n += 1 + sovBrpb(uint64(m.StartTs)) + } + if m.EndTs != 0 { + n += 1 + sovBrpb(uint64(m.EndTs)) + } + l = len(m.Name) + if l > 0 { + n += 1 + l + sovBrpb(uint64(l)) + } + if len(m.TableFilter) > 0 { + for _, s := range m.TableFilter { + l = len(s) + n += 1 + l + sovBrpb(uint64(l)) + } + } + if m.XXX_unrecognized != nil { + n += len(m.XXX_unrecognized) + } + return n +} + func (m *StorageBackend) Size() (n int) { var l int _ = l @@ -6537,6 +6714,186 @@ func (m *BackupRequest) Unmarshal(dAtA []byte) error { } return nil } +func (m *StreamBackupTaskInfo) Unmarshal(dAtA []byte) error { + l := len(dAtA) + iNdEx := 0 + for iNdEx < l { + preIndex := iNdEx + var wire uint64 + for shift := uint(0); ; shift += 7 { + if shift >= 64 { + return ErrIntOverflowBrpb + } + if iNdEx >= l { + return io.ErrUnexpectedEOF + } + b := dAtA[iNdEx] + iNdEx++ + wire |= (uint64(b) & 0x7F) << shift + if b < 0x80 { + break + } + } + fieldNum := int32(wire >> 3) + wireType := int(wire & 0x7) + if wireType == 4 { + return fmt.Errorf("proto: StreamBackupTaskInfo: wiretype end group for non-group") + } + if fieldNum <= 0 { + return fmt.Errorf("proto: StreamBackupTaskInfo: illegal tag %d (wire type %d)", fieldNum, wire) + } + switch fieldNum { + case 1: + if wireType != 2 { + return fmt.Errorf("proto: wrong wireType = %d for field Storage", wireType) + } + var msglen int + for shift := uint(0); ; shift += 7 { + if shift >= 64 { + return ErrIntOverflowBrpb + } + if iNdEx >= l { + return io.ErrUnexpectedEOF + } + b := dAtA[iNdEx] + iNdEx++ + msglen |= (int(b) & 0x7F) << shift + if b < 0x80 { + break + } + } + if msglen < 0 { + return ErrInvalidLengthBrpb + } + postIndex := iNdEx + msglen + if postIndex > l { + return io.ErrUnexpectedEOF + } + if m.Storage == nil { + m.Storage = &StorageBackend{} + } + if err := m.Storage.Unmarshal(dAtA[iNdEx:postIndex]); err != nil { + return err + } + iNdEx = postIndex + case 2: + if wireType != 0 { + return fmt.Errorf("proto: wrong wireType = %d for field StartTs", wireType) + } + m.StartTs = 0 + for shift := uint(0); ; shift += 7 { + if shift >= 64 { + return ErrIntOverflowBrpb + } + if iNdEx >= l { + return io.ErrUnexpectedEOF + } + b := dAtA[iNdEx] + iNdEx++ + m.StartTs |= (uint64(b) & 0x7F) << shift + if b < 0x80 { + break + } + } + case 3: + if wireType != 0 { + return fmt.Errorf("proto: wrong wireType = %d for field EndTs", wireType) + } + m.EndTs = 0 + for shift := uint(0); ; shift += 7 { + if shift >= 64 { + return ErrIntOverflowBrpb + } + if iNdEx >= l { + return io.ErrUnexpectedEOF + } + b := dAtA[iNdEx] + iNdEx++ + m.EndTs |= (uint64(b) & 0x7F) << shift + if b < 0x80 { + break + } + } + case 4: + if wireType != 2 { + return fmt.Errorf("proto: wrong wireType = %d for field Name", wireType) + } + var stringLen uint64 + for shift := uint(0); ; shift += 7 { + if shift >= 64 { + return ErrIntOverflowBrpb + } + if iNdEx >= l { + return io.ErrUnexpectedEOF + } + b := dAtA[iNdEx] + iNdEx++ + stringLen |= (uint64(b) & 0x7F) << shift + if b < 0x80 { + break + } + } + intStringLen := int(stringLen) + if intStringLen < 0 { + return ErrInvalidLengthBrpb + } + postIndex := iNdEx + intStringLen + if postIndex > l { + return io.ErrUnexpectedEOF + } + m.Name = string(dAtA[iNdEx:postIndex]) + iNdEx = postIndex + case 5: + if wireType != 2 { + return fmt.Errorf("proto: wrong wireType = %d for field TableFilter", wireType) + } + var stringLen uint64 + for shift := uint(0); ; shift += 7 { + if shift >= 64 { + return ErrIntOverflowBrpb + } + if iNdEx >= l { + return io.ErrUnexpectedEOF + } + b := dAtA[iNdEx] + iNdEx++ + stringLen |= (uint64(b) & 0x7F) << shift + if b < 0x80 { + break + } + } + intStringLen := int(stringLen) + if intStringLen < 0 { + return ErrInvalidLengthBrpb + } + postIndex := iNdEx + intStringLen + if postIndex > l { + return io.ErrUnexpectedEOF + } + m.TableFilter = append(m.TableFilter, string(dAtA[iNdEx:postIndex])) + iNdEx = postIndex + default: + iNdEx = preIndex + skippy, err := skipBrpb(dAtA[iNdEx:]) + if err != nil { + return err + } + if skippy < 0 { + return ErrInvalidLengthBrpb + } + if (iNdEx + skippy) > l { + return io.ErrUnexpectedEOF + } + m.XXX_unrecognized = append(m.XXX_unrecognized, dAtA[iNdEx:iNdEx+skippy]...) + iNdEx += skippy + } + } + + if iNdEx > l { + return io.ErrUnexpectedEOF + } + return nil +} func (m *StorageBackend) Unmarshal(dAtA []byte) error { l := len(dAtA) iNdEx := 0 @@ -8681,127 +9038,133 @@ var ( ErrIntOverflowBrpb = fmt.Errorf("proto: integer overflow") ) -func init() { proto.RegisterFile("brpb.proto", fileDescriptor_brpb_502372d4112beef5) } - -var fileDescriptor_brpb_502372d4112beef5 = []byte{ - // 1896 bytes of a gzipped FileDescriptorProto - 0x1f, 0x8b, 0x08, 0x00, 0x00, 0x00, 0x00, 0x00, 0x02, 0xff, 0xbc, 0x58, 0x5f, 0x8f, 0x1b, 0x49, - 0x11, 0xdf, 0xb1, 0xc7, 0x7f, 0xa6, 0xfc, 0x37, 0x4d, 0xc8, 0x59, 0x0e, 0xd9, 0x98, 0x89, 0x12, - 0x96, 0x3b, 0xc9, 0x07, 0xbb, 0xb9, 0x53, 0xc4, 0x09, 0x9d, 0xe2, 0xdd, 0xbd, 0xdb, 0xbd, 0xdd, - 0x5b, 0x96, 0xf6, 0x01, 0x22, 0x2f, 0xa3, 0xf1, 0x4c, 0xdb, 0x1e, 0x3c, 0x9e, 0x19, 0xa6, 0xdb, - 0x4e, 0xcc, 0x07, 0xe0, 0x81, 0x17, 0xc4, 0x1b, 0x5f, 0x00, 0x89, 0x0f, 0xc1, 0x03, 0x8f, 0x77, - 0x3a, 0x1e, 0x90, 0x78, 0xe1, 0x11, 0x85, 0x2f, 0x82, 0xaa, 0xbb, 0x67, 0xd6, 0x4e, 0xd6, 0x9b, - 0x80, 0xd0, 0x3d, 0x6d, 0xf7, 0xaf, 0xaa, 0xba, 0xa7, 0xaa, 0x7e, 0x55, 0xd5, 0x6b, 0x80, 0x51, - 0x9a, 0x8c, 0xfa, 0x49, 0x1a, 0x8b, 0x98, 0x94, 0x47, 0xae, 0x37, 0x5b, 0x24, 0xdd, 0xc6, 0x6c, - 0x99, 0x26, 0x5e, 0x06, 0x77, 0x1b, 0x2c, 0x4d, 0xe3, 0x5c, 0xab, 0x4b, 0x58, 0xe4, 0xa5, 0xab, - 0x44, 0x04, 0x71, 0x94, 0x63, 0xb7, 0x27, 0xf1, 0x24, 0x96, 0xcb, 0xf7, 0x71, 0xa5, 0xd1, 0x56, - 0xba, 0xe0, 0x42, 0x2e, 0x15, 0x60, 0xff, 0xa5, 0x04, 0x30, 0x90, 0x77, 0x7c, 0xce, 0x84, 0x4b, - 0xee, 0x01, 0x78, 0xe1, 0x82, 0x0b, 0x96, 0x3a, 0x81, 0xdf, 0x31, 0x7a, 0xc6, 0x9e, 0x49, 0x2d, - 0x8d, 0x9c, 0xfa, 0xe4, 0x7b, 0xd0, 0xca, 0xc4, 0x4b, 0x96, 0xf2, 0x20, 0x8e, 0x3a, 0x85, 0x9e, - 0xb1, 0x67, 0xd1, 0xa6, 0x86, 0x7f, 0xae, 0x50, 0x62, 0x43, 0x69, 0x1c, 0x84, 0x8c, 0x77, 0xcc, - 0x5e, 0x71, 0xaf, 0xb6, 0x5f, 0xef, 0x2b, 0x3f, 0xfa, 0x9f, 0x04, 0x21, 0xa3, 0x4a, 0x44, 0x1e, - 0x40, 0x83, 0x0b, 0x37, 0x15, 0xf9, 0x51, 0x25, 0x79, 0x5d, 0x5d, 0x82, 0xd9, 0x41, 0xf7, 0xa1, - 0xc6, 0x22, 0x3f, 0x57, 0x29, 0x4b, 0x15, 0x60, 0x91, 0x9f, 0x29, 0xec, 0x41, 0x85, 0x7b, 0x53, - 0x36, 0x77, 0x79, 0xa7, 0x22, 0xef, 0x6a, 0x66, 0x77, 0x0d, 0x25, 0x4c, 0x33, 0x31, 0xe9, 0x82, - 0x15, 0x70, 0x27, 0x75, 0x9f, 0x3b, 0xb3, 0x65, 0xa7, 0xda, 0x33, 0xf6, 0xaa, 0xb4, 0x12, 0x70, - 0xea, 0x3e, 0x3f, 0x5b, 0x92, 0xf7, 0x01, 0x50, 0x90, 0xba, 0xd1, 0x84, 0xf1, 0x8e, 0x25, 0x0f, - 0x6a, 0x67, 0x07, 0x51, 0xf7, 0x39, 0x45, 0x01, 0xb5, 0x52, 0xbd, 0xe2, 0x84, 0x80, 0xe9, 0xfb, - 0x21, 0xef, 0x40, 0xcf, 0xd8, 0xab, 0x53, 0xb9, 0xc6, 0xe0, 0x8d, 0xae, 0x02, 0x53, 0x93, 0x81, - 0xb1, 0x46, 0x79, 0x4c, 0x3a, 0x50, 0xc9, 0x64, 0xf5, 0x9e, 0xb1, 0x57, 0xa2, 0xd9, 0x16, 0x6f, - 0xc7, 0x90, 0x38, 0x41, 0xe4, 0xb3, 0x17, 0x9d, 0x46, 0xcf, 0x58, 0xbf, 0x1d, 0xf3, 0x22, 0xc3, - 0x66, 0xa1, 0xce, 0x29, 0xaa, 0x90, 0x03, 0xa8, 0x2b, 0xaf, 0xb4, 0x49, 0x73, 0x8b, 0x49, 0x4d, - 0x69, 0x29, 0xa3, 0x27, 0xd0, 0xca, 0x7d, 0xd4, 0x76, 0xad, 0x2d, 0x76, 0x8d, 0xcc, 0x51, 0x65, - 0xf9, 0x43, 0xa8, 0xf9, 0x7e, 0xa8, 0x6c, 0x18, 0xef, 0xb4, 0xb7, 0x58, 0x81, 0xef, 0x87, 0xa7, - 0x4a, 0x07, 0x93, 0xab, 0xc4, 0x4e, 0xca, 0xf8, 0x22, 0x14, 0x9d, 0x5b, 0x32, 0x1c, 0x75, 0x05, - 0x52, 0x89, 0x91, 0xc7, 0x50, 0x73, 0x93, 0x20, 0x8f, 0x18, 0xe9, 0x19, 0x7b, 0xcd, 0xfd, 0x6f, - 0xf5, 0x33, 0xae, 0x3f, 0xbd, 0x3c, 0xd5, 0xb1, 0xa3, 0xe0, 0x26, 0x81, 0x5e, 0x7f, 0x66, 0x56, - 0x8b, 0x6d, 0x93, 0x9a, 0x89, 0x2b, 0xa6, 0xf6, 0x57, 0x05, 0x30, 0xf1, 0x6e, 0xcc, 0x47, 0xe4, - 0xce, 0x99, 0xa4, 0xac, 0x45, 0xe5, 0x9a, 0xdc, 0x81, 0x32, 0x9f, 0xba, 0xfb, 0x1f, 0x7c, 0x28, - 0x49, 0x5a, 0xa7, 0x7a, 0x47, 0xee, 0x82, 0xa5, 0x88, 0x37, 0x63, 0xab, 0x4e, 0x51, 0x8a, 0xaa, - 0x12, 0x38, 0x63, 0x2b, 0xf2, 0x0e, 0x54, 0x90, 0x70, 0x28, 0x32, 0x95, 0x15, 0x8b, 0x7c, 0x14, - 0xfc, 0x7f, 0xe8, 0xda, 0x85, 0xaa, 0x97, 0x7a, 0x1f, 0x3e, 0x7e, 0x11, 0xa7, 0x9d, 0x8a, 0x94, - 0xe6, 0x7b, 0xfc, 0x2e, 0x11, 0x0b, 0x37, 0x74, 0x66, 0x4b, 0x2e, 0x09, 0x6a, 0xd2, 0xaa, 0x04, - 0xce, 0x96, 0x1c, 0x4f, 0x56, 0xc2, 0xd1, 0x4a, 0x48, 0x8a, 0xca, 0x93, 0x25, 0x34, 0x40, 0x84, - 0x34, 0xa1, 0xe0, 0x8d, 0x25, 0x1f, 0x2d, 0x5a, 0xf0, 0xc6, 0x18, 0x11, 0x1e, 0xfc, 0x86, 0x49, - 0x1e, 0x9a, 0x54, 0xae, 0xf1, 0x06, 0x2f, 0x48, 0xa6, 0x58, 0xdd, 0x4b, 0x49, 0xc2, 0x3a, 0xad, - 0x2a, 0xe0, 0x74, 0x69, 0xff, 0xc3, 0x80, 0x6a, 0x96, 0x4b, 0xf2, 0x1e, 0xc0, 0x9c, 0x09, 0xd7, - 0x51, 0x55, 0x6c, 0x5c, 0x53, 0xc5, 0xd6, 0x5c, 0xeb, 0x72, 0x54, 0xf6, 0xdd, 0x5c, 0xb9, 0x70, - 0x9d, 0x32, 0xca, 0x95, 0xf2, 0x5a, 0xc1, 0x16, 0x6f, 0x2e, 0xd8, 0xcd, 0xa2, 0x34, 0xdf, 0xbe, - 0x28, 0x4b, 0xbd, 0x62, 0x56, 0x94, 0xf6, 0x57, 0x06, 0x94, 0xd5, 0xc1, 0x18, 0x21, 0x7f, 0x24, - 0x19, 0x52, 0xa7, 0x05, 0x7f, 0x44, 0x6e, 0x43, 0x49, 0xb8, 0xa3, 0x90, 0x69, 0x7a, 0xa8, 0xcd, - 0x46, 0x86, 0x8a, 0x37, 0x65, 0xc8, 0xbc, 0x39, 0x43, 0xa5, 0xd7, 0x32, 0xf4, 0x7d, 0x68, 0x8b, - 0x60, 0x1c, 0xba, 0x7c, 0xea, 0xa4, 0x2c, 0x09, 0x03, 0xcf, 0xe5, 0x92, 0x21, 0x0d, 0xda, 0xd2, - 0x38, 0xd5, 0x30, 0x7e, 0x1a, 0x17, 0xae, 0xe0, 0x92, 0x23, 0x75, 0xaa, 0x36, 0xf6, 0x25, 0x54, - 0x33, 0xb7, 0x37, 0x49, 0x6c, 0x6c, 0x27, 0x71, 0x61, 0x83, 0xc4, 0x8a, 0x24, 0xc5, 0x8c, 0x24, - 0xf6, 0x11, 0x34, 0x0f, 0x75, 0x77, 0x3f, 0x3a, 0xc6, 0x99, 0x82, 0x5d, 0xca, 0x5b, 0xa4, 0x29, - 0x8b, 0x84, 0x6e, 0xff, 0xd9, 0x16, 0x25, 0x29, 0xfb, 0xf5, 0x82, 0x71, 0x21, 0x0f, 0x35, 0x69, - 0xb6, 0xb5, 0xff, 0x66, 0x40, 0x49, 0x59, 0xb7, 0xa1, 0x38, 0xe7, 0x13, 0x5d, 0x85, 0xb8, 0x24, - 0x03, 0x68, 0x5f, 0x4d, 0x14, 0x47, 0xce, 0x2d, 0x79, 0x7f, 0x6d, 0xff, 0x4e, 0x96, 0xca, 0xcd, - 0x2f, 0x38, 0xd9, 0xc9, 0xa7, 0xc9, 0xa9, 0xaf, 0x4e, 0xed, 0x43, 0x75, 0xb6, 0xd4, 0xb6, 0xa6, - 0xb4, 0xbd, 0x95, 0x37, 0x89, 0x33, 0xb6, 0xca, 0xcc, 0x2a, 0xb3, 0xa5, 0xd2, 0x3f, 0x80, 0x7a, - 0xca, 0x26, 0x41, 0x1c, 0x69, 0x9b, 0x92, 0xb4, 0x69, 0xf6, 0xb3, 0xa9, 0x99, 0x19, 0xd4, 0x94, - 0x96, 0xdc, 0x0e, 0xaa, 0x50, 0xf6, 0x99, 0x70, 0x83, 0xd0, 0x0e, 0x01, 0x0e, 0x55, 0x51, 0x44, - 0xe3, 0x98, 0x7c, 0x0c, 0x35, 0x5d, 0x33, 0x62, 0x95, 0xa8, 0x06, 0xd3, 0xdc, 0xdf, 0xed, 0x6f, - 0x8c, 0xdc, 0xe3, 0x7c, 0xf3, 0x39, 0x13, 0xd3, 0xd8, 0xa7, 0xa0, 0x4c, 0xbe, 0x58, 0x25, 0x4c, - 0xce, 0x54, 0x75, 0xc0, 0x55, 0x3e, 0x74, 0x19, 0x9e, 0xb1, 0x95, 0xfd, 0x3b, 0x13, 0x1a, 0x03, - 0xdd, 0x15, 0x65, 0x38, 0xdf, 0x34, 0x84, 0x37, 0x32, 0x5f, 0xd8, 0x9e, 0xf9, 0xe2, 0xcd, 0xed, - 0xcb, 0x7c, 0x73, 0xfb, 0x2a, 0xbd, 0xd6, 0xbe, 0xee, 0x61, 0x49, 0x0a, 0xe6, 0x84, 0xc1, 0x3c, - 0x10, 0xba, 0x81, 0x59, 0x88, 0x9c, 0x23, 0x40, 0x7a, 0x50, 0xf3, 0xe2, 0x48, 0x11, 0xc6, 0x5b, - 0xc9, 0x1e, 0xd6, 0xa0, 0xeb, 0x10, 0xf9, 0x18, 0x5a, 0x5c, 0xc4, 0xa9, 0x3b, 0x61, 0x0e, 0x66, - 0x9f, 0x45, 0xbe, 0x6c, 0x65, 0x6b, 0x6c, 0x18, 0x2a, 0xf1, 0x40, 0x49, 0x69, 0x93, 0x6f, 0xec, - 0x37, 0xa7, 0x38, 0x6c, 0x4e, 0x71, 0xc5, 0xee, 0x5a, 0xde, 0x02, 0x91, 0x7b, 0xf1, 0x3c, 0x49, - 0x19, 0xc7, 0x8f, 0x57, 0xf9, 0xab, 0xcb, 0xfc, 0xbd, 0x93, 0x73, 0xef, 0x4a, 0x8e, 0xc9, 0xa2, - 0x2d, 0x6f, 0x13, 0x20, 0xef, 0xc1, 0xad, 0xf5, 0x33, 0x42, 0xb6, 0x64, 0xa1, 0x1c, 0xd1, 0x25, - 0xba, 0x7e, 0xf8, 0x39, 0xe2, 0xe4, 0x20, 0xe7, 0x4a, 0x10, 0x8d, 0x63, 0x3d, 0x96, 0x49, 0x7e, - 0x57, 0x4e, 0xaa, 0x8c, 0x1f, 0xb8, 0xfe, 0xcc, 0xac, 0x96, 0xdb, 0x15, 0x3d, 0xcf, 0x7e, 0x5b, - 0x80, 0xe6, 0x66, 0x00, 0x88, 0x0d, 0x66, 0x14, 0xc7, 0x89, 0xe4, 0xc1, 0x5a, 0x5b, 0xbd, 0x88, - 0xe3, 0xe4, 0x64, 0x87, 0x4a, 0x19, 0x79, 0x08, 0xa5, 0x30, 0xf6, 0xdc, 0x50, 0xd2, 0xa1, 0xb6, - 0xdf, 0xc8, 0x94, 0xce, 0x11, 0x3c, 0xd9, 0xa1, 0x4a, 0x4a, 0xbe, 0x03, 0x05, 0x7e, 0xa0, 0xab, - 0x0f, 0xf2, 0x78, 0x1f, 0x9c, 0xec, 0xd0, 0x02, 0x3f, 0x20, 0xf7, 0xa1, 0x38, 0xf1, 0xb8, 0x2e, - 0xb0, 0x5a, 0x26, 0xfe, 0xf4, 0x70, 0x78, 0xb2, 0x43, 0x51, 0x42, 0x3e, 0x82, 0x86, 0x17, 0xc6, - 0x0b, 0xdf, 0xf1, 0x57, 0x91, 0x3b, 0x0f, 0x3c, 0x5d, 0x57, 0xb7, 0xaf, 0xea, 0x38, 0x5e, 0xf8, - 0x47, 0x4a, 0x76, 0xb2, 0x43, 0xeb, 0xde, 0xda, 0x1e, 0xdd, 0x98, 0xfa, 0x63, 0xd5, 0xf0, 0xd6, - 0xdc, 0x38, 0x39, 0xfa, 0x04, 0xcf, 0x97, 0xb2, 0x81, 0x05, 0x15, 0x4d, 0x0a, 0xbb, 0x0c, 0x26, - 0x7a, 0x68, 0xdf, 0x85, 0x92, 0x74, 0x02, 0x7b, 0x3b, 0x46, 0x28, 0x1b, 0xf0, 0x32, 0x5a, 0x5f, - 0x17, 0xa0, 0x30, 0x3c, 0xc0, 0x8e, 0xcd, 0x22, 0x3f, 0x89, 0x03, 0xdd, 0xb3, 0x2c, 0x9a, 0xef, - 0xf1, 0x0d, 0xa0, 0x8a, 0x5c, 0x3f, 0x54, 0xf5, 0x0e, 0xf1, 0xd1, 0xc2, 0x9b, 0x31, 0xa1, 0x9b, - 0xa1, 0xde, 0x21, 0x9e, 0xa4, 0x6c, 0x1c, 0xbc, 0x90, 0x71, 0xb0, 0xa8, 0xde, 0xa9, 0xf2, 0x51, - 0xbc, 0xf5, 0x42, 0x97, 0xab, 0xf6, 0x6e, 0x61, 0xf9, 0x48, 0xf0, 0x10, 0x31, 0xec, 0x7e, 0x9c, - 0x33, 0xe9, 0xa2, 0x45, 0x71, 0x89, 0x88, 0xeb, 0x85, 0xb2, 0x50, 0x2c, 0x8a, 0x4b, 0xac, 0x20, - 0xd7, 0xf3, 0x18, 0xe7, 0xb2, 0x46, 0xab, 0xea, 0x91, 0xa8, 0x10, 0x2c, 0xd3, 0x77, 0xe1, 0x16, - 0x67, 0x5e, 0xca, 0x84, 0xb3, 0xa6, 0x65, 0x49, 0xad, 0x96, 0x12, 0x3c, 0xcd, 0x75, 0xf7, 0xa0, - 0x3d, 0x8e, 0x53, 0x8f, 0x39, 0x18, 0x0c, 0x87, 0x8b, 0x55, 0xc8, 0x74, 0x45, 0x34, 0x25, 0x7e, - 0xe9, 0x8a, 0xe9, 0x10, 0x51, 0xf2, 0x00, 0x9a, 0x9c, 0x33, 0x67, 0x36, 0x97, 0xe7, 0x61, 0x57, - 0x51, 0x45, 0x52, 0xe3, 0x9c, 0x9d, 0xcd, 0xf1, 0xb0, 0x53, 0xdf, 0xfe, 0xd2, 0x80, 0xe2, 0xa7, - 0x87, 0xc3, 0x37, 0x85, 0x53, 0x87, 0xad, 0xb0, 0x25, 0x6c, 0xc5, 0x9b, 0xc3, 0x66, 0x5e, 0x13, - 0xb6, 0x87, 0xd0, 0x4c, 0x52, 0xe6, 0xb3, 0x71, 0x10, 0x31, 0xdf, 0xc1, 0x78, 0xa9, 0xe0, 0x36, - 0xae, 0xd0, 0xa7, 0x5e, 0x88, 0xe3, 0xd3, 0x43, 0x20, 0x12, 0x81, 0x1b, 0x72, 0x67, 0x14, 0xc6, - 0x23, 0x1d, 0xea, 0xd6, 0x1a, 0x3e, 0x08, 0xe3, 0x91, 0xfd, 0x07, 0x03, 0xca, 0x03, 0xf5, 0x65, - 0x6f, 0x47, 0x8e, 0xe2, 0x16, 0x72, 0x98, 0x5b, 0xbc, 0x2c, 0xdd, 0xec, 0x65, 0xf9, 0x75, 0x2f, - 0x71, 0x48, 0xd6, 0xd7, 0x2b, 0x84, 0x3c, 0xca, 0x6f, 0x31, 0xf4, 0x7c, 0xd2, 0x35, 0xa1, 0xbe, - 0x3c, 0xbf, 0xf5, 0x01, 0x34, 0x92, 0x34, 0x5e, 0x06, 0x3e, 0x4b, 0x1d, 0xf9, 0xc6, 0x55, 0xa1, - 0xaf, 0x67, 0xe0, 0x05, 0xbe, 0x75, 0x3f, 0x80, 0x92, 0x2b, 0x44, 0x9a, 0xbd, 0xa9, 0xee, 0x5f, - 0x57, 0x93, 0xfd, 0xa7, 0xa8, 0x71, 0x1c, 0x89, 0x74, 0x45, 0x95, 0x76, 0xf7, 0x09, 0xc0, 0x15, - 0x88, 0x6c, 0xcd, 0x5e, 0x13, 0x16, 0xc5, 0x25, 0xbe, 0x43, 0x96, 0x6e, 0xb8, 0xc8, 0xee, 0x54, - 0x9b, 0x1f, 0x15, 0x9e, 0x18, 0xf6, 0x2e, 0x98, 0x58, 0xbb, 0x2a, 0x86, 0xf3, 0x58, 0x64, 0x4f, - 0x6f, 0xbd, 0xb3, 0x7f, 0x6f, 0x40, 0x33, 0x1b, 0x6b, 0x3c, 0x89, 0x23, 0x8e, 0x2c, 0x2c, 0xa9, - 0x79, 0x6c, 0x6c, 0x76, 0x29, 0x39, 0x7f, 0xa9, 0x92, 0xfd, 0x8f, 0xd3, 0xed, 0x2d, 0xfe, 0xdf, - 0xb4, 0xbf, 0x36, 0xe0, 0xde, 0xf1, 0x0b, 0xc1, 0xd2, 0xc8, 0x0d, 0x75, 0x8f, 0xa5, 0x0c, 0x53, - 0xc4, 0xb2, 0xc1, 0x7b, 0xcd, 0x70, 0x32, 0xfe, 0xab, 0xe1, 0x74, 0x1f, 0x6a, 0xf1, 0xe8, 0x57, - 0xcc, 0x13, 0xeb, 0x89, 0x02, 0x05, 0xc9, 0x34, 0x7d, 0x17, 0x5f, 0x26, 0xf2, 0x4e, 0xa5, 0xa1, - 0x78, 0x57, 0xd3, 0x98, 0x54, 0x79, 0x08, 0x4d, 0x2f, 0x8e, 0x04, 0x8b, 0x84, 0x13, 0xb2, 0x68, - 0x22, 0xa6, 0x7a, 0x52, 0x37, 0x34, 0x7a, 0x2e, 0x41, 0xbb, 0x07, 0xbb, 0xdb, 0x9c, 0x51, 0xe1, - 0xb6, 0xff, 0x64, 0x40, 0xf7, 0x15, 0x95, 0xa1, 0xbb, 0xfc, 0x06, 0x9d, 0x7d, 0xdd, 0x93, 0xe2, - 0x75, 0x9e, 0xdc, 0x83, 0xbb, 0xd7, 0x7e, 0xa6, 0x72, 0xe3, 0xdd, 0x1f, 0x43, 0xeb, 0x95, 0x21, - 0x4d, 0x6a, 0x50, 0xf9, 0xd9, 0xc5, 0xd9, 0xc5, 0x4f, 0x7e, 0x71, 0xd1, 0xde, 0x21, 0x15, 0x28, - 0x9e, 0x3f, 0x7b, 0xdc, 0x36, 0x08, 0x40, 0x79, 0x78, 0xf1, 0xf4, 0xf2, 0xf2, 0x97, 0xed, 0x02, - 0xa9, 0x82, 0xf9, 0x6c, 0xf8, 0xc5, 0x51, 0xbb, 0xb8, 0x7f, 0x0c, 0x65, 0x45, 0x43, 0xf2, 0x11, - 0xe8, 0x5f, 0x53, 0xc8, 0xb7, 0xf3, 0x4a, 0x5b, 0x7f, 0x77, 0x75, 0xef, 0xbc, 0x0a, 0xeb, 0x40, - 0xee, 0xfc, 0xc0, 0xd8, 0xff, 0xab, 0x01, 0xad, 0x57, 0xbe, 0x92, 0x3c, 0xc3, 0x07, 0xb1, 0x8c, - 0x39, 0x79, 0x98, 0x73, 0xf9, 0x26, 0x82, 0x75, 0x1f, 0xbd, 0x49, 0x2d, 0xbb, 0x91, 0xfc, 0x14, - 0x4c, 0xee, 0x2e, 0x19, 0xb1, 0xb7, 0x58, 0xac, 0x65, 0xb2, 0xfb, 0xe0, 0x46, 0x9d, 0xec, 0xc8, - 0xc1, 0xa3, 0x7f, 0xfe, 0xb9, 0x6a, 0x7c, 0xf9, 0x72, 0xd7, 0xf8, 0xfb, 0xcb, 0x5d, 0xe3, 0x5f, - 0x2f, 0x77, 0x8d, 0x3f, 0xfe, 0x7b, 0x77, 0x07, 0xda, 0x71, 0x3a, 0xe9, 0x8b, 0x60, 0xb6, 0xec, - 0xcf, 0x96, 0xf2, 0x27, 0xa1, 0x51, 0x59, 0xfe, 0x39, 0xf8, 0x4f, 0x00, 0x00, 0x00, 0xff, 0xff, - 0x34, 0xb0, 0xf5, 0x9b, 0x88, 0x12, 0x00, 0x00, +func init() { proto.RegisterFile("brpb.proto", fileDescriptor_brpb_ad1bbe2886ef0925) } + +var fileDescriptor_brpb_ad1bbe2886ef0925 = []byte{ + // 1990 bytes of a gzipped FileDescriptorProto + 0x1f, 0x8b, 0x08, 0x00, 0x00, 0x00, 0x00, 0x00, 0x02, 0xff, 0xbc, 0x58, 0x4f, 0x73, 0x1b, 0x49, + 0x15, 0xf7, 0x48, 0xa3, 0x3f, 0xf3, 0xf4, 0x37, 0x4d, 0x36, 0x2b, 0x14, 0xe2, 0x88, 0x49, 0x25, + 0x98, 0xdd, 0x2a, 0xed, 0x62, 0x67, 0xb7, 0x52, 0x6c, 0x51, 0x5b, 0x96, 0xed, 0xac, 0xbd, 0xf6, + 0x1a, 0xd3, 0x32, 0x50, 0xe4, 0x32, 0x35, 0x9a, 0x69, 0xd9, 0x83, 0x46, 0x33, 0xc3, 0x74, 0x4b, + 0x89, 0xf8, 0x00, 0x1c, 0xb8, 0x50, 0xdc, 0xf8, 0x02, 0x54, 0xf1, 0x21, 0x38, 0x70, 0xdc, 0xad, + 0xe5, 0x00, 0xc5, 0x85, 0x23, 0x15, 0xbe, 0x08, 0xf5, 0xba, 0x7b, 0xc6, 0x52, 0x62, 0x39, 0x81, + 0xa2, 0xf6, 0xe4, 0xee, 0xdf, 0x7b, 0xdd, 0x3d, 0xfd, 0xde, 0xef, 0xfd, 0x5e, 0x5b, 0x00, 0xa3, + 0x34, 0x19, 0xf5, 0x93, 0x34, 0x16, 0x31, 0x29, 0x8f, 0x5c, 0x6f, 0x32, 0x4b, 0xba, 0x8d, 0xc9, + 0x3c, 0x4d, 0xbc, 0x0c, 0xee, 0x36, 0x58, 0x9a, 0xc6, 0xb9, 0x57, 0x97, 0xb0, 0xc8, 0x4b, 0x17, + 0x89, 0x08, 0xe2, 0x28, 0xc7, 0x6e, 0x5f, 0xc4, 0x17, 0xb1, 0x1c, 0x7e, 0x80, 0x23, 0x8d, 0xb6, + 0xd2, 0x19, 0x17, 0x72, 0xa8, 0x00, 0xfb, 0xcf, 0x25, 0x80, 0x81, 0x3c, 0xe3, 0x0b, 0x26, 0x5c, + 0x72, 0x0f, 0xc0, 0x0b, 0x67, 0x5c, 0xb0, 0xd4, 0x09, 0xfc, 0x8e, 0xd1, 0x33, 0xb6, 0x4c, 0x6a, + 0x69, 0xe4, 0xc8, 0x27, 0xdf, 0x83, 0x56, 0x66, 0x9e, 0xb3, 0x94, 0x07, 0x71, 0xd4, 0x29, 0xf4, + 0x8c, 0x2d, 0x8b, 0x36, 0x35, 0xfc, 0x33, 0x85, 0x12, 0x1b, 0x4a, 0xe3, 0x20, 0x64, 0xbc, 0x63, + 0xf6, 0x8a, 0x5b, 0xb5, 0xed, 0x7a, 0x5f, 0xdd, 0xa3, 0xff, 0x34, 0x08, 0x19, 0x55, 0x26, 0xf2, + 0x00, 0x1a, 0x5c, 0xb8, 0xa9, 0xc8, 0xb7, 0x2a, 0xc9, 0xe3, 0xea, 0x12, 0xcc, 0x36, 0xba, 0x0f, + 0x35, 0x16, 0xf9, 0xb9, 0x4b, 0x59, 0xba, 0x00, 0x8b, 0xfc, 0xcc, 0x61, 0x0b, 0x2a, 0xdc, 0xbb, + 0x64, 0x53, 0x97, 0x77, 0x2a, 0xf2, 0xac, 0x66, 0x76, 0xd6, 0x50, 0xc2, 0x34, 0x33, 0x93, 0x2e, + 0x58, 0x01, 0x77, 0x52, 0xf7, 0xb9, 0x33, 0x99, 0x77, 0xaa, 0x3d, 0x63, 0xab, 0x4a, 0x2b, 0x01, + 0xa7, 0xee, 0xf3, 0xe3, 0x39, 0xf9, 0x00, 0x00, 0x0d, 0xa9, 0x1b, 0x5d, 0x30, 0xde, 0xb1, 0xe4, + 0x46, 0xed, 0x6c, 0x23, 0xea, 0x3e, 0xa7, 0x68, 0xa0, 0x56, 0xaa, 0x47, 0x9c, 0x10, 0x30, 0x7d, + 0x3f, 0xe4, 0x1d, 0xe8, 0x19, 0x5b, 0x75, 0x2a, 0xc7, 0x18, 0xbc, 0xd1, 0x55, 0x60, 0x6a, 0x32, + 0x30, 0xd6, 0x28, 0x8f, 0x49, 0x07, 0x2a, 0x99, 0xad, 0xde, 0x33, 0xb6, 0x4a, 0x34, 0x9b, 0xe2, + 0xe9, 0x18, 0x12, 0x27, 0x88, 0x7c, 0xf6, 0xa2, 0xd3, 0xe8, 0x19, 0xcb, 0xa7, 0x63, 0x5e, 0x64, + 0xd8, 0x2c, 0xf4, 0x39, 0x42, 0x17, 0xb2, 0x03, 0x75, 0x75, 0x2b, 0xbd, 0xa4, 0xb9, 0x66, 0x49, + 0x4d, 0x79, 0xa9, 0x45, 0x4f, 0xa0, 0x95, 0xdf, 0x51, 0xaf, 0x6b, 0xad, 0x59, 0xd7, 0xc8, 0x2e, + 0xaa, 0x56, 0xfe, 0x00, 0x6a, 0xbe, 0x1f, 0xaa, 0x35, 0x8c, 0x77, 0xda, 0x6b, 0x56, 0x81, 0xef, + 0x87, 0x47, 0xca, 0x07, 0x93, 0xab, 0xcc, 0x4e, 0xca, 0xf8, 0x2c, 0x14, 0x9d, 0x5b, 0x32, 0x1c, + 0x75, 0x05, 0x52, 0x89, 0x91, 0xc7, 0x50, 0x73, 0x93, 0x20, 0x8f, 0x18, 0xe9, 0x19, 0x5b, 0xcd, + 0xed, 0x6f, 0xf5, 0x33, 0xae, 0xef, 0x9e, 0x1d, 0xe9, 0xd8, 0x51, 0x70, 0x93, 0x40, 0x8f, 0x3f, + 0x37, 0xab, 0xc5, 0xb6, 0x49, 0xcd, 0xc4, 0x15, 0x97, 0xf6, 0x57, 0x05, 0x30, 0xf1, 0x6c, 0xcc, + 0x47, 0xe4, 0x4e, 0x99, 0xa4, 0xac, 0x45, 0xe5, 0x98, 0xdc, 0x81, 0x32, 0xbf, 0x74, 0xb7, 0x3f, + 0xfa, 0x58, 0x92, 0xb4, 0x4e, 0xf5, 0x8c, 0xdc, 0x05, 0x4b, 0x11, 0x6f, 0xc2, 0x16, 0x9d, 0xa2, + 0x34, 0x55, 0x25, 0x70, 0xcc, 0x16, 0xe4, 0x5d, 0xa8, 0x20, 0xe1, 0xd0, 0x64, 0xaa, 0x55, 0x2c, + 0xf2, 0xd1, 0xf0, 0xff, 0xa1, 0x6b, 0x17, 0xaa, 0x5e, 0xea, 0x7d, 0xfc, 0xf8, 0x45, 0x9c, 0x76, + 0x2a, 0xd2, 0x9a, 0xcf, 0xf1, 0xbb, 0x44, 0x2c, 0xdc, 0xd0, 0x99, 0xcc, 0xb9, 0x24, 0xa8, 0x49, + 0xab, 0x12, 0x38, 0x9e, 0x73, 0xdc, 0x59, 0x19, 0x47, 0x0b, 0x21, 0x29, 0x2a, 0x77, 0x96, 0xd0, + 0x00, 0x11, 0xd2, 0x84, 0x82, 0x37, 0x96, 0x7c, 0xb4, 0x68, 0xc1, 0x1b, 0x63, 0x44, 0x78, 0xf0, + 0x6b, 0x26, 0x79, 0x68, 0x52, 0x39, 0xc6, 0x13, 0xbc, 0x20, 0xb9, 0xc4, 0xea, 0x9e, 0x4b, 0x12, + 0xd6, 0x69, 0x55, 0x01, 0x47, 0x73, 0xfb, 0x1f, 0x06, 0x54, 0xb3, 0x5c, 0x92, 0xf7, 0x01, 0xa6, + 0x4c, 0xb8, 0x8e, 0xaa, 0x62, 0xe3, 0x9a, 0x2a, 0xb6, 0xa6, 0xda, 0x97, 0xa3, 0xb3, 0xef, 0xe6, + 0xce, 0x85, 0xeb, 0x9c, 0xd1, 0xae, 0x9c, 0x97, 0x0a, 0xb6, 0x78, 0x73, 0xc1, 0xae, 0x16, 0xa5, + 0xf9, 0xf6, 0x45, 0x59, 0xea, 0x15, 0xb3, 0xa2, 0xb4, 0xbf, 0x32, 0xa0, 0xac, 0x36, 0xc6, 0x08, + 0xf9, 0x23, 0xc9, 0x90, 0x3a, 0x2d, 0xf8, 0x23, 0x72, 0x1b, 0x4a, 0xc2, 0x1d, 0x85, 0x4c, 0xd3, + 0x43, 0x4d, 0x56, 0x32, 0x54, 0xbc, 0x29, 0x43, 0xe6, 0xcd, 0x19, 0x2a, 0xbd, 0x96, 0xa1, 0xef, + 0x43, 0x5b, 0x04, 0xe3, 0xd0, 0xe5, 0x97, 0x4e, 0xca, 0x92, 0x30, 0xf0, 0x5c, 0x2e, 0x19, 0xd2, + 0xa0, 0x2d, 0x8d, 0x53, 0x0d, 0xe3, 0xa7, 0x71, 0xe1, 0x0a, 0x2e, 0x39, 0x52, 0xa7, 0x6a, 0x62, + 0x9f, 0x41, 0x35, 0xbb, 0xf6, 0x2a, 0x89, 0x8d, 0xf5, 0x24, 0x2e, 0xac, 0x90, 0x58, 0x91, 0xa4, + 0x98, 0x91, 0xc4, 0xde, 0x87, 0xe6, 0x9e, 0x56, 0xf7, 0xfd, 0x03, 0xec, 0x29, 0xa8, 0x52, 0xde, + 0x2c, 0x4d, 0x59, 0x24, 0xb4, 0xfc, 0x67, 0x53, 0xb4, 0xa4, 0xec, 0x57, 0x33, 0xc6, 0x85, 0xdc, + 0xd4, 0xa4, 0xd9, 0xd4, 0xfe, 0xab, 0x01, 0x25, 0xb5, 0xba, 0x0d, 0xc5, 0x29, 0xbf, 0xd0, 0x55, + 0x88, 0x43, 0x32, 0x80, 0xf6, 0x55, 0x47, 0x71, 0x64, 0xdf, 0x92, 0xe7, 0xd7, 0xb6, 0xef, 0x64, + 0xa9, 0x5c, 0xfd, 0x82, 0xc3, 0x8d, 0xbc, 0x9b, 0x1c, 0xf9, 0x6a, 0xd7, 0x3e, 0x54, 0x27, 0x73, + 0xbd, 0xd6, 0x94, 0x6b, 0x6f, 0xe5, 0x22, 0x71, 0xcc, 0x16, 0xd9, 0xb2, 0xca, 0x64, 0xae, 0xfc, + 0x77, 0xa0, 0x9e, 0xb2, 0x8b, 0x20, 0x8e, 0xf4, 0x9a, 0x92, 0x5c, 0xd3, 0xec, 0x67, 0x5d, 0x33, + 0x5b, 0x50, 0x53, 0x5e, 0x72, 0x3a, 0xa8, 0x42, 0xd9, 0x67, 0xc2, 0x0d, 0x42, 0x3b, 0x04, 0xd8, + 0x53, 0x45, 0x11, 0x8d, 0x63, 0xf2, 0x29, 0xd4, 0x74, 0xcd, 0x88, 0x45, 0xa2, 0x04, 0xa6, 0xb9, + 0xbd, 0xd9, 0x5f, 0x69, 0xb9, 0x07, 0xf9, 0xe4, 0x0b, 0x26, 0x2e, 0x63, 0x9f, 0x82, 0x5a, 0x72, + 0xbe, 0x48, 0x98, 0xec, 0xa9, 0x6a, 0x83, 0xab, 0x7c, 0xe8, 0x32, 0x3c, 0x66, 0x0b, 0xfb, 0xb7, + 0x26, 0x34, 0x06, 0x5a, 0x15, 0x65, 0x38, 0xdf, 0xd4, 0x84, 0x57, 0x32, 0x5f, 0x58, 0x9f, 0xf9, + 0xe2, 0xcd, 0xf2, 0x65, 0xbe, 0x59, 0xbe, 0x4a, 0xaf, 0xc9, 0xd7, 0x3d, 0x2c, 0x49, 0xc1, 0x9c, + 0x30, 0x98, 0x06, 0x42, 0x0b, 0x98, 0x85, 0xc8, 0x09, 0x02, 0xa4, 0x07, 0x35, 0x2f, 0x8e, 0x14, + 0x61, 0xbc, 0x85, 0xd4, 0xb0, 0x06, 0x5d, 0x86, 0xc8, 0xa7, 0xd0, 0xe2, 0x22, 0x4e, 0xdd, 0x0b, + 0xe6, 0x60, 0xf6, 0x59, 0xe4, 0x4b, 0x29, 0x5b, 0x62, 0xc3, 0x50, 0x99, 0x07, 0xca, 0x4a, 0x9b, + 0x7c, 0x65, 0xbe, 0xda, 0xc5, 0x61, 0xb5, 0x8b, 0x2b, 0x76, 0xd7, 0x72, 0x09, 0x44, 0xee, 0xc5, + 0xd3, 0x24, 0x65, 0x1c, 0x3f, 0x5e, 0xe5, 0xaf, 0x2e, 0xf3, 0xf7, 0x6e, 0xce, 0xbd, 0x2b, 0x3b, + 0x26, 0x8b, 0xb6, 0xbc, 0x55, 0x80, 0xbc, 0x0f, 0xb7, 0x96, 0xf7, 0x08, 0xd9, 0x9c, 0x85, 0xb2, + 0x45, 0x97, 0xe8, 0xf2, 0xe6, 0x27, 0x88, 0x93, 0x9d, 0x9c, 0x2b, 0x41, 0x34, 0x8e, 0x75, 0x5b, + 0x26, 0xf9, 0x59, 0x39, 0xa9, 0x32, 0x7e, 0xe0, 0xf8, 0x73, 0xb3, 0x5a, 0x6e, 0x57, 0x74, 0x3f, + 0xfb, 0xbb, 0x01, 0xb7, 0x87, 0x22, 0x65, 0xee, 0x54, 0x51, 0xe2, 0xdc, 0xe5, 0x13, 0xc9, 0xc2, + 0x0f, 0xa1, 0xa2, 0x03, 0x21, 0x09, 0xb1, 0x3e, 0x5e, 0x99, 0x1b, 0xf9, 0x36, 0x28, 0x56, 0x38, + 0x82, 0x67, 0xf5, 0x2a, 0xe7, 0xe7, 0x9c, 0xbc, 0x03, 0xc8, 0x0a, 0x34, 0x28, 0x81, 0x2b, 0xb1, + 0xc8, 0x3f, 0xe7, 0x79, 0x0f, 0x35, 0x97, 0x7a, 0xe8, 0x77, 0xa1, 0x2e, 0x65, 0x11, 0xb5, 0x5d, + 0xb0, 0x54, 0x4a, 0xab, 0x45, 0x6b, 0x12, 0x7b, 0x2a, 0x21, 0xda, 0x0c, 0x5d, 0x2e, 0x9c, 0x59, + 0xe2, 0x23, 0x31, 0x04, 0xa7, 0x65, 0x25, 0xd8, 0xb4, 0x8c, 0xa2, 0x35, 0xe3, 0xf6, 0x6f, 0x0a, + 0xd0, 0x5c, 0xfd, 0x48, 0x62, 0x83, 0x19, 0xc5, 0x71, 0xa2, 0xaf, 0x92, 0xb7, 0x8a, 0xd3, 0x38, + 0x4e, 0x0e, 0x37, 0xa8, 0xb4, 0x91, 0x87, 0x50, 0x0a, 0x63, 0xcf, 0x0d, 0xe5, 0xc7, 0xd7, 0xb6, + 0x1b, 0x99, 0xd3, 0x09, 0x82, 0x87, 0x1b, 0x54, 0x59, 0xc9, 0x77, 0xa0, 0xc0, 0x77, 0xb4, 0xa2, + 0x40, 0x1e, 0x93, 0x9d, 0xc3, 0x0d, 0x5a, 0xe0, 0x3b, 0xe4, 0x3e, 0x14, 0x2f, 0x3c, 0xae, 0x45, + 0xa3, 0x96, 0x99, 0x3f, 0xdb, 0x1b, 0x1e, 0x6e, 0x50, 0xb4, 0x90, 0x4f, 0xa0, 0xe1, 0x85, 0xf1, + 0xcc, 0x77, 0xfc, 0x45, 0xe4, 0x4e, 0x03, 0x4f, 0x6b, 0xc5, 0xed, 0x2b, 0x6d, 0x8a, 0x67, 0xfe, + 0xbe, 0xb2, 0x1d, 0x6e, 0xd0, 0xba, 0xb7, 0x34, 0xc7, 0x6b, 0x5c, 0xfa, 0x63, 0x25, 0xe2, 0x4b, + 0xd7, 0x38, 0xdc, 0x7f, 0x8a, 0xfb, 0x4b, 0xdb, 0xc0, 0x82, 0x8a, 0x26, 0xba, 0x5d, 0x06, 0x13, + 0x6f, 0x68, 0xdf, 0x85, 0x92, 0xbc, 0x04, 0x06, 0x1c, 0xb3, 0x9e, 0x3d, 0x5a, 0x24, 0x03, 0xbe, + 0x2e, 0x40, 0x61, 0xb8, 0x83, 0x5d, 0x88, 0x45, 0x7e, 0x12, 0x07, 0x5a, 0x87, 0x2d, 0x9a, 0xcf, + 0xf1, 0x5d, 0xa3, 0x84, 0x4b, 0x3f, 0xbe, 0xf5, 0x0c, 0xf1, 0xd1, 0xcc, 0x9b, 0x30, 0xa1, 0x05, + 0x5e, 0xcf, 0x10, 0x4f, 0x52, 0x36, 0x0e, 0x5e, 0xe8, 0xcc, 0xea, 0x99, 0x92, 0x04, 0x55, 0x8b, + 0x5e, 0xe8, 0x72, 0xd5, 0xb2, 0x2c, 0x94, 0x04, 0x09, 0xee, 0x21, 0x86, 0x8a, 0xce, 0x39, 0x93, + 0x57, 0xb4, 0x28, 0x0e, 0x11, 0x71, 0xbd, 0x50, 0x16, 0xbf, 0x45, 0x71, 0x88, 0xaa, 0xe0, 0x7a, + 0x1e, 0xe3, 0x5c, 0xea, 0x4e, 0x55, 0x3d, 0x7c, 0x15, 0x82, 0xd2, 0xf3, 0x1e, 0xdc, 0xe2, 0xcc, + 0x4b, 0x99, 0x70, 0x96, 0xbc, 0x2c, 0xe9, 0xd5, 0x52, 0x86, 0xdd, 0xdc, 0x77, 0x0b, 0xda, 0xe3, + 0x38, 0xf5, 0x98, 0x83, 0xc1, 0x70, 0xb8, 0x58, 0x84, 0x4c, 0x57, 0x79, 0x53, 0xe2, 0x67, 0xae, + 0xb8, 0x1c, 0x22, 0x4a, 0x1e, 0x40, 0x93, 0x73, 0xe6, 0x4c, 0xa6, 0x72, 0x3f, 0x54, 0x4a, 0x55, + 0xf8, 0x35, 0xce, 0xd9, 0xf1, 0x14, 0x37, 0x3b, 0xf2, 0xed, 0x2f, 0x0d, 0x28, 0x7e, 0xb6, 0x37, + 0x7c, 0x53, 0x38, 0x75, 0xd8, 0x0a, 0x6b, 0xc2, 0x56, 0xbc, 0x39, 0x6c, 0xe6, 0x35, 0x61, 0x7b, + 0x08, 0xcd, 0x24, 0x65, 0x3e, 0x1b, 0x07, 0x11, 0xf3, 0x1d, 0x8c, 0x97, 0x0a, 0x6e, 0xe3, 0x0a, + 0xdd, 0xf5, 0x42, 0x7c, 0x12, 0x78, 0x08, 0x44, 0x22, 0x70, 0x43, 0xee, 0x8c, 0xc2, 0x78, 0xa4, + 0x43, 0xdd, 0x5a, 0xc2, 0x07, 0x61, 0x3c, 0xb2, 0x7f, 0x6f, 0x40, 0x79, 0xa0, 0xbe, 0xec, 0xed, + 0xc8, 0x51, 0x5c, 0x43, 0x0e, 0x73, 0xcd, 0x2d, 0x4b, 0x37, 0xdf, 0xb2, 0xfc, 0xfa, 0x2d, 0xb1, + 0xf1, 0xd7, 0x97, 0x2b, 0x84, 0x3c, 0xca, 0x4f, 0x31, 0x74, 0xcf, 0xd5, 0x35, 0xa1, 0xbe, 0x3c, + 0x3f, 0xf5, 0x01, 0x34, 0x92, 0x34, 0x9e, 0x07, 0x3e, 0x4b, 0x1d, 0xa9, 0x39, 0x2a, 0xf4, 0xf5, + 0x0c, 0x3c, 0x45, 0xed, 0xf9, 0x08, 0x4a, 0xae, 0x10, 0x69, 0xf6, 0x4e, 0xbc, 0x7f, 0x5d, 0x4d, + 0xf6, 0x77, 0xd1, 0xe3, 0x20, 0x12, 0xe9, 0x82, 0x2a, 0xef, 0xee, 0x13, 0x80, 0x2b, 0x10, 0xd9, + 0x9a, 0xbd, 0x90, 0x2c, 0x8a, 0x43, 0x7c, 0x5b, 0xcd, 0xdd, 0x70, 0x96, 0x9d, 0xa9, 0x26, 0x3f, + 0x2c, 0x3c, 0x31, 0xec, 0x4d, 0x30, 0xb1, 0x76, 0x55, 0x0c, 0xa7, 0xb1, 0xc8, 0xfe, 0x9d, 0xd0, + 0x33, 0xfb, 0x77, 0x06, 0x34, 0xb3, 0x56, 0xcd, 0x93, 0x38, 0xe2, 0xc8, 0xc2, 0x92, 0x7a, 0x63, + 0x18, 0xab, 0x2a, 0x25, 0xdf, 0x14, 0x54, 0xd9, 0xfe, 0xc7, 0x8e, 0xfd, 0x16, 0xff, 0x43, 0xdb, + 0x5f, 0x1b, 0x70, 0xef, 0xe0, 0x85, 0x60, 0x69, 0xe4, 0x86, 0x5a, 0x63, 0x29, 0xc3, 0x14, 0xb1, + 0xec, 0x31, 0x71, 0x4d, 0xc3, 0x35, 0xfe, 0xab, 0x86, 0x7b, 0x1f, 0x6a, 0xf1, 0xe8, 0x97, 0xcc, + 0x13, 0xcb, 0x89, 0x02, 0x05, 0x9d, 0xea, 0x16, 0x91, 0xaa, 0x33, 0x95, 0x87, 0xe2, 0x5d, 0x4d, + 0x63, 0xd2, 0xe5, 0x21, 0x34, 0xbd, 0x38, 0x12, 0x2c, 0x12, 0x4e, 0xc8, 0xa2, 0x0b, 0x71, 0xa9, + 0x5f, 0x1f, 0x0d, 0x8d, 0x9e, 0x48, 0xd0, 0xee, 0xc1, 0xe6, 0xba, 0xcb, 0xa8, 0x70, 0xdb, 0x7f, + 0x34, 0xa0, 0xfb, 0x8a, 0xcb, 0xd0, 0x9d, 0x7f, 0x83, 0x97, 0x7d, 0xfd, 0x26, 0xc5, 0xeb, 0x6e, + 0x72, 0x0f, 0xee, 0x5e, 0xfb, 0x99, 0xea, 0x1a, 0xef, 0xfd, 0x08, 0x5a, 0xaf, 0x3c, 0x3c, 0x48, + 0x0d, 0x2a, 0x3f, 0x3d, 0x3d, 0x3e, 0xfd, 0xf1, 0xcf, 0x4f, 0xdb, 0x1b, 0xa4, 0x02, 0xc5, 0x93, + 0x67, 0x8f, 0xdb, 0x06, 0x01, 0x28, 0x0f, 0x4f, 0x77, 0xcf, 0xce, 0x7e, 0xd1, 0x2e, 0x90, 0x2a, + 0x98, 0xcf, 0x86, 0xe7, 0xfb, 0xed, 0xe2, 0xf6, 0x01, 0x94, 0x15, 0x0d, 0xc9, 0x27, 0xa0, 0x7f, + 0x21, 0x22, 0xef, 0xe4, 0x95, 0xb6, 0xfc, 0x96, 0xec, 0xde, 0x79, 0x15, 0xd6, 0x81, 0xdc, 0xf8, + 0xd0, 0xd8, 0xfe, 0x8b, 0x01, 0xad, 0x57, 0xbe, 0x92, 0x3c, 0xc3, 0x47, 0xbe, 0x8c, 0x39, 0x79, + 0x98, 0x73, 0xf9, 0x26, 0x82, 0x75, 0x1f, 0xbd, 0xc9, 0x2d, 0x3b, 0x91, 0xfc, 0x04, 0x4c, 0xee, + 0xce, 0x19, 0xb1, 0xd7, 0xac, 0x58, 0xca, 0x64, 0xf7, 0xc1, 0x8d, 0x3e, 0xd9, 0x96, 0x83, 0x47, + 0xff, 0xfc, 0x53, 0xd5, 0xf8, 0xf2, 0xe5, 0xa6, 0xf1, 0xb7, 0x97, 0x9b, 0xc6, 0xbf, 0x5e, 0x6e, + 0x1a, 0x7f, 0xf8, 0xf7, 0xe6, 0x06, 0xb4, 0xe3, 0xf4, 0xa2, 0x2f, 0x82, 0xc9, 0xbc, 0x3f, 0x99, + 0xcb, 0x9f, 0xb9, 0x46, 0x65, 0xf9, 0x67, 0xe7, 0x3f, 0x01, 0x00, 0x00, 0xff, 0xff, 0x46, 0xe5, + 0x31, 0xae, 0x5c, 0x13, 0x00, 0x00, } diff --git a/proto/brpb.proto b/proto/brpb.proto index 906bbadca..370d5e7b5 100644 --- a/proto/brpb.proto +++ b/proto/brpb.proto @@ -184,6 +184,39 @@ message BackupRequest { CipherInfo cipher_info = 14; } +message StreamBackupTaskInfo { + // The storage for backup, parsed by BR. + StorageBackend storage = 1; + // The time range for backing up. + uint64 start_ts = 2; + uint64 end_ts = 3; + + // Misc meta datas. + // The name of the task, also the ID of the task. + string name = 4; + // The table filter of the task. + // Only for displaying the task info. + repeated string table_filter = 5; + + // The last timestamp of the task has been updated. + // This is a simple solution for unfrequent config changing: + // When we watched a config change(via polling or etcd watching), + // We perform a incremental scan between [last_update_ts, now), + // for filling the diff data during conf changing. + // The current implementation scan [0, now) for every task ranges newly added, + // So this field is reserved for future usage. + reserved "last_update_ts"; + + // We use '/tidb/br-stream/ranges// -> ' + //for storing all the target ranges of the task, the "ranges" field will not be saved in the taskinfo. + reserved "ranges"; + + // The status field allow us mark the task as 'paused'. + // We use '/tidb/br-stream/pause/ -> ()' for pausing a task for now. + // If we need more complexed status transforming, maybe add the status field back would be fine. + reserved "status"; +} + message StorageBackend { oneof backend { Noop noop = 1; From 404125cde7bb091d61ef13c7f6e1b32d18dbcacc Mon Sep 17 00:00:00 2001 From: Yu Juncen Date: Tue, 23 Nov 2021 16:44:31 +0800 Subject: [PATCH 2/2] br: align the spaces --- pkg/brpb/brpb.pb.go | 52 ++++++++++++++++++++++----------------------- proto/brpb.proto | 2 +- 2 files changed, 27 insertions(+), 27 deletions(-) diff --git a/pkg/brpb/brpb.pb.go b/pkg/brpb/brpb.pb.go index 291bc7403..a7201d8d3 100644 --- a/pkg/brpb/brpb.pb.go +++ b/pkg/brpb/brpb.pb.go @@ -61,7 +61,7 @@ func (x CompressionType) String() string { return proto.EnumName(CompressionType_name, int32(x)) } func (CompressionType) EnumDescriptor() ([]byte, []int) { - return fileDescriptor_brpb_ad1bbe2886ef0925, []int{0} + return fileDescriptor_brpb_bb8e335ec668bcb4, []int{0} } // The message save the metadata of a backup. @@ -120,7 +120,7 @@ func (m *BackupMeta) Reset() { *m = BackupMeta{} } func (m *BackupMeta) String() string { return proto.CompactTextString(m) } func (*BackupMeta) ProtoMessage() {} func (*BackupMeta) Descriptor() ([]byte, []int) { - return fileDescriptor_brpb_ad1bbe2886ef0925, []int{0} + return fileDescriptor_brpb_bb8e335ec668bcb4, []int{0} } func (m *BackupMeta) XXX_Unmarshal(b []byte) error { return m.Unmarshal(b) @@ -291,7 +291,7 @@ func (m *File) Reset() { *m = File{} } func (m *File) String() string { return proto.CompactTextString(m) } func (*File) ProtoMessage() {} func (*File) Descriptor() ([]byte, []int) { - return fileDescriptor_brpb_ad1bbe2886ef0925, []int{1} + return fileDescriptor_brpb_bb8e335ec668bcb4, []int{1} } func (m *File) XXX_Unmarshal(b []byte) error { return m.Unmarshal(b) @@ -426,7 +426,7 @@ func (m *MetaFile) Reset() { *m = MetaFile{} } func (m *MetaFile) String() string { return proto.CompactTextString(m) } func (*MetaFile) ProtoMessage() {} func (*MetaFile) Descriptor() ([]byte, []int) { - return fileDescriptor_brpb_ad1bbe2886ef0925, []int{2} + return fileDescriptor_brpb_bb8e335ec668bcb4, []int{2} } func (m *MetaFile) XXX_Unmarshal(b []byte) error { return m.Unmarshal(b) @@ -509,7 +509,7 @@ func (m *Schema) Reset() { *m = Schema{} } func (m *Schema) String() string { return proto.CompactTextString(m) } func (*Schema) ProtoMessage() {} func (*Schema) Descriptor() ([]byte, []int) { - return fileDescriptor_brpb_ad1bbe2886ef0925, []int{3} + return fileDescriptor_brpb_bb8e335ec668bcb4, []int{3} } func (m *Schema) XXX_Unmarshal(b []byte) error { return m.Unmarshal(b) @@ -600,7 +600,7 @@ func (m *RawRange) Reset() { *m = RawRange{} } func (m *RawRange) String() string { return proto.CompactTextString(m) } func (*RawRange) ProtoMessage() {} func (*RawRange) Descriptor() ([]byte, []int) { - return fileDescriptor_brpb_ad1bbe2886ef0925, []int{4} + return fileDescriptor_brpb_bb8e335ec668bcb4, []int{4} } func (m *RawRange) XXX_Unmarshal(b []byte) error { return m.Unmarshal(b) @@ -662,7 +662,7 @@ func (m *ClusterIDError) Reset() { *m = ClusterIDError{} } func (m *ClusterIDError) String() string { return proto.CompactTextString(m) } func (*ClusterIDError) ProtoMessage() {} func (*ClusterIDError) Descriptor() ([]byte, []int) { - return fileDescriptor_brpb_ad1bbe2886ef0925, []int{5} + return fileDescriptor_brpb_bb8e335ec668bcb4, []int{5} } func (m *ClusterIDError) XXX_Unmarshal(b []byte) error { return m.Unmarshal(b) @@ -721,7 +721,7 @@ func (m *Error) Reset() { *m = Error{} } func (m *Error) String() string { return proto.CompactTextString(m) } func (*Error) ProtoMessage() {} func (*Error) Descriptor() ([]byte, []int) { - return fileDescriptor_brpb_ad1bbe2886ef0925, []int{6} + return fileDescriptor_brpb_bb8e335ec668bcb4, []int{6} } func (m *Error) XXX_Unmarshal(b []byte) error { return m.Unmarshal(b) @@ -910,7 +910,7 @@ func (m *CipherInfo) Reset() { *m = CipherInfo{} } func (m *CipherInfo) String() string { return proto.CompactTextString(m) } func (*CipherInfo) ProtoMessage() {} func (*CipherInfo) Descriptor() ([]byte, []int) { - return fileDescriptor_brpb_ad1bbe2886ef0925, []int{7} + return fileDescriptor_brpb_bb8e335ec668bcb4, []int{7} } func (m *CipherInfo) XXX_Unmarshal(b []byte) error { return m.Unmarshal(b) @@ -983,7 +983,7 @@ func (m *BackupRequest) Reset() { *m = BackupRequest{} } func (m *BackupRequest) String() string { return proto.CompactTextString(m) } func (*BackupRequest) ProtoMessage() {} func (*BackupRequest) Descriptor() ([]byte, []int) { - return fileDescriptor_brpb_ad1bbe2886ef0925, []int{8} + return fileDescriptor_brpb_bb8e335ec668bcb4, []int{8} } func (m *BackupRequest) XXX_Unmarshal(b []byte) error { return m.Unmarshal(b) @@ -1124,7 +1124,7 @@ func (m *StreamBackupTaskInfo) Reset() { *m = StreamBackupTaskInfo{} } func (m *StreamBackupTaskInfo) String() string { return proto.CompactTextString(m) } func (*StreamBackupTaskInfo) ProtoMessage() {} func (*StreamBackupTaskInfo) Descriptor() ([]byte, []int) { - return fileDescriptor_brpb_ad1bbe2886ef0925, []int{9} + return fileDescriptor_brpb_bb8e335ec668bcb4, []int{9} } func (m *StreamBackupTaskInfo) XXX_Unmarshal(b []byte) error { return m.Unmarshal(b) @@ -1206,7 +1206,7 @@ func (m *StorageBackend) Reset() { *m = StorageBackend{} } func (m *StorageBackend) String() string { return proto.CompactTextString(m) } func (*StorageBackend) ProtoMessage() {} func (*StorageBackend) Descriptor() ([]byte, []int) { - return fileDescriptor_brpb_ad1bbe2886ef0925, []int{10} + return fileDescriptor_brpb_bb8e335ec668bcb4, []int{10} } func (m *StorageBackend) XXX_Unmarshal(b []byte) error { return m.Unmarshal(b) @@ -1477,7 +1477,7 @@ func (m *Noop) Reset() { *m = Noop{} } func (m *Noop) String() string { return proto.CompactTextString(m) } func (*Noop) ProtoMessage() {} func (*Noop) Descriptor() ([]byte, []int) { - return fileDescriptor_brpb_ad1bbe2886ef0925, []int{11} + return fileDescriptor_brpb_bb8e335ec668bcb4, []int{11} } func (m *Noop) XXX_Unmarshal(b []byte) error { return m.Unmarshal(b) @@ -1518,7 +1518,7 @@ func (m *Local) Reset() { *m = Local{} } func (m *Local) String() string { return proto.CompactTextString(m) } func (*Local) ProtoMessage() {} func (*Local) Descriptor() ([]byte, []int) { - return fileDescriptor_brpb_ad1bbe2886ef0925, []int{12} + return fileDescriptor_brpb_bb8e335ec668bcb4, []int{12} } func (m *Local) XXX_Unmarshal(b []byte) error { return m.Unmarshal(b) @@ -1578,7 +1578,7 @@ func (m *S3) Reset() { *m = S3{} } func (m *S3) String() string { return proto.CompactTextString(m) } func (*S3) ProtoMessage() {} func (*S3) Descriptor() ([]byte, []int) { - return fileDescriptor_brpb_ad1bbe2886ef0925, []int{13} + return fileDescriptor_brpb_bb8e335ec668bcb4, []int{13} } func (m *S3) XXX_Unmarshal(b []byte) error { return m.Unmarshal(b) @@ -1707,7 +1707,7 @@ func (m *GCS) Reset() { *m = GCS{} } func (m *GCS) String() string { return proto.CompactTextString(m) } func (*GCS) ProtoMessage() {} func (*GCS) Descriptor() ([]byte, []int) { - return fileDescriptor_brpb_ad1bbe2886ef0925, []int{14} + return fileDescriptor_brpb_bb8e335ec668bcb4, []int{14} } func (m *GCS) XXX_Unmarshal(b []byte) error { return m.Unmarshal(b) @@ -1793,7 +1793,7 @@ func (m *Bucket) Reset() { *m = Bucket{} } func (m *Bucket) String() string { return proto.CompactTextString(m) } func (*Bucket) ProtoMessage() {} func (*Bucket) Descriptor() ([]byte, []int) { - return fileDescriptor_brpb_ad1bbe2886ef0925, []int{15} + return fileDescriptor_brpb_bb8e335ec668bcb4, []int{15} } func (m *Bucket) XXX_Unmarshal(b []byte) error { return m.Unmarshal(b) @@ -1871,7 +1871,7 @@ func (m *CloudDynamic) Reset() { *m = CloudDynamic{} } func (m *CloudDynamic) String() string { return proto.CompactTextString(m) } func (*CloudDynamic) ProtoMessage() {} func (*CloudDynamic) Descriptor() ([]byte, []int) { - return fileDescriptor_brpb_ad1bbe2886ef0925, []int{16} + return fileDescriptor_brpb_bb8e335ec668bcb4, []int{16} } func (m *CloudDynamic) XXX_Unmarshal(b []byte) error { return m.Unmarshal(b) @@ -1934,7 +1934,7 @@ func (m *HDFS) Reset() { *m = HDFS{} } func (m *HDFS) String() string { return proto.CompactTextString(m) } func (*HDFS) ProtoMessage() {} func (*HDFS) Descriptor() ([]byte, []int) { - return fileDescriptor_brpb_ad1bbe2886ef0925, []int{17} + return fileDescriptor_brpb_bb8e335ec668bcb4, []int{17} } func (m *HDFS) XXX_Unmarshal(b []byte) error { return m.Unmarshal(b) @@ -1984,7 +1984,7 @@ func (m *BackupResponse) Reset() { *m = BackupResponse{} } func (m *BackupResponse) String() string { return proto.CompactTextString(m) } func (*BackupResponse) ProtoMessage() {} func (*BackupResponse) Descriptor() ([]byte, []int) { - return fileDescriptor_brpb_ad1bbe2886ef0925, []int{18} + return fileDescriptor_brpb_bb8e335ec668bcb4, []int{18} } func (m *BackupResponse) XXX_Unmarshal(b []byte) error { return m.Unmarshal(b) @@ -2055,7 +2055,7 @@ func (m *ExternalStorageRestoreRequest) Reset() { *m = ExternalStorageRe func (m *ExternalStorageRestoreRequest) String() string { return proto.CompactTextString(m) } func (*ExternalStorageRestoreRequest) ProtoMessage() {} func (*ExternalStorageRestoreRequest) Descriptor() ([]byte, []int) { - return fileDescriptor_brpb_ad1bbe2886ef0925, []int{19} + return fileDescriptor_brpb_bb8e335ec668bcb4, []int{19} } func (m *ExternalStorageRestoreRequest) XXX_Unmarshal(b []byte) error { return m.Unmarshal(b) @@ -2122,7 +2122,7 @@ func (m *ExternalStorageRestoreResponse) Reset() { *m = ExternalStorageR func (m *ExternalStorageRestoreResponse) String() string { return proto.CompactTextString(m) } func (*ExternalStorageRestoreResponse) ProtoMessage() {} func (*ExternalStorageRestoreResponse) Descriptor() ([]byte, []int) { - return fileDescriptor_brpb_ad1bbe2886ef0925, []int{20} + return fileDescriptor_brpb_bb8e335ec668bcb4, []int{20} } func (m *ExternalStorageRestoreResponse) XXX_Unmarshal(b []byte) error { return m.Unmarshal(b) @@ -2164,7 +2164,7 @@ func (m *ExternalStorageSaveRequest) Reset() { *m = ExternalStorageSaveR func (m *ExternalStorageSaveRequest) String() string { return proto.CompactTextString(m) } func (*ExternalStorageSaveRequest) ProtoMessage() {} func (*ExternalStorageSaveRequest) Descriptor() ([]byte, []int) { - return fileDescriptor_brpb_ad1bbe2886ef0925, []int{21} + return fileDescriptor_brpb_bb8e335ec668bcb4, []int{21} } func (m *ExternalStorageSaveRequest) XXX_Unmarshal(b []byte) error { return m.Unmarshal(b) @@ -2224,7 +2224,7 @@ func (m *ExternalStorageSaveResponse) Reset() { *m = ExternalStorageSave func (m *ExternalStorageSaveResponse) String() string { return proto.CompactTextString(m) } func (*ExternalStorageSaveResponse) ProtoMessage() {} func (*ExternalStorageSaveResponse) Descriptor() ([]byte, []int) { - return fileDescriptor_brpb_ad1bbe2886ef0925, []int{22} + return fileDescriptor_brpb_bb8e335ec668bcb4, []int{22} } func (m *ExternalStorageSaveResponse) XXX_Unmarshal(b []byte) error { return m.Unmarshal(b) @@ -9038,9 +9038,9 @@ var ( ErrIntOverflowBrpb = fmt.Errorf("proto: integer overflow") ) -func init() { proto.RegisterFile("brpb.proto", fileDescriptor_brpb_ad1bbe2886ef0925) } +func init() { proto.RegisterFile("brpb.proto", fileDescriptor_brpb_bb8e335ec668bcb4) } -var fileDescriptor_brpb_ad1bbe2886ef0925 = []byte{ +var fileDescriptor_brpb_bb8e335ec668bcb4 = []byte{ // 1990 bytes of a gzipped FileDescriptorProto 0x1f, 0x8b, 0x08, 0x00, 0x00, 0x00, 0x00, 0x00, 0x02, 0xff, 0xbc, 0x58, 0x4f, 0x73, 0x1b, 0x49, 0x15, 0xf7, 0x48, 0xa3, 0x3f, 0xf3, 0xf4, 0x37, 0x4d, 0x36, 0x2b, 0x14, 0xe2, 0x88, 0x49, 0x25, diff --git a/proto/brpb.proto b/proto/brpb.proto index 370d5e7b5..9e1a55efd 100644 --- a/proto/brpb.proto +++ b/proto/brpb.proto @@ -208,7 +208,7 @@ message StreamBackupTaskInfo { reserved "last_update_ts"; // We use '/tidb/br-stream/ranges// -> ' - //for storing all the target ranges of the task, the "ranges" field will not be saved in the taskinfo. + // for storing all the target ranges of the task, the "ranges" field will not be saved in the taskinfo. reserved "ranges"; // The status field allow us mark the task as 'paused'.