// Code generated by protoc-gen-gogo. DO NOT EDIT. // source: pkg/dataobj/internal/metadata/pointersmd/pointersmd.proto package pointersmd import ( fmt "fmt" proto "github.com/gogo/protobuf/proto" datasetmd "github.com/grafana/loki/v3/pkg/dataobj/internal/metadata/datasetmd" io "io" math "math" math_bits "math/bits" reflect "reflect" strconv "strconv" strings "strings" ) // Reference imports to suppress errors if they are not otherwise used. var _ = proto.Marshal var _ = fmt.Errorf var _ = math.Inf // This is a compile-time assertion to ensure that this generated file // is compatible with the proto package it is being compiled against. // A compilation error at this line likely means your copy of the // proto package needs to be updated. const _ = proto.GoGoProtoPackageIsVersion3 // please upgrade the proto package // ColumnType represents the valid types that a pointer's column can have. type ColumnType int32 const ( // Invalid column type. COLUMN_TYPE_UNSPECIFIED ColumnType = 0 // COLUMN_TYPE_PATH is a column containing the data object path in object storage. COLUMN_TYPE_PATH ColumnType = 1 // COLUMN_TYPE_SECTION is the section number within the referenced data object. COLUMN_TYPE_SECTION ColumnType = 2 // COLUMN_TYPE_POINTER_ is the type of index this pointer holds: Stream or Column. COLUMN_TYPE_POINTER_KIND ColumnType = 3 // COLUMN_TYPE_STREAM_ID is a column containing the streamID within the index object COLUMN_TYPE_STREAM_ID ColumnType = 4 // COLUMN_TYPE_STREAM_ID_REF is a column containing the streamID within the referenced object COLUMN_TYPE_STREAM_ID_REF ColumnType = 5 // COLUMN_TYPE_MIN_TIMESTAMP is a column containing the minimum timestamp of // a stream. COLUMN_TYPE_MIN_TIMESTAMP ColumnType = 6 // COLUMN_TYPE_MAX_TIMESTAMP is a column containing the maximum timestamp of // a stream. COLUMN_TYPE_MAX_TIMESTAMP ColumnType = 7 // COLUMN_TYPE_ROW_COUNT is a column indicating the number of rows for a stream. COLUMN_TYPE_ROW_COUNT ColumnType = 8 // COLUMN_TYPE_UNCOMPRESSED_SIZE is a column indicating the uncompressed size // of a stream. Size of a stream is the sum of the length of all log lines and // the length of all structured metadata values COLUMN_TYPE_UNCOMPRESSED_SIZE ColumnType = 9 // COLUMN_TYPE_COLUMN_NAME is the name of a column within a referenced section COLUMN_TYPE_COLUMN_NAME ColumnType = 10 // COLUMN_TYPE_COLUMN_INDEX is the index of a column within a referenced section to uniquely refer to it. COLUMN_TYPE_COLUMN_INDEX ColumnType = 11 // COLUMN_TYPE_VALUES_BLOOM_FILTER is the raw bytes of a bloom filter for values stored in referenced column & section. COLUMN_TYPE_VALUES_BLOOM_FILTER ColumnType = 12 ) var ColumnType_name = map[int32]string{ 0: "COLUMN_TYPE_UNSPECIFIED", 1: "COLUMN_TYPE_PATH", 2: "COLUMN_TYPE_SECTION", 3: "COLUMN_TYPE_POINTER_KIND", 4: "COLUMN_TYPE_STREAM_ID", 5: "COLUMN_TYPE_STREAM_ID_REF", 6: "COLUMN_TYPE_MIN_TIMESTAMP", 7: "COLUMN_TYPE_MAX_TIMESTAMP", 8: "COLUMN_TYPE_ROW_COUNT", 9: "COLUMN_TYPE_UNCOMPRESSED_SIZE", 10: "COLUMN_TYPE_COLUMN_NAME", 11: "COLUMN_TYPE_COLUMN_INDEX", 12: "COLUMN_TYPE_VALUES_BLOOM_FILTER", } var ColumnType_value = map[string]int32{ "COLUMN_TYPE_UNSPECIFIED": 0, "COLUMN_TYPE_PATH": 1, "COLUMN_TYPE_SECTION": 2, "COLUMN_TYPE_POINTER_KIND": 3, "COLUMN_TYPE_STREAM_ID": 4, "COLUMN_TYPE_STREAM_ID_REF": 5, "COLUMN_TYPE_MIN_TIMESTAMP": 6, "COLUMN_TYPE_MAX_TIMESTAMP": 7, "COLUMN_TYPE_ROW_COUNT": 8, "COLUMN_TYPE_UNCOMPRESSED_SIZE": 9, "COLUMN_TYPE_COLUMN_NAME": 10, "COLUMN_TYPE_COLUMN_INDEX": 11, "COLUMN_TYPE_VALUES_BLOOM_FILTER": 12, } func (ColumnType) EnumDescriptor() ([]byte, []int) { return fileDescriptor_807d51c83b4cb61f, []int{0} } // Metadata describes the metadata for the pointers section. type Metadata struct { // Columns within the pointers section. Columns []*ColumnDesc `protobuf:"bytes,1,rep,name=columns,proto3" json:"columns,omitempty"` // Section sort information. SortInfo *datasetmd.SectionSortInfo `protobuf:"bytes,2,opt,name=sort_info,json=sortInfo,proto3" json:"sort_info,omitempty"` } func (m *Metadata) Reset() { *m = Metadata{} } func (*Metadata) ProtoMessage() {} func (*Metadata) Descriptor() ([]byte, []int) { return fileDescriptor_807d51c83b4cb61f, []int{0} } func (m *Metadata) XXX_Unmarshal(b []byte) error { return m.Unmarshal(b) } func (m *Metadata) XXX_Marshal(b []byte, deterministic bool) ([]byte, error) { if deterministic { return xxx_messageInfo_Metadata.Marshal(b, m, deterministic) } else { b = b[:cap(b)] n, err := m.MarshalToSizedBuffer(b) if err != nil { return nil, err } return b[:n], nil } } func (m *Metadata) XXX_Merge(src proto.Message) { xxx_messageInfo_Metadata.Merge(m, src) } func (m *Metadata) XXX_Size() int { return m.Size() } func (m *Metadata) XXX_DiscardUnknown() { xxx_messageInfo_Metadata.DiscardUnknown(m) } var xxx_messageInfo_Metadata proto.InternalMessageInfo func (m *Metadata) GetColumns() []*ColumnDesc { if m != nil { return m.Columns } return nil } func (m *Metadata) GetSortInfo() *datasetmd.SectionSortInfo { if m != nil { return m.SortInfo } return nil } // ColumnDesc describes an individual column within the pointers table. type ColumnDesc struct { // Information about the column. Info *datasetmd.ColumnInfo `protobuf:"bytes,1,opt,name=info,proto3" json:"info,omitempty"` // Column type. Type ColumnType `protobuf:"varint,2,opt,name=type,proto3,enum=dataobj.metadata.pointers.v1.ColumnType" json:"type,omitempty"` } func (m *ColumnDesc) Reset() { *m = ColumnDesc{} } func (*ColumnDesc) ProtoMessage() {} func (*ColumnDesc) Descriptor() ([]byte, []int) { return fileDescriptor_807d51c83b4cb61f, []int{1} } func (m *ColumnDesc) XXX_Unmarshal(b []byte) error { return m.Unmarshal(b) } func (m *ColumnDesc) XXX_Marshal(b []byte, deterministic bool) ([]byte, error) { if deterministic { return xxx_messageInfo_ColumnDesc.Marshal(b, m, deterministic) } else { b = b[:cap(b)] n, err := m.MarshalToSizedBuffer(b) if err != nil { return nil, err } return b[:n], nil } } func (m *ColumnDesc) XXX_Merge(src proto.Message) { xxx_messageInfo_ColumnDesc.Merge(m, src) } func (m *ColumnDesc) XXX_Size() int { return m.Size() } func (m *ColumnDesc) XXX_DiscardUnknown() { xxx_messageInfo_ColumnDesc.DiscardUnknown(m) } var xxx_messageInfo_ColumnDesc proto.InternalMessageInfo func (m *ColumnDesc) GetInfo() *datasetmd.ColumnInfo { if m != nil { return m.Info } return nil } func (m *ColumnDesc) GetType() ColumnType { if m != nil { return m.Type } return COLUMN_TYPE_UNSPECIFIED } // ColumnMetadata describes the metadata for a column. type ColumnMetadata struct { // Pages within the column. Pages []*PageDesc `protobuf:"bytes,1,rep,name=pages,proto3" json:"pages,omitempty"` } func (m *ColumnMetadata) Reset() { *m = ColumnMetadata{} } func (*ColumnMetadata) ProtoMessage() {} func (*ColumnMetadata) Descriptor() ([]byte, []int) { return fileDescriptor_807d51c83b4cb61f, []int{2} } func (m *ColumnMetadata) XXX_Unmarshal(b []byte) error { return m.Unmarshal(b) } func (m *ColumnMetadata) XXX_Marshal(b []byte, deterministic bool) ([]byte, error) { if deterministic { return xxx_messageInfo_ColumnMetadata.Marshal(b, m, deterministic) } else { b = b[:cap(b)] n, err := m.MarshalToSizedBuffer(b) if err != nil { return nil, err } return b[:n], nil } } func (m *ColumnMetadata) XXX_Merge(src proto.Message) { xxx_messageInfo_ColumnMetadata.Merge(m, src) } func (m *ColumnMetadata) XXX_Size() int { return m.Size() } func (m *ColumnMetadata) XXX_DiscardUnknown() { xxx_messageInfo_ColumnMetadata.DiscardUnknown(m) } var xxx_messageInfo_ColumnMetadata proto.InternalMessageInfo func (m *ColumnMetadata) GetPages() []*PageDesc { if m != nil { return m.Pages } return nil } // PageDesc describes an individual page within a column. type PageDesc struct { // Information about the page. Info *datasetmd.PageInfo `protobuf:"bytes,1,opt,name=info,proto3" json:"info,omitempty"` } func (m *PageDesc) Reset() { *m = PageDesc{} } func (*PageDesc) ProtoMessage() {} func (*PageDesc) Descriptor() ([]byte, []int) { return fileDescriptor_807d51c83b4cb61f, []int{3} } func (m *PageDesc) XXX_Unmarshal(b []byte) error { return m.Unmarshal(b) } func (m *PageDesc) XXX_Marshal(b []byte, deterministic bool) ([]byte, error) { if deterministic { return xxx_messageInfo_PageDesc.Marshal(b, m, deterministic) } else { b = b[:cap(b)] n, err := m.MarshalToSizedBuffer(b) if err != nil { return nil, err } return b[:n], nil } } func (m *PageDesc) XXX_Merge(src proto.Message) { xxx_messageInfo_PageDesc.Merge(m, src) } func (m *PageDesc) XXX_Size() int { return m.Size() } func (m *PageDesc) XXX_DiscardUnknown() { xxx_messageInfo_PageDesc.DiscardUnknown(m) } var xxx_messageInfo_PageDesc proto.InternalMessageInfo func (m *PageDesc) GetInfo() *datasetmd.PageInfo { if m != nil { return m.Info } return nil } func init() { proto.RegisterEnum("dataobj.metadata.pointers.v1.ColumnType", ColumnType_name, ColumnType_value) proto.RegisterType((*Metadata)(nil), "dataobj.metadata.pointers.v1.Metadata") proto.RegisterType((*ColumnDesc)(nil), "dataobj.metadata.pointers.v1.ColumnDesc") proto.RegisterType((*ColumnMetadata)(nil), "dataobj.metadata.pointers.v1.ColumnMetadata") proto.RegisterType((*PageDesc)(nil), "dataobj.metadata.pointers.v1.PageDesc") } func init() { proto.RegisterFile("pkg/dataobj/internal/metadata/pointersmd/pointersmd.proto", fileDescriptor_807d51c83b4cb61f) } var fileDescriptor_807d51c83b4cb61f = []byte{ // 572 bytes of a gzipped FileDescriptorProto 0x1f, 0x8b, 0x08, 0x00, 0x00, 0x00, 0x00, 0x00, 0x02, 0xff, 0x8c, 0x54, 0xcb, 0x6e, 0xd3, 0x40, 0x14, 0xf5, 0xf4, 0x99, 0x4e, 0x51, 0x35, 0x1a, 0x40, 0x6d, 0xa1, 0x1d, 0x4a, 0x10, 0x50, 0x21, 0x64, 0x8b, 0x76, 0x81, 0x2a, 0xba, 0x71, 0xed, 0xa9, 0x18, 0x11, 0x3f, 0x64, 0x3b, 0x50, 0xba, 0xb1, 0xdc, 0xc4, 0x09, 0xa1, 0x89, 0xc7, 0x8a, 0xdd, 0x4a, 0xd9, 0xb1, 0x63, 0xc3, 0x82, 0x2d, 0x7f, 0xc0, 0xa7, 0xb0, 0xcc, 0xb2, 0x4b, 0xe2, 0x6c, 0x58, 0xf6, 0x13, 0x50, 0x1c, 0x9b, 0x3c, 0x8a, 0xa2, 0x6e, 0xac, 0xab, 0x7b, 0xee, 0x39, 0xf7, 0x9e, 0x23, 0x79, 0xe0, 0x41, 0x78, 0x5e, 0x97, 0xaa, 0x5e, 0xec, 0xf1, 0xb3, 0xcf, 0x52, 0x23, 0x88, 0xfd, 0x76, 0xe0, 0x35, 0xa5, 0x96, 0x1f, 0x7b, 0x83, 0xa6, 0x14, 0xf2, 0xb4, 0x17, 0xb5, 0xaa, 0x63, 0xa5, 0x18, 0xb6, 0x79, 0xcc, 0xf1, 0x56, 0x46, 0x13, 0xf3, 0x69, 0x31, 0x1f, 0x11, 0x2f, 0x5f, 0x3d, 0x78, 0x3d, 0x5b, 0x78, 0xf0, 0x89, 0xfc, 0xb8, 0x55, 0x1d, 0x55, 0x43, 0xd9, 0xe2, 0x0f, 0x00, 0x0b, 0x5a, 0x36, 0x86, 0x8f, 0xe0, 0x72, 0x85, 0x37, 0x2f, 0x5a, 0x41, 0xb4, 0x01, 0x76, 0xe6, 0x77, 0x57, 0xf7, 0x76, 0xc5, 0x59, 0x5b, 0x45, 0x25, 0x1d, 0x56, 0xfd, 0xa8, 0x62, 0xe5, 0x44, 0xcc, 0xe0, 0x4a, 0xc4, 0xdb, 0xb1, 0xdb, 0x08, 0x6a, 0x7c, 0x63, 0x6e, 0x07, 0xec, 0xae, 0xee, 0xbd, 0xbc, 0xa9, 0x92, 0x9d, 0x31, 0x10, 0xb1, 0xfd, 0x4a, 0xdc, 0xe0, 0x81, 0xcd, 0xdb, 0x31, 0x0b, 0x6a, 0xdc, 0x2a, 0x44, 0x59, 0x55, 0xfc, 0x0a, 0x20, 0x1c, 0xad, 0xc0, 0x6f, 0xe0, 0x42, 0x2a, 0x0a, 0x52, 0xd1, 0xe7, 0x33, 0x45, 0x87, 0xb4, 0x54, 0x2f, 0x25, 0xe1, 0x43, 0xb8, 0x10, 0x77, 0x42, 0x3f, 0xbd, 0x68, 0xed, 0x76, 0xbe, 0x9c, 0x4e, 0xe8, 0x5b, 0x29, 0xab, 0xa8, 0xc3, 0xb5, 0x61, 0xef, 0x5f, 0x54, 0x87, 0x70, 0x31, 0xf4, 0xea, 0x7e, 0x1e, 0xd4, 0xb3, 0xd9, 0x82, 0xa6, 0x57, 0xf7, 0xd3, 0x98, 0x86, 0xa4, 0x22, 0x85, 0x85, 0xbc, 0x85, 0x0f, 0x26, 0x6c, 0x3d, 0x9d, 0x69, 0x6b, 0x40, 0x1a, 0x99, 0x7a, 0xf1, 0x6d, 0x3e, 0x0f, 0x68, 0x70, 0x2b, 0x7e, 0x08, 0xd7, 0x15, 0xa3, 0x54, 0xd6, 0x74, 0xd7, 0xf9, 0x68, 0x52, 0xb7, 0xac, 0xdb, 0x26, 0x55, 0xd8, 0x31, 0xa3, 0x2a, 0x12, 0xf0, 0x3d, 0x88, 0xc6, 0x41, 0x53, 0x76, 0xde, 0x22, 0x80, 0xd7, 0xe1, 0xdd, 0xf1, 0xae, 0x4d, 0x15, 0x87, 0x19, 0x3a, 0x9a, 0xc3, 0x5b, 0x70, 0x63, 0x62, 0xdc, 0x60, 0xba, 0x43, 0x2d, 0xf7, 0x1d, 0xd3, 0x55, 0x34, 0x8f, 0x37, 0xe1, 0xfd, 0x09, 0x9a, 0x63, 0x51, 0x59, 0x73, 0x99, 0x8a, 0x16, 0xf0, 0x36, 0xdc, 0xfc, 0x2f, 0xe4, 0x5a, 0xf4, 0x18, 0x2d, 0x4e, 0xc3, 0x1a, 0xd3, 0x5d, 0x87, 0x69, 0xd4, 0x76, 0x64, 0xcd, 0x44, 0x4b, 0x37, 0x60, 0xf9, 0x64, 0x0c, 0x5e, 0x9e, 0xde, 0x6b, 0x19, 0x1f, 0x5c, 0xc5, 0x28, 0xeb, 0x0e, 0x2a, 0xe0, 0xc7, 0x70, 0x7b, 0xd2, 0xbc, 0x62, 0x68, 0xa6, 0x45, 0x6d, 0x9b, 0xaa, 0xae, 0xcd, 0x4e, 0x29, 0x5a, 0x99, 0xce, 0x27, 0xab, 0x75, 0x59, 0xa3, 0x08, 0x4e, 0x1b, 0xce, 0x6a, 0xa6, 0xab, 0xf4, 0x04, 0xad, 0xe2, 0x27, 0xf0, 0xd1, 0x38, 0xfa, 0x5e, 0x2e, 0x95, 0xa9, 0xed, 0x1e, 0x95, 0x0c, 0x43, 0x73, 0x8f, 0x59, 0xc9, 0xa1, 0x16, 0xba, 0x73, 0xd4, 0xe9, 0xf6, 0x88, 0x70, 0xd5, 0x23, 0xc2, 0x75, 0x8f, 0x80, 0x2f, 0x09, 0x01, 0x3f, 0x13, 0x02, 0x7e, 0x25, 0x04, 0x74, 0x13, 0x02, 0x7e, 0x27, 0x04, 0xfc, 0x49, 0x88, 0x70, 0x9d, 0x10, 0xf0, 0xbd, 0x4f, 0x84, 0x6e, 0x9f, 0x08, 0x57, 0x7d, 0x22, 0x9c, 0x2a, 0xf5, 0x46, 0xfc, 0xe9, 0xe2, 0x4c, 0xac, 0xf0, 0x96, 0x54, 0x6f, 0x7b, 0x35, 0x2f, 0xf0, 0xa4, 0x26, 0x3f, 0x6f, 0x48, 0x97, 0xfb, 0xd2, 0x6d, 0x9f, 0x8b, 0xb3, 0xa5, 0xf4, 0x6f, 0xde, 0xff, 0x1b, 0x00, 0x00, 0xff, 0xff, 0x3e, 0x1b, 0xc0, 0xa9, 0x61, 0x04, 0x00, 0x00, } func (x ColumnType) String() string { s, ok := ColumnType_name[int32(x)] if ok { return s } return strconv.Itoa(int(x)) } func (this *Metadata) Equal(that interface{}) bool { if that == nil { return this == nil } that1, ok := that.(*Metadata) if !ok { that2, ok := that.(Metadata) if ok { that1 = &that2 } else { return false } } if that1 == nil { return this == nil } else if this == nil { return false } if len(this.Columns) != len(that1.Columns) { return false } for i := range this.Columns { if !this.Columns[i].Equal(that1.Columns[i]) { return false } } if !this.SortInfo.Equal(that1.SortInfo) { return false } return true } func (this *ColumnDesc) Equal(that interface{}) bool { if that == nil { return this == nil } that1, ok := that.(*ColumnDesc) if !ok { that2, ok := that.(ColumnDesc) if ok { that1 = &that2 } else { return false } } if that1 == nil { return this == nil } else if this == nil { return false } if !this.Info.Equal(that1.Info) { return false } if this.Type != that1.Type { return false } return true } func (this *ColumnMetadata) Equal(that interface{}) bool { if that == nil { return this == nil } that1, ok := that.(*ColumnMetadata) if !ok { that2, ok := that.(ColumnMetadata) if ok { that1 = &that2 } else { return false } } if that1 == nil { return this == nil } else if this == nil { return false } if len(this.Pages) != len(that1.Pages) { return false } for i := range this.Pages { if !this.Pages[i].Equal(that1.Pages[i]) { return false } } return true } func (this *PageDesc) Equal(that interface{}) bool { if that == nil { return this == nil } that1, ok := that.(*PageDesc) if !ok { that2, ok := that.(PageDesc) if ok { that1 = &that2 } else { return false } } if that1 == nil { return this == nil } else if this == nil { return false } if !this.Info.Equal(that1.Info) { return false } return true } func (this *Metadata) GoString() string { if this == nil { return "nil" } s := make([]string, 0, 6) s = append(s, "&pointersmd.Metadata{") if this.Columns != nil { s = append(s, "Columns: "+fmt.Sprintf("%#v", this.Columns)+",\n") } if this.SortInfo != nil { s = append(s, "SortInfo: "+fmt.Sprintf("%#v", this.SortInfo)+",\n") } s = append(s, "}") return strings.Join(s, "") } func (this *ColumnDesc) GoString() string { if this == nil { return "nil" } s := make([]string, 0, 6) s = append(s, "&pointersmd.ColumnDesc{") if this.Info != nil { s = append(s, "Info: "+fmt.Sprintf("%#v", this.Info)+",\n") } s = append(s, "Type: "+fmt.Sprintf("%#v", this.Type)+",\n") s = append(s, "}") return strings.Join(s, "") } func (this *ColumnMetadata) GoString() string { if this == nil { return "nil" } s := make([]string, 0, 5) s = append(s, "&pointersmd.ColumnMetadata{") if this.Pages != nil { s = append(s, "Pages: "+fmt.Sprintf("%#v", this.Pages)+",\n") } s = append(s, "}") return strings.Join(s, "") } func (this *PageDesc) GoString() string { if this == nil { return "nil" } s := make([]string, 0, 5) s = append(s, "&pointersmd.PageDesc{") if this.Info != nil { s = append(s, "Info: "+fmt.Sprintf("%#v", this.Info)+",\n") } s = append(s, "}") return strings.Join(s, "") } func valueToGoStringPointersmd(v interface{}, typ string) string { rv := reflect.ValueOf(v) if rv.IsNil() { return "nil" } pv := reflect.Indirect(rv).Interface() return fmt.Sprintf("func(v %v) *%v { return &v } ( %#v )", typ, typ, pv) } func (m *Metadata) Marshal() (dAtA []byte, err error) { size := m.Size() dAtA = make([]byte, size) n, err := m.MarshalToSizedBuffer(dAtA[:size]) if err != nil { return nil, err } return dAtA[:n], nil } func (m *Metadata) MarshalTo(dAtA []byte) (int, error) { size := m.Size() return m.MarshalToSizedBuffer(dAtA[:size]) } func (m *Metadata) MarshalToSizedBuffer(dAtA []byte) (int, error) { i := len(dAtA) _ = i var l int _ = l if m.SortInfo != nil { { size, err := m.SortInfo.MarshalToSizedBuffer(dAtA[:i]) if err != nil { return 0, err } i -= size i = encodeVarintPointersmd(dAtA, i, uint64(size)) } i-- dAtA[i] = 0x12 } if len(m.Columns) > 0 { for iNdEx := len(m.Columns) - 1; iNdEx >= 0; iNdEx-- { { size, err := m.Columns[iNdEx].MarshalToSizedBuffer(dAtA[:i]) if err != nil { return 0, err } i -= size i = encodeVarintPointersmd(dAtA, i, uint64(size)) } i-- dAtA[i] = 0xa } } return len(dAtA) - i, nil } func (m *ColumnDesc) Marshal() (dAtA []byte, err error) { size := m.Size() dAtA = make([]byte, size) n, err := m.MarshalToSizedBuffer(dAtA[:size]) if err != nil { return nil, err } return dAtA[:n], nil } func (m *ColumnDesc) MarshalTo(dAtA []byte) (int, error) { size := m.Size() return m.MarshalToSizedBuffer(dAtA[:size]) } func (m *ColumnDesc) MarshalToSizedBuffer(dAtA []byte) (int, error) { i := len(dAtA) _ = i var l int _ = l if m.Type != 0 { i = encodeVarintPointersmd(dAtA, i, uint64(m.Type)) i-- dAtA[i] = 0x10 } if m.Info != nil { { size, err := m.Info.MarshalToSizedBuffer(dAtA[:i]) if err != nil { return 0, err } i -= size i = encodeVarintPointersmd(dAtA, i, uint64(size)) } i-- dAtA[i] = 0xa } return len(dAtA) - i, nil } func (m *ColumnMetadata) Marshal() (dAtA []byte, err error) { size := m.Size() dAtA = make([]byte, size) n, err := m.MarshalToSizedBuffer(dAtA[:size]) if err != nil { return nil, err } return dAtA[:n], nil } func (m *ColumnMetadata) MarshalTo(dAtA []byte) (int, error) { size := m.Size() return m.MarshalToSizedBuffer(dAtA[:size]) } func (m *ColumnMetadata) MarshalToSizedBuffer(dAtA []byte) (int, error) { i := len(dAtA) _ = i var l int _ = l if len(m.Pages) > 0 { for iNdEx := len(m.Pages) - 1; iNdEx >= 0; iNdEx-- { { size, err := m.Pages[iNdEx].MarshalToSizedBuffer(dAtA[:i]) if err != nil { return 0, err } i -= size i = encodeVarintPointersmd(dAtA, i, uint64(size)) } i-- dAtA[i] = 0xa } } return len(dAtA) - i, nil } func (m *PageDesc) Marshal() (dAtA []byte, err error) { size := m.Size() dAtA = make([]byte, size) n, err := m.MarshalToSizedBuffer(dAtA[:size]) if err != nil { return nil, err } return dAtA[:n], nil } func (m *PageDesc) MarshalTo(dAtA []byte) (int, error) { size := m.Size() return m.MarshalToSizedBuffer(dAtA[:size]) } func (m *PageDesc) MarshalToSizedBuffer(dAtA []byte) (int, error) { i := len(dAtA) _ = i var l int _ = l if m.Info != nil { { size, err := m.Info.MarshalToSizedBuffer(dAtA[:i]) if err != nil { return 0, err } i -= size i = encodeVarintPointersmd(dAtA, i, uint64(size)) } i-- dAtA[i] = 0xa } return len(dAtA) - i, nil } func encodeVarintPointersmd(dAtA []byte, offset int, v uint64) int { offset -= sovPointersmd(v) base := offset for v >= 1<<7 { dAtA[offset] = uint8(v&0x7f | 0x80) v >>= 7 offset++ } dAtA[offset] = uint8(v) return base } func (m *Metadata) Size() (n int) { if m == nil { return 0 } var l int _ = l if len(m.Columns) > 0 { for _, e := range m.Columns { l = e.Size() n += 1 + l + sovPointersmd(uint64(l)) } } if m.SortInfo != nil { l = m.SortInfo.Size() n += 1 + l + sovPointersmd(uint64(l)) } return n } func (m *ColumnDesc) Size() (n int) { if m == nil { return 0 } var l int _ = l if m.Info != nil { l = m.Info.Size() n += 1 + l + sovPointersmd(uint64(l)) } if m.Type != 0 { n += 1 + sovPointersmd(uint64(m.Type)) } return n } func (m *ColumnMetadata) Size() (n int) { if m == nil { return 0 } var l int _ = l if len(m.Pages) > 0 { for _, e := range m.Pages { l = e.Size() n += 1 + l + sovPointersmd(uint64(l)) } } return n } func (m *PageDesc) Size() (n int) { if m == nil { return 0 } var l int _ = l if m.Info != nil { l = m.Info.Size() n += 1 + l + sovPointersmd(uint64(l)) } return n } func sovPointersmd(x uint64) (n int) { return (math_bits.Len64(x|1) + 6) / 7 } func sozPointersmd(x uint64) (n int) { return sovPointersmd(uint64((x << 1) ^ uint64((int64(x) >> 63)))) } func (this *Metadata) String() string { if this == nil { return "nil" } repeatedStringForColumns := "[]*ColumnDesc{" for _, f := range this.Columns { repeatedStringForColumns += strings.Replace(f.String(), "ColumnDesc", "ColumnDesc", 1) + "," } repeatedStringForColumns += "}" s := strings.Join([]string{`&Metadata{`, `Columns:` + repeatedStringForColumns + `,`, `SortInfo:` + strings.Replace(fmt.Sprintf("%v", this.SortInfo), "SectionSortInfo", "datasetmd.SectionSortInfo", 1) + `,`, `}`, }, "") return s } func (this *ColumnDesc) String() string { if this == nil { return "nil" } s := strings.Join([]string{`&ColumnDesc{`, `Info:` + strings.Replace(fmt.Sprintf("%v", this.Info), "ColumnInfo", "datasetmd.ColumnInfo", 1) + `,`, `Type:` + fmt.Sprintf("%v", this.Type) + `,`, `}`, }, "") return s } func (this *ColumnMetadata) String() string { if this == nil { return "nil" } repeatedStringForPages := "[]*PageDesc{" for _, f := range this.Pages { repeatedStringForPages += strings.Replace(f.String(), "PageDesc", "PageDesc", 1) + "," } repeatedStringForPages += "}" s := strings.Join([]string{`&ColumnMetadata{`, `Pages:` + repeatedStringForPages + `,`, `}`, }, "") return s } func (this *PageDesc) String() string { if this == nil { return "nil" } s := strings.Join([]string{`&PageDesc{`, `Info:` + strings.Replace(fmt.Sprintf("%v", this.Info), "PageInfo", "datasetmd.PageInfo", 1) + `,`, `}`, }, "") return s } func valueToStringPointersmd(v interface{}) string { rv := reflect.ValueOf(v) if rv.IsNil() { return "nil" } pv := reflect.Indirect(rv).Interface() return fmt.Sprintf("*%v", pv) } func (m *Metadata) 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 ErrIntOverflowPointersmd } 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: Metadata: wiretype end group for non-group") } if fieldNum <= 0 { return fmt.Errorf("proto: Metadata: illegal tag %d (wire type %d)", fieldNum, wire) } switch fieldNum { case 1: if wireType != 2 { return fmt.Errorf("proto: wrong wireType = %d for field Columns", wireType) } var msglen int for shift := uint(0); ; shift += 7 { if shift >= 64 { return ErrIntOverflowPointersmd } if iNdEx >= l { return io.ErrUnexpectedEOF } b := dAtA[iNdEx] iNdEx++ msglen |= int(b&0x7F) << shift if b < 0x80 { break } } if msglen < 0 { return ErrInvalidLengthPointersmd } postIndex := iNdEx + msglen if postIndex < 0 { return ErrInvalidLengthPointersmd } if postIndex > l { return io.ErrUnexpectedEOF } m.Columns = append(m.Columns, &ColumnDesc{}) if err := m.Columns[len(m.Columns)-1].Unmarshal(dAtA[iNdEx:postIndex]); err != nil { return err } iNdEx = postIndex case 2: if wireType != 2 { return fmt.Errorf("proto: wrong wireType = %d for field SortInfo", wireType) } var msglen int for shift := uint(0); ; shift += 7 { if shift >= 64 { return ErrIntOverflowPointersmd } if iNdEx >= l { return io.ErrUnexpectedEOF } b := dAtA[iNdEx] iNdEx++ msglen |= int(b&0x7F) << shift if b < 0x80 { break } } if msglen < 0 { return ErrInvalidLengthPointersmd } postIndex := iNdEx + msglen if postIndex < 0 { return ErrInvalidLengthPointersmd } if postIndex > l { return io.ErrUnexpectedEOF } if m.SortInfo == nil { m.SortInfo = &datasetmd.SectionSortInfo{} } if err := m.SortInfo.Unmarshal(dAtA[iNdEx:postIndex]); err != nil { return err } iNdEx = postIndex default: iNdEx = preIndex skippy, err := skipPointersmd(dAtA[iNdEx:]) if err != nil { return err } if skippy < 0 { return ErrInvalidLengthPointersmd } if (iNdEx + skippy) < 0 { return ErrInvalidLengthPointersmd } if (iNdEx + skippy) > l { return io.ErrUnexpectedEOF } iNdEx += skippy } } if iNdEx > l { return io.ErrUnexpectedEOF } return nil } func (m *ColumnDesc) 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 ErrIntOverflowPointersmd } 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: ColumnDesc: wiretype end group for non-group") } if fieldNum <= 0 { return fmt.Errorf("proto: ColumnDesc: illegal tag %d (wire type %d)", fieldNum, wire) } switch fieldNum { case 1: if wireType != 2 { return fmt.Errorf("proto: wrong wireType = %d for field Info", wireType) } var msglen int for shift := uint(0); ; shift += 7 { if shift >= 64 { return ErrIntOverflowPointersmd } if iNdEx >= l { return io.ErrUnexpectedEOF } b := dAtA[iNdEx] iNdEx++ msglen |= int(b&0x7F) << shift if b < 0x80 { break } } if msglen < 0 { return ErrInvalidLengthPointersmd } postIndex := iNdEx + msglen if postIndex < 0 { return ErrInvalidLengthPointersmd } if postIndex > l { return io.ErrUnexpectedEOF } if m.Info == nil { m.Info = &datasetmd.ColumnInfo{} } if err := m.Info.Unmarshal(dAtA[iNdEx:postIndex]); err != nil { return err } iNdEx = postIndex case 2: if wireType != 0 { return fmt.Errorf("proto: wrong wireType = %d for field Type", wireType) } m.Type = 0 for shift := uint(0); ; shift += 7 { if shift >= 64 { return ErrIntOverflowPointersmd } if iNdEx >= l { return io.ErrUnexpectedEOF } b := dAtA[iNdEx] iNdEx++ m.Type |= ColumnType(b&0x7F) << shift if b < 0x80 { break } } default: iNdEx = preIndex skippy, err := skipPointersmd(dAtA[iNdEx:]) if err != nil { return err } if skippy < 0 { return ErrInvalidLengthPointersmd } if (iNdEx + skippy) < 0 { return ErrInvalidLengthPointersmd } if (iNdEx + skippy) > l { return io.ErrUnexpectedEOF } iNdEx += skippy } } if iNdEx > l { return io.ErrUnexpectedEOF } return nil } func (m *ColumnMetadata) 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 ErrIntOverflowPointersmd } 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: ColumnMetadata: wiretype end group for non-group") } if fieldNum <= 0 { return fmt.Errorf("proto: ColumnMetadata: illegal tag %d (wire type %d)", fieldNum, wire) } switch fieldNum { case 1: if wireType != 2 { return fmt.Errorf("proto: wrong wireType = %d for field Pages", wireType) } var msglen int for shift := uint(0); ; shift += 7 { if shift >= 64 { return ErrIntOverflowPointersmd } if iNdEx >= l { return io.ErrUnexpectedEOF } b := dAtA[iNdEx] iNdEx++ msglen |= int(b&0x7F) << shift if b < 0x80 { break } } if msglen < 0 { return ErrInvalidLengthPointersmd } postIndex := iNdEx + msglen if postIndex < 0 { return ErrInvalidLengthPointersmd } if postIndex > l { return io.ErrUnexpectedEOF } m.Pages = append(m.Pages, &PageDesc{}) if err := m.Pages[len(m.Pages)-1].Unmarshal(dAtA[iNdEx:postIndex]); err != nil { return err } iNdEx = postIndex default: iNdEx = preIndex skippy, err := skipPointersmd(dAtA[iNdEx:]) if err != nil { return err } if skippy < 0 { return ErrInvalidLengthPointersmd } if (iNdEx + skippy) < 0 { return ErrInvalidLengthPointersmd } if (iNdEx + skippy) > l { return io.ErrUnexpectedEOF } iNdEx += skippy } } if iNdEx > l { return io.ErrUnexpectedEOF } return nil } func (m *PageDesc) 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 ErrIntOverflowPointersmd } 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: PageDesc: wiretype end group for non-group") } if fieldNum <= 0 { return fmt.Errorf("proto: PageDesc: illegal tag %d (wire type %d)", fieldNum, wire) } switch fieldNum { case 1: if wireType != 2 { return fmt.Errorf("proto: wrong wireType = %d for field Info", wireType) } var msglen int for shift := uint(0); ; shift += 7 { if shift >= 64 { return ErrIntOverflowPointersmd } if iNdEx >= l { return io.ErrUnexpectedEOF } b := dAtA[iNdEx] iNdEx++ msglen |= int(b&0x7F) << shift if b < 0x80 { break } } if msglen < 0 { return ErrInvalidLengthPointersmd } postIndex := iNdEx + msglen if postIndex < 0 { return ErrInvalidLengthPointersmd } if postIndex > l { return io.ErrUnexpectedEOF } if m.Info == nil { m.Info = &datasetmd.PageInfo{} } if err := m.Info.Unmarshal(dAtA[iNdEx:postIndex]); err != nil { return err } iNdEx = postIndex default: iNdEx = preIndex skippy, err := skipPointersmd(dAtA[iNdEx:]) if err != nil { return err } if skippy < 0 { return ErrInvalidLengthPointersmd } if (iNdEx + skippy) < 0 { return ErrInvalidLengthPointersmd } if (iNdEx + skippy) > l { return io.ErrUnexpectedEOF } iNdEx += skippy } } if iNdEx > l { return io.ErrUnexpectedEOF } return nil } func skipPointersmd(dAtA []byte) (n int, err error) { l := len(dAtA) iNdEx := 0 for iNdEx < l { var wire uint64 for shift := uint(0); ; shift += 7 { if shift >= 64 { return 0, ErrIntOverflowPointersmd } if iNdEx >= l { return 0, io.ErrUnexpectedEOF } b := dAtA[iNdEx] iNdEx++ wire |= (uint64(b) & 0x7F) << shift if b < 0x80 { break } } wireType := int(wire & 0x7) switch wireType { case 0: for shift := uint(0); ; shift += 7 { if shift >= 64 { return 0, ErrIntOverflowPointersmd } if iNdEx >= l { return 0, io.ErrUnexpectedEOF } iNdEx++ if dAtA[iNdEx-1] < 0x80 { break } } return iNdEx, nil case 1: iNdEx += 8 return iNdEx, nil case 2: var length int for shift := uint(0); ; shift += 7 { if shift >= 64 { return 0, ErrIntOverflowPointersmd } if iNdEx >= l { return 0, io.ErrUnexpectedEOF } b := dAtA[iNdEx] iNdEx++ length |= (int(b) & 0x7F) << shift if b < 0x80 { break } } if length < 0 { return 0, ErrInvalidLengthPointersmd } iNdEx += length if iNdEx < 0 { return 0, ErrInvalidLengthPointersmd } return iNdEx, nil case 3: for { var innerWire uint64 var start int = iNdEx for shift := uint(0); ; shift += 7 { if shift >= 64 { return 0, ErrIntOverflowPointersmd } if iNdEx >= l { return 0, io.ErrUnexpectedEOF } b := dAtA[iNdEx] iNdEx++ innerWire |= (uint64(b) & 0x7F) << shift if b < 0x80 { break } } innerWireType := int(innerWire & 0x7) if innerWireType == 4 { break } next, err := skipPointersmd(dAtA[start:]) if err != nil { return 0, err } iNdEx = start + next if iNdEx < 0 { return 0, ErrInvalidLengthPointersmd } } return iNdEx, nil case 4: return iNdEx, nil case 5: iNdEx += 4 return iNdEx, nil default: return 0, fmt.Errorf("proto: illegal wireType %d", wireType) } } panic("unreachable") } var ( ErrInvalidLengthPointersmd = fmt.Errorf("proto: negative length found during unmarshaling") ErrIntOverflowPointersmd = fmt.Errorf("proto: integer overflow") )