// Code generated by protoc-gen-go. DO NOT EDIT. // source: pilosa.proto package pilosa import ( fmt "fmt" proto "github.com/golang/protobuf/proto" math "math" ) import ( context "golang.org/x/net/context" grpc "google.golang.org/grpc" ) // 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.ProtoPackageIsVersion2 // please upgrade the proto package type QueryPQLRequest struct { Index string `protobuf:"bytes,1,opt,name=index,proto3" json:"index,omitempty"` Pql string `protobuf:"bytes,2,opt,name=pql,proto3" json:"pql,omitempty"` XXX_NoUnkeyedLiteral struct{} `json:"-"` XXX_unrecognized []byte `json:"-"` XXX_sizecache int32 `json:"-"` } func (m *QueryPQLRequest) Reset() { *m = QueryPQLRequest{} } func (m *QueryPQLRequest) String() string { return proto.CompactTextString(m) } func (*QueryPQLRequest) ProtoMessage() {} func (*QueryPQLRequest) Descriptor() ([]byte, []int) { return fileDescriptor_ef0691a44d1e275c, []int{0} } func (m *QueryPQLRequest) XXX_Unmarshal(b []byte) error { return xxx_messageInfo_QueryPQLRequest.Unmarshal(m, b) } func (m *QueryPQLRequest) XXX_Marshal(b []byte, deterministic bool) ([]byte, error) { return xxx_messageInfo_QueryPQLRequest.Marshal(b, m, deterministic) } func (m *QueryPQLRequest) XXX_Merge(src proto.Message) { xxx_messageInfo_QueryPQLRequest.Merge(m, src) } func (m *QueryPQLRequest) XXX_Size() int { return xxx_messageInfo_QueryPQLRequest.Size(m) } func (m *QueryPQLRequest) XXX_DiscardUnknown() { xxx_messageInfo_QueryPQLRequest.DiscardUnknown(m) } var xxx_messageInfo_QueryPQLRequest proto.InternalMessageInfo func (m *QueryPQLRequest) GetIndex() string { if m != nil { return m.Index } return "" } func (m *QueryPQLRequest) GetPql() string { if m != nil { return m.Pql } return "" } type StatusError struct { Code uint32 `protobuf:"varint,1,opt,name=Code,proto3" json:"Code,omitempty"` Message string `protobuf:"bytes,2,opt,name=Message,proto3" json:"Message,omitempty"` XXX_NoUnkeyedLiteral struct{} `json:"-"` XXX_unrecognized []byte `json:"-"` XXX_sizecache int32 `json:"-"` } func (m *StatusError) Reset() { *m = StatusError{} } func (m *StatusError) String() string { return proto.CompactTextString(m) } func (*StatusError) ProtoMessage() {} func (*StatusError) Descriptor() ([]byte, []int) { return fileDescriptor_ef0691a44d1e275c, []int{1} } func (m *StatusError) XXX_Unmarshal(b []byte) error { return xxx_messageInfo_StatusError.Unmarshal(m, b) } func (m *StatusError) XXX_Marshal(b []byte, deterministic bool) ([]byte, error) { return xxx_messageInfo_StatusError.Marshal(b, m, deterministic) } func (m *StatusError) XXX_Merge(src proto.Message) { xxx_messageInfo_StatusError.Merge(m, src) } func (m *StatusError) XXX_Size() int { return xxx_messageInfo_StatusError.Size(m) } func (m *StatusError) XXX_DiscardUnknown() { xxx_messageInfo_StatusError.DiscardUnknown(m) } var xxx_messageInfo_StatusError proto.InternalMessageInfo func (m *StatusError) GetCode() uint32 { if m != nil { return m.Code } return 0 } func (m *StatusError) GetMessage() string { if m != nil { return m.Message } return "" } type RowResponse struct { Headers []*ColumnInfo `protobuf:"bytes,1,rep,name=headers,proto3" json:"headers,omitempty"` Columns []*ColumnResponse `protobuf:"bytes,2,rep,name=columns,proto3" json:"columns,omitempty"` StatusError *StatusError `protobuf:"bytes,3,opt,name=StatusError,proto3" json:"StatusError,omitempty"` XXX_NoUnkeyedLiteral struct{} `json:"-"` XXX_unrecognized []byte `json:"-"` XXX_sizecache int32 `json:"-"` } func (m *RowResponse) Reset() { *m = RowResponse{} } func (m *RowResponse) String() string { return proto.CompactTextString(m) } func (*RowResponse) ProtoMessage() {} func (*RowResponse) Descriptor() ([]byte, []int) { return fileDescriptor_ef0691a44d1e275c, []int{2} } func (m *RowResponse) XXX_Unmarshal(b []byte) error { return xxx_messageInfo_RowResponse.Unmarshal(m, b) } func (m *RowResponse) XXX_Marshal(b []byte, deterministic bool) ([]byte, error) { return xxx_messageInfo_RowResponse.Marshal(b, m, deterministic) } func (m *RowResponse) XXX_Merge(src proto.Message) { xxx_messageInfo_RowResponse.Merge(m, src) } func (m *RowResponse) XXX_Size() int { return xxx_messageInfo_RowResponse.Size(m) } func (m *RowResponse) XXX_DiscardUnknown() { xxx_messageInfo_RowResponse.DiscardUnknown(m) } var xxx_messageInfo_RowResponse proto.InternalMessageInfo func (m *RowResponse) GetHeaders() []*ColumnInfo { if m != nil { return m.Headers } return nil } func (m *RowResponse) GetColumns() []*ColumnResponse { if m != nil { return m.Columns } return nil } func (m *RowResponse) GetStatusError() *StatusError { if m != nil { return m.StatusError } return nil } type ColumnInfo struct { Name string `protobuf:"bytes,1,opt,name=name,proto3" json:"name,omitempty"` Datatype string `protobuf:"bytes,2,opt,name=datatype,proto3" json:"datatype,omitempty"` XXX_NoUnkeyedLiteral struct{} `json:"-"` XXX_unrecognized []byte `json:"-"` XXX_sizecache int32 `json:"-"` } func (m *ColumnInfo) Reset() { *m = ColumnInfo{} } func (m *ColumnInfo) String() string { return proto.CompactTextString(m) } func (*ColumnInfo) ProtoMessage() {} func (*ColumnInfo) Descriptor() ([]byte, []int) { return fileDescriptor_ef0691a44d1e275c, []int{3} } func (m *ColumnInfo) XXX_Unmarshal(b []byte) error { return xxx_messageInfo_ColumnInfo.Unmarshal(m, b) } func (m *ColumnInfo) XXX_Marshal(b []byte, deterministic bool) ([]byte, error) { return xxx_messageInfo_ColumnInfo.Marshal(b, m, deterministic) } func (m *ColumnInfo) XXX_Merge(src proto.Message) { xxx_messageInfo_ColumnInfo.Merge(m, src) } func (m *ColumnInfo) XXX_Size() int { return xxx_messageInfo_ColumnInfo.Size(m) } func (m *ColumnInfo) XXX_DiscardUnknown() { xxx_messageInfo_ColumnInfo.DiscardUnknown(m) } var xxx_messageInfo_ColumnInfo proto.InternalMessageInfo func (m *ColumnInfo) GetName() string { if m != nil { return m.Name } return "" } func (m *ColumnInfo) GetDatatype() string { if m != nil { return m.Datatype } return "" } type ColumnResponse struct { // Types that are valid to be assigned to ColumnVal: // *ColumnResponse_StringVal // *ColumnResponse_Uint64Val // *ColumnResponse_Int64Val // *ColumnResponse_BoolVal // *ColumnResponse_BlobVal // *ColumnResponse_Uint64ArrayVal // *ColumnResponse_StringArrayVal // *ColumnResponse_Float64Val ColumnVal isColumnResponse_ColumnVal `protobuf_oneof:"columnVal"` XXX_NoUnkeyedLiteral struct{} `json:"-"` XXX_unrecognized []byte `json:"-"` XXX_sizecache int32 `json:"-"` } func (m *ColumnResponse) Reset() { *m = ColumnResponse{} } func (m *ColumnResponse) String() string { return proto.CompactTextString(m) } func (*ColumnResponse) ProtoMessage() {} func (*ColumnResponse) Descriptor() ([]byte, []int) { return fileDescriptor_ef0691a44d1e275c, []int{4} } func (m *ColumnResponse) XXX_Unmarshal(b []byte) error { return xxx_messageInfo_ColumnResponse.Unmarshal(m, b) } func (m *ColumnResponse) XXX_Marshal(b []byte, deterministic bool) ([]byte, error) { return xxx_messageInfo_ColumnResponse.Marshal(b, m, deterministic) } func (m *ColumnResponse) XXX_Merge(src proto.Message) { xxx_messageInfo_ColumnResponse.Merge(m, src) } func (m *ColumnResponse) XXX_Size() int { return xxx_messageInfo_ColumnResponse.Size(m) } func (m *ColumnResponse) XXX_DiscardUnknown() { xxx_messageInfo_ColumnResponse.DiscardUnknown(m) } var xxx_messageInfo_ColumnResponse proto.InternalMessageInfo type isColumnResponse_ColumnVal interface { isColumnResponse_ColumnVal() } type ColumnResponse_StringVal struct { StringVal string `protobuf:"bytes,1,opt,name=stringVal,proto3,oneof"` } type ColumnResponse_Uint64Val struct { Uint64Val uint64 `protobuf:"varint,2,opt,name=uint64Val,proto3,oneof"` } type ColumnResponse_Int64Val struct { Int64Val int64 `protobuf:"varint,3,opt,name=int64Val,proto3,oneof"` } type ColumnResponse_BoolVal struct { BoolVal bool `protobuf:"varint,4,opt,name=boolVal,proto3,oneof"` } type ColumnResponse_BlobVal struct { BlobVal []byte `protobuf:"bytes,5,opt,name=blobVal,proto3,oneof"` } type ColumnResponse_Uint64ArrayVal struct { Uint64ArrayVal *Uint64Array `protobuf:"bytes,6,opt,name=uint64ArrayVal,proto3,oneof"` } type ColumnResponse_StringArrayVal struct { StringArrayVal *StringArray `protobuf:"bytes,7,opt,name=stringArrayVal,proto3,oneof"` } type ColumnResponse_Float64Val struct { Float64Val float64 `protobuf:"fixed64,8,opt,name=float64Val,proto3,oneof"` } func (*ColumnResponse_StringVal) isColumnResponse_ColumnVal() {} func (*ColumnResponse_Uint64Val) isColumnResponse_ColumnVal() {} func (*ColumnResponse_Int64Val) isColumnResponse_ColumnVal() {} func (*ColumnResponse_BoolVal) isColumnResponse_ColumnVal() {} func (*ColumnResponse_BlobVal) isColumnResponse_ColumnVal() {} func (*ColumnResponse_Uint64ArrayVal) isColumnResponse_ColumnVal() {} func (*ColumnResponse_StringArrayVal) isColumnResponse_ColumnVal() {} func (*ColumnResponse_Float64Val) isColumnResponse_ColumnVal() {} func (m *ColumnResponse) GetColumnVal() isColumnResponse_ColumnVal { if m != nil { return m.ColumnVal } return nil } func (m *ColumnResponse) GetStringVal() string { if x, ok := m.GetColumnVal().(*ColumnResponse_StringVal); ok { return x.StringVal } return "" } func (m *ColumnResponse) GetUint64Val() uint64 { if x, ok := m.GetColumnVal().(*ColumnResponse_Uint64Val); ok { return x.Uint64Val } return 0 } func (m *ColumnResponse) GetInt64Val() int64 { if x, ok := m.GetColumnVal().(*ColumnResponse_Int64Val); ok { return x.Int64Val } return 0 } func (m *ColumnResponse) GetBoolVal() bool { if x, ok := m.GetColumnVal().(*ColumnResponse_BoolVal); ok { return x.BoolVal } return false } func (m *ColumnResponse) GetBlobVal() []byte { if x, ok := m.GetColumnVal().(*ColumnResponse_BlobVal); ok { return x.BlobVal } return nil } func (m *ColumnResponse) GetUint64ArrayVal() *Uint64Array { if x, ok := m.GetColumnVal().(*ColumnResponse_Uint64ArrayVal); ok { return x.Uint64ArrayVal } return nil } func (m *ColumnResponse) GetStringArrayVal() *StringArray { if x, ok := m.GetColumnVal().(*ColumnResponse_StringArrayVal); ok { return x.StringArrayVal } return nil } func (m *ColumnResponse) GetFloat64Val() float64 { if x, ok := m.GetColumnVal().(*ColumnResponse_Float64Val); ok { return x.Float64Val } return 0 } // XXX_OneofFuncs is for the internal use of the proto package. func (*ColumnResponse) XXX_OneofFuncs() (func(msg proto.Message, b *proto.Buffer) error, func(msg proto.Message, tag, wire int, b *proto.Buffer) (bool, error), func(msg proto.Message) (n int), []interface{}) { return _ColumnResponse_OneofMarshaler, _ColumnResponse_OneofUnmarshaler, _ColumnResponse_OneofSizer, []interface{}{ (*ColumnResponse_StringVal)(nil), (*ColumnResponse_Uint64Val)(nil), (*ColumnResponse_Int64Val)(nil), (*ColumnResponse_BoolVal)(nil), (*ColumnResponse_BlobVal)(nil), (*ColumnResponse_Uint64ArrayVal)(nil), (*ColumnResponse_StringArrayVal)(nil), (*ColumnResponse_Float64Val)(nil), } } func _ColumnResponse_OneofMarshaler(msg proto.Message, b *proto.Buffer) error { m := msg.(*ColumnResponse) // columnVal switch x := m.ColumnVal.(type) { case *ColumnResponse_StringVal: b.EncodeVarint(1<<3 | proto.WireBytes) b.EncodeStringBytes(x.StringVal) case *ColumnResponse_Uint64Val: b.EncodeVarint(2<<3 | proto.WireVarint) b.EncodeVarint(uint64(x.Uint64Val)) case *ColumnResponse_Int64Val: b.EncodeVarint(3<<3 | proto.WireVarint) b.EncodeVarint(uint64(x.Int64Val)) case *ColumnResponse_BoolVal: t := uint64(0) if x.BoolVal { t = 1 } b.EncodeVarint(4<<3 | proto.WireVarint) b.EncodeVarint(t) case *ColumnResponse_BlobVal: b.EncodeVarint(5<<3 | proto.WireBytes) b.EncodeRawBytes(x.BlobVal) case *ColumnResponse_Uint64ArrayVal: b.EncodeVarint(6<<3 | proto.WireBytes) if err := b.EncodeMessage(x.Uint64ArrayVal); err != nil { return err } case *ColumnResponse_StringArrayVal: b.EncodeVarint(7<<3 | proto.WireBytes) if err := b.EncodeMessage(x.StringArrayVal); err != nil { return err } case *ColumnResponse_Float64Val: b.EncodeVarint(8<<3 | proto.WireFixed64) b.EncodeFixed64(math.Float64bits(x.Float64Val)) case nil: default: return fmt.Errorf("ColumnResponse.ColumnVal has unexpected type %T", x) } return nil } func _ColumnResponse_OneofUnmarshaler(msg proto.Message, tag, wire int, b *proto.Buffer) (bool, error) { m := msg.(*ColumnResponse) switch tag { case 1: // columnVal.stringVal if wire != proto.WireBytes { return true, proto.ErrInternalBadWireType } x, err := b.DecodeStringBytes() m.ColumnVal = &ColumnResponse_StringVal{x} return true, err case 2: // columnVal.uint64Val if wire != proto.WireVarint { return true, proto.ErrInternalBadWireType } x, err := b.DecodeVarint() m.ColumnVal = &ColumnResponse_Uint64Val{x} return true, err case 3: // columnVal.int64Val if wire != proto.WireVarint { return true, proto.ErrInternalBadWireType } x, err := b.DecodeVarint() m.ColumnVal = &ColumnResponse_Int64Val{int64(x)} return true, err case 4: // columnVal.boolVal if wire != proto.WireVarint { return true, proto.ErrInternalBadWireType } x, err := b.DecodeVarint() m.ColumnVal = &ColumnResponse_BoolVal{x != 0} return true, err case 5: // columnVal.blobVal if wire != proto.WireBytes { return true, proto.ErrInternalBadWireType } x, err := b.DecodeRawBytes(true) m.ColumnVal = &ColumnResponse_BlobVal{x} return true, err case 6: // columnVal.uint64ArrayVal if wire != proto.WireBytes { return true, proto.ErrInternalBadWireType } msg := new(Uint64Array) err := b.DecodeMessage(msg) m.ColumnVal = &ColumnResponse_Uint64ArrayVal{msg} return true, err case 7: // columnVal.stringArrayVal if wire != proto.WireBytes { return true, proto.ErrInternalBadWireType } msg := new(StringArray) err := b.DecodeMessage(msg) m.ColumnVal = &ColumnResponse_StringArrayVal{msg} return true, err case 8: // columnVal.float64Val if wire != proto.WireFixed64 { return true, proto.ErrInternalBadWireType } x, err := b.DecodeFixed64() m.ColumnVal = &ColumnResponse_Float64Val{math.Float64frombits(x)} return true, err default: return false, nil } } func _ColumnResponse_OneofSizer(msg proto.Message) (n int) { m := msg.(*ColumnResponse) // columnVal switch x := m.ColumnVal.(type) { case *ColumnResponse_StringVal: n += 1 // tag and wire n += proto.SizeVarint(uint64(len(x.StringVal))) n += len(x.StringVal) case *ColumnResponse_Uint64Val: n += 1 // tag and wire n += proto.SizeVarint(uint64(x.Uint64Val)) case *ColumnResponse_Int64Val: n += 1 // tag and wire n += proto.SizeVarint(uint64(x.Int64Val)) case *ColumnResponse_BoolVal: n += 1 // tag and wire n += 1 case *ColumnResponse_BlobVal: n += 1 // tag and wire n += proto.SizeVarint(uint64(len(x.BlobVal))) n += len(x.BlobVal) case *ColumnResponse_Uint64ArrayVal: s := proto.Size(x.Uint64ArrayVal) n += 1 // tag and wire n += proto.SizeVarint(uint64(s)) n += s case *ColumnResponse_StringArrayVal: s := proto.Size(x.StringArrayVal) n += 1 // tag and wire n += proto.SizeVarint(uint64(s)) n += s case *ColumnResponse_Float64Val: n += 1 // tag and wire n += 8 case nil: default: panic(fmt.Sprintf("proto: unexpected type %T in oneof", x)) } return n } type InspectRequest struct { Index string `protobuf:"bytes,1,opt,name=index,proto3" json:"index,omitempty"` Columns *IdsOrKeys `protobuf:"bytes,2,opt,name=columns,proto3" json:"columns,omitempty"` FilterFields []string `protobuf:"bytes,3,rep,name=filterFields,proto3" json:"filterFields,omitempty"` Limit uint64 `protobuf:"varint,4,opt,name=limit,proto3" json:"limit,omitempty"` Offset uint64 `protobuf:"varint,5,opt,name=offset,proto3" json:"offset,omitempty"` XXX_NoUnkeyedLiteral struct{} `json:"-"` XXX_unrecognized []byte `json:"-"` XXX_sizecache int32 `json:"-"` } func (m *InspectRequest) Reset() { *m = InspectRequest{} } func (m *InspectRequest) String() string { return proto.CompactTextString(m) } func (*InspectRequest) ProtoMessage() {} func (*InspectRequest) Descriptor() ([]byte, []int) { return fileDescriptor_ef0691a44d1e275c, []int{5} } func (m *InspectRequest) XXX_Unmarshal(b []byte) error { return xxx_messageInfo_InspectRequest.Unmarshal(m, b) } func (m *InspectRequest) XXX_Marshal(b []byte, deterministic bool) ([]byte, error) { return xxx_messageInfo_InspectRequest.Marshal(b, m, deterministic) } func (m *InspectRequest) XXX_Merge(src proto.Message) { xxx_messageInfo_InspectRequest.Merge(m, src) } func (m *InspectRequest) XXX_Size() int { return xxx_messageInfo_InspectRequest.Size(m) } func (m *InspectRequest) XXX_DiscardUnknown() { xxx_messageInfo_InspectRequest.DiscardUnknown(m) } var xxx_messageInfo_InspectRequest proto.InternalMessageInfo func (m *InspectRequest) GetIndex() string { if m != nil { return m.Index } return "" } func (m *InspectRequest) GetColumns() *IdsOrKeys { if m != nil { return m.Columns } return nil } func (m *InspectRequest) GetFilterFields() []string { if m != nil { return m.FilterFields } return nil } func (m *InspectRequest) GetLimit() uint64 { if m != nil { return m.Limit } return 0 } func (m *InspectRequest) GetOffset() uint64 { if m != nil { return m.Offset } return 0 } type Uint64Array struct { Vals []uint64 `protobuf:"varint,1,rep,packed,name=vals,proto3" json:"vals,omitempty"` XXX_NoUnkeyedLiteral struct{} `json:"-"` XXX_unrecognized []byte `json:"-"` XXX_sizecache int32 `json:"-"` } func (m *Uint64Array) Reset() { *m = Uint64Array{} } func (m *Uint64Array) String() string { return proto.CompactTextString(m) } func (*Uint64Array) ProtoMessage() {} func (*Uint64Array) Descriptor() ([]byte, []int) { return fileDescriptor_ef0691a44d1e275c, []int{6} } func (m *Uint64Array) XXX_Unmarshal(b []byte) error { return xxx_messageInfo_Uint64Array.Unmarshal(m, b) } func (m *Uint64Array) XXX_Marshal(b []byte, deterministic bool) ([]byte, error) { return xxx_messageInfo_Uint64Array.Marshal(b, m, deterministic) } func (m *Uint64Array) XXX_Merge(src proto.Message) { xxx_messageInfo_Uint64Array.Merge(m, src) } func (m *Uint64Array) XXX_Size() int { return xxx_messageInfo_Uint64Array.Size(m) } func (m *Uint64Array) XXX_DiscardUnknown() { xxx_messageInfo_Uint64Array.DiscardUnknown(m) } var xxx_messageInfo_Uint64Array proto.InternalMessageInfo func (m *Uint64Array) GetVals() []uint64 { if m != nil { return m.Vals } return nil } type StringArray struct { Vals []string `protobuf:"bytes,1,rep,name=vals,proto3" json:"vals,omitempty"` XXX_NoUnkeyedLiteral struct{} `json:"-"` XXX_unrecognized []byte `json:"-"` XXX_sizecache int32 `json:"-"` } func (m *StringArray) Reset() { *m = StringArray{} } func (m *StringArray) String() string { return proto.CompactTextString(m) } func (*StringArray) ProtoMessage() {} func (*StringArray) Descriptor() ([]byte, []int) { return fileDescriptor_ef0691a44d1e275c, []int{7} } func (m *StringArray) XXX_Unmarshal(b []byte) error { return xxx_messageInfo_StringArray.Unmarshal(m, b) } func (m *StringArray) XXX_Marshal(b []byte, deterministic bool) ([]byte, error) { return xxx_messageInfo_StringArray.Marshal(b, m, deterministic) } func (m *StringArray) XXX_Merge(src proto.Message) { xxx_messageInfo_StringArray.Merge(m, src) } func (m *StringArray) XXX_Size() int { return xxx_messageInfo_StringArray.Size(m) } func (m *StringArray) XXX_DiscardUnknown() { xxx_messageInfo_StringArray.DiscardUnknown(m) } var xxx_messageInfo_StringArray proto.InternalMessageInfo func (m *StringArray) GetVals() []string { if m != nil { return m.Vals } return nil } type IdsOrKeys struct { // Types that are valid to be assigned to Type: // *IdsOrKeys_Ids // *IdsOrKeys_Keys Type isIdsOrKeys_Type `protobuf_oneof:"type"` XXX_NoUnkeyedLiteral struct{} `json:"-"` XXX_unrecognized []byte `json:"-"` XXX_sizecache int32 `json:"-"` } func (m *IdsOrKeys) Reset() { *m = IdsOrKeys{} } func (m *IdsOrKeys) String() string { return proto.CompactTextString(m) } func (*IdsOrKeys) ProtoMessage() {} func (*IdsOrKeys) Descriptor() ([]byte, []int) { return fileDescriptor_ef0691a44d1e275c, []int{8} } func (m *IdsOrKeys) XXX_Unmarshal(b []byte) error { return xxx_messageInfo_IdsOrKeys.Unmarshal(m, b) } func (m *IdsOrKeys) XXX_Marshal(b []byte, deterministic bool) ([]byte, error) { return xxx_messageInfo_IdsOrKeys.Marshal(b, m, deterministic) } func (m *IdsOrKeys) XXX_Merge(src proto.Message) { xxx_messageInfo_IdsOrKeys.Merge(m, src) } func (m *IdsOrKeys) XXX_Size() int { return xxx_messageInfo_IdsOrKeys.Size(m) } func (m *IdsOrKeys) XXX_DiscardUnknown() { xxx_messageInfo_IdsOrKeys.DiscardUnknown(m) } var xxx_messageInfo_IdsOrKeys proto.InternalMessageInfo type isIdsOrKeys_Type interface { isIdsOrKeys_Type() } type IdsOrKeys_Ids struct { Ids *Uint64Array `protobuf:"bytes,1,opt,name=ids,proto3,oneof"` } type IdsOrKeys_Keys struct { Keys *StringArray `protobuf:"bytes,2,opt,name=keys,proto3,oneof"` } func (*IdsOrKeys_Ids) isIdsOrKeys_Type() {} func (*IdsOrKeys_Keys) isIdsOrKeys_Type() {} func (m *IdsOrKeys) GetType() isIdsOrKeys_Type { if m != nil { return m.Type } return nil } func (m *IdsOrKeys) GetIds() *Uint64Array { if x, ok := m.GetType().(*IdsOrKeys_Ids); ok { return x.Ids } return nil } func (m *IdsOrKeys) GetKeys() *StringArray { if x, ok := m.GetType().(*IdsOrKeys_Keys); ok { return x.Keys } return nil } // XXX_OneofFuncs is for the internal use of the proto package. func (*IdsOrKeys) XXX_OneofFuncs() (func(msg proto.Message, b *proto.Buffer) error, func(msg proto.Message, tag, wire int, b *proto.Buffer) (bool, error), func(msg proto.Message) (n int), []interface{}) { return _IdsOrKeys_OneofMarshaler, _IdsOrKeys_OneofUnmarshaler, _IdsOrKeys_OneofSizer, []interface{}{ (*IdsOrKeys_Ids)(nil), (*IdsOrKeys_Keys)(nil), } } func _IdsOrKeys_OneofMarshaler(msg proto.Message, b *proto.Buffer) error { m := msg.(*IdsOrKeys) // type switch x := m.Type.(type) { case *IdsOrKeys_Ids: b.EncodeVarint(1<<3 | proto.WireBytes) if err := b.EncodeMessage(x.Ids); err != nil { return err } case *IdsOrKeys_Keys: b.EncodeVarint(2<<3 | proto.WireBytes) if err := b.EncodeMessage(x.Keys); err != nil { return err } case nil: default: return fmt.Errorf("IdsOrKeys.Type has unexpected type %T", x) } return nil } func _IdsOrKeys_OneofUnmarshaler(msg proto.Message, tag, wire int, b *proto.Buffer) (bool, error) { m := msg.(*IdsOrKeys) switch tag { case 1: // type.ids if wire != proto.WireBytes { return true, proto.ErrInternalBadWireType } msg := new(Uint64Array) err := b.DecodeMessage(msg) m.Type = &IdsOrKeys_Ids{msg} return true, err case 2: // type.keys if wire != proto.WireBytes { return true, proto.ErrInternalBadWireType } msg := new(StringArray) err := b.DecodeMessage(msg) m.Type = &IdsOrKeys_Keys{msg} return true, err default: return false, nil } } func _IdsOrKeys_OneofSizer(msg proto.Message) (n int) { m := msg.(*IdsOrKeys) // type switch x := m.Type.(type) { case *IdsOrKeys_Ids: s := proto.Size(x.Ids) n += 1 // tag and wire n += proto.SizeVarint(uint64(s)) n += s case *IdsOrKeys_Keys: s := proto.Size(x.Keys) n += 1 // tag and wire n += proto.SizeVarint(uint64(s)) n += s case nil: default: panic(fmt.Sprintf("proto: unexpected type %T in oneof", x)) } return n } func init() { proto.RegisterType((*QueryPQLRequest)(nil), "pilosa.QueryPQLRequest") proto.RegisterType((*StatusError)(nil), "pilosa.StatusError") proto.RegisterType((*RowResponse)(nil), "pilosa.RowResponse") proto.RegisterType((*ColumnInfo)(nil), "pilosa.ColumnInfo") proto.RegisterType((*ColumnResponse)(nil), "pilosa.ColumnResponse") proto.RegisterType((*InspectRequest)(nil), "pilosa.InspectRequest") proto.RegisterType((*Uint64Array)(nil), "pilosa.Uint64Array") proto.RegisterType((*StringArray)(nil), "pilosa.StringArray") proto.RegisterType((*IdsOrKeys)(nil), "pilosa.IdsOrKeys") } // Reference imports to suppress errors if they are not otherwise used. var _ context.Context var _ grpc.ClientConn // This is a compile-time assertion to ensure that this generated file // is compatible with the grpc package it is being compiled against. const _ = grpc.SupportPackageIsVersion4 // PilosaClient is the client API for Pilosa service. // // For semantics around ctx use and closing/ending streaming RPCs, please refer to https://godoc.org/google.golang.org/grpc#ClientConn.NewStream. type PilosaClient interface { QueryPQL(ctx context.Context, in *QueryPQLRequest, opts ...grpc.CallOption) (Pilosa_QueryPQLClient, error) Inspect(ctx context.Context, in *InspectRequest, opts ...grpc.CallOption) (Pilosa_InspectClient, error) } type pilosaClient struct { cc *grpc.ClientConn } func NewPilosaClient(cc *grpc.ClientConn) PilosaClient { return &pilosaClient{cc} } func (c *pilosaClient) QueryPQL(ctx context.Context, in *QueryPQLRequest, opts ...grpc.CallOption) (Pilosa_QueryPQLClient, error) { stream, err := c.cc.NewStream(ctx, &_Pilosa_serviceDesc.Streams[0], "/pilosa.Pilosa/QueryPQL", opts...) if err != nil { return nil, err } x := &pilosaQueryPQLClient{stream} if err := x.ClientStream.SendMsg(in); err != nil { return nil, err } if err := x.ClientStream.CloseSend(); err != nil { return nil, err } return x, nil } type Pilosa_QueryPQLClient interface { Recv() (*RowResponse, error) grpc.ClientStream } type pilosaQueryPQLClient struct { grpc.ClientStream } func (x *pilosaQueryPQLClient) Recv() (*RowResponse, error) { m := new(RowResponse) if err := x.ClientStream.RecvMsg(m); err != nil { return nil, err } return m, nil } func (c *pilosaClient) Inspect(ctx context.Context, in *InspectRequest, opts ...grpc.CallOption) (Pilosa_InspectClient, error) { stream, err := c.cc.NewStream(ctx, &_Pilosa_serviceDesc.Streams[1], "/pilosa.Pilosa/Inspect", opts...) if err != nil { return nil, err } x := &pilosaInspectClient{stream} if err := x.ClientStream.SendMsg(in); err != nil { return nil, err } if err := x.ClientStream.CloseSend(); err != nil { return nil, err } return x, nil } type Pilosa_InspectClient interface { Recv() (*RowResponse, error) grpc.ClientStream } type pilosaInspectClient struct { grpc.ClientStream } func (x *pilosaInspectClient) Recv() (*RowResponse, error) { m := new(RowResponse) if err := x.ClientStream.RecvMsg(m); err != nil { return nil, err } return m, nil } // PilosaServer is the server API for Pilosa service. type PilosaServer interface { QueryPQL(*QueryPQLRequest, Pilosa_QueryPQLServer) error Inspect(*InspectRequest, Pilosa_InspectServer) error } func RegisterPilosaServer(s *grpc.Server, srv PilosaServer) { s.RegisterService(&_Pilosa_serviceDesc, srv) } func _Pilosa_QueryPQL_Handler(srv interface{}, stream grpc.ServerStream) error { m := new(QueryPQLRequest) if err := stream.RecvMsg(m); err != nil { return err } return srv.(PilosaServer).QueryPQL(m, &pilosaQueryPQLServer{stream}) } type Pilosa_QueryPQLServer interface { Send(*RowResponse) error grpc.ServerStream } type pilosaQueryPQLServer struct { grpc.ServerStream } func (x *pilosaQueryPQLServer) Send(m *RowResponse) error { return x.ServerStream.SendMsg(m) } func _Pilosa_Inspect_Handler(srv interface{}, stream grpc.ServerStream) error { m := new(InspectRequest) if err := stream.RecvMsg(m); err != nil { return err } return srv.(PilosaServer).Inspect(m, &pilosaInspectServer{stream}) } type Pilosa_InspectServer interface { Send(*RowResponse) error grpc.ServerStream } type pilosaInspectServer struct { grpc.ServerStream } func (x *pilosaInspectServer) Send(m *RowResponse) error { return x.ServerStream.SendMsg(m) } var _Pilosa_serviceDesc = grpc.ServiceDesc{ ServiceName: "pilosa.Pilosa", HandlerType: (*PilosaServer)(nil), Methods: []grpc.MethodDesc{}, Streams: []grpc.StreamDesc{ { StreamName: "QueryPQL", Handler: _Pilosa_QueryPQL_Handler, ServerStreams: true, }, { StreamName: "Inspect", Handler: _Pilosa_Inspect_Handler, ServerStreams: true, }, }, Metadata: "pilosa.proto", } func init() { proto.RegisterFile("pilosa.proto", fileDescriptor_ef0691a44d1e275c) } var fileDescriptor_ef0691a44d1e275c = []byte{ // 568 bytes of a gzipped FileDescriptorProto 0x1f, 0x8b, 0x08, 0x00, 0x00, 0x00, 0x00, 0x00, 0x02, 0xff, 0x7c, 0x54, 0xdd, 0x6e, 0xd3, 0x30, 0x14, 0x8e, 0x97, 0x2c, 0x69, 0x4e, 0xc6, 0x00, 0x83, 0x46, 0x54, 0x21, 0x14, 0x72, 0x43, 0x10, 0x68, 0x9a, 0xca, 0x8f, 0x04, 0x8c, 0x0b, 0x36, 0x81, 0x5a, 0x01, 0x62, 0x33, 0x62, 0xf7, 0xee, 0xe2, 0x96, 0x08, 0x37, 0xce, 0x62, 0x17, 0xe8, 0x2d, 0xcf, 0x02, 0x4f, 0xc4, 0x0b, 0x21, 0x3b, 0x3f, 0x4d, 0x2a, 0x95, 0x3b, 0x9f, 0xef, 0xfb, 0xce, 0xf1, 0xf9, 0xb3, 0x61, 0xaf, 0xc8, 0xb8, 0x90, 0xf4, 0xb0, 0x28, 0x85, 0x12, 0xd8, 0xad, 0xac, 0xf8, 0x05, 0x5c, 0x3f, 0x5f, 0xb2, 0x72, 0x75, 0x76, 0xfe, 0x81, 0xb0, 0xab, 0x25, 0x93, 0x0a, 0xdf, 0x86, 0xdd, 0x2c, 0x4f, 0xd9, 0xcf, 0x10, 0x45, 0x28, 0xf1, 0x49, 0x65, 0xe0, 0x1b, 0x60, 0x17, 0x57, 0x3c, 0xdc, 0x31, 0x98, 0x3e, 0xc6, 0xaf, 0x20, 0xf8, 0xac, 0xa8, 0x5a, 0xca, 0xb7, 0x65, 0x29, 0x4a, 0x8c, 0xc1, 0x39, 0x15, 0x29, 0x33, 0x5e, 0xd7, 0x88, 0x39, 0xe3, 0x10, 0xbc, 0x8f, 0x4c, 0x4a, 0x3a, 0x67, 0xb5, 0x63, 0x63, 0xc6, 0xbf, 0x11, 0x04, 0x44, 0xfc, 0x20, 0x4c, 0x16, 0x22, 0x97, 0x0c, 0x3f, 0x06, 0xef, 0x2b, 0xa3, 0x29, 0x2b, 0x65, 0x88, 0x22, 0x3b, 0x09, 0x46, 0xf8, 0xb0, 0xce, 0xf7, 0x54, 0xf0, 0xe5, 0x22, 0x9f, 0xe4, 0x33, 0x41, 0x1a, 0x09, 0x3e, 0x02, 0xef, 0xd2, 0xc0, 0x32, 0xdc, 0x31, 0xea, 0x83, 0xbe, 0xba, 0x09, 0x4b, 0x1a, 0x19, 0x7e, 0xd6, 0x4b, 0x36, 0xb4, 0x23, 0x94, 0x04, 0xa3, 0x5b, 0x8d, 0x57, 0x87, 0x22, 0x5d, 0x5d, 0x7c, 0x0c, 0xb0, 0xbe, 0x5f, 0x97, 0x98, 0xd3, 0x05, 0xab, 0x1b, 0x63, 0xce, 0x78, 0x08, 0x83, 0x94, 0x2a, 0xaa, 0x56, 0x45, 0x53, 0x63, 0x6b, 0xc7, 0x7f, 0x77, 0x60, 0xbf, 0x9f, 0x10, 0xbe, 0x07, 0xbe, 0x54, 0x65, 0x96, 0xcf, 0x2f, 0x28, 0xaf, 0xe2, 0x8c, 0x2d, 0xb2, 0x86, 0x34, 0xbf, 0xcc, 0x72, 0xf5, 0xfc, 0xa9, 0xe6, 0x75, 0x3c, 0x47, 0xf3, 0x2d, 0x84, 0xef, 0xc2, 0xa0, 0xa5, 0x75, 0x11, 0xf6, 0xd8, 0x22, 0x2d, 0x82, 0x87, 0xe0, 0x4d, 0x85, 0xe0, 0x9a, 0x74, 0x22, 0x94, 0x0c, 0xc6, 0x16, 0x69, 0x00, 0xc3, 0x71, 0x31, 0xd5, 0xdc, 0x6e, 0x84, 0x92, 0x3d, 0xc3, 0x55, 0x00, 0x7e, 0x0d, 0xfb, 0xd5, 0x15, 0x6f, 0xca, 0x92, 0xae, 0xb4, 0xc4, 0xed, 0x37, 0xe8, 0xcb, 0x9a, 0x1d, 0x5b, 0x64, 0x43, 0xac, 0xdd, 0xab, 0x0a, 0x5a, 0x77, 0x6f, 0xb3, 0xbf, 0x2d, 0xab, 0xdd, 0xfb, 0x62, 0x1c, 0x01, 0xcc, 0xb8, 0xa0, 0x75, 0x55, 0x83, 0x08, 0x25, 0x68, 0x6c, 0x91, 0x0e, 0x76, 0x12, 0x80, 0x5f, 0x0d, 0xf2, 0x82, 0xf2, 0xf8, 0x0f, 0x82, 0xfd, 0x49, 0x2e, 0x0b, 0x76, 0xa9, 0xfe, 0xbf, 0xb2, 0x8f, 0xba, 0x5b, 0xa2, 0xf3, 0xb9, 0xd9, 0xe4, 0x33, 0x49, 0xe5, 0xa7, 0xf2, 0x3d, 0x5b, 0xc9, 0xf5, 0x82, 0xc4, 0xb0, 0x37, 0xcb, 0xb8, 0x62, 0xe5, 0xbb, 0x8c, 0xf1, 0x54, 0x86, 0x76, 0x64, 0x27, 0x3e, 0xe9, 0x61, 0xfa, 0x1a, 0x9e, 0x2d, 0x32, 0x65, 0x9a, 0xeb, 0x90, 0xca, 0xc0, 0x07, 0xe0, 0x8a, 0xd9, 0x4c, 0x32, 0x65, 0xfa, 0xea, 0x90, 0xda, 0x8a, 0xef, 0x43, 0xd0, 0x69, 0x9b, 0x5e, 0x9e, 0xef, 0x94, 0x57, 0xeb, 0xed, 0x10, 0x73, 0xd6, 0x92, 0x4e, 0x6b, 0x7a, 0x12, 0xbf, 0x96, 0xcc, 0xc1, 0x6f, 0xb3, 0xc5, 0x0f, 0xc0, 0xce, 0x52, 0x69, 0xaa, 0xdc, 0x3a, 0x1c, 0xad, 0xc0, 0x0f, 0xc1, 0xf9, 0xc6, 0x56, 0x4d, 0xdd, 0x5b, 0xe6, 0x60, 0x24, 0x27, 0x2e, 0x38, 0x7a, 0x59, 0x47, 0xbf, 0x10, 0xb8, 0x67, 0x46, 0x86, 0x8f, 0x61, 0xd0, 0x7c, 0x0a, 0xf8, 0x4e, 0xe3, 0xbb, 0xf1, 0x4d, 0x0c, 0xdb, 0xa0, 0x9d, 0x67, 0x1c, 0x5b, 0x47, 0x08, 0xbf, 0x04, 0xaf, 0x1e, 0x0f, 0x6e, 0x9f, 0x65, 0x7f, 0x5e, 0x5b, 0x7d, 0xa7, 0xae, 0xf9, 0x9d, 0x9e, 0xfc, 0x0b, 0x00, 0x00, 0xff, 0xff, 0x9e, 0xd3, 0x7d, 0xab, 0xad, 0x04, 0x00, 0x00, }