diff --git a/gopilosa_pbuf/public.pb.go b/gopilosa_pbuf/public.pb.go index e610499..d9d7d7d 100644 --- a/gopilosa_pbuf/public.pb.go +++ b/gopilosa_pbuf/public.pb.go @@ -1,38 +1,13 @@ -// Code generated by protoc-gen-go. +// Code generated by protoc-gen-go. DO NOT EDIT. // source: gopilosa_pbuf/public.proto -// DO NOT EDIT! - -/* -Package gopilosa_pbuf is a generated protocol buffer package. - -It is generated from these files: - gopilosa_pbuf/public.proto - -It has these top-level messages: - Row - RowIdentifiers - Pair - FieldRow - GroupCount - ValCount - ColumnAttrSet - Attr - AttrMap - QueryRequest - QueryResponse - QueryResult - ImportRequest - ImportValueRequest - TranslateKeysRequest - TranslateKeysResponse - ImportRoaringRequestView - ImportRoaringRequest -*/ + package gopilosa_pbuf -import proto "github.com/golang/protobuf/proto" -import fmt "fmt" -import math "math" +import ( + fmt "fmt" + proto "github.com/golang/protobuf/proto" + math "math" +) // Reference imports to suppress errors if they are not otherwise used. var _ = proto.Marshal @@ -46,15 +21,38 @@ var _ = math.Inf const _ = proto.ProtoPackageIsVersion2 // please upgrade the proto package type Row struct { - Columns []uint64 `protobuf:"varint,1,rep,packed,name=Columns" json:"Columns,omitempty"` - Keys []string `protobuf:"bytes,3,rep,name=Keys" json:"Keys,omitempty"` - Attrs []*Attr `protobuf:"bytes,2,rep,name=Attrs" json:"Attrs,omitempty"` + Columns []uint64 `protobuf:"varint,1,rep,packed,name=Columns,proto3" json:"Columns,omitempty"` + Keys []string `protobuf:"bytes,3,rep,name=Keys,proto3" json:"Keys,omitempty"` + Attrs []*Attr `protobuf:"bytes,2,rep,name=Attrs,proto3" json:"Attrs,omitempty"` + XXX_NoUnkeyedLiteral struct{} `json:"-"` + XXX_unrecognized []byte `json:"-"` + XXX_sizecache int32 `json:"-"` +} + +func (m *Row) Reset() { *m = Row{} } +func (m *Row) String() string { return proto.CompactTextString(m) } +func (*Row) ProtoMessage() {} +func (*Row) Descriptor() ([]byte, []int) { + return fileDescriptor_a66c591da5e2e6d0, []int{0} +} + +func (m *Row) XXX_Unmarshal(b []byte) error { + return xxx_messageInfo_Row.Unmarshal(m, b) +} +func (m *Row) XXX_Marshal(b []byte, deterministic bool) ([]byte, error) { + return xxx_messageInfo_Row.Marshal(b, m, deterministic) +} +func (m *Row) XXX_Merge(src proto.Message) { + xxx_messageInfo_Row.Merge(m, src) +} +func (m *Row) XXX_Size() int { + return xxx_messageInfo_Row.Size(m) +} +func (m *Row) XXX_DiscardUnknown() { + xxx_messageInfo_Row.DiscardUnknown(m) } -func (m *Row) Reset() { *m = Row{} } -func (m *Row) String() string { return proto.CompactTextString(m) } -func (*Row) ProtoMessage() {} -func (*Row) Descriptor() ([]byte, []int) { return fileDescriptor0, []int{0} } +var xxx_messageInfo_Row proto.InternalMessageInfo func (m *Row) GetColumns() []uint64 { if m != nil { @@ -78,14 +76,37 @@ func (m *Row) GetAttrs() []*Attr { } type RowIdentifiers struct { - Rows []uint64 `protobuf:"varint,1,rep,packed,name=Rows" json:"Rows,omitempty"` - Keys []string `protobuf:"bytes,2,rep,name=Keys" json:"Keys,omitempty"` + Rows []uint64 `protobuf:"varint,1,rep,packed,name=Rows,proto3" json:"Rows,omitempty"` + Keys []string `protobuf:"bytes,2,rep,name=Keys,proto3" json:"Keys,omitempty"` + XXX_NoUnkeyedLiteral struct{} `json:"-"` + XXX_unrecognized []byte `json:"-"` + XXX_sizecache int32 `json:"-"` } -func (m *RowIdentifiers) Reset() { *m = RowIdentifiers{} } -func (m *RowIdentifiers) String() string { return proto.CompactTextString(m) } -func (*RowIdentifiers) ProtoMessage() {} -func (*RowIdentifiers) Descriptor() ([]byte, []int) { return fileDescriptor0, []int{1} } +func (m *RowIdentifiers) Reset() { *m = RowIdentifiers{} } +func (m *RowIdentifiers) String() string { return proto.CompactTextString(m) } +func (*RowIdentifiers) ProtoMessage() {} +func (*RowIdentifiers) Descriptor() ([]byte, []int) { + return fileDescriptor_a66c591da5e2e6d0, []int{1} +} + +func (m *RowIdentifiers) XXX_Unmarshal(b []byte) error { + return xxx_messageInfo_RowIdentifiers.Unmarshal(m, b) +} +func (m *RowIdentifiers) XXX_Marshal(b []byte, deterministic bool) ([]byte, error) { + return xxx_messageInfo_RowIdentifiers.Marshal(b, m, deterministic) +} +func (m *RowIdentifiers) XXX_Merge(src proto.Message) { + xxx_messageInfo_RowIdentifiers.Merge(m, src) +} +func (m *RowIdentifiers) XXX_Size() int { + return xxx_messageInfo_RowIdentifiers.Size(m) +} +func (m *RowIdentifiers) XXX_DiscardUnknown() { + xxx_messageInfo_RowIdentifiers.DiscardUnknown(m) +} + +var xxx_messageInfo_RowIdentifiers proto.InternalMessageInfo func (m *RowIdentifiers) GetRows() []uint64 { if m != nil { @@ -102,15 +123,38 @@ func (m *RowIdentifiers) GetKeys() []string { } type Pair struct { - ID uint64 `protobuf:"varint,1,opt,name=ID" json:"ID,omitempty"` - Key string `protobuf:"bytes,3,opt,name=Key" json:"Key,omitempty"` - Count uint64 `protobuf:"varint,2,opt,name=Count" json:"Count,omitempty"` + ID uint64 `protobuf:"varint,1,opt,name=ID,proto3" json:"ID,omitempty"` + Key string `protobuf:"bytes,3,opt,name=Key,proto3" json:"Key,omitempty"` + Count uint64 `protobuf:"varint,2,opt,name=Count,proto3" json:"Count,omitempty"` + XXX_NoUnkeyedLiteral struct{} `json:"-"` + XXX_unrecognized []byte `json:"-"` + XXX_sizecache int32 `json:"-"` +} + +func (m *Pair) Reset() { *m = Pair{} } +func (m *Pair) String() string { return proto.CompactTextString(m) } +func (*Pair) ProtoMessage() {} +func (*Pair) Descriptor() ([]byte, []int) { + return fileDescriptor_a66c591da5e2e6d0, []int{2} } -func (m *Pair) Reset() { *m = Pair{} } -func (m *Pair) String() string { return proto.CompactTextString(m) } -func (*Pair) ProtoMessage() {} -func (*Pair) Descriptor() ([]byte, []int) { return fileDescriptor0, []int{2} } +func (m *Pair) XXX_Unmarshal(b []byte) error { + return xxx_messageInfo_Pair.Unmarshal(m, b) +} +func (m *Pair) XXX_Marshal(b []byte, deterministic bool) ([]byte, error) { + return xxx_messageInfo_Pair.Marshal(b, m, deterministic) +} +func (m *Pair) XXX_Merge(src proto.Message) { + xxx_messageInfo_Pair.Merge(m, src) +} +func (m *Pair) XXX_Size() int { + return xxx_messageInfo_Pair.Size(m) +} +func (m *Pair) XXX_DiscardUnknown() { + xxx_messageInfo_Pair.DiscardUnknown(m) +} + +var xxx_messageInfo_Pair proto.InternalMessageInfo func (m *Pair) GetID() uint64 { if m != nil { @@ -134,15 +178,38 @@ func (m *Pair) GetCount() uint64 { } type FieldRow struct { - Field string `protobuf:"bytes,1,opt,name=Field" json:"Field,omitempty"` - RowID uint64 `protobuf:"varint,2,opt,name=RowID" json:"RowID,omitempty"` - RowKey string `protobuf:"bytes,3,opt,name=RowKey" json:"RowKey,omitempty"` + Field string `protobuf:"bytes,1,opt,name=Field,proto3" json:"Field,omitempty"` + RowID uint64 `protobuf:"varint,2,opt,name=RowID,proto3" json:"RowID,omitempty"` + RowKey string `protobuf:"bytes,3,opt,name=RowKey,proto3" json:"RowKey,omitempty"` + XXX_NoUnkeyedLiteral struct{} `json:"-"` + XXX_unrecognized []byte `json:"-"` + XXX_sizecache int32 `json:"-"` } -func (m *FieldRow) Reset() { *m = FieldRow{} } -func (m *FieldRow) String() string { return proto.CompactTextString(m) } -func (*FieldRow) ProtoMessage() {} -func (*FieldRow) Descriptor() ([]byte, []int) { return fileDescriptor0, []int{3} } +func (m *FieldRow) Reset() { *m = FieldRow{} } +func (m *FieldRow) String() string { return proto.CompactTextString(m) } +func (*FieldRow) ProtoMessage() {} +func (*FieldRow) Descriptor() ([]byte, []int) { + return fileDescriptor_a66c591da5e2e6d0, []int{3} +} + +func (m *FieldRow) XXX_Unmarshal(b []byte) error { + return xxx_messageInfo_FieldRow.Unmarshal(m, b) +} +func (m *FieldRow) XXX_Marshal(b []byte, deterministic bool) ([]byte, error) { + return xxx_messageInfo_FieldRow.Marshal(b, m, deterministic) +} +func (m *FieldRow) XXX_Merge(src proto.Message) { + xxx_messageInfo_FieldRow.Merge(m, src) +} +func (m *FieldRow) XXX_Size() int { + return xxx_messageInfo_FieldRow.Size(m) +} +func (m *FieldRow) XXX_DiscardUnknown() { + xxx_messageInfo_FieldRow.DiscardUnknown(m) +} + +var xxx_messageInfo_FieldRow proto.InternalMessageInfo func (m *FieldRow) GetField() string { if m != nil { @@ -166,14 +233,38 @@ func (m *FieldRow) GetRowKey() string { } type GroupCount struct { - Group []*FieldRow `protobuf:"bytes,1,rep,name=Group" json:"Group,omitempty"` - Count uint64 `protobuf:"varint,2,opt,name=Count" json:"Count,omitempty"` + Group []*FieldRow `protobuf:"bytes,1,rep,name=Group,proto3" json:"Group,omitempty"` + Count uint64 `protobuf:"varint,2,opt,name=Count,proto3" json:"Count,omitempty"` + Sum int64 `protobuf:"varint,3,opt,name=Sum,proto3" json:"Sum,omitempty"` + XXX_NoUnkeyedLiteral struct{} `json:"-"` + XXX_unrecognized []byte `json:"-"` + XXX_sizecache int32 `json:"-"` +} + +func (m *GroupCount) Reset() { *m = GroupCount{} } +func (m *GroupCount) String() string { return proto.CompactTextString(m) } +func (*GroupCount) ProtoMessage() {} +func (*GroupCount) Descriptor() ([]byte, []int) { + return fileDescriptor_a66c591da5e2e6d0, []int{4} +} + +func (m *GroupCount) XXX_Unmarshal(b []byte) error { + return xxx_messageInfo_GroupCount.Unmarshal(m, b) +} +func (m *GroupCount) XXX_Marshal(b []byte, deterministic bool) ([]byte, error) { + return xxx_messageInfo_GroupCount.Marshal(b, m, deterministic) +} +func (m *GroupCount) XXX_Merge(src proto.Message) { + xxx_messageInfo_GroupCount.Merge(m, src) +} +func (m *GroupCount) XXX_Size() int { + return xxx_messageInfo_GroupCount.Size(m) +} +func (m *GroupCount) XXX_DiscardUnknown() { + xxx_messageInfo_GroupCount.DiscardUnknown(m) } -func (m *GroupCount) Reset() { *m = GroupCount{} } -func (m *GroupCount) String() string { return proto.CompactTextString(m) } -func (*GroupCount) ProtoMessage() {} -func (*GroupCount) Descriptor() ([]byte, []int) { return fileDescriptor0, []int{4} } +var xxx_messageInfo_GroupCount proto.InternalMessageInfo func (m *GroupCount) GetGroup() []*FieldRow { if m != nil { @@ -189,15 +280,45 @@ func (m *GroupCount) GetCount() uint64 { return 0 } +func (m *GroupCount) GetSum() int64 { + if m != nil { + return m.Sum + } + return 0 +} + type ValCount struct { - Val int64 `protobuf:"varint,1,opt,name=Val" json:"Val,omitempty"` - Count int64 `protobuf:"varint,2,opt,name=Count" json:"Count,omitempty"` + Val int64 `protobuf:"varint,1,opt,name=Val,proto3" json:"Val,omitempty"` + Count int64 `protobuf:"varint,2,opt,name=Count,proto3" json:"Count,omitempty"` + XXX_NoUnkeyedLiteral struct{} `json:"-"` + XXX_unrecognized []byte `json:"-"` + XXX_sizecache int32 `json:"-"` } -func (m *ValCount) Reset() { *m = ValCount{} } -func (m *ValCount) String() string { return proto.CompactTextString(m) } -func (*ValCount) ProtoMessage() {} -func (*ValCount) Descriptor() ([]byte, []int) { return fileDescriptor0, []int{5} } +func (m *ValCount) Reset() { *m = ValCount{} } +func (m *ValCount) String() string { return proto.CompactTextString(m) } +func (*ValCount) ProtoMessage() {} +func (*ValCount) Descriptor() ([]byte, []int) { + return fileDescriptor_a66c591da5e2e6d0, []int{5} +} + +func (m *ValCount) XXX_Unmarshal(b []byte) error { + return xxx_messageInfo_ValCount.Unmarshal(m, b) +} +func (m *ValCount) XXX_Marshal(b []byte, deterministic bool) ([]byte, error) { + return xxx_messageInfo_ValCount.Marshal(b, m, deterministic) +} +func (m *ValCount) XXX_Merge(src proto.Message) { + xxx_messageInfo_ValCount.Merge(m, src) +} +func (m *ValCount) XXX_Size() int { + return xxx_messageInfo_ValCount.Size(m) +} +func (m *ValCount) XXX_DiscardUnknown() { + xxx_messageInfo_ValCount.DiscardUnknown(m) +} + +var xxx_messageInfo_ValCount proto.InternalMessageInfo func (m *ValCount) GetVal() int64 { if m != nil { @@ -214,15 +335,38 @@ func (m *ValCount) GetCount() int64 { } type ColumnAttrSet struct { - ID uint64 `protobuf:"varint,1,opt,name=ID" json:"ID,omitempty"` - Key string `protobuf:"bytes,3,opt,name=Key" json:"Key,omitempty"` - Attrs []*Attr `protobuf:"bytes,2,rep,name=Attrs" json:"Attrs,omitempty"` + ID uint64 `protobuf:"varint,1,opt,name=ID,proto3" json:"ID,omitempty"` + Key string `protobuf:"bytes,3,opt,name=Key,proto3" json:"Key,omitempty"` + Attrs []*Attr `protobuf:"bytes,2,rep,name=Attrs,proto3" json:"Attrs,omitempty"` + XXX_NoUnkeyedLiteral struct{} `json:"-"` + XXX_unrecognized []byte `json:"-"` + XXX_sizecache int32 `json:"-"` +} + +func (m *ColumnAttrSet) Reset() { *m = ColumnAttrSet{} } +func (m *ColumnAttrSet) String() string { return proto.CompactTextString(m) } +func (*ColumnAttrSet) ProtoMessage() {} +func (*ColumnAttrSet) Descriptor() ([]byte, []int) { + return fileDescriptor_a66c591da5e2e6d0, []int{6} +} + +func (m *ColumnAttrSet) XXX_Unmarshal(b []byte) error { + return xxx_messageInfo_ColumnAttrSet.Unmarshal(m, b) +} +func (m *ColumnAttrSet) XXX_Marshal(b []byte, deterministic bool) ([]byte, error) { + return xxx_messageInfo_ColumnAttrSet.Marshal(b, m, deterministic) +} +func (m *ColumnAttrSet) XXX_Merge(src proto.Message) { + xxx_messageInfo_ColumnAttrSet.Merge(m, src) +} +func (m *ColumnAttrSet) XXX_Size() int { + return xxx_messageInfo_ColumnAttrSet.Size(m) +} +func (m *ColumnAttrSet) XXX_DiscardUnknown() { + xxx_messageInfo_ColumnAttrSet.DiscardUnknown(m) } -func (m *ColumnAttrSet) Reset() { *m = ColumnAttrSet{} } -func (m *ColumnAttrSet) String() string { return proto.CompactTextString(m) } -func (*ColumnAttrSet) ProtoMessage() {} -func (*ColumnAttrSet) Descriptor() ([]byte, []int) { return fileDescriptor0, []int{6} } +var xxx_messageInfo_ColumnAttrSet proto.InternalMessageInfo func (m *ColumnAttrSet) GetID() uint64 { if m != nil { @@ -246,18 +390,41 @@ func (m *ColumnAttrSet) GetAttrs() []*Attr { } type Attr struct { - Key string `protobuf:"bytes,1,opt,name=Key" json:"Key,omitempty"` - Type uint64 `protobuf:"varint,2,opt,name=Type" json:"Type,omitempty"` - StringValue string `protobuf:"bytes,3,opt,name=StringValue" json:"StringValue,omitempty"` - IntValue int64 `protobuf:"varint,4,opt,name=IntValue" json:"IntValue,omitempty"` - BoolValue bool `protobuf:"varint,5,opt,name=BoolValue" json:"BoolValue,omitempty"` - FloatValue float64 `protobuf:"fixed64,6,opt,name=FloatValue" json:"FloatValue,omitempty"` + Key string `protobuf:"bytes,1,opt,name=Key,proto3" json:"Key,omitempty"` + Type uint64 `protobuf:"varint,2,opt,name=Type,proto3" json:"Type,omitempty"` + StringValue string `protobuf:"bytes,3,opt,name=StringValue,proto3" json:"StringValue,omitempty"` + IntValue int64 `protobuf:"varint,4,opt,name=IntValue,proto3" json:"IntValue,omitempty"` + BoolValue bool `protobuf:"varint,5,opt,name=BoolValue,proto3" json:"BoolValue,omitempty"` + FloatValue float64 `protobuf:"fixed64,6,opt,name=FloatValue,proto3" json:"FloatValue,omitempty"` + XXX_NoUnkeyedLiteral struct{} `json:"-"` + XXX_unrecognized []byte `json:"-"` + XXX_sizecache int32 `json:"-"` } -func (m *Attr) Reset() { *m = Attr{} } -func (m *Attr) String() string { return proto.CompactTextString(m) } -func (*Attr) ProtoMessage() {} -func (*Attr) Descriptor() ([]byte, []int) { return fileDescriptor0, []int{7} } +func (m *Attr) Reset() { *m = Attr{} } +func (m *Attr) String() string { return proto.CompactTextString(m) } +func (*Attr) ProtoMessage() {} +func (*Attr) Descriptor() ([]byte, []int) { + return fileDescriptor_a66c591da5e2e6d0, []int{7} +} + +func (m *Attr) XXX_Unmarshal(b []byte) error { + return xxx_messageInfo_Attr.Unmarshal(m, b) +} +func (m *Attr) XXX_Marshal(b []byte, deterministic bool) ([]byte, error) { + return xxx_messageInfo_Attr.Marshal(b, m, deterministic) +} +func (m *Attr) XXX_Merge(src proto.Message) { + xxx_messageInfo_Attr.Merge(m, src) +} +func (m *Attr) XXX_Size() int { + return xxx_messageInfo_Attr.Size(m) +} +func (m *Attr) XXX_DiscardUnknown() { + xxx_messageInfo_Attr.DiscardUnknown(m) +} + +var xxx_messageInfo_Attr proto.InternalMessageInfo func (m *Attr) GetKey() string { if m != nil { @@ -302,13 +469,36 @@ func (m *Attr) GetFloatValue() float64 { } type AttrMap struct { - Attrs []*Attr `protobuf:"bytes,1,rep,name=Attrs" json:"Attrs,omitempty"` + Attrs []*Attr `protobuf:"bytes,1,rep,name=Attrs,proto3" json:"Attrs,omitempty"` + XXX_NoUnkeyedLiteral struct{} `json:"-"` + XXX_unrecognized []byte `json:"-"` + XXX_sizecache int32 `json:"-"` +} + +func (m *AttrMap) Reset() { *m = AttrMap{} } +func (m *AttrMap) String() string { return proto.CompactTextString(m) } +func (*AttrMap) ProtoMessage() {} +func (*AttrMap) Descriptor() ([]byte, []int) { + return fileDescriptor_a66c591da5e2e6d0, []int{8} +} + +func (m *AttrMap) XXX_Unmarshal(b []byte) error { + return xxx_messageInfo_AttrMap.Unmarshal(m, b) +} +func (m *AttrMap) XXX_Marshal(b []byte, deterministic bool) ([]byte, error) { + return xxx_messageInfo_AttrMap.Marshal(b, m, deterministic) +} +func (m *AttrMap) XXX_Merge(src proto.Message) { + xxx_messageInfo_AttrMap.Merge(m, src) +} +func (m *AttrMap) XXX_Size() int { + return xxx_messageInfo_AttrMap.Size(m) +} +func (m *AttrMap) XXX_DiscardUnknown() { + xxx_messageInfo_AttrMap.DiscardUnknown(m) } -func (m *AttrMap) Reset() { *m = AttrMap{} } -func (m *AttrMap) String() string { return proto.CompactTextString(m) } -func (*AttrMap) ProtoMessage() {} -func (*AttrMap) Descriptor() ([]byte, []int) { return fileDescriptor0, []int{8} } +var xxx_messageInfo_AttrMap proto.InternalMessageInfo func (m *AttrMap) GetAttrs() []*Attr { if m != nil { @@ -318,18 +508,41 @@ func (m *AttrMap) GetAttrs() []*Attr { } type QueryRequest struct { - Query string `protobuf:"bytes,1,opt,name=Query" json:"Query,omitempty"` - Shards []uint64 `protobuf:"varint,2,rep,packed,name=Shards" json:"Shards,omitempty"` - ColumnAttrs bool `protobuf:"varint,3,opt,name=ColumnAttrs" json:"ColumnAttrs,omitempty"` - Remote bool `protobuf:"varint,5,opt,name=Remote" json:"Remote,omitempty"` - ExcludeRowAttrs bool `protobuf:"varint,6,opt,name=ExcludeRowAttrs" json:"ExcludeRowAttrs,omitempty"` - ExcludeColumns bool `protobuf:"varint,7,opt,name=ExcludeColumns" json:"ExcludeColumns,omitempty"` + Query string `protobuf:"bytes,1,opt,name=Query,proto3" json:"Query,omitempty"` + Shards []uint64 `protobuf:"varint,2,rep,packed,name=Shards,proto3" json:"Shards,omitempty"` + ColumnAttrs bool `protobuf:"varint,3,opt,name=ColumnAttrs,proto3" json:"ColumnAttrs,omitempty"` + Remote bool `protobuf:"varint,5,opt,name=Remote,proto3" json:"Remote,omitempty"` + ExcludeRowAttrs bool `protobuf:"varint,6,opt,name=ExcludeRowAttrs,proto3" json:"ExcludeRowAttrs,omitempty"` + ExcludeColumns bool `protobuf:"varint,7,opt,name=ExcludeColumns,proto3" json:"ExcludeColumns,omitempty"` + XXX_NoUnkeyedLiteral struct{} `json:"-"` + XXX_unrecognized []byte `json:"-"` + XXX_sizecache int32 `json:"-"` +} + +func (m *QueryRequest) Reset() { *m = QueryRequest{} } +func (m *QueryRequest) String() string { return proto.CompactTextString(m) } +func (*QueryRequest) ProtoMessage() {} +func (*QueryRequest) Descriptor() ([]byte, []int) { + return fileDescriptor_a66c591da5e2e6d0, []int{9} +} + +func (m *QueryRequest) XXX_Unmarshal(b []byte) error { + return xxx_messageInfo_QueryRequest.Unmarshal(m, b) +} +func (m *QueryRequest) XXX_Marshal(b []byte, deterministic bool) ([]byte, error) { + return xxx_messageInfo_QueryRequest.Marshal(b, m, deterministic) +} +func (m *QueryRequest) XXX_Merge(src proto.Message) { + xxx_messageInfo_QueryRequest.Merge(m, src) +} +func (m *QueryRequest) XXX_Size() int { + return xxx_messageInfo_QueryRequest.Size(m) +} +func (m *QueryRequest) XXX_DiscardUnknown() { + xxx_messageInfo_QueryRequest.DiscardUnknown(m) } -func (m *QueryRequest) Reset() { *m = QueryRequest{} } -func (m *QueryRequest) String() string { return proto.CompactTextString(m) } -func (*QueryRequest) ProtoMessage() {} -func (*QueryRequest) Descriptor() ([]byte, []int) { return fileDescriptor0, []int{9} } +var xxx_messageInfo_QueryRequest proto.InternalMessageInfo func (m *QueryRequest) GetQuery() string { if m != nil { @@ -374,15 +587,38 @@ func (m *QueryRequest) GetExcludeColumns() bool { } type QueryResponse struct { - Err string `protobuf:"bytes,1,opt,name=Err" json:"Err,omitempty"` - Results []*QueryResult `protobuf:"bytes,2,rep,name=Results" json:"Results,omitempty"` - ColumnAttrSets []*ColumnAttrSet `protobuf:"bytes,3,rep,name=ColumnAttrSets" json:"ColumnAttrSets,omitempty"` + Err string `protobuf:"bytes,1,opt,name=Err,proto3" json:"Err,omitempty"` + Results []*QueryResult `protobuf:"bytes,2,rep,name=Results,proto3" json:"Results,omitempty"` + ColumnAttrSets []*ColumnAttrSet `protobuf:"bytes,3,rep,name=ColumnAttrSets,proto3" json:"ColumnAttrSets,omitempty"` + XXX_NoUnkeyedLiteral struct{} `json:"-"` + XXX_unrecognized []byte `json:"-"` + XXX_sizecache int32 `json:"-"` } -func (m *QueryResponse) Reset() { *m = QueryResponse{} } -func (m *QueryResponse) String() string { return proto.CompactTextString(m) } -func (*QueryResponse) ProtoMessage() {} -func (*QueryResponse) Descriptor() ([]byte, []int) { return fileDescriptor0, []int{10} } +func (m *QueryResponse) Reset() { *m = QueryResponse{} } +func (m *QueryResponse) String() string { return proto.CompactTextString(m) } +func (*QueryResponse) ProtoMessage() {} +func (*QueryResponse) Descriptor() ([]byte, []int) { + return fileDescriptor_a66c591da5e2e6d0, []int{10} +} + +func (m *QueryResponse) XXX_Unmarshal(b []byte) error { + return xxx_messageInfo_QueryResponse.Unmarshal(m, b) +} +func (m *QueryResponse) XXX_Marshal(b []byte, deterministic bool) ([]byte, error) { + return xxx_messageInfo_QueryResponse.Marshal(b, m, deterministic) +} +func (m *QueryResponse) XXX_Merge(src proto.Message) { + xxx_messageInfo_QueryResponse.Merge(m, src) +} +func (m *QueryResponse) XXX_Size() int { + return xxx_messageInfo_QueryResponse.Size(m) +} +func (m *QueryResponse) XXX_DiscardUnknown() { + xxx_messageInfo_QueryResponse.DiscardUnknown(m) +} + +var xxx_messageInfo_QueryResponse proto.InternalMessageInfo func (m *QueryResponse) GetErr() string { if m != nil { @@ -406,21 +642,44 @@ func (m *QueryResponse) GetColumnAttrSets() []*ColumnAttrSet { } type QueryResult struct { - Type uint32 `protobuf:"varint,6,opt,name=Type" json:"Type,omitempty"` - Row *Row `protobuf:"bytes,1,opt,name=Row" json:"Row,omitempty"` - N uint64 `protobuf:"varint,2,opt,name=N" json:"N,omitempty"` - Pairs []*Pair `protobuf:"bytes,3,rep,name=Pairs" json:"Pairs,omitempty"` - Changed bool `protobuf:"varint,4,opt,name=Changed" json:"Changed,omitempty"` - ValCount *ValCount `protobuf:"bytes,5,opt,name=ValCount" json:"ValCount,omitempty"` - RowIDs []uint64 `protobuf:"varint,7,rep,packed,name=RowIDs" json:"RowIDs,omitempty"` - GroupCounts []*GroupCount `protobuf:"bytes,8,rep,name=GroupCounts" json:"GroupCounts,omitempty"` - RowIdentifiers *RowIdentifiers `protobuf:"bytes,9,opt,name=RowIdentifiers" json:"RowIdentifiers,omitempty"` -} - -func (m *QueryResult) Reset() { *m = QueryResult{} } -func (m *QueryResult) String() string { return proto.CompactTextString(m) } -func (*QueryResult) ProtoMessage() {} -func (*QueryResult) Descriptor() ([]byte, []int) { return fileDescriptor0, []int{11} } + Type uint32 `protobuf:"varint,6,opt,name=Type,proto3" json:"Type,omitempty"` + Row *Row `protobuf:"bytes,1,opt,name=Row,proto3" json:"Row,omitempty"` + N uint64 `protobuf:"varint,2,opt,name=N,proto3" json:"N,omitempty"` + Pairs []*Pair `protobuf:"bytes,3,rep,name=Pairs,proto3" json:"Pairs,omitempty"` + Changed bool `protobuf:"varint,4,opt,name=Changed,proto3" json:"Changed,omitempty"` + ValCount *ValCount `protobuf:"bytes,5,opt,name=ValCount,proto3" json:"ValCount,omitempty"` + RowIDs []uint64 `protobuf:"varint,7,rep,packed,name=RowIDs,proto3" json:"RowIDs,omitempty"` + GroupCounts []*GroupCount `protobuf:"bytes,8,rep,name=GroupCounts,proto3" json:"GroupCounts,omitempty"` + RowIdentifiers *RowIdentifiers `protobuf:"bytes,9,opt,name=RowIdentifiers,proto3" json:"RowIdentifiers,omitempty"` + XXX_NoUnkeyedLiteral struct{} `json:"-"` + XXX_unrecognized []byte `json:"-"` + XXX_sizecache int32 `json:"-"` +} + +func (m *QueryResult) Reset() { *m = QueryResult{} } +func (m *QueryResult) String() string { return proto.CompactTextString(m) } +func (*QueryResult) ProtoMessage() {} +func (*QueryResult) Descriptor() ([]byte, []int) { + return fileDescriptor_a66c591da5e2e6d0, []int{11} +} + +func (m *QueryResult) XXX_Unmarshal(b []byte) error { + return xxx_messageInfo_QueryResult.Unmarshal(m, b) +} +func (m *QueryResult) XXX_Marshal(b []byte, deterministic bool) ([]byte, error) { + return xxx_messageInfo_QueryResult.Marshal(b, m, deterministic) +} +func (m *QueryResult) XXX_Merge(src proto.Message) { + xxx_messageInfo_QueryResult.Merge(m, src) +} +func (m *QueryResult) XXX_Size() int { + return xxx_messageInfo_QueryResult.Size(m) +} +func (m *QueryResult) XXX_DiscardUnknown() { + xxx_messageInfo_QueryResult.DiscardUnknown(m) +} + +var xxx_messageInfo_QueryResult proto.InternalMessageInfo func (m *QueryResult) GetType() uint32 { if m != nil { @@ -486,20 +745,43 @@ func (m *QueryResult) GetRowIdentifiers() *RowIdentifiers { } type ImportRequest struct { - Index string `protobuf:"bytes,1,opt,name=Index" json:"Index,omitempty"` - Field string `protobuf:"bytes,2,opt,name=Field" json:"Field,omitempty"` - Shard uint64 `protobuf:"varint,3,opt,name=Shard" json:"Shard,omitempty"` - RowIDs []uint64 `protobuf:"varint,4,rep,packed,name=RowIDs" json:"RowIDs,omitempty"` - ColumnIDs []uint64 `protobuf:"varint,5,rep,packed,name=ColumnIDs" json:"ColumnIDs,omitempty"` - RowKeys []string `protobuf:"bytes,7,rep,name=RowKeys" json:"RowKeys,omitempty"` - ColumnKeys []string `protobuf:"bytes,8,rep,name=ColumnKeys" json:"ColumnKeys,omitempty"` - Timestamps []int64 `protobuf:"varint,6,rep,packed,name=Timestamps" json:"Timestamps,omitempty"` + Index string `protobuf:"bytes,1,opt,name=Index,proto3" json:"Index,omitempty"` + Field string `protobuf:"bytes,2,opt,name=Field,proto3" json:"Field,omitempty"` + Shard uint64 `protobuf:"varint,3,opt,name=Shard,proto3" json:"Shard,omitempty"` + RowIDs []uint64 `protobuf:"varint,4,rep,packed,name=RowIDs,proto3" json:"RowIDs,omitempty"` + ColumnIDs []uint64 `protobuf:"varint,5,rep,packed,name=ColumnIDs,proto3" json:"ColumnIDs,omitempty"` + RowKeys []string `protobuf:"bytes,7,rep,name=RowKeys,proto3" json:"RowKeys,omitempty"` + ColumnKeys []string `protobuf:"bytes,8,rep,name=ColumnKeys,proto3" json:"ColumnKeys,omitempty"` + Timestamps []int64 `protobuf:"varint,6,rep,packed,name=Timestamps,proto3" json:"Timestamps,omitempty"` + XXX_NoUnkeyedLiteral struct{} `json:"-"` + XXX_unrecognized []byte `json:"-"` + XXX_sizecache int32 `json:"-"` } -func (m *ImportRequest) Reset() { *m = ImportRequest{} } -func (m *ImportRequest) String() string { return proto.CompactTextString(m) } -func (*ImportRequest) ProtoMessage() {} -func (*ImportRequest) Descriptor() ([]byte, []int) { return fileDescriptor0, []int{12} } +func (m *ImportRequest) Reset() { *m = ImportRequest{} } +func (m *ImportRequest) String() string { return proto.CompactTextString(m) } +func (*ImportRequest) ProtoMessage() {} +func (*ImportRequest) Descriptor() ([]byte, []int) { + return fileDescriptor_a66c591da5e2e6d0, []int{12} +} + +func (m *ImportRequest) XXX_Unmarshal(b []byte) error { + return xxx_messageInfo_ImportRequest.Unmarshal(m, b) +} +func (m *ImportRequest) XXX_Marshal(b []byte, deterministic bool) ([]byte, error) { + return xxx_messageInfo_ImportRequest.Marshal(b, m, deterministic) +} +func (m *ImportRequest) XXX_Merge(src proto.Message) { + xxx_messageInfo_ImportRequest.Merge(m, src) +} +func (m *ImportRequest) XXX_Size() int { + return xxx_messageInfo_ImportRequest.Size(m) +} +func (m *ImportRequest) XXX_DiscardUnknown() { + xxx_messageInfo_ImportRequest.DiscardUnknown(m) +} + +var xxx_messageInfo_ImportRequest proto.InternalMessageInfo func (m *ImportRequest) GetIndex() string { if m != nil { @@ -558,18 +840,41 @@ func (m *ImportRequest) GetTimestamps() []int64 { } type ImportValueRequest struct { - Index string `protobuf:"bytes,1,opt,name=Index" json:"Index,omitempty"` - Field string `protobuf:"bytes,2,opt,name=Field" json:"Field,omitempty"` - Shard uint64 `protobuf:"varint,3,opt,name=Shard" json:"Shard,omitempty"` - ColumnIDs []uint64 `protobuf:"varint,5,rep,packed,name=ColumnIDs" json:"ColumnIDs,omitempty"` - ColumnKeys []string `protobuf:"bytes,7,rep,name=ColumnKeys" json:"ColumnKeys,omitempty"` - Values []int64 `protobuf:"varint,6,rep,packed,name=Values" json:"Values,omitempty"` + Index string `protobuf:"bytes,1,opt,name=Index,proto3" json:"Index,omitempty"` + Field string `protobuf:"bytes,2,opt,name=Field,proto3" json:"Field,omitempty"` + Shard uint64 `protobuf:"varint,3,opt,name=Shard,proto3" json:"Shard,omitempty"` + ColumnIDs []uint64 `protobuf:"varint,5,rep,packed,name=ColumnIDs,proto3" json:"ColumnIDs,omitempty"` + ColumnKeys []string `protobuf:"bytes,7,rep,name=ColumnKeys,proto3" json:"ColumnKeys,omitempty"` + Values []int64 `protobuf:"varint,6,rep,packed,name=Values,proto3" json:"Values,omitempty"` + XXX_NoUnkeyedLiteral struct{} `json:"-"` + XXX_unrecognized []byte `json:"-"` + XXX_sizecache int32 `json:"-"` +} + +func (m *ImportValueRequest) Reset() { *m = ImportValueRequest{} } +func (m *ImportValueRequest) String() string { return proto.CompactTextString(m) } +func (*ImportValueRequest) ProtoMessage() {} +func (*ImportValueRequest) Descriptor() ([]byte, []int) { + return fileDescriptor_a66c591da5e2e6d0, []int{13} } -func (m *ImportValueRequest) Reset() { *m = ImportValueRequest{} } -func (m *ImportValueRequest) String() string { return proto.CompactTextString(m) } -func (*ImportValueRequest) ProtoMessage() {} -func (*ImportValueRequest) Descriptor() ([]byte, []int) { return fileDescriptor0, []int{13} } +func (m *ImportValueRequest) XXX_Unmarshal(b []byte) error { + return xxx_messageInfo_ImportValueRequest.Unmarshal(m, b) +} +func (m *ImportValueRequest) XXX_Marshal(b []byte, deterministic bool) ([]byte, error) { + return xxx_messageInfo_ImportValueRequest.Marshal(b, m, deterministic) +} +func (m *ImportValueRequest) XXX_Merge(src proto.Message) { + xxx_messageInfo_ImportValueRequest.Merge(m, src) +} +func (m *ImportValueRequest) XXX_Size() int { + return xxx_messageInfo_ImportValueRequest.Size(m) +} +func (m *ImportValueRequest) XXX_DiscardUnknown() { + xxx_messageInfo_ImportValueRequest.DiscardUnknown(m) +} + +var xxx_messageInfo_ImportValueRequest proto.InternalMessageInfo func (m *ImportValueRequest) GetIndex() string { if m != nil { @@ -614,15 +919,38 @@ func (m *ImportValueRequest) GetValues() []int64 { } type TranslateKeysRequest struct { - Index string `protobuf:"bytes,1,opt,name=Index" json:"Index,omitempty"` - Field string `protobuf:"bytes,2,opt,name=Field" json:"Field,omitempty"` - Keys []string `protobuf:"bytes,3,rep,name=Keys" json:"Keys,omitempty"` + Index string `protobuf:"bytes,1,opt,name=Index,proto3" json:"Index,omitempty"` + Field string `protobuf:"bytes,2,opt,name=Field,proto3" json:"Field,omitempty"` + Keys []string `protobuf:"bytes,3,rep,name=Keys,proto3" json:"Keys,omitempty"` + XXX_NoUnkeyedLiteral struct{} `json:"-"` + XXX_unrecognized []byte `json:"-"` + XXX_sizecache int32 `json:"-"` } -func (m *TranslateKeysRequest) Reset() { *m = TranslateKeysRequest{} } -func (m *TranslateKeysRequest) String() string { return proto.CompactTextString(m) } -func (*TranslateKeysRequest) ProtoMessage() {} -func (*TranslateKeysRequest) Descriptor() ([]byte, []int) { return fileDescriptor0, []int{14} } +func (m *TranslateKeysRequest) Reset() { *m = TranslateKeysRequest{} } +func (m *TranslateKeysRequest) String() string { return proto.CompactTextString(m) } +func (*TranslateKeysRequest) ProtoMessage() {} +func (*TranslateKeysRequest) Descriptor() ([]byte, []int) { + return fileDescriptor_a66c591da5e2e6d0, []int{14} +} + +func (m *TranslateKeysRequest) XXX_Unmarshal(b []byte) error { + return xxx_messageInfo_TranslateKeysRequest.Unmarshal(m, b) +} +func (m *TranslateKeysRequest) XXX_Marshal(b []byte, deterministic bool) ([]byte, error) { + return xxx_messageInfo_TranslateKeysRequest.Marshal(b, m, deterministic) +} +func (m *TranslateKeysRequest) XXX_Merge(src proto.Message) { + xxx_messageInfo_TranslateKeysRequest.Merge(m, src) +} +func (m *TranslateKeysRequest) XXX_Size() int { + return xxx_messageInfo_TranslateKeysRequest.Size(m) +} +func (m *TranslateKeysRequest) XXX_DiscardUnknown() { + xxx_messageInfo_TranslateKeysRequest.DiscardUnknown(m) +} + +var xxx_messageInfo_TranslateKeysRequest proto.InternalMessageInfo func (m *TranslateKeysRequest) GetIndex() string { if m != nil { @@ -646,13 +974,36 @@ func (m *TranslateKeysRequest) GetKeys() []string { } type TranslateKeysResponse struct { - IDs []uint64 `protobuf:"varint,3,rep,packed,name=IDs" json:"IDs,omitempty"` + IDs []uint64 `protobuf:"varint,3,rep,packed,name=IDs,proto3" json:"IDs,omitempty"` + XXX_NoUnkeyedLiteral struct{} `json:"-"` + XXX_unrecognized []byte `json:"-"` + XXX_sizecache int32 `json:"-"` +} + +func (m *TranslateKeysResponse) Reset() { *m = TranslateKeysResponse{} } +func (m *TranslateKeysResponse) String() string { return proto.CompactTextString(m) } +func (*TranslateKeysResponse) ProtoMessage() {} +func (*TranslateKeysResponse) Descriptor() ([]byte, []int) { + return fileDescriptor_a66c591da5e2e6d0, []int{15} +} + +func (m *TranslateKeysResponse) XXX_Unmarshal(b []byte) error { + return xxx_messageInfo_TranslateKeysResponse.Unmarshal(m, b) +} +func (m *TranslateKeysResponse) XXX_Marshal(b []byte, deterministic bool) ([]byte, error) { + return xxx_messageInfo_TranslateKeysResponse.Marshal(b, m, deterministic) +} +func (m *TranslateKeysResponse) XXX_Merge(src proto.Message) { + xxx_messageInfo_TranslateKeysResponse.Merge(m, src) +} +func (m *TranslateKeysResponse) XXX_Size() int { + return xxx_messageInfo_TranslateKeysResponse.Size(m) +} +func (m *TranslateKeysResponse) XXX_DiscardUnknown() { + xxx_messageInfo_TranslateKeysResponse.DiscardUnknown(m) } -func (m *TranslateKeysResponse) Reset() { *m = TranslateKeysResponse{} } -func (m *TranslateKeysResponse) String() string { return proto.CompactTextString(m) } -func (*TranslateKeysResponse) ProtoMessage() {} -func (*TranslateKeysResponse) Descriptor() ([]byte, []int) { return fileDescriptor0, []int{15} } +var xxx_messageInfo_TranslateKeysResponse proto.InternalMessageInfo func (m *TranslateKeysResponse) GetIDs() []uint64 { if m != nil { @@ -662,14 +1013,37 @@ func (m *TranslateKeysResponse) GetIDs() []uint64 { } type ImportRoaringRequestView struct { - Name string `protobuf:"bytes,1,opt,name=Name" json:"Name,omitempty"` - Data []byte `protobuf:"bytes,2,opt,name=Data,proto3" json:"Data,omitempty"` + Name string `protobuf:"bytes,1,opt,name=Name,proto3" json:"Name,omitempty"` + Data []byte `protobuf:"bytes,2,opt,name=Data,proto3" json:"Data,omitempty"` + XXX_NoUnkeyedLiteral struct{} `json:"-"` + XXX_unrecognized []byte `json:"-"` + XXX_sizecache int32 `json:"-"` +} + +func (m *ImportRoaringRequestView) Reset() { *m = ImportRoaringRequestView{} } +func (m *ImportRoaringRequestView) String() string { return proto.CompactTextString(m) } +func (*ImportRoaringRequestView) ProtoMessage() {} +func (*ImportRoaringRequestView) Descriptor() ([]byte, []int) { + return fileDescriptor_a66c591da5e2e6d0, []int{16} } -func (m *ImportRoaringRequestView) Reset() { *m = ImportRoaringRequestView{} } -func (m *ImportRoaringRequestView) String() string { return proto.CompactTextString(m) } -func (*ImportRoaringRequestView) ProtoMessage() {} -func (*ImportRoaringRequestView) Descriptor() ([]byte, []int) { return fileDescriptor0, []int{16} } +func (m *ImportRoaringRequestView) XXX_Unmarshal(b []byte) error { + return xxx_messageInfo_ImportRoaringRequestView.Unmarshal(m, b) +} +func (m *ImportRoaringRequestView) XXX_Marshal(b []byte, deterministic bool) ([]byte, error) { + return xxx_messageInfo_ImportRoaringRequestView.Marshal(b, m, deterministic) +} +func (m *ImportRoaringRequestView) XXX_Merge(src proto.Message) { + xxx_messageInfo_ImportRoaringRequestView.Merge(m, src) +} +func (m *ImportRoaringRequestView) XXX_Size() int { + return xxx_messageInfo_ImportRoaringRequestView.Size(m) +} +func (m *ImportRoaringRequestView) XXX_DiscardUnknown() { + xxx_messageInfo_ImportRoaringRequestView.DiscardUnknown(m) +} + +var xxx_messageInfo_ImportRoaringRequestView proto.InternalMessageInfo func (m *ImportRoaringRequestView) GetName() string { if m != nil { @@ -686,14 +1060,37 @@ func (m *ImportRoaringRequestView) GetData() []byte { } type ImportRoaringRequest struct { - Clear bool `protobuf:"varint,1,opt,name=Clear" json:"Clear,omitempty"` - Views []*ImportRoaringRequestView `protobuf:"bytes,2,rep,name=views" json:"views,omitempty"` + Clear bool `protobuf:"varint,1,opt,name=Clear,proto3" json:"Clear,omitempty"` + Views []*ImportRoaringRequestView `protobuf:"bytes,2,rep,name=views,proto3" json:"views,omitempty"` + XXX_NoUnkeyedLiteral struct{} `json:"-"` + XXX_unrecognized []byte `json:"-"` + XXX_sizecache int32 `json:"-"` +} + +func (m *ImportRoaringRequest) Reset() { *m = ImportRoaringRequest{} } +func (m *ImportRoaringRequest) String() string { return proto.CompactTextString(m) } +func (*ImportRoaringRequest) ProtoMessage() {} +func (*ImportRoaringRequest) Descriptor() ([]byte, []int) { + return fileDescriptor_a66c591da5e2e6d0, []int{17} +} + +func (m *ImportRoaringRequest) XXX_Unmarshal(b []byte) error { + return xxx_messageInfo_ImportRoaringRequest.Unmarshal(m, b) +} +func (m *ImportRoaringRequest) XXX_Marshal(b []byte, deterministic bool) ([]byte, error) { + return xxx_messageInfo_ImportRoaringRequest.Marshal(b, m, deterministic) +} +func (m *ImportRoaringRequest) XXX_Merge(src proto.Message) { + xxx_messageInfo_ImportRoaringRequest.Merge(m, src) +} +func (m *ImportRoaringRequest) XXX_Size() int { + return xxx_messageInfo_ImportRoaringRequest.Size(m) +} +func (m *ImportRoaringRequest) XXX_DiscardUnknown() { + xxx_messageInfo_ImportRoaringRequest.DiscardUnknown(m) } -func (m *ImportRoaringRequest) Reset() { *m = ImportRoaringRequest{} } -func (m *ImportRoaringRequest) String() string { return proto.CompactTextString(m) } -func (*ImportRoaringRequest) ProtoMessage() {} -func (*ImportRoaringRequest) Descriptor() ([]byte, []int) { return fileDescriptor0, []int{17} } +var xxx_messageInfo_ImportRoaringRequest proto.InternalMessageInfo func (m *ImportRoaringRequest) GetClear() bool { if m != nil { @@ -730,63 +1127,64 @@ func init() { proto.RegisterType((*ImportRoaringRequest)(nil), "gopilosa_pbuf.ImportRoaringRequest") } -func init() { proto.RegisterFile("gopilosa_pbuf/public.proto", fileDescriptor0) } - -var fileDescriptor0 = []byte{ - // 875 bytes of a gzipped FileDescriptorProto - 0x1f, 0x8b, 0x08, 0x00, 0x00, 0x00, 0x00, 0x00, 0x02, 0xff, 0xac, 0x56, 0x5f, 0x8f, 0xdb, 0x44, - 0x10, 0xd7, 0xc6, 0x4e, 0xe2, 0x4c, 0x2e, 0x47, 0xb5, 0x1c, 0xc5, 0x9c, 0x0e, 0x64, 0x59, 0x08, - 0xdc, 0x07, 0x0e, 0x29, 0xed, 0x03, 0x12, 0x02, 0x89, 0x36, 0x57, 0x14, 0x55, 0x9c, 0xe8, 0xdc, - 0x29, 0x4f, 0x08, 0xb4, 0xd7, 0x6c, 0xaf, 0x16, 0x8e, 0xd7, 0xd8, 0x6b, 0xd2, 0x7c, 0x18, 0xde, - 0x79, 0xe0, 0x83, 0xf0, 0x35, 0x78, 0xe6, 0x4b, 0xa0, 0x9d, 0xf5, 0x9e, 0x1d, 0x5f, 0xcb, 0x3f, - 0xf5, 0x6d, 0x7e, 0x33, 0xb3, 0xe3, 0xf9, 0xcd, 0xbf, 0x04, 0x8e, 0xaf, 0x55, 0x91, 0x66, 0xaa, - 0x12, 0x3f, 0x14, 0x57, 0xf5, 0xf3, 0x4f, 0x8b, 0xfa, 0x2a, 0x4b, 0x9f, 0x9d, 0x16, 0xa5, 0xd2, - 0x8a, 0xcf, 0xf6, 0x6c, 0xf1, 0xf7, 0xe0, 0xa1, 0xda, 0xf2, 0x10, 0xc6, 0x8f, 0x54, 0x56, 0x6f, - 0xf2, 0x2a, 0x64, 0x91, 0x97, 0xf8, 0xe8, 0x20, 0xe7, 0xe0, 0x3f, 0x91, 0xbb, 0x2a, 0xf4, 0x22, - 0x2f, 0x99, 0x20, 0xc9, 0xfc, 0x1e, 0x0c, 0xbf, 0xd2, 0xba, 0xac, 0xc2, 0x41, 0xe4, 0x25, 0xd3, - 0xf9, 0xdb, 0xa7, 0x7b, 0x31, 0x4f, 0x8d, 0x0d, 0xad, 0x47, 0xfc, 0x19, 0x1c, 0xa2, 0xda, 0x2e, - 0xd7, 0x32, 0xd7, 0xe9, 0xf3, 0x54, 0x96, 0x14, 0x10, 0xd5, 0xd6, 0x7d, 0x87, 0xe4, 0x9b, 0x8f, - 0x0c, 0xda, 0x8f, 0xc4, 0x5f, 0x82, 0xff, 0xad, 0x48, 0x4b, 0x7e, 0x08, 0x83, 0xe5, 0x22, 0x64, - 0x11, 0x4b, 0x7c, 0x1c, 0x2c, 0x17, 0xfc, 0x0e, 0x78, 0x4f, 0xe4, 0x2e, 0xf4, 0x22, 0x96, 0x4c, - 0xd0, 0x88, 0xfc, 0x08, 0x86, 0x8f, 0x54, 0x9d, 0xeb, 0x70, 0x40, 0x4e, 0x16, 0xc4, 0xe7, 0x10, - 0x3c, 0x4e, 0x65, 0xb6, 0x36, 0xf4, 0x8e, 0x60, 0x48, 0x32, 0x85, 0x99, 0xa0, 0x05, 0x46, 0x6b, - 0x72, 0x5b, 0xb8, 0x77, 0x04, 0xf8, 0x5d, 0x18, 0xa1, 0xda, 0xb6, 0x9f, 0x68, 0x50, 0xfc, 0x14, - 0xe0, 0xeb, 0x52, 0xd5, 0x05, 0x45, 0xe7, 0x9f, 0xc0, 0x90, 0x10, 0xd1, 0x98, 0xce, 0xdf, 0xed, - 0x95, 0xc0, 0x7d, 0x19, 0xad, 0xd7, 0x6b, 0x52, 0x9c, 0x43, 0xb0, 0x12, 0x99, 0x0d, 0x78, 0x07, - 0xbc, 0x95, 0xc8, 0x28, 0x41, 0x0f, 0x8d, 0xb8, 0xff, 0xc6, 0x73, 0x6f, 0xbe, 0x83, 0x99, 0x6d, - 0x8d, 0xa9, 0xef, 0x85, 0xd4, 0xff, 0xa2, 0x3e, 0xff, 0xa1, 0x5d, 0xbf, 0x32, 0xf0, 0x8d, 0xe4, - 0xa2, 0xb0, 0x36, 0x0a, 0x07, 0xff, 0x72, 0x57, 0xc8, 0x86, 0x01, 0xc9, 0x3c, 0x82, 0xe9, 0x85, - 0x2e, 0xd3, 0xfc, 0x7a, 0x25, 0xb2, 0x5a, 0x36, 0xdf, 0xec, 0xaa, 0xf8, 0x31, 0x04, 0xcb, 0x5c, - 0x5b, 0xb3, 0x4f, 0x3c, 0x6e, 0x30, 0x3f, 0x81, 0xc9, 0x43, 0xa5, 0x32, 0x6b, 0x1c, 0x46, 0x2c, - 0x09, 0xb0, 0x55, 0xf0, 0x0f, 0x00, 0x1e, 0x67, 0x4a, 0x34, 0x6f, 0x47, 0x11, 0x4b, 0x18, 0x76, - 0x34, 0xf1, 0x03, 0x18, 0x9b, 0x4c, 0xbf, 0x11, 0x45, 0x4b, 0x90, 0xfd, 0x23, 0xc1, 0xdf, 0x19, - 0x1c, 0x3c, 0xad, 0x65, 0xb9, 0x43, 0xf9, 0x53, 0x2d, 0x2b, 0x6d, 0xaa, 0x4c, 0xd8, 0x8d, 0x06, - 0x01, 0x33, 0x04, 0x17, 0x2f, 0x44, 0xb9, 0xb6, 0x35, 0xf3, 0xb1, 0x41, 0x86, 0x70, 0x5b, 0xfd, - 0x8a, 0x08, 0x07, 0xd8, 0x55, 0xd1, 0xf8, 0xc8, 0x8d, 0xd2, 0x8e, 0x51, 0x83, 0x78, 0x02, 0x6f, - 0x9d, 0xbd, 0x7c, 0x96, 0xd5, 0x6b, 0x89, 0x6a, 0x6b, 0x5f, 0x8f, 0xc8, 0xa1, 0xaf, 0xe6, 0x1f, - 0xc1, 0x61, 0xa3, 0x72, 0x2b, 0x39, 0x26, 0xc7, 0x9e, 0x36, 0xfe, 0x85, 0xc1, 0xac, 0xa1, 0x52, - 0x15, 0x2a, 0xaf, 0xa4, 0x69, 0xda, 0x59, 0x59, 0xba, 0xa6, 0x9d, 0x95, 0x25, 0x7f, 0x00, 0x63, - 0x94, 0x55, 0x9d, 0x69, 0xd7, 0xfc, 0xe3, 0x5e, 0x6d, 0x5c, 0x80, 0x3a, 0xd3, 0xe8, 0x5c, 0xf9, - 0x02, 0x0e, 0xf7, 0x66, 0xcc, 0x6e, 0xff, 0x74, 0x7e, 0xd2, 0x7b, 0xbc, 0xe7, 0x84, 0xbd, 0x37, - 0xf1, 0x9f, 0x03, 0x98, 0x76, 0xc2, 0xdf, 0x0c, 0x90, 0xa1, 0x3d, 0x6b, 0x06, 0xe8, 0x43, 0x3a, - 0x3f, 0x94, 0xf1, 0x74, 0xce, 0x7b, 0xe1, 0xcd, 0xfe, 0xd0, 0x75, 0x3a, 0x00, 0x76, 0xde, 0xcc, - 0x1d, 0x3b, 0x37, 0xdd, 0x36, 0x87, 0xc1, 0x25, 0xd5, 0xef, 0xb6, 0xb1, 0xa1, 0xf5, 0xa0, 0xb3, - 0xf6, 0x42, 0xe4, 0xd7, 0x72, 0x4d, 0xc3, 0x17, 0xa0, 0x83, 0xfc, 0x7e, 0xbb, 0x7a, 0xd4, 0xa8, - 0xdb, 0x2b, 0xec, 0xcc, 0xd8, 0xee, 0xa8, 0x3d, 0x0d, 0xcb, 0x85, 0xe9, 0x08, 0x4d, 0x85, 0x45, - 0xfc, 0x73, 0x98, 0xb6, 0xa7, 0xa1, 0x0a, 0x03, 0xca, 0xeb, 0xbd, 0x5e, 0xbc, 0xd6, 0x03, 0xbb, - 0xde, 0xfc, 0xac, 0x7f, 0x21, 0xc3, 0x09, 0xe5, 0xf3, 0xfe, 0xed, 0x6a, 0x74, 0x9c, 0xb0, 0xf7, - 0x28, 0xfe, 0x83, 0xc1, 0x6c, 0xb9, 0x29, 0x54, 0xa9, 0x3b, 0x93, 0xbd, 0xcc, 0xd7, 0xf2, 0xa5, - 0x9b, 0x6c, 0x02, 0xed, 0x29, 0x1c, 0xf4, 0x4e, 0x21, 0x4d, 0x38, 0x4d, 0xb4, 0x8f, 0x16, 0x74, - 0xf8, 0xfa, 0x7b, 0x7c, 0x4f, 0x60, 0x62, 0x7b, 0x6d, 0x4c, 0x43, 0x32, 0xb5, 0x0a, 0x53, 0x74, - 0x7b, 0x32, 0x6d, 0x99, 0x26, 0xe8, 0xa0, 0x59, 0x69, 0xeb, 0x46, 0xc6, 0x80, 0x8c, 0x1d, 0x8d, - 0xb1, 0x5f, 0xa6, 0x1b, 0x59, 0x69, 0xb1, 0x29, 0xcc, 0x7a, 0x78, 0x89, 0x87, 0x1d, 0x4d, 0xfc, - 0x1b, 0x03, 0x6e, 0x39, 0xd2, 0x09, 0x78, 0x73, 0x44, 0xff, 0x9e, 0xd0, 0x7e, 0xda, 0xe3, 0x5b, - 0x69, 0xdf, 0x85, 0x11, 0xe5, 0xe3, 0x52, 0x6e, 0x50, 0xbc, 0x82, 0xa3, 0xcb, 0x52, 0xe4, 0x55, - 0x26, 0xb4, 0x34, 0x8e, 0xff, 0x27, 0xdf, 0x57, 0xfc, 0xfc, 0xc6, 0xf7, 0xe0, 0x9d, 0x5e, 0xdc, - 0x76, 0xff, 0x0d, 0x01, 0x8f, 0x08, 0x18, 0x31, 0x7e, 0x08, 0x61, 0x33, 0x14, 0x4a, 0x98, 0xa3, - 0xdc, 0xa4, 0xb0, 0x4a, 0xe5, 0xd6, 0x84, 0x3e, 0x17, 0x1b, 0xd9, 0x64, 0x41, 0xb2, 0xd1, 0x2d, - 0x84, 0x16, 0x94, 0xc3, 0x01, 0x92, 0x1c, 0xff, 0x08, 0x47, 0xaf, 0x8a, 0x41, 0xbf, 0x4f, 0x99, - 0x14, 0xf6, 0xde, 0x04, 0x68, 0x01, 0xff, 0x02, 0x86, 0x3f, 0xa7, 0x72, 0xeb, 0xee, 0xcd, 0xc7, - 0xbd, 0x29, 0x7e, 0x5d, 0x36, 0x68, 0x5f, 0x5d, 0x8d, 0xe8, 0x5f, 0xca, 0xfd, 0xbf, 0x02, 0x00, - 0x00, 0xff, 0xff, 0x84, 0xb9, 0x90, 0x2b, 0xc3, 0x08, 0x00, 0x00, +func init() { proto.RegisterFile("gopilosa_pbuf/public.proto", fileDescriptor_a66c591da5e2e6d0) } + +var fileDescriptor_a66c591da5e2e6d0 = []byte{ + // 882 bytes of a gzipped FileDescriptorProto + 0x1f, 0x8b, 0x08, 0x00, 0x00, 0x00, 0x00, 0x00, 0x02, 0xff, 0xac, 0x56, 0x5f, 0x6f, 0xe3, 0x44, + 0x10, 0x97, 0x63, 0x27, 0x71, 0x26, 0x4d, 0x41, 0x4b, 0x39, 0x4c, 0x55, 0x90, 0x65, 0x21, 0xf0, + 0x3d, 0x50, 0xa4, 0xdc, 0x3d, 0x20, 0x21, 0x90, 0xb8, 0x4b, 0x0f, 0x45, 0x27, 0x2a, 0x98, 0x56, + 0x79, 0x42, 0xa0, 0x6d, 0xb3, 0xd7, 0xb3, 0x70, 0xbc, 0xc6, 0x7f, 0xc8, 0xf5, 0xc3, 0xf0, 0xce, + 0x03, 0x1f, 0x84, 0xaf, 0xc1, 0x33, 0x5f, 0x02, 0xcd, 0xac, 0x37, 0x76, 0xdc, 0xf2, 0x57, 0xbc, + 0xcd, 0x6f, 0x66, 0x76, 0x76, 0x7e, 0x33, 0xb3, 0x63, 0xc3, 0xf1, 0x8d, 0xce, 0x93, 0x54, 0x97, + 0xf2, 0xbb, 0xfc, 0xaa, 0x7e, 0xf1, 0x51, 0x5e, 0x5f, 0xa5, 0xc9, 0xf5, 0x69, 0x5e, 0xe8, 0x4a, + 0x8b, 0xd9, 0x9e, 0x2d, 0xfa, 0x16, 0x5c, 0xd4, 0x5b, 0x11, 0xc0, 0xf8, 0xa9, 0x4e, 0xeb, 0x4d, + 0x56, 0x06, 0x4e, 0xe8, 0xc6, 0x1e, 0x5a, 0x28, 0x04, 0x78, 0xcf, 0xd5, 0x6d, 0x19, 0xb8, 0xa1, + 0x1b, 0x4f, 0x90, 0x65, 0xf1, 0x10, 0x86, 0x9f, 0x57, 0x55, 0x51, 0x06, 0x83, 0xd0, 0x8d, 0xa7, + 0xf3, 0x37, 0x4e, 0xf7, 0x62, 0x9e, 0x92, 0x0d, 0x8d, 0x47, 0xf4, 0x31, 0x1c, 0xa2, 0xde, 0x2e, + 0xd7, 0x2a, 0xab, 0x92, 0x17, 0x89, 0x2a, 0x38, 0x20, 0xea, 0xad, 0xbd, 0x87, 0xe5, 0xdd, 0x25, + 0x83, 0xf6, 0x92, 0xe8, 0x33, 0xf0, 0xbe, 0x92, 0x49, 0x21, 0x0e, 0x61, 0xb0, 0x5c, 0x04, 0x4e, + 0xe8, 0xc4, 0x1e, 0x0e, 0x96, 0x0b, 0xf1, 0x3a, 0xb8, 0xcf, 0xd5, 0x6d, 0xe0, 0x86, 0x4e, 0x3c, + 0x41, 0x12, 0xc5, 0x11, 0x0c, 0x9f, 0xea, 0x3a, 0xab, 0x82, 0x01, 0x3b, 0x19, 0x10, 0x9d, 0x83, + 0xff, 0x2c, 0x51, 0xe9, 0x9a, 0xe8, 0x1d, 0xc1, 0x90, 0x65, 0x0e, 0x33, 0x41, 0x03, 0x48, 0x4b, + 0xb9, 0x2d, 0xec, 0x39, 0x06, 0xe2, 0x01, 0x8c, 0x50, 0x6f, 0xdb, 0x2b, 0x1a, 0x14, 0x5d, 0x03, + 0x7c, 0x51, 0xe8, 0x3a, 0xe7, 0xe8, 0xe2, 0x43, 0x18, 0x32, 0x62, 0x1a, 0xd3, 0xf9, 0x5b, 0xbd, + 0x12, 0xd8, 0x9b, 0xd1, 0x78, 0xdd, 0x9f, 0x22, 0x51, 0xb9, 0xa8, 0x37, 0x7c, 0x8f, 0x8b, 0x24, + 0x46, 0x73, 0xf0, 0x57, 0x32, 0xdd, 0x59, 0x57, 0x32, 0xe5, 0x94, 0x5d, 0x24, 0x71, 0x3f, 0x8a, + 0x6b, 0x89, 0x7e, 0x03, 0x33, 0xd3, 0x2c, 0xaa, 0xf8, 0x85, 0xaa, 0xfe, 0x41, 0xc5, 0xfe, 0x45, + 0x03, 0x7f, 0x76, 0xc0, 0x23, 0xc9, 0x46, 0x71, 0xda, 0x28, 0x02, 0xbc, 0xcb, 0xdb, 0x5c, 0x35, + 0x9c, 0x58, 0x16, 0x21, 0x4c, 0x2f, 0xaa, 0x22, 0xc9, 0x6e, 0x56, 0x32, 0xad, 0x55, 0x73, 0x67, + 0x57, 0x25, 0x8e, 0xc1, 0x5f, 0x66, 0x95, 0x31, 0x7b, 0xcc, 0x63, 0x87, 0xc5, 0x09, 0x4c, 0x9e, + 0x68, 0x9d, 0x1a, 0xe3, 0x30, 0x74, 0x62, 0x1f, 0x5b, 0x85, 0x78, 0x17, 0xe0, 0x59, 0xaa, 0x65, + 0x73, 0x76, 0x14, 0x3a, 0xb1, 0x83, 0x1d, 0x4d, 0xf4, 0x18, 0xc6, 0x94, 0xe9, 0x97, 0x32, 0x6f, + 0x09, 0x3a, 0x7f, 0x4b, 0xf0, 0x57, 0x07, 0x0e, 0xbe, 0xae, 0x55, 0x71, 0x8b, 0xea, 0x87, 0x5a, + 0x95, 0x15, 0x55, 0x99, 0xb1, 0x1d, 0x16, 0x06, 0x34, 0x16, 0x17, 0x2f, 0x65, 0xb1, 0x36, 0x35, + 0xf3, 0xb0, 0x41, 0x44, 0xb8, 0xad, 0x7e, 0xc9, 0x84, 0x7d, 0xec, 0xaa, 0x78, 0xa0, 0xd4, 0x46, + 0x57, 0x96, 0x51, 0x83, 0x44, 0x0c, 0xaf, 0x9d, 0xbd, 0xba, 0x4e, 0xeb, 0xb5, 0x42, 0xbd, 0x35, + 0xa7, 0x47, 0xec, 0xd0, 0x57, 0x8b, 0xf7, 0xe1, 0xb0, 0x51, 0xd9, 0x47, 0x3a, 0x66, 0xc7, 0x9e, + 0x36, 0xfa, 0xc9, 0x81, 0x59, 0x43, 0xa5, 0xcc, 0x75, 0x56, 0x2a, 0x6a, 0xda, 0x59, 0x51, 0xd8, + 0xa6, 0x9d, 0x15, 0x85, 0x78, 0x0c, 0x63, 0x54, 0x65, 0x9d, 0x56, 0xb6, 0xf9, 0xc7, 0xbd, 0xda, + 0xd8, 0x00, 0x75, 0x5a, 0xa1, 0x75, 0x15, 0x0b, 0x38, 0xdc, 0x9b, 0x31, 0xb3, 0x0f, 0xa6, 0xf3, + 0x93, 0xde, 0xe1, 0x3d, 0x27, 0xec, 0x9d, 0x89, 0x7e, 0x1f, 0xc0, 0xb4, 0x13, 0x7e, 0x37, 0x40, + 0x44, 0x7b, 0xd6, 0x0c, 0xd0, 0x7b, 0xbc, 0x90, 0x38, 0xe3, 0xe9, 0x5c, 0xf4, 0xc2, 0xd3, 0x8b, + 0xe2, 0x7d, 0x75, 0x00, 0xce, 0x79, 0x33, 0x77, 0xce, 0x39, 0x75, 0x9b, 0x56, 0x85, 0x4d, 0xaa, + 0xdf, 0x6d, 0xb2, 0xa1, 0xf1, 0xe0, 0x45, 0xf7, 0x52, 0x66, 0x37, 0x6a, 0xcd, 0xc3, 0xe7, 0xa3, + 0x85, 0xe2, 0x51, 0xfb, 0xf4, 0xb8, 0x51, 0x77, 0x1f, 0xb5, 0x35, 0x63, 0xfb, 0x46, 0xcd, 0xb2, + 0x58, 0x2e, 0xa8, 0x23, 0x3c, 0x15, 0x06, 0x89, 0x4f, 0x60, 0xda, 0x2e, 0x8b, 0x32, 0xf0, 0x39, + 0xaf, 0xb7, 0x7b, 0xf1, 0x5a, 0x0f, 0xec, 0x7a, 0x8b, 0xb3, 0xfe, 0xce, 0x0c, 0x26, 0x9c, 0xcf, + 0x3b, 0x77, 0xab, 0xd1, 0x71, 0xc2, 0xde, 0xa1, 0xe8, 0x37, 0x07, 0x66, 0xcb, 0x4d, 0xae, 0x8b, + 0xaa, 0x33, 0xd9, 0xcb, 0x6c, 0xad, 0x5e, 0xd9, 0xc9, 0x66, 0xd0, 0x2e, 0xc7, 0x41, 0x6f, 0x39, + 0xf2, 0x84, 0xf3, 0x44, 0x7b, 0x68, 0x40, 0x87, 0xaf, 0xb7, 0xc7, 0xf7, 0x04, 0x26, 0xa6, 0xd7, + 0x64, 0x1a, 0xb2, 0xa9, 0x55, 0x50, 0xd1, 0xcd, 0x12, 0x35, 0x65, 0x9a, 0xa0, 0x85, 0xf4, 0xa4, + 0x8d, 0x1b, 0x1b, 0x7d, 0x36, 0x76, 0x34, 0x64, 0xbf, 0x4c, 0x36, 0xaa, 0xac, 0xe4, 0x26, 0xa7, + 0xe7, 0xe1, 0xc6, 0x2e, 0x76, 0x34, 0xd1, 0x2f, 0x0e, 0x08, 0xc3, 0x91, 0x57, 0xc0, 0xff, 0x47, + 0xf4, 0xaf, 0x09, 0xed, 0xa7, 0x3d, 0xbe, 0x93, 0xf6, 0x03, 0x18, 0x71, 0x3e, 0x36, 0xe5, 0x06, + 0x45, 0x2b, 0x38, 0xba, 0x2c, 0x64, 0x56, 0xa6, 0xb2, 0x52, 0xe4, 0xf8, 0x5f, 0xf2, 0xbd, 0xe7, + 0x83, 0x1c, 0x3d, 0x84, 0x37, 0x7b, 0x71, 0xdb, 0xf7, 0x4f, 0x04, 0x5c, 0x26, 0x40, 0x62, 0xf4, + 0x04, 0x82, 0x66, 0x28, 0xb4, 0xa4, 0xa5, 0xdc, 0xa4, 0xb0, 0x4a, 0xd4, 0x96, 0x42, 0x9f, 0xcb, + 0x8d, 0x6a, 0xb2, 0x60, 0x99, 0x74, 0x0b, 0x59, 0x49, 0xce, 0xe1, 0x00, 0x59, 0x8e, 0xbe, 0x87, + 0xa3, 0xfb, 0x62, 0xf0, 0xf7, 0x29, 0x55, 0xd2, 0xec, 0x1b, 0x1f, 0x0d, 0x10, 0x9f, 0xc2, 0xf0, + 0xc7, 0x44, 0x6d, 0xed, 0xbe, 0xf9, 0xa0, 0x37, 0xc5, 0x7f, 0x96, 0x0d, 0x9a, 0x53, 0x57, 0x23, + 0xfe, 0x6f, 0x79, 0xf4, 0x47, 0x00, 0x00, 0x00, 0xff, 0xff, 0xb2, 0x8b, 0x83, 0x06, 0xd5, 0x08, + 0x00, 0x00, } diff --git a/gopilosa_pbuf/public.proto b/gopilosa_pbuf/public.proto index 920e19d..f33fad5 100644 --- a/gopilosa_pbuf/public.proto +++ b/gopilosa_pbuf/public.proto @@ -28,6 +28,7 @@ message FieldRow{ message GroupCount{ repeated FieldRow Group = 1; uint64 Count = 2; + int64 Sum = 3; } message ValCount { @@ -119,4 +120,4 @@ message ImportRoaringRequestView { message ImportRoaringRequest { bool Clear = 1; repeated ImportRoaringRequestView views = 2; -} \ No newline at end of file +} diff --git a/orm.go b/orm.go index 83286e5..717a2b4 100644 --- a/orm.go +++ b/orm.go @@ -579,12 +579,12 @@ type groupByBuilder struct { aggregate *PQLBaseQuery } -// groupByBuilderOption is a functional option type for index.GroupBy -type groupByBuilderOption func(g *groupByBuilder) error +// GroupByBuilderOption is a functional option type for index.GroupBy +type GroupByBuilderOption func(g *groupByBuilder) error // OptGroupByBuilderRows is a functional option on groupByBuilder // used to set the rows. -func OptGroupByBuilderRows(rows ...*PQLRowsQuery) groupByBuilderOption { +func OptGroupByBuilderRows(rows ...*PQLRowsQuery) GroupByBuilderOption { return func(g *groupByBuilder) error { g.rows = rows return nil @@ -593,7 +593,7 @@ func OptGroupByBuilderRows(rows ...*PQLRowsQuery) groupByBuilderOption { // OptGroupByBuilderLimit is a functional option on groupByBuilder // used to set the limit. -func OptGroupByBuilderLimit(l int64) groupByBuilderOption { +func OptGroupByBuilderLimit(l int64) GroupByBuilderOption { return func(g *groupByBuilder) error { g.limit = l return nil @@ -602,7 +602,7 @@ func OptGroupByBuilderLimit(l int64) groupByBuilderOption { // OptGroupByBuilderFilter is a functional option on groupByBuilder // used to set the filter. -func OptGroupByBuilderFilter(q *PQLRowQuery) groupByBuilderOption { +func OptGroupByBuilderFilter(q *PQLRowQuery) GroupByBuilderOption { return func(g *groupByBuilder) error { g.filter = q return nil @@ -611,7 +611,7 @@ func OptGroupByBuilderFilter(q *PQLRowQuery) groupByBuilderOption { // OptGroupByBuilderAggregate is a functional option on groupByBuilder // used to set the aggregate. -func OptGroupByBuilderAggregate(agg *PQLBaseQuery) groupByBuilderOption { +func OptGroupByBuilderAggregate(agg *PQLBaseQuery) GroupByBuilderOption { return func(g *groupByBuilder) error { g.aggregate = agg return nil @@ -619,7 +619,7 @@ func OptGroupByBuilderAggregate(agg *PQLBaseQuery) groupByBuilderOption { } // GroupByBase creates a GroupBy query with the given functional options. -func (idx *Index) GroupByBase(opts ...groupByBuilderOption) *PQLBaseQuery { +func (idx *Index) GroupByBase(opts ...GroupByBuilderOption) *PQLBaseQuery { bldr := &groupByBuilder{} for _, opt := range opts { err := opt(bldr) diff --git a/response.go b/response.go index 6f2dac3..c917932 100644 --- a/response.go +++ b/response.go @@ -460,6 +460,7 @@ type FieldRow struct { type GroupCount struct { Groups []FieldRow `json:"groups"` Count int64 `json:"count"` + Sum int64 `json:"sum"` } // GroupCountResult is returned from GroupBy call. @@ -539,6 +540,7 @@ func groupCountsFromInternal(items []*pbuf.GroupCount) GroupCountResult { result = append(result, GroupCount{ Groups: groups, Count: int64(g.Count), + Sum: int64(g.Sum), }) } return GroupCountResult(result)