// Code generated by protoc-gen-go. DO NOT EDIT. // versions: // protoc-gen-go v1.28.1-devel // protoc v3.21.8 // source: pilosa.proto package proto import ( context "context" grpc "google.golang.org/grpc" codes "google.golang.org/grpc/codes" status "google.golang.org/grpc/status" protoreflect "google.golang.org/protobuf/reflect/protoreflect" protoimpl "google.golang.org/protobuf/runtime/protoimpl" reflect "reflect" sync "sync" ) const ( // Verify that this generated code is sufficiently up-to-date. _ = protoimpl.EnforceVersion(20 - protoimpl.MinVersion) // Verify that runtime/protoimpl is sufficiently up-to-date. _ = protoimpl.EnforceVersion(protoimpl.MaxVersion - 20) ) type QueryPQLRequest struct { state protoimpl.MessageState sizeCache protoimpl.SizeCache unknownFields protoimpl.UnknownFields Index string `protobuf:"bytes,1,opt,name=index,proto3" json:"index,omitempty"` Pql string `protobuf:"bytes,2,opt,name=pql,proto3" json:"pql,omitempty"` } func (x *QueryPQLRequest) Reset() { *x = QueryPQLRequest{} if protoimpl.UnsafeEnabled { mi := &file_pilosa_proto_msgTypes[0] ms := protoimpl.X.MessageStateOf(protoimpl.Pointer(x)) ms.StoreMessageInfo(mi) } } func (x *QueryPQLRequest) String() string { return protoimpl.X.MessageStringOf(x) } func (*QueryPQLRequest) ProtoMessage() {} func (x *QueryPQLRequest) ProtoReflect() protoreflect.Message { mi := &file_pilosa_proto_msgTypes[0] if protoimpl.UnsafeEnabled && x != nil { ms := protoimpl.X.MessageStateOf(protoimpl.Pointer(x)) if ms.LoadMessageInfo() == nil { ms.StoreMessageInfo(mi) } return ms } return mi.MessageOf(x) } // Deprecated: Use QueryPQLRequest.ProtoReflect.Descriptor instead. func (*QueryPQLRequest) Descriptor() ([]byte, []int) { return file_pilosa_proto_rawDescGZIP(), []int{0} } func (x *QueryPQLRequest) GetIndex() string { if x != nil { return x.Index } return "" } func (x *QueryPQLRequest) GetPql() string { if x != nil { return x.Pql } return "" } type QuerySQLRequest struct { state protoimpl.MessageState sizeCache protoimpl.SizeCache unknownFields protoimpl.UnknownFields Sql string `protobuf:"bytes,1,opt,name=sql,proto3" json:"sql,omitempty"` } func (x *QuerySQLRequest) Reset() { *x = QuerySQLRequest{} if protoimpl.UnsafeEnabled { mi := &file_pilosa_proto_msgTypes[1] ms := protoimpl.X.MessageStateOf(protoimpl.Pointer(x)) ms.StoreMessageInfo(mi) } } func (x *QuerySQLRequest) String() string { return protoimpl.X.MessageStringOf(x) } func (*QuerySQLRequest) ProtoMessage() {} func (x *QuerySQLRequest) ProtoReflect() protoreflect.Message { mi := &file_pilosa_proto_msgTypes[1] if protoimpl.UnsafeEnabled && x != nil { ms := protoimpl.X.MessageStateOf(protoimpl.Pointer(x)) if ms.LoadMessageInfo() == nil { ms.StoreMessageInfo(mi) } return ms } return mi.MessageOf(x) } // Deprecated: Use QuerySQLRequest.ProtoReflect.Descriptor instead. func (*QuerySQLRequest) Descriptor() ([]byte, []int) { return file_pilosa_proto_rawDescGZIP(), []int{1} } func (x *QuerySQLRequest) GetSql() string { if x != nil { return x.Sql } return "" } type StatusError struct { state protoimpl.MessageState sizeCache protoimpl.SizeCache unknownFields protoimpl.UnknownFields Code uint32 `protobuf:"varint,1,opt,name=Code,proto3" json:"Code,omitempty"` Message string `protobuf:"bytes,2,opt,name=Message,proto3" json:"Message,omitempty"` } func (x *StatusError) Reset() { *x = StatusError{} if protoimpl.UnsafeEnabled { mi := &file_pilosa_proto_msgTypes[2] ms := protoimpl.X.MessageStateOf(protoimpl.Pointer(x)) ms.StoreMessageInfo(mi) } } func (x *StatusError) String() string { return protoimpl.X.MessageStringOf(x) } func (*StatusError) ProtoMessage() {} func (x *StatusError) ProtoReflect() protoreflect.Message { mi := &file_pilosa_proto_msgTypes[2] if protoimpl.UnsafeEnabled && x != nil { ms := protoimpl.X.MessageStateOf(protoimpl.Pointer(x)) if ms.LoadMessageInfo() == nil { ms.StoreMessageInfo(mi) } return ms } return mi.MessageOf(x) } // Deprecated: Use StatusError.ProtoReflect.Descriptor instead. func (*StatusError) Descriptor() ([]byte, []int) { return file_pilosa_proto_rawDescGZIP(), []int{2} } func (x *StatusError) GetCode() uint32 { if x != nil { return x.Code } return 0 } func (x *StatusError) GetMessage() string { if x != nil { return x.Message } return "" } type RowResponse struct { state protoimpl.MessageState sizeCache protoimpl.SizeCache unknownFields protoimpl.UnknownFields 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"` Duration int64 `protobuf:"varint,4,opt,name=duration,proto3" json:"duration,omitempty"` } func (x *RowResponse) Reset() { *x = RowResponse{} if protoimpl.UnsafeEnabled { mi := &file_pilosa_proto_msgTypes[3] ms := protoimpl.X.MessageStateOf(protoimpl.Pointer(x)) ms.StoreMessageInfo(mi) } } func (x *RowResponse) String() string { return protoimpl.X.MessageStringOf(x) } func (*RowResponse) ProtoMessage() {} func (x *RowResponse) ProtoReflect() protoreflect.Message { mi := &file_pilosa_proto_msgTypes[3] if protoimpl.UnsafeEnabled && x != nil { ms := protoimpl.X.MessageStateOf(protoimpl.Pointer(x)) if ms.LoadMessageInfo() == nil { ms.StoreMessageInfo(mi) } return ms } return mi.MessageOf(x) } // Deprecated: Use RowResponse.ProtoReflect.Descriptor instead. func (*RowResponse) Descriptor() ([]byte, []int) { return file_pilosa_proto_rawDescGZIP(), []int{3} } func (x *RowResponse) GetHeaders() []*ColumnInfo { if x != nil { return x.Headers } return nil } func (x *RowResponse) GetColumns() []*ColumnResponse { if x != nil { return x.Columns } return nil } func (x *RowResponse) GetStatusError() *StatusError { if x != nil { return x.StatusError } return nil } func (x *RowResponse) GetDuration() int64 { if x != nil { return x.Duration } return 0 } type Row struct { state protoimpl.MessageState sizeCache protoimpl.SizeCache unknownFields protoimpl.UnknownFields Columns []*ColumnResponse `protobuf:"bytes,1,rep,name=columns,proto3" json:"columns,omitempty"` } func (x *Row) Reset() { *x = Row{} if protoimpl.UnsafeEnabled { mi := &file_pilosa_proto_msgTypes[4] ms := protoimpl.X.MessageStateOf(protoimpl.Pointer(x)) ms.StoreMessageInfo(mi) } } func (x *Row) String() string { return protoimpl.X.MessageStringOf(x) } func (*Row) ProtoMessage() {} func (x *Row) ProtoReflect() protoreflect.Message { mi := &file_pilosa_proto_msgTypes[4] if protoimpl.UnsafeEnabled && x != nil { ms := protoimpl.X.MessageStateOf(protoimpl.Pointer(x)) if ms.LoadMessageInfo() == nil { ms.StoreMessageInfo(mi) } return ms } return mi.MessageOf(x) } // Deprecated: Use Row.ProtoReflect.Descriptor instead. func (*Row) Descriptor() ([]byte, []int) { return file_pilosa_proto_rawDescGZIP(), []int{4} } func (x *Row) GetColumns() []*ColumnResponse { if x != nil { return x.Columns } return nil } type TableResponse struct { state protoimpl.MessageState sizeCache protoimpl.SizeCache unknownFields protoimpl.UnknownFields Headers []*ColumnInfo `protobuf:"bytes,1,rep,name=headers,proto3" json:"headers,omitempty"` Rows []*Row `protobuf:"bytes,2,rep,name=rows,proto3" json:"rows,omitempty"` StatusError *StatusError `protobuf:"bytes,3,opt,name=StatusError,proto3" json:"StatusError,omitempty"` Duration int64 `protobuf:"varint,4,opt,name=duration,proto3" json:"duration,omitempty"` } func (x *TableResponse) Reset() { *x = TableResponse{} if protoimpl.UnsafeEnabled { mi := &file_pilosa_proto_msgTypes[5] ms := protoimpl.X.MessageStateOf(protoimpl.Pointer(x)) ms.StoreMessageInfo(mi) } } func (x *TableResponse) String() string { return protoimpl.X.MessageStringOf(x) } func (*TableResponse) ProtoMessage() {} func (x *TableResponse) ProtoReflect() protoreflect.Message { mi := &file_pilosa_proto_msgTypes[5] if protoimpl.UnsafeEnabled && x != nil { ms := protoimpl.X.MessageStateOf(protoimpl.Pointer(x)) if ms.LoadMessageInfo() == nil { ms.StoreMessageInfo(mi) } return ms } return mi.MessageOf(x) } // Deprecated: Use TableResponse.ProtoReflect.Descriptor instead. func (*TableResponse) Descriptor() ([]byte, []int) { return file_pilosa_proto_rawDescGZIP(), []int{5} } func (x *TableResponse) GetHeaders() []*ColumnInfo { if x != nil { return x.Headers } return nil } func (x *TableResponse) GetRows() []*Row { if x != nil { return x.Rows } return nil } func (x *TableResponse) GetStatusError() *StatusError { if x != nil { return x.StatusError } return nil } func (x *TableResponse) GetDuration() int64 { if x != nil { return x.Duration } return 0 } type ColumnInfo struct { state protoimpl.MessageState sizeCache protoimpl.SizeCache unknownFields protoimpl.UnknownFields Name string `protobuf:"bytes,1,opt,name=name,proto3" json:"name,omitempty"` Datatype string `protobuf:"bytes,2,opt,name=datatype,proto3" json:"datatype,omitempty"` } func (x *ColumnInfo) Reset() { *x = ColumnInfo{} if protoimpl.UnsafeEnabled { mi := &file_pilosa_proto_msgTypes[6] ms := protoimpl.X.MessageStateOf(protoimpl.Pointer(x)) ms.StoreMessageInfo(mi) } } func (x *ColumnInfo) String() string { return protoimpl.X.MessageStringOf(x) } func (*ColumnInfo) ProtoMessage() {} func (x *ColumnInfo) ProtoReflect() protoreflect.Message { mi := &file_pilosa_proto_msgTypes[6] if protoimpl.UnsafeEnabled && x != nil { ms := protoimpl.X.MessageStateOf(protoimpl.Pointer(x)) if ms.LoadMessageInfo() == nil { ms.StoreMessageInfo(mi) } return ms } return mi.MessageOf(x) } // Deprecated: Use ColumnInfo.ProtoReflect.Descriptor instead. func (*ColumnInfo) Descriptor() ([]byte, []int) { return file_pilosa_proto_rawDescGZIP(), []int{6} } func (x *ColumnInfo) GetName() string { if x != nil { return x.Name } return "" } func (x *ColumnInfo) GetDatatype() string { if x != nil { return x.Datatype } return "" } type ColumnResponse struct { state protoimpl.MessageState sizeCache protoimpl.SizeCache unknownFields protoimpl.UnknownFields // Types that are assignable to ColumnVal: // // *ColumnResponse_StringVal // *ColumnResponse_Uint64Val // *ColumnResponse_Int64Val // *ColumnResponse_BoolVal // *ColumnResponse_BlobVal // *ColumnResponse_Uint64ArrayVal // *ColumnResponse_StringArrayVal // *ColumnResponse_Float64Val // *ColumnResponse_DecimalVal // *ColumnResponse_TimestampVal ColumnVal isColumnResponse_ColumnVal `protobuf_oneof:"columnVal"` } func (x *ColumnResponse) Reset() { *x = ColumnResponse{} if protoimpl.UnsafeEnabled { mi := &file_pilosa_proto_msgTypes[7] ms := protoimpl.X.MessageStateOf(protoimpl.Pointer(x)) ms.StoreMessageInfo(mi) } } func (x *ColumnResponse) String() string { return protoimpl.X.MessageStringOf(x) } func (*ColumnResponse) ProtoMessage() {} func (x *ColumnResponse) ProtoReflect() protoreflect.Message { mi := &file_pilosa_proto_msgTypes[7] if protoimpl.UnsafeEnabled && x != nil { ms := protoimpl.X.MessageStateOf(protoimpl.Pointer(x)) if ms.LoadMessageInfo() == nil { ms.StoreMessageInfo(mi) } return ms } return mi.MessageOf(x) } // Deprecated: Use ColumnResponse.ProtoReflect.Descriptor instead. func (*ColumnResponse) Descriptor() ([]byte, []int) { return file_pilosa_proto_rawDescGZIP(), []int{7} } func (m *ColumnResponse) GetColumnVal() isColumnResponse_ColumnVal { if m != nil { return m.ColumnVal } return nil } func (x *ColumnResponse) GetStringVal() string { if x, ok := x.GetColumnVal().(*ColumnResponse_StringVal); ok { return x.StringVal } return "" } func (x *ColumnResponse) GetUint64Val() uint64 { if x, ok := x.GetColumnVal().(*ColumnResponse_Uint64Val); ok { return x.Uint64Val } return 0 } func (x *ColumnResponse) GetInt64Val() int64 { if x, ok := x.GetColumnVal().(*ColumnResponse_Int64Val); ok { return x.Int64Val } return 0 } func (x *ColumnResponse) GetBoolVal() bool { if x, ok := x.GetColumnVal().(*ColumnResponse_BoolVal); ok { return x.BoolVal } return false } func (x *ColumnResponse) GetBlobVal() []byte { if x, ok := x.GetColumnVal().(*ColumnResponse_BlobVal); ok { return x.BlobVal } return nil } func (x *ColumnResponse) GetUint64ArrayVal() *Uint64Array { if x, ok := x.GetColumnVal().(*ColumnResponse_Uint64ArrayVal); ok { return x.Uint64ArrayVal } return nil } func (x *ColumnResponse) GetStringArrayVal() *StringArray { if x, ok := x.GetColumnVal().(*ColumnResponse_StringArrayVal); ok { return x.StringArrayVal } return nil } func (x *ColumnResponse) GetFloat64Val() float64 { if x, ok := x.GetColumnVal().(*ColumnResponse_Float64Val); ok { return x.Float64Val } return 0 } func (x *ColumnResponse) GetDecimalVal() *Decimal { if x, ok := x.GetColumnVal().(*ColumnResponse_DecimalVal); ok { return x.DecimalVal } return nil } func (x *ColumnResponse) GetTimestampVal() string { if x, ok := x.GetColumnVal().(*ColumnResponse_TimestampVal); ok { return x.TimestampVal } return "" } 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"` } type ColumnResponse_DecimalVal struct { DecimalVal *Decimal `protobuf:"bytes,9,opt,name=decimalVal,proto3,oneof"` } type ColumnResponse_TimestampVal struct { TimestampVal string `protobuf:"bytes,10,opt,name=timestampVal,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 (*ColumnResponse_DecimalVal) isColumnResponse_ColumnVal() {} func (*ColumnResponse_TimestampVal) isColumnResponse_ColumnVal() {} type Decimal struct { state protoimpl.MessageState sizeCache protoimpl.SizeCache unknownFields protoimpl.UnknownFields Value int64 `protobuf:"varint,1,opt,name=value,proto3" json:"value,omitempty"` Scale int64 `protobuf:"varint,2,opt,name=scale,proto3" json:"scale,omitempty"` } func (x *Decimal) Reset() { *x = Decimal{} if protoimpl.UnsafeEnabled { mi := &file_pilosa_proto_msgTypes[8] ms := protoimpl.X.MessageStateOf(protoimpl.Pointer(x)) ms.StoreMessageInfo(mi) } } func (x *Decimal) String() string { return protoimpl.X.MessageStringOf(x) } func (*Decimal) ProtoMessage() {} func (x *Decimal) ProtoReflect() protoreflect.Message { mi := &file_pilosa_proto_msgTypes[8] if protoimpl.UnsafeEnabled && x != nil { ms := protoimpl.X.MessageStateOf(protoimpl.Pointer(x)) if ms.LoadMessageInfo() == nil { ms.StoreMessageInfo(mi) } return ms } return mi.MessageOf(x) } // Deprecated: Use Decimal.ProtoReflect.Descriptor instead. func (*Decimal) Descriptor() ([]byte, []int) { return file_pilosa_proto_rawDescGZIP(), []int{8} } func (x *Decimal) GetValue() int64 { if x != nil { return x.Value } return 0 } func (x *Decimal) GetScale() int64 { if x != nil { return x.Scale } return 0 } type InspectRequest struct { state protoimpl.MessageState sizeCache protoimpl.SizeCache unknownFields protoimpl.UnknownFields 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"` Query string `protobuf:"bytes,6,opt,name=query,proto3" json:"query,omitempty"` } func (x *InspectRequest) Reset() { *x = InspectRequest{} if protoimpl.UnsafeEnabled { mi := &file_pilosa_proto_msgTypes[9] ms := protoimpl.X.MessageStateOf(protoimpl.Pointer(x)) ms.StoreMessageInfo(mi) } } func (x *InspectRequest) String() string { return protoimpl.X.MessageStringOf(x) } func (*InspectRequest) ProtoMessage() {} func (x *InspectRequest) ProtoReflect() protoreflect.Message { mi := &file_pilosa_proto_msgTypes[9] if protoimpl.UnsafeEnabled && x != nil { ms := protoimpl.X.MessageStateOf(protoimpl.Pointer(x)) if ms.LoadMessageInfo() == nil { ms.StoreMessageInfo(mi) } return ms } return mi.MessageOf(x) } // Deprecated: Use InspectRequest.ProtoReflect.Descriptor instead. func (*InspectRequest) Descriptor() ([]byte, []int) { return file_pilosa_proto_rawDescGZIP(), []int{9} } func (x *InspectRequest) GetIndex() string { if x != nil { return x.Index } return "" } func (x *InspectRequest) GetColumns() *IdsOrKeys { if x != nil { return x.Columns } return nil } func (x *InspectRequest) GetFilterFields() []string { if x != nil { return x.FilterFields } return nil } func (x *InspectRequest) GetLimit() uint64 { if x != nil { return x.Limit } return 0 } func (x *InspectRequest) GetOffset() uint64 { if x != nil { return x.Offset } return 0 } func (x *InspectRequest) GetQuery() string { if x != nil { return x.Query } return "" } type Uint64Array struct { state protoimpl.MessageState sizeCache protoimpl.SizeCache unknownFields protoimpl.UnknownFields Vals []uint64 `protobuf:"varint,1,rep,packed,name=vals,proto3" json:"vals,omitempty"` } func (x *Uint64Array) Reset() { *x = Uint64Array{} if protoimpl.UnsafeEnabled { mi := &file_pilosa_proto_msgTypes[10] ms := protoimpl.X.MessageStateOf(protoimpl.Pointer(x)) ms.StoreMessageInfo(mi) } } func (x *Uint64Array) String() string { return protoimpl.X.MessageStringOf(x) } func (*Uint64Array) ProtoMessage() {} func (x *Uint64Array) ProtoReflect() protoreflect.Message { mi := &file_pilosa_proto_msgTypes[10] if protoimpl.UnsafeEnabled && x != nil { ms := protoimpl.X.MessageStateOf(protoimpl.Pointer(x)) if ms.LoadMessageInfo() == nil { ms.StoreMessageInfo(mi) } return ms } return mi.MessageOf(x) } // Deprecated: Use Uint64Array.ProtoReflect.Descriptor instead. func (*Uint64Array) Descriptor() ([]byte, []int) { return file_pilosa_proto_rawDescGZIP(), []int{10} } func (x *Uint64Array) GetVals() []uint64 { if x != nil { return x.Vals } return nil } type StringArray struct { state protoimpl.MessageState sizeCache protoimpl.SizeCache unknownFields protoimpl.UnknownFields Vals []string `protobuf:"bytes,1,rep,name=vals,proto3" json:"vals,omitempty"` } func (x *StringArray) Reset() { *x = StringArray{} if protoimpl.UnsafeEnabled { mi := &file_pilosa_proto_msgTypes[11] ms := protoimpl.X.MessageStateOf(protoimpl.Pointer(x)) ms.StoreMessageInfo(mi) } } func (x *StringArray) String() string { return protoimpl.X.MessageStringOf(x) } func (*StringArray) ProtoMessage() {} func (x *StringArray) ProtoReflect() protoreflect.Message { mi := &file_pilosa_proto_msgTypes[11] if protoimpl.UnsafeEnabled && x != nil { ms := protoimpl.X.MessageStateOf(protoimpl.Pointer(x)) if ms.LoadMessageInfo() == nil { ms.StoreMessageInfo(mi) } return ms } return mi.MessageOf(x) } // Deprecated: Use StringArray.ProtoReflect.Descriptor instead. func (*StringArray) Descriptor() ([]byte, []int) { return file_pilosa_proto_rawDescGZIP(), []int{11} } func (x *StringArray) GetVals() []string { if x != nil { return x.Vals } return nil } type IdsOrKeys struct { state protoimpl.MessageState sizeCache protoimpl.SizeCache unknownFields protoimpl.UnknownFields // Types that are assignable to Type: // // *IdsOrKeys_Ids // *IdsOrKeys_Keys Type isIdsOrKeys_Type `protobuf_oneof:"type"` } func (x *IdsOrKeys) Reset() { *x = IdsOrKeys{} if protoimpl.UnsafeEnabled { mi := &file_pilosa_proto_msgTypes[12] ms := protoimpl.X.MessageStateOf(protoimpl.Pointer(x)) ms.StoreMessageInfo(mi) } } func (x *IdsOrKeys) String() string { return protoimpl.X.MessageStringOf(x) } func (*IdsOrKeys) ProtoMessage() {} func (x *IdsOrKeys) ProtoReflect() protoreflect.Message { mi := &file_pilosa_proto_msgTypes[12] if protoimpl.UnsafeEnabled && x != nil { ms := protoimpl.X.MessageStateOf(protoimpl.Pointer(x)) if ms.LoadMessageInfo() == nil { ms.StoreMessageInfo(mi) } return ms } return mi.MessageOf(x) } // Deprecated: Use IdsOrKeys.ProtoReflect.Descriptor instead. func (*IdsOrKeys) Descriptor() ([]byte, []int) { return file_pilosa_proto_rawDescGZIP(), []int{12} } func (m *IdsOrKeys) GetType() isIdsOrKeys_Type { if m != nil { return m.Type } return nil } func (x *IdsOrKeys) GetIds() *Uint64Array { if x, ok := x.GetType().(*IdsOrKeys_Ids); ok { return x.Ids } return nil } func (x *IdsOrKeys) GetKeys() *StringArray { if x, ok := x.GetType().(*IdsOrKeys_Keys); ok { return x.Keys } return nil } 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() {} type Index struct { state protoimpl.MessageState sizeCache protoimpl.SizeCache unknownFields protoimpl.UnknownFields Name string `protobuf:"bytes,1,opt,name=name,proto3" json:"name,omitempty"` } func (x *Index) Reset() { *x = Index{} if protoimpl.UnsafeEnabled { mi := &file_pilosa_proto_msgTypes[13] ms := protoimpl.X.MessageStateOf(protoimpl.Pointer(x)) ms.StoreMessageInfo(mi) } } func (x *Index) String() string { return protoimpl.X.MessageStringOf(x) } func (*Index) ProtoMessage() {} func (x *Index) ProtoReflect() protoreflect.Message { mi := &file_pilosa_proto_msgTypes[13] if protoimpl.UnsafeEnabled && x != nil { ms := protoimpl.X.MessageStateOf(protoimpl.Pointer(x)) if ms.LoadMessageInfo() == nil { ms.StoreMessageInfo(mi) } return ms } return mi.MessageOf(x) } // Deprecated: Use Index.ProtoReflect.Descriptor instead. func (*Index) Descriptor() ([]byte, []int) { return file_pilosa_proto_rawDescGZIP(), []int{13} } func (x *Index) GetName() string { if x != nil { return x.Name } return "" } type CreateIndexRequest struct { state protoimpl.MessageState sizeCache protoimpl.SizeCache unknownFields protoimpl.UnknownFields Name string `protobuf:"bytes,1,opt,name=name,proto3" json:"name,omitempty"` Keys bool `protobuf:"varint,2,opt,name=keys,proto3" json:"keys,omitempty"` Description string `protobuf:"bytes,3,opt,name=description,proto3" json:"description,omitempty"` } func (x *CreateIndexRequest) Reset() { *x = CreateIndexRequest{} if protoimpl.UnsafeEnabled { mi := &file_pilosa_proto_msgTypes[14] ms := protoimpl.X.MessageStateOf(protoimpl.Pointer(x)) ms.StoreMessageInfo(mi) } } func (x *CreateIndexRequest) String() string { return protoimpl.X.MessageStringOf(x) } func (*CreateIndexRequest) ProtoMessage() {} func (x *CreateIndexRequest) ProtoReflect() protoreflect.Message { mi := &file_pilosa_proto_msgTypes[14] if protoimpl.UnsafeEnabled && x != nil { ms := protoimpl.X.MessageStateOf(protoimpl.Pointer(x)) if ms.LoadMessageInfo() == nil { ms.StoreMessageInfo(mi) } return ms } return mi.MessageOf(x) } // Deprecated: Use CreateIndexRequest.ProtoReflect.Descriptor instead. func (*CreateIndexRequest) Descriptor() ([]byte, []int) { return file_pilosa_proto_rawDescGZIP(), []int{14} } func (x *CreateIndexRequest) GetName() string { if x != nil { return x.Name } return "" } func (x *CreateIndexRequest) GetKeys() bool { if x != nil { return x.Keys } return false } func (x *CreateIndexRequest) GetDescription() string { if x != nil { return x.Description } return "" } type CreateIndexResponse struct { state protoimpl.MessageState sizeCache protoimpl.SizeCache unknownFields protoimpl.UnknownFields } func (x *CreateIndexResponse) Reset() { *x = CreateIndexResponse{} if protoimpl.UnsafeEnabled { mi := &file_pilosa_proto_msgTypes[15] ms := protoimpl.X.MessageStateOf(protoimpl.Pointer(x)) ms.StoreMessageInfo(mi) } } func (x *CreateIndexResponse) String() string { return protoimpl.X.MessageStringOf(x) } func (*CreateIndexResponse) ProtoMessage() {} func (x *CreateIndexResponse) ProtoReflect() protoreflect.Message { mi := &file_pilosa_proto_msgTypes[15] if protoimpl.UnsafeEnabled && x != nil { ms := protoimpl.X.MessageStateOf(protoimpl.Pointer(x)) if ms.LoadMessageInfo() == nil { ms.StoreMessageInfo(mi) } return ms } return mi.MessageOf(x) } // Deprecated: Use CreateIndexResponse.ProtoReflect.Descriptor instead. func (*CreateIndexResponse) Descriptor() ([]byte, []int) { return file_pilosa_proto_rawDescGZIP(), []int{15} } type GetIndexRequest struct { state protoimpl.MessageState sizeCache protoimpl.SizeCache unknownFields protoimpl.UnknownFields Name string `protobuf:"bytes,1,opt,name=name,proto3" json:"name,omitempty"` } func (x *GetIndexRequest) Reset() { *x = GetIndexRequest{} if protoimpl.UnsafeEnabled { mi := &file_pilosa_proto_msgTypes[16] ms := protoimpl.X.MessageStateOf(protoimpl.Pointer(x)) ms.StoreMessageInfo(mi) } } func (x *GetIndexRequest) String() string { return protoimpl.X.MessageStringOf(x) } func (*GetIndexRequest) ProtoMessage() {} func (x *GetIndexRequest) ProtoReflect() protoreflect.Message { mi := &file_pilosa_proto_msgTypes[16] if protoimpl.UnsafeEnabled && x != nil { ms := protoimpl.X.MessageStateOf(protoimpl.Pointer(x)) if ms.LoadMessageInfo() == nil { ms.StoreMessageInfo(mi) } return ms } return mi.MessageOf(x) } // Deprecated: Use GetIndexRequest.ProtoReflect.Descriptor instead. func (*GetIndexRequest) Descriptor() ([]byte, []int) { return file_pilosa_proto_rawDescGZIP(), []int{16} } func (x *GetIndexRequest) GetName() string { if x != nil { return x.Name } return "" } type GetIndexResponse struct { state protoimpl.MessageState sizeCache protoimpl.SizeCache unknownFields protoimpl.UnknownFields Index *Index `protobuf:"bytes,1,opt,name=index,proto3" json:"index,omitempty"` } func (x *GetIndexResponse) Reset() { *x = GetIndexResponse{} if protoimpl.UnsafeEnabled { mi := &file_pilosa_proto_msgTypes[17] ms := protoimpl.X.MessageStateOf(protoimpl.Pointer(x)) ms.StoreMessageInfo(mi) } } func (x *GetIndexResponse) String() string { return protoimpl.X.MessageStringOf(x) } func (*GetIndexResponse) ProtoMessage() {} func (x *GetIndexResponse) ProtoReflect() protoreflect.Message { mi := &file_pilosa_proto_msgTypes[17] if protoimpl.UnsafeEnabled && x != nil { ms := protoimpl.X.MessageStateOf(protoimpl.Pointer(x)) if ms.LoadMessageInfo() == nil { ms.StoreMessageInfo(mi) } return ms } return mi.MessageOf(x) } // Deprecated: Use GetIndexResponse.ProtoReflect.Descriptor instead. func (*GetIndexResponse) Descriptor() ([]byte, []int) { return file_pilosa_proto_rawDescGZIP(), []int{17} } func (x *GetIndexResponse) GetIndex() *Index { if x != nil { return x.Index } return nil } type GetIndexesRequest struct { state protoimpl.MessageState sizeCache protoimpl.SizeCache unknownFields protoimpl.UnknownFields } func (x *GetIndexesRequest) Reset() { *x = GetIndexesRequest{} if protoimpl.UnsafeEnabled { mi := &file_pilosa_proto_msgTypes[18] ms := protoimpl.X.MessageStateOf(protoimpl.Pointer(x)) ms.StoreMessageInfo(mi) } } func (x *GetIndexesRequest) String() string { return protoimpl.X.MessageStringOf(x) } func (*GetIndexesRequest) ProtoMessage() {} func (x *GetIndexesRequest) ProtoReflect() protoreflect.Message { mi := &file_pilosa_proto_msgTypes[18] if protoimpl.UnsafeEnabled && x != nil { ms := protoimpl.X.MessageStateOf(protoimpl.Pointer(x)) if ms.LoadMessageInfo() == nil { ms.StoreMessageInfo(mi) } return ms } return mi.MessageOf(x) } // Deprecated: Use GetIndexesRequest.ProtoReflect.Descriptor instead. func (*GetIndexesRequest) Descriptor() ([]byte, []int) { return file_pilosa_proto_rawDescGZIP(), []int{18} } type GetIndexesResponse struct { state protoimpl.MessageState sizeCache protoimpl.SizeCache unknownFields protoimpl.UnknownFields Indexes []*Index `protobuf:"bytes,1,rep,name=indexes,proto3" json:"indexes,omitempty"` } func (x *GetIndexesResponse) Reset() { *x = GetIndexesResponse{} if protoimpl.UnsafeEnabled { mi := &file_pilosa_proto_msgTypes[19] ms := protoimpl.X.MessageStateOf(protoimpl.Pointer(x)) ms.StoreMessageInfo(mi) } } func (x *GetIndexesResponse) String() string { return protoimpl.X.MessageStringOf(x) } func (*GetIndexesResponse) ProtoMessage() {} func (x *GetIndexesResponse) ProtoReflect() protoreflect.Message { mi := &file_pilosa_proto_msgTypes[19] if protoimpl.UnsafeEnabled && x != nil { ms := protoimpl.X.MessageStateOf(protoimpl.Pointer(x)) if ms.LoadMessageInfo() == nil { ms.StoreMessageInfo(mi) } return ms } return mi.MessageOf(x) } // Deprecated: Use GetIndexesResponse.ProtoReflect.Descriptor instead. func (*GetIndexesResponse) Descriptor() ([]byte, []int) { return file_pilosa_proto_rawDescGZIP(), []int{19} } func (x *GetIndexesResponse) GetIndexes() []*Index { if x != nil { return x.Indexes } return nil } type DeleteIndexRequest struct { state protoimpl.MessageState sizeCache protoimpl.SizeCache unknownFields protoimpl.UnknownFields Name string `protobuf:"bytes,1,opt,name=name,proto3" json:"name,omitempty"` } func (x *DeleteIndexRequest) Reset() { *x = DeleteIndexRequest{} if protoimpl.UnsafeEnabled { mi := &file_pilosa_proto_msgTypes[20] ms := protoimpl.X.MessageStateOf(protoimpl.Pointer(x)) ms.StoreMessageInfo(mi) } } func (x *DeleteIndexRequest) String() string { return protoimpl.X.MessageStringOf(x) } func (*DeleteIndexRequest) ProtoMessage() {} func (x *DeleteIndexRequest) ProtoReflect() protoreflect.Message { mi := &file_pilosa_proto_msgTypes[20] if protoimpl.UnsafeEnabled && x != nil { ms := protoimpl.X.MessageStateOf(protoimpl.Pointer(x)) if ms.LoadMessageInfo() == nil { ms.StoreMessageInfo(mi) } return ms } return mi.MessageOf(x) } // Deprecated: Use DeleteIndexRequest.ProtoReflect.Descriptor instead. func (*DeleteIndexRequest) Descriptor() ([]byte, []int) { return file_pilosa_proto_rawDescGZIP(), []int{20} } func (x *DeleteIndexRequest) GetName() string { if x != nil { return x.Name } return "" } type DeleteIndexResponse struct { state protoimpl.MessageState sizeCache protoimpl.SizeCache unknownFields protoimpl.UnknownFields } func (x *DeleteIndexResponse) Reset() { *x = DeleteIndexResponse{} if protoimpl.UnsafeEnabled { mi := &file_pilosa_proto_msgTypes[21] ms := protoimpl.X.MessageStateOf(protoimpl.Pointer(x)) ms.StoreMessageInfo(mi) } } func (x *DeleteIndexResponse) String() string { return protoimpl.X.MessageStringOf(x) } func (*DeleteIndexResponse) ProtoMessage() {} func (x *DeleteIndexResponse) ProtoReflect() protoreflect.Message { mi := &file_pilosa_proto_msgTypes[21] if protoimpl.UnsafeEnabled && x != nil { ms := protoimpl.X.MessageStateOf(protoimpl.Pointer(x)) if ms.LoadMessageInfo() == nil { ms.StoreMessageInfo(mi) } return ms } return mi.MessageOf(x) } // Deprecated: Use DeleteIndexResponse.ProtoReflect.Descriptor instead. func (*DeleteIndexResponse) Descriptor() ([]byte, []int) { return file_pilosa_proto_rawDescGZIP(), []int{21} } var File_pilosa_proto protoreflect.FileDescriptor var file_pilosa_proto_rawDesc = []byte{ 0x0a, 0x0c, 0x70, 0x69, 0x6c, 0x6f, 0x73, 0x61, 0x2e, 0x70, 0x72, 0x6f, 0x74, 0x6f, 0x12, 0x05, 0x70, 0x72, 0x6f, 0x74, 0x6f, 0x22, 0x39, 0x0a, 0x0f, 0x51, 0x75, 0x65, 0x72, 0x79, 0x50, 0x51, 0x4c, 0x52, 0x65, 0x71, 0x75, 0x65, 0x73, 0x74, 0x12, 0x14, 0x0a, 0x05, 0x69, 0x6e, 0x64, 0x65, 0x78, 0x18, 0x01, 0x20, 0x01, 0x28, 0x09, 0x52, 0x05, 0x69, 0x6e, 0x64, 0x65, 0x78, 0x12, 0x10, 0x0a, 0x03, 0x70, 0x71, 0x6c, 0x18, 0x02, 0x20, 0x01, 0x28, 0x09, 0x52, 0x03, 0x70, 0x71, 0x6c, 0x22, 0x23, 0x0a, 0x0f, 0x51, 0x75, 0x65, 0x72, 0x79, 0x53, 0x51, 0x4c, 0x52, 0x65, 0x71, 0x75, 0x65, 0x73, 0x74, 0x12, 0x10, 0x0a, 0x03, 0x73, 0x71, 0x6c, 0x18, 0x01, 0x20, 0x01, 0x28, 0x09, 0x52, 0x03, 0x73, 0x71, 0x6c, 0x22, 0x3b, 0x0a, 0x0b, 0x53, 0x74, 0x61, 0x74, 0x75, 0x73, 0x45, 0x72, 0x72, 0x6f, 0x72, 0x12, 0x12, 0x0a, 0x04, 0x43, 0x6f, 0x64, 0x65, 0x18, 0x01, 0x20, 0x01, 0x28, 0x0d, 0x52, 0x04, 0x43, 0x6f, 0x64, 0x65, 0x12, 0x18, 0x0a, 0x07, 0x4d, 0x65, 0x73, 0x73, 0x61, 0x67, 0x65, 0x18, 0x02, 0x20, 0x01, 0x28, 0x09, 0x52, 0x07, 0x4d, 0x65, 0x73, 0x73, 0x61, 0x67, 0x65, 0x22, 0xbd, 0x01, 0x0a, 0x0b, 0x52, 0x6f, 0x77, 0x52, 0x65, 0x73, 0x70, 0x6f, 0x6e, 0x73, 0x65, 0x12, 0x2b, 0x0a, 0x07, 0x68, 0x65, 0x61, 0x64, 0x65, 0x72, 0x73, 0x18, 0x01, 0x20, 0x03, 0x28, 0x0b, 0x32, 0x11, 0x2e, 0x70, 0x72, 0x6f, 0x74, 0x6f, 0x2e, 0x43, 0x6f, 0x6c, 0x75, 0x6d, 0x6e, 0x49, 0x6e, 0x66, 0x6f, 0x52, 0x07, 0x68, 0x65, 0x61, 0x64, 0x65, 0x72, 0x73, 0x12, 0x2f, 0x0a, 0x07, 0x63, 0x6f, 0x6c, 0x75, 0x6d, 0x6e, 0x73, 0x18, 0x02, 0x20, 0x03, 0x28, 0x0b, 0x32, 0x15, 0x2e, 0x70, 0x72, 0x6f, 0x74, 0x6f, 0x2e, 0x43, 0x6f, 0x6c, 0x75, 0x6d, 0x6e, 0x52, 0x65, 0x73, 0x70, 0x6f, 0x6e, 0x73, 0x65, 0x52, 0x07, 0x63, 0x6f, 0x6c, 0x75, 0x6d, 0x6e, 0x73, 0x12, 0x34, 0x0a, 0x0b, 0x53, 0x74, 0x61, 0x74, 0x75, 0x73, 0x45, 0x72, 0x72, 0x6f, 0x72, 0x18, 0x03, 0x20, 0x01, 0x28, 0x0b, 0x32, 0x12, 0x2e, 0x70, 0x72, 0x6f, 0x74, 0x6f, 0x2e, 0x53, 0x74, 0x61, 0x74, 0x75, 0x73, 0x45, 0x72, 0x72, 0x6f, 0x72, 0x52, 0x0b, 0x53, 0x74, 0x61, 0x74, 0x75, 0x73, 0x45, 0x72, 0x72, 0x6f, 0x72, 0x12, 0x1a, 0x0a, 0x08, 0x64, 0x75, 0x72, 0x61, 0x74, 0x69, 0x6f, 0x6e, 0x18, 0x04, 0x20, 0x01, 0x28, 0x03, 0x52, 0x08, 0x64, 0x75, 0x72, 0x61, 0x74, 0x69, 0x6f, 0x6e, 0x22, 0x36, 0x0a, 0x03, 0x52, 0x6f, 0x77, 0x12, 0x2f, 0x0a, 0x07, 0x63, 0x6f, 0x6c, 0x75, 0x6d, 0x6e, 0x73, 0x18, 0x01, 0x20, 0x03, 0x28, 0x0b, 0x32, 0x15, 0x2e, 0x70, 0x72, 0x6f, 0x74, 0x6f, 0x2e, 0x43, 0x6f, 0x6c, 0x75, 0x6d, 0x6e, 0x52, 0x65, 0x73, 0x70, 0x6f, 0x6e, 0x73, 0x65, 0x52, 0x07, 0x63, 0x6f, 0x6c, 0x75, 0x6d, 0x6e, 0x73, 0x22, 0xae, 0x01, 0x0a, 0x0d, 0x54, 0x61, 0x62, 0x6c, 0x65, 0x52, 0x65, 0x73, 0x70, 0x6f, 0x6e, 0x73, 0x65, 0x12, 0x2b, 0x0a, 0x07, 0x68, 0x65, 0x61, 0x64, 0x65, 0x72, 0x73, 0x18, 0x01, 0x20, 0x03, 0x28, 0x0b, 0x32, 0x11, 0x2e, 0x70, 0x72, 0x6f, 0x74, 0x6f, 0x2e, 0x43, 0x6f, 0x6c, 0x75, 0x6d, 0x6e, 0x49, 0x6e, 0x66, 0x6f, 0x52, 0x07, 0x68, 0x65, 0x61, 0x64, 0x65, 0x72, 0x73, 0x12, 0x1e, 0x0a, 0x04, 0x72, 0x6f, 0x77, 0x73, 0x18, 0x02, 0x20, 0x03, 0x28, 0x0b, 0x32, 0x0a, 0x2e, 0x70, 0x72, 0x6f, 0x74, 0x6f, 0x2e, 0x52, 0x6f, 0x77, 0x52, 0x04, 0x72, 0x6f, 0x77, 0x73, 0x12, 0x34, 0x0a, 0x0b, 0x53, 0x74, 0x61, 0x74, 0x75, 0x73, 0x45, 0x72, 0x72, 0x6f, 0x72, 0x18, 0x03, 0x20, 0x01, 0x28, 0x0b, 0x32, 0x12, 0x2e, 0x70, 0x72, 0x6f, 0x74, 0x6f, 0x2e, 0x53, 0x74, 0x61, 0x74, 0x75, 0x73, 0x45, 0x72, 0x72, 0x6f, 0x72, 0x52, 0x0b, 0x53, 0x74, 0x61, 0x74, 0x75, 0x73, 0x45, 0x72, 0x72, 0x6f, 0x72, 0x12, 0x1a, 0x0a, 0x08, 0x64, 0x75, 0x72, 0x61, 0x74, 0x69, 0x6f, 0x6e, 0x18, 0x04, 0x20, 0x01, 0x28, 0x03, 0x52, 0x08, 0x64, 0x75, 0x72, 0x61, 0x74, 0x69, 0x6f, 0x6e, 0x22, 0x3c, 0x0a, 0x0a, 0x43, 0x6f, 0x6c, 0x75, 0x6d, 0x6e, 0x49, 0x6e, 0x66, 0x6f, 0x12, 0x12, 0x0a, 0x04, 0x6e, 0x61, 0x6d, 0x65, 0x18, 0x01, 0x20, 0x01, 0x28, 0x09, 0x52, 0x04, 0x6e, 0x61, 0x6d, 0x65, 0x12, 0x1a, 0x0a, 0x08, 0x64, 0x61, 0x74, 0x61, 0x74, 0x79, 0x70, 0x65, 0x18, 0x02, 0x20, 0x01, 0x28, 0x09, 0x52, 0x08, 0x64, 0x61, 0x74, 0x61, 0x74, 0x79, 0x70, 0x65, 0x22, 0xa9, 0x03, 0x0a, 0x0e, 0x43, 0x6f, 0x6c, 0x75, 0x6d, 0x6e, 0x52, 0x65, 0x73, 0x70, 0x6f, 0x6e, 0x73, 0x65, 0x12, 0x1e, 0x0a, 0x09, 0x73, 0x74, 0x72, 0x69, 0x6e, 0x67, 0x56, 0x61, 0x6c, 0x18, 0x01, 0x20, 0x01, 0x28, 0x09, 0x48, 0x00, 0x52, 0x09, 0x73, 0x74, 0x72, 0x69, 0x6e, 0x67, 0x56, 0x61, 0x6c, 0x12, 0x1e, 0x0a, 0x09, 0x75, 0x69, 0x6e, 0x74, 0x36, 0x34, 0x56, 0x61, 0x6c, 0x18, 0x02, 0x20, 0x01, 0x28, 0x04, 0x48, 0x00, 0x52, 0x09, 0x75, 0x69, 0x6e, 0x74, 0x36, 0x34, 0x56, 0x61, 0x6c, 0x12, 0x1c, 0x0a, 0x08, 0x69, 0x6e, 0x74, 0x36, 0x34, 0x56, 0x61, 0x6c, 0x18, 0x03, 0x20, 0x01, 0x28, 0x03, 0x48, 0x00, 0x52, 0x08, 0x69, 0x6e, 0x74, 0x36, 0x34, 0x56, 0x61, 0x6c, 0x12, 0x1a, 0x0a, 0x07, 0x62, 0x6f, 0x6f, 0x6c, 0x56, 0x61, 0x6c, 0x18, 0x04, 0x20, 0x01, 0x28, 0x08, 0x48, 0x00, 0x52, 0x07, 0x62, 0x6f, 0x6f, 0x6c, 0x56, 0x61, 0x6c, 0x12, 0x1a, 0x0a, 0x07, 0x62, 0x6c, 0x6f, 0x62, 0x56, 0x61, 0x6c, 0x18, 0x05, 0x20, 0x01, 0x28, 0x0c, 0x48, 0x00, 0x52, 0x07, 0x62, 0x6c, 0x6f, 0x62, 0x56, 0x61, 0x6c, 0x12, 0x3c, 0x0a, 0x0e, 0x75, 0x69, 0x6e, 0x74, 0x36, 0x34, 0x41, 0x72, 0x72, 0x61, 0x79, 0x56, 0x61, 0x6c, 0x18, 0x06, 0x20, 0x01, 0x28, 0x0b, 0x32, 0x12, 0x2e, 0x70, 0x72, 0x6f, 0x74, 0x6f, 0x2e, 0x55, 0x69, 0x6e, 0x74, 0x36, 0x34, 0x41, 0x72, 0x72, 0x61, 0x79, 0x48, 0x00, 0x52, 0x0e, 0x75, 0x69, 0x6e, 0x74, 0x36, 0x34, 0x41, 0x72, 0x72, 0x61, 0x79, 0x56, 0x61, 0x6c, 0x12, 0x3c, 0x0a, 0x0e, 0x73, 0x74, 0x72, 0x69, 0x6e, 0x67, 0x41, 0x72, 0x72, 0x61, 0x79, 0x56, 0x61, 0x6c, 0x18, 0x07, 0x20, 0x01, 0x28, 0x0b, 0x32, 0x12, 0x2e, 0x70, 0x72, 0x6f, 0x74, 0x6f, 0x2e, 0x53, 0x74, 0x72, 0x69, 0x6e, 0x67, 0x41, 0x72, 0x72, 0x61, 0x79, 0x48, 0x00, 0x52, 0x0e, 0x73, 0x74, 0x72, 0x69, 0x6e, 0x67, 0x41, 0x72, 0x72, 0x61, 0x79, 0x56, 0x61, 0x6c, 0x12, 0x20, 0x0a, 0x0a, 0x66, 0x6c, 0x6f, 0x61, 0x74, 0x36, 0x34, 0x56, 0x61, 0x6c, 0x18, 0x08, 0x20, 0x01, 0x28, 0x01, 0x48, 0x00, 0x52, 0x0a, 0x66, 0x6c, 0x6f, 0x61, 0x74, 0x36, 0x34, 0x56, 0x61, 0x6c, 0x12, 0x30, 0x0a, 0x0a, 0x64, 0x65, 0x63, 0x69, 0x6d, 0x61, 0x6c, 0x56, 0x61, 0x6c, 0x18, 0x09, 0x20, 0x01, 0x28, 0x0b, 0x32, 0x0e, 0x2e, 0x70, 0x72, 0x6f, 0x74, 0x6f, 0x2e, 0x44, 0x65, 0x63, 0x69, 0x6d, 0x61, 0x6c, 0x48, 0x00, 0x52, 0x0a, 0x64, 0x65, 0x63, 0x69, 0x6d, 0x61, 0x6c, 0x56, 0x61, 0x6c, 0x12, 0x24, 0x0a, 0x0c, 0x74, 0x69, 0x6d, 0x65, 0x73, 0x74, 0x61, 0x6d, 0x70, 0x56, 0x61, 0x6c, 0x18, 0x0a, 0x20, 0x01, 0x28, 0x09, 0x48, 0x00, 0x52, 0x0c, 0x74, 0x69, 0x6d, 0x65, 0x73, 0x74, 0x61, 0x6d, 0x70, 0x56, 0x61, 0x6c, 0x42, 0x0b, 0x0a, 0x09, 0x63, 0x6f, 0x6c, 0x75, 0x6d, 0x6e, 0x56, 0x61, 0x6c, 0x22, 0x35, 0x0a, 0x07, 0x44, 0x65, 0x63, 0x69, 0x6d, 0x61, 0x6c, 0x12, 0x14, 0x0a, 0x05, 0x76, 0x61, 0x6c, 0x75, 0x65, 0x18, 0x01, 0x20, 0x01, 0x28, 0x03, 0x52, 0x05, 0x76, 0x61, 0x6c, 0x75, 0x65, 0x12, 0x14, 0x0a, 0x05, 0x73, 0x63, 0x61, 0x6c, 0x65, 0x18, 0x02, 0x20, 0x01, 0x28, 0x03, 0x52, 0x05, 0x73, 0x63, 0x61, 0x6c, 0x65, 0x22, 0xba, 0x01, 0x0a, 0x0e, 0x49, 0x6e, 0x73, 0x70, 0x65, 0x63, 0x74, 0x52, 0x65, 0x71, 0x75, 0x65, 0x73, 0x74, 0x12, 0x14, 0x0a, 0x05, 0x69, 0x6e, 0x64, 0x65, 0x78, 0x18, 0x01, 0x20, 0x01, 0x28, 0x09, 0x52, 0x05, 0x69, 0x6e, 0x64, 0x65, 0x78, 0x12, 0x2a, 0x0a, 0x07, 0x63, 0x6f, 0x6c, 0x75, 0x6d, 0x6e, 0x73, 0x18, 0x02, 0x20, 0x01, 0x28, 0x0b, 0x32, 0x10, 0x2e, 0x70, 0x72, 0x6f, 0x74, 0x6f, 0x2e, 0x49, 0x64, 0x73, 0x4f, 0x72, 0x4b, 0x65, 0x79, 0x73, 0x52, 0x07, 0x63, 0x6f, 0x6c, 0x75, 0x6d, 0x6e, 0x73, 0x12, 0x22, 0x0a, 0x0c, 0x66, 0x69, 0x6c, 0x74, 0x65, 0x72, 0x46, 0x69, 0x65, 0x6c, 0x64, 0x73, 0x18, 0x03, 0x20, 0x03, 0x28, 0x09, 0x52, 0x0c, 0x66, 0x69, 0x6c, 0x74, 0x65, 0x72, 0x46, 0x69, 0x65, 0x6c, 0x64, 0x73, 0x12, 0x14, 0x0a, 0x05, 0x6c, 0x69, 0x6d, 0x69, 0x74, 0x18, 0x04, 0x20, 0x01, 0x28, 0x04, 0x52, 0x05, 0x6c, 0x69, 0x6d, 0x69, 0x74, 0x12, 0x16, 0x0a, 0x06, 0x6f, 0x66, 0x66, 0x73, 0x65, 0x74, 0x18, 0x05, 0x20, 0x01, 0x28, 0x04, 0x52, 0x06, 0x6f, 0x66, 0x66, 0x73, 0x65, 0x74, 0x12, 0x14, 0x0a, 0x05, 0x71, 0x75, 0x65, 0x72, 0x79, 0x18, 0x06, 0x20, 0x01, 0x28, 0x09, 0x52, 0x05, 0x71, 0x75, 0x65, 0x72, 0x79, 0x22, 0x21, 0x0a, 0x0b, 0x55, 0x69, 0x6e, 0x74, 0x36, 0x34, 0x41, 0x72, 0x72, 0x61, 0x79, 0x12, 0x12, 0x0a, 0x04, 0x76, 0x61, 0x6c, 0x73, 0x18, 0x01, 0x20, 0x03, 0x28, 0x04, 0x52, 0x04, 0x76, 0x61, 0x6c, 0x73, 0x22, 0x21, 0x0a, 0x0b, 0x53, 0x74, 0x72, 0x69, 0x6e, 0x67, 0x41, 0x72, 0x72, 0x61, 0x79, 0x12, 0x12, 0x0a, 0x04, 0x76, 0x61, 0x6c, 0x73, 0x18, 0x01, 0x20, 0x03, 0x28, 0x09, 0x52, 0x04, 0x76, 0x61, 0x6c, 0x73, 0x22, 0x65, 0x0a, 0x09, 0x49, 0x64, 0x73, 0x4f, 0x72, 0x4b, 0x65, 0x79, 0x73, 0x12, 0x26, 0x0a, 0x03, 0x69, 0x64, 0x73, 0x18, 0x01, 0x20, 0x01, 0x28, 0x0b, 0x32, 0x12, 0x2e, 0x70, 0x72, 0x6f, 0x74, 0x6f, 0x2e, 0x55, 0x69, 0x6e, 0x74, 0x36, 0x34, 0x41, 0x72, 0x72, 0x61, 0x79, 0x48, 0x00, 0x52, 0x03, 0x69, 0x64, 0x73, 0x12, 0x28, 0x0a, 0x04, 0x6b, 0x65, 0x79, 0x73, 0x18, 0x02, 0x20, 0x01, 0x28, 0x0b, 0x32, 0x12, 0x2e, 0x70, 0x72, 0x6f, 0x74, 0x6f, 0x2e, 0x53, 0x74, 0x72, 0x69, 0x6e, 0x67, 0x41, 0x72, 0x72, 0x61, 0x79, 0x48, 0x00, 0x52, 0x04, 0x6b, 0x65, 0x79, 0x73, 0x42, 0x06, 0x0a, 0x04, 0x74, 0x79, 0x70, 0x65, 0x22, 0x1b, 0x0a, 0x05, 0x49, 0x6e, 0x64, 0x65, 0x78, 0x12, 0x12, 0x0a, 0x04, 0x6e, 0x61, 0x6d, 0x65, 0x18, 0x01, 0x20, 0x01, 0x28, 0x09, 0x52, 0x04, 0x6e, 0x61, 0x6d, 0x65, 0x22, 0x5e, 0x0a, 0x12, 0x43, 0x72, 0x65, 0x61, 0x74, 0x65, 0x49, 0x6e, 0x64, 0x65, 0x78, 0x52, 0x65, 0x71, 0x75, 0x65, 0x73, 0x74, 0x12, 0x12, 0x0a, 0x04, 0x6e, 0x61, 0x6d, 0x65, 0x18, 0x01, 0x20, 0x01, 0x28, 0x09, 0x52, 0x04, 0x6e, 0x61, 0x6d, 0x65, 0x12, 0x12, 0x0a, 0x04, 0x6b, 0x65, 0x79, 0x73, 0x18, 0x02, 0x20, 0x01, 0x28, 0x08, 0x52, 0x04, 0x6b, 0x65, 0x79, 0x73, 0x12, 0x20, 0x0a, 0x0b, 0x64, 0x65, 0x73, 0x63, 0x72, 0x69, 0x70, 0x74, 0x69, 0x6f, 0x6e, 0x18, 0x03, 0x20, 0x01, 0x28, 0x09, 0x52, 0x0b, 0x64, 0x65, 0x73, 0x63, 0x72, 0x69, 0x70, 0x74, 0x69, 0x6f, 0x6e, 0x22, 0x15, 0x0a, 0x13, 0x43, 0x72, 0x65, 0x61, 0x74, 0x65, 0x49, 0x6e, 0x64, 0x65, 0x78, 0x52, 0x65, 0x73, 0x70, 0x6f, 0x6e, 0x73, 0x65, 0x22, 0x25, 0x0a, 0x0f, 0x47, 0x65, 0x74, 0x49, 0x6e, 0x64, 0x65, 0x78, 0x52, 0x65, 0x71, 0x75, 0x65, 0x73, 0x74, 0x12, 0x12, 0x0a, 0x04, 0x6e, 0x61, 0x6d, 0x65, 0x18, 0x01, 0x20, 0x01, 0x28, 0x09, 0x52, 0x04, 0x6e, 0x61, 0x6d, 0x65, 0x22, 0x36, 0x0a, 0x10, 0x47, 0x65, 0x74, 0x49, 0x6e, 0x64, 0x65, 0x78, 0x52, 0x65, 0x73, 0x70, 0x6f, 0x6e, 0x73, 0x65, 0x12, 0x22, 0x0a, 0x05, 0x69, 0x6e, 0x64, 0x65, 0x78, 0x18, 0x01, 0x20, 0x01, 0x28, 0x0b, 0x32, 0x0c, 0x2e, 0x70, 0x72, 0x6f, 0x74, 0x6f, 0x2e, 0x49, 0x6e, 0x64, 0x65, 0x78, 0x52, 0x05, 0x69, 0x6e, 0x64, 0x65, 0x78, 0x22, 0x13, 0x0a, 0x11, 0x47, 0x65, 0x74, 0x49, 0x6e, 0x64, 0x65, 0x78, 0x65, 0x73, 0x52, 0x65, 0x71, 0x75, 0x65, 0x73, 0x74, 0x22, 0x3c, 0x0a, 0x12, 0x47, 0x65, 0x74, 0x49, 0x6e, 0x64, 0x65, 0x78, 0x65, 0x73, 0x52, 0x65, 0x73, 0x70, 0x6f, 0x6e, 0x73, 0x65, 0x12, 0x26, 0x0a, 0x07, 0x69, 0x6e, 0x64, 0x65, 0x78, 0x65, 0x73, 0x18, 0x01, 0x20, 0x03, 0x28, 0x0b, 0x32, 0x0c, 0x2e, 0x70, 0x72, 0x6f, 0x74, 0x6f, 0x2e, 0x49, 0x6e, 0x64, 0x65, 0x78, 0x52, 0x07, 0x69, 0x6e, 0x64, 0x65, 0x78, 0x65, 0x73, 0x22, 0x28, 0x0a, 0x12, 0x44, 0x65, 0x6c, 0x65, 0x74, 0x65, 0x49, 0x6e, 0x64, 0x65, 0x78, 0x52, 0x65, 0x71, 0x75, 0x65, 0x73, 0x74, 0x12, 0x12, 0x0a, 0x04, 0x6e, 0x61, 0x6d, 0x65, 0x18, 0x01, 0x20, 0x01, 0x28, 0x09, 0x52, 0x04, 0x6e, 0x61, 0x6d, 0x65, 0x22, 0x15, 0x0a, 0x13, 0x44, 0x65, 0x6c, 0x65, 0x74, 0x65, 0x49, 0x6e, 0x64, 0x65, 0x78, 0x52, 0x65, 0x73, 0x70, 0x6f, 0x6e, 0x73, 0x65, 0x32, 0xd0, 0x04, 0x0a, 0x06, 0x50, 0x69, 0x6c, 0x6f, 0x73, 0x61, 0x12, 0x46, 0x0a, 0x0b, 0x43, 0x72, 0x65, 0x61, 0x74, 0x65, 0x49, 0x6e, 0x64, 0x65, 0x78, 0x12, 0x19, 0x2e, 0x70, 0x72, 0x6f, 0x74, 0x6f, 0x2e, 0x43, 0x72, 0x65, 0x61, 0x74, 0x65, 0x49, 0x6e, 0x64, 0x65, 0x78, 0x52, 0x65, 0x71, 0x75, 0x65, 0x73, 0x74, 0x1a, 0x1a, 0x2e, 0x70, 0x72, 0x6f, 0x74, 0x6f, 0x2e, 0x43, 0x72, 0x65, 0x61, 0x74, 0x65, 0x49, 0x6e, 0x64, 0x65, 0x78, 0x52, 0x65, 0x73, 0x70, 0x6f, 0x6e, 0x73, 0x65, 0x22, 0x00, 0x12, 0x43, 0x0a, 0x0a, 0x47, 0x65, 0x74, 0x49, 0x6e, 0x64, 0x65, 0x78, 0x65, 0x73, 0x12, 0x18, 0x2e, 0x70, 0x72, 0x6f, 0x74, 0x6f, 0x2e, 0x47, 0x65, 0x74, 0x49, 0x6e, 0x64, 0x65, 0x78, 0x65, 0x73, 0x52, 0x65, 0x71, 0x75, 0x65, 0x73, 0x74, 0x1a, 0x19, 0x2e, 0x70, 0x72, 0x6f, 0x74, 0x6f, 0x2e, 0x47, 0x65, 0x74, 0x49, 0x6e, 0x64, 0x65, 0x78, 0x65, 0x73, 0x52, 0x65, 0x73, 0x70, 0x6f, 0x6e, 0x73, 0x65, 0x22, 0x00, 0x12, 0x3d, 0x0a, 0x08, 0x47, 0x65, 0x74, 0x49, 0x6e, 0x64, 0x65, 0x78, 0x12, 0x16, 0x2e, 0x70, 0x72, 0x6f, 0x74, 0x6f, 0x2e, 0x47, 0x65, 0x74, 0x49, 0x6e, 0x64, 0x65, 0x78, 0x52, 0x65, 0x71, 0x75, 0x65, 0x73, 0x74, 0x1a, 0x17, 0x2e, 0x70, 0x72, 0x6f, 0x74, 0x6f, 0x2e, 0x47, 0x65, 0x74, 0x49, 0x6e, 0x64, 0x65, 0x78, 0x52, 0x65, 0x73, 0x70, 0x6f, 0x6e, 0x73, 0x65, 0x22, 0x00, 0x12, 0x46, 0x0a, 0x0b, 0x44, 0x65, 0x6c, 0x65, 0x74, 0x65, 0x49, 0x6e, 0x64, 0x65, 0x78, 0x12, 0x19, 0x2e, 0x70, 0x72, 0x6f, 0x74, 0x6f, 0x2e, 0x44, 0x65, 0x6c, 0x65, 0x74, 0x65, 0x49, 0x6e, 0x64, 0x65, 0x78, 0x52, 0x65, 0x71, 0x75, 0x65, 0x73, 0x74, 0x1a, 0x1a, 0x2e, 0x70, 0x72, 0x6f, 0x74, 0x6f, 0x2e, 0x44, 0x65, 0x6c, 0x65, 0x74, 0x65, 0x49, 0x6e, 0x64, 0x65, 0x78, 0x52, 0x65, 0x73, 0x70, 0x6f, 0x6e, 0x73, 0x65, 0x22, 0x00, 0x12, 0x3a, 0x0a, 0x08, 0x51, 0x75, 0x65, 0x72, 0x79, 0x53, 0x51, 0x4c, 0x12, 0x16, 0x2e, 0x70, 0x72, 0x6f, 0x74, 0x6f, 0x2e, 0x51, 0x75, 0x65, 0x72, 0x79, 0x53, 0x51, 0x4c, 0x52, 0x65, 0x71, 0x75, 0x65, 0x73, 0x74, 0x1a, 0x12, 0x2e, 0x70, 0x72, 0x6f, 0x74, 0x6f, 0x2e, 0x52, 0x6f, 0x77, 0x52, 0x65, 0x73, 0x70, 0x6f, 0x6e, 0x73, 0x65, 0x22, 0x00, 0x30, 0x01, 0x12, 0x3f, 0x0a, 0x0d, 0x51, 0x75, 0x65, 0x72, 0x79, 0x53, 0x51, 0x4c, 0x55, 0x6e, 0x61, 0x72, 0x79, 0x12, 0x16, 0x2e, 0x70, 0x72, 0x6f, 0x74, 0x6f, 0x2e, 0x51, 0x75, 0x65, 0x72, 0x79, 0x53, 0x51, 0x4c, 0x52, 0x65, 0x71, 0x75, 0x65, 0x73, 0x74, 0x1a, 0x14, 0x2e, 0x70, 0x72, 0x6f, 0x74, 0x6f, 0x2e, 0x54, 0x61, 0x62, 0x6c, 0x65, 0x52, 0x65, 0x73, 0x70, 0x6f, 0x6e, 0x73, 0x65, 0x22, 0x00, 0x12, 0x3a, 0x0a, 0x08, 0x51, 0x75, 0x65, 0x72, 0x79, 0x50, 0x51, 0x4c, 0x12, 0x16, 0x2e, 0x70, 0x72, 0x6f, 0x74, 0x6f, 0x2e, 0x51, 0x75, 0x65, 0x72, 0x79, 0x50, 0x51, 0x4c, 0x52, 0x65, 0x71, 0x75, 0x65, 0x73, 0x74, 0x1a, 0x12, 0x2e, 0x70, 0x72, 0x6f, 0x74, 0x6f, 0x2e, 0x52, 0x6f, 0x77, 0x52, 0x65, 0x73, 0x70, 0x6f, 0x6e, 0x73, 0x65, 0x22, 0x00, 0x30, 0x01, 0x12, 0x3f, 0x0a, 0x0d, 0x51, 0x75, 0x65, 0x72, 0x79, 0x50, 0x51, 0x4c, 0x55, 0x6e, 0x61, 0x72, 0x79, 0x12, 0x16, 0x2e, 0x70, 0x72, 0x6f, 0x74, 0x6f, 0x2e, 0x51, 0x75, 0x65, 0x72, 0x79, 0x50, 0x51, 0x4c, 0x52, 0x65, 0x71, 0x75, 0x65, 0x73, 0x74, 0x1a, 0x14, 0x2e, 0x70, 0x72, 0x6f, 0x74, 0x6f, 0x2e, 0x54, 0x61, 0x62, 0x6c, 0x65, 0x52, 0x65, 0x73, 0x70, 0x6f, 0x6e, 0x73, 0x65, 0x22, 0x00, 0x12, 0x38, 0x0a, 0x07, 0x49, 0x6e, 0x73, 0x70, 0x65, 0x63, 0x74, 0x12, 0x15, 0x2e, 0x70, 0x72, 0x6f, 0x74, 0x6f, 0x2e, 0x49, 0x6e, 0x73, 0x70, 0x65, 0x63, 0x74, 0x52, 0x65, 0x71, 0x75, 0x65, 0x73, 0x74, 0x1a, 0x12, 0x2e, 0x70, 0x72, 0x6f, 0x74, 0x6f, 0x2e, 0x52, 0x6f, 0x77, 0x52, 0x65, 0x73, 0x70, 0x6f, 0x6e, 0x73, 0x65, 0x22, 0x00, 0x30, 0x01, 0x42, 0x0a, 0x5a, 0x08, 0x2e, 0x2e, 0x2f, 0x70, 0x72, 0x6f, 0x74, 0x6f, 0x62, 0x06, 0x70, 0x72, 0x6f, 0x74, 0x6f, 0x33, } var ( file_pilosa_proto_rawDescOnce sync.Once file_pilosa_proto_rawDescData = file_pilosa_proto_rawDesc ) func file_pilosa_proto_rawDescGZIP() []byte { file_pilosa_proto_rawDescOnce.Do(func() { file_pilosa_proto_rawDescData = protoimpl.X.CompressGZIP(file_pilosa_proto_rawDescData) }) return file_pilosa_proto_rawDescData } var file_pilosa_proto_msgTypes = make([]protoimpl.MessageInfo, 22) var file_pilosa_proto_goTypes = []interface{}{ (*QueryPQLRequest)(nil), // 0: proto.QueryPQLRequest (*QuerySQLRequest)(nil), // 1: proto.QuerySQLRequest (*StatusError)(nil), // 2: proto.StatusError (*RowResponse)(nil), // 3: proto.RowResponse (*Row)(nil), // 4: proto.Row (*TableResponse)(nil), // 5: proto.TableResponse (*ColumnInfo)(nil), // 6: proto.ColumnInfo (*ColumnResponse)(nil), // 7: proto.ColumnResponse (*Decimal)(nil), // 8: proto.Decimal (*InspectRequest)(nil), // 9: proto.InspectRequest (*Uint64Array)(nil), // 10: proto.Uint64Array (*StringArray)(nil), // 11: proto.StringArray (*IdsOrKeys)(nil), // 12: proto.IdsOrKeys (*Index)(nil), // 13: proto.Index (*CreateIndexRequest)(nil), // 14: proto.CreateIndexRequest (*CreateIndexResponse)(nil), // 15: proto.CreateIndexResponse (*GetIndexRequest)(nil), // 16: proto.GetIndexRequest (*GetIndexResponse)(nil), // 17: proto.GetIndexResponse (*GetIndexesRequest)(nil), // 18: proto.GetIndexesRequest (*GetIndexesResponse)(nil), // 19: proto.GetIndexesResponse (*DeleteIndexRequest)(nil), // 20: proto.DeleteIndexRequest (*DeleteIndexResponse)(nil), // 21: proto.DeleteIndexResponse } var file_pilosa_proto_depIdxs = []int32{ 6, // 0: proto.RowResponse.headers:type_name -> proto.ColumnInfo 7, // 1: proto.RowResponse.columns:type_name -> proto.ColumnResponse 2, // 2: proto.RowResponse.StatusError:type_name -> proto.StatusError 7, // 3: proto.Row.columns:type_name -> proto.ColumnResponse 6, // 4: proto.TableResponse.headers:type_name -> proto.ColumnInfo 4, // 5: proto.TableResponse.rows:type_name -> proto.Row 2, // 6: proto.TableResponse.StatusError:type_name -> proto.StatusError 10, // 7: proto.ColumnResponse.uint64ArrayVal:type_name -> proto.Uint64Array 11, // 8: proto.ColumnResponse.stringArrayVal:type_name -> proto.StringArray 8, // 9: proto.ColumnResponse.decimalVal:type_name -> proto.Decimal 12, // 10: proto.InspectRequest.columns:type_name -> proto.IdsOrKeys 10, // 11: proto.IdsOrKeys.ids:type_name -> proto.Uint64Array 11, // 12: proto.IdsOrKeys.keys:type_name -> proto.StringArray 13, // 13: proto.GetIndexResponse.index:type_name -> proto.Index 13, // 14: proto.GetIndexesResponse.indexes:type_name -> proto.Index 14, // 15: proto.Pilosa.CreateIndex:input_type -> proto.CreateIndexRequest 18, // 16: proto.Pilosa.GetIndexes:input_type -> proto.GetIndexesRequest 16, // 17: proto.Pilosa.GetIndex:input_type -> proto.GetIndexRequest 20, // 18: proto.Pilosa.DeleteIndex:input_type -> proto.DeleteIndexRequest 1, // 19: proto.Pilosa.QuerySQL:input_type -> proto.QuerySQLRequest 1, // 20: proto.Pilosa.QuerySQLUnary:input_type -> proto.QuerySQLRequest 0, // 21: proto.Pilosa.QueryPQL:input_type -> proto.QueryPQLRequest 0, // 22: proto.Pilosa.QueryPQLUnary:input_type -> proto.QueryPQLRequest 9, // 23: proto.Pilosa.Inspect:input_type -> proto.InspectRequest 15, // 24: proto.Pilosa.CreateIndex:output_type -> proto.CreateIndexResponse 19, // 25: proto.Pilosa.GetIndexes:output_type -> proto.GetIndexesResponse 17, // 26: proto.Pilosa.GetIndex:output_type -> proto.GetIndexResponse 21, // 27: proto.Pilosa.DeleteIndex:output_type -> proto.DeleteIndexResponse 3, // 28: proto.Pilosa.QuerySQL:output_type -> proto.RowResponse 5, // 29: proto.Pilosa.QuerySQLUnary:output_type -> proto.TableResponse 3, // 30: proto.Pilosa.QueryPQL:output_type -> proto.RowResponse 5, // 31: proto.Pilosa.QueryPQLUnary:output_type -> proto.TableResponse 3, // 32: proto.Pilosa.Inspect:output_type -> proto.RowResponse 24, // [24:33] is the sub-list for method output_type 15, // [15:24] is the sub-list for method input_type 15, // [15:15] is the sub-list for extension type_name 15, // [15:15] is the sub-list for extension extendee 0, // [0:15] is the sub-list for field type_name } func init() { file_pilosa_proto_init() } func file_pilosa_proto_init() { if File_pilosa_proto != nil { return } if !protoimpl.UnsafeEnabled { file_pilosa_proto_msgTypes[0].Exporter = func(v interface{}, i int) interface{} { switch v := v.(*QueryPQLRequest); i { case 0: return &v.state case 1: return &v.sizeCache case 2: return &v.unknownFields default: return nil } } file_pilosa_proto_msgTypes[1].Exporter = func(v interface{}, i int) interface{} { switch v := v.(*QuerySQLRequest); i { case 0: return &v.state case 1: return &v.sizeCache case 2: return &v.unknownFields default: return nil } } file_pilosa_proto_msgTypes[2].Exporter = func(v interface{}, i int) interface{} { switch v := v.(*StatusError); i { case 0: return &v.state case 1: return &v.sizeCache case 2: return &v.unknownFields default: return nil } } file_pilosa_proto_msgTypes[3].Exporter = func(v interface{}, i int) interface{} { switch v := v.(*RowResponse); i { case 0: return &v.state case 1: return &v.sizeCache case 2: return &v.unknownFields default: return nil } } file_pilosa_proto_msgTypes[4].Exporter = func(v interface{}, i int) interface{} { switch v := v.(*Row); i { case 0: return &v.state case 1: return &v.sizeCache case 2: return &v.unknownFields default: return nil } } file_pilosa_proto_msgTypes[5].Exporter = func(v interface{}, i int) interface{} { switch v := v.(*TableResponse); i { case 0: return &v.state case 1: return &v.sizeCache case 2: return &v.unknownFields default: return nil } } file_pilosa_proto_msgTypes[6].Exporter = func(v interface{}, i int) interface{} { switch v := v.(*ColumnInfo); i { case 0: return &v.state case 1: return &v.sizeCache case 2: return &v.unknownFields default: return nil } } file_pilosa_proto_msgTypes[7].Exporter = func(v interface{}, i int) interface{} { switch v := v.(*ColumnResponse); i { case 0: return &v.state case 1: return &v.sizeCache case 2: return &v.unknownFields default: return nil } } file_pilosa_proto_msgTypes[8].Exporter = func(v interface{}, i int) interface{} { switch v := v.(*Decimal); i { case 0: return &v.state case 1: return &v.sizeCache case 2: return &v.unknownFields default: return nil } } file_pilosa_proto_msgTypes[9].Exporter = func(v interface{}, i int) interface{} { switch v := v.(*InspectRequest); i { case 0: return &v.state case 1: return &v.sizeCache case 2: return &v.unknownFields default: return nil } } file_pilosa_proto_msgTypes[10].Exporter = func(v interface{}, i int) interface{} { switch v := v.(*Uint64Array); i { case 0: return &v.state case 1: return &v.sizeCache case 2: return &v.unknownFields default: return nil } } file_pilosa_proto_msgTypes[11].Exporter = func(v interface{}, i int) interface{} { switch v := v.(*StringArray); i { case 0: return &v.state case 1: return &v.sizeCache case 2: return &v.unknownFields default: return nil } } file_pilosa_proto_msgTypes[12].Exporter = func(v interface{}, i int) interface{} { switch v := v.(*IdsOrKeys); i { case 0: return &v.state case 1: return &v.sizeCache case 2: return &v.unknownFields default: return nil } } file_pilosa_proto_msgTypes[13].Exporter = func(v interface{}, i int) interface{} { switch v := v.(*Index); i { case 0: return &v.state case 1: return &v.sizeCache case 2: return &v.unknownFields default: return nil } } file_pilosa_proto_msgTypes[14].Exporter = func(v interface{}, i int) interface{} { switch v := v.(*CreateIndexRequest); i { case 0: return &v.state case 1: return &v.sizeCache case 2: return &v.unknownFields default: return nil } } file_pilosa_proto_msgTypes[15].Exporter = func(v interface{}, i int) interface{} { switch v := v.(*CreateIndexResponse); i { case 0: return &v.state case 1: return &v.sizeCache case 2: return &v.unknownFields default: return nil } } file_pilosa_proto_msgTypes[16].Exporter = func(v interface{}, i int) interface{} { switch v := v.(*GetIndexRequest); i { case 0: return &v.state case 1: return &v.sizeCache case 2: return &v.unknownFields default: return nil } } file_pilosa_proto_msgTypes[17].Exporter = func(v interface{}, i int) interface{} { switch v := v.(*GetIndexResponse); i { case 0: return &v.state case 1: return &v.sizeCache case 2: return &v.unknownFields default: return nil } } file_pilosa_proto_msgTypes[18].Exporter = func(v interface{}, i int) interface{} { switch v := v.(*GetIndexesRequest); i { case 0: return &v.state case 1: return &v.sizeCache case 2: return &v.unknownFields default: return nil } } file_pilosa_proto_msgTypes[19].Exporter = func(v interface{}, i int) interface{} { switch v := v.(*GetIndexesResponse); i { case 0: return &v.state case 1: return &v.sizeCache case 2: return &v.unknownFields default: return nil } } file_pilosa_proto_msgTypes[20].Exporter = func(v interface{}, i int) interface{} { switch v := v.(*DeleteIndexRequest); i { case 0: return &v.state case 1: return &v.sizeCache case 2: return &v.unknownFields default: return nil } } file_pilosa_proto_msgTypes[21].Exporter = func(v interface{}, i int) interface{} { switch v := v.(*DeleteIndexResponse); i { case 0: return &v.state case 1: return &v.sizeCache case 2: return &v.unknownFields default: return nil } } } file_pilosa_proto_msgTypes[7].OneofWrappers = []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), (*ColumnResponse_DecimalVal)(nil), (*ColumnResponse_TimestampVal)(nil), } file_pilosa_proto_msgTypes[12].OneofWrappers = []interface{}{ (*IdsOrKeys_Ids)(nil), (*IdsOrKeys_Keys)(nil), } type x struct{} out := protoimpl.TypeBuilder{ File: protoimpl.DescBuilder{ GoPackagePath: reflect.TypeOf(x{}).PkgPath(), RawDescriptor: file_pilosa_proto_rawDesc, NumEnums: 0, NumMessages: 22, NumExtensions: 0, NumServices: 1, }, GoTypes: file_pilosa_proto_goTypes, DependencyIndexes: file_pilosa_proto_depIdxs, MessageInfos: file_pilosa_proto_msgTypes, }.Build() File_pilosa_proto = out.File file_pilosa_proto_rawDesc = nil file_pilosa_proto_goTypes = nil file_pilosa_proto_depIdxs = nil } // Reference imports to suppress errors if they are not otherwise used. var _ context.Context var _ grpc.ClientConnInterface // 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.SupportPackageIsVersion6 // 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 { CreateIndex(ctx context.Context, in *CreateIndexRequest, opts ...grpc.CallOption) (*CreateIndexResponse, error) GetIndexes(ctx context.Context, in *GetIndexesRequest, opts ...grpc.CallOption) (*GetIndexesResponse, error) GetIndex(ctx context.Context, in *GetIndexRequest, opts ...grpc.CallOption) (*GetIndexResponse, error) DeleteIndex(ctx context.Context, in *DeleteIndexRequest, opts ...grpc.CallOption) (*DeleteIndexResponse, error) QuerySQL(ctx context.Context, in *QuerySQLRequest, opts ...grpc.CallOption) (Pilosa_QuerySQLClient, error) QuerySQLUnary(ctx context.Context, in *QuerySQLRequest, opts ...grpc.CallOption) (*TableResponse, error) QueryPQL(ctx context.Context, in *QueryPQLRequest, opts ...grpc.CallOption) (Pilosa_QueryPQLClient, error) QueryPQLUnary(ctx context.Context, in *QueryPQLRequest, opts ...grpc.CallOption) (*TableResponse, error) Inspect(ctx context.Context, in *InspectRequest, opts ...grpc.CallOption) (Pilosa_InspectClient, error) } type pilosaClient struct { cc grpc.ClientConnInterface } func NewPilosaClient(cc grpc.ClientConnInterface) PilosaClient { return &pilosaClient{cc} } func (c *pilosaClient) CreateIndex(ctx context.Context, in *CreateIndexRequest, opts ...grpc.CallOption) (*CreateIndexResponse, error) { out := new(CreateIndexResponse) err := c.cc.Invoke(ctx, "/proto.Pilosa/CreateIndex", in, out, opts...) if err != nil { return nil, err } return out, nil } func (c *pilosaClient) GetIndexes(ctx context.Context, in *GetIndexesRequest, opts ...grpc.CallOption) (*GetIndexesResponse, error) { out := new(GetIndexesResponse) err := c.cc.Invoke(ctx, "/proto.Pilosa/GetIndexes", in, out, opts...) if err != nil { return nil, err } return out, nil } func (c *pilosaClient) GetIndex(ctx context.Context, in *GetIndexRequest, opts ...grpc.CallOption) (*GetIndexResponse, error) { out := new(GetIndexResponse) err := c.cc.Invoke(ctx, "/proto.Pilosa/GetIndex", in, out, opts...) if err != nil { return nil, err } return out, nil } func (c *pilosaClient) DeleteIndex(ctx context.Context, in *DeleteIndexRequest, opts ...grpc.CallOption) (*DeleteIndexResponse, error) { out := new(DeleteIndexResponse) err := c.cc.Invoke(ctx, "/proto.Pilosa/DeleteIndex", in, out, opts...) if err != nil { return nil, err } return out, nil } func (c *pilosaClient) QuerySQL(ctx context.Context, in *QuerySQLRequest, opts ...grpc.CallOption) (Pilosa_QuerySQLClient, error) { stream, err := c.cc.NewStream(ctx, &_Pilosa_serviceDesc.Streams[0], "/proto.Pilosa/QuerySQL", opts...) if err != nil { return nil, err } x := &pilosaQuerySQLClient{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_QuerySQLClient interface { Recv() (*RowResponse, error) grpc.ClientStream } type pilosaQuerySQLClient struct { grpc.ClientStream } func (x *pilosaQuerySQLClient) Recv() (*RowResponse, error) { m := new(RowResponse) if err := x.ClientStream.RecvMsg(m); err != nil { return nil, err } return m, nil } func (c *pilosaClient) QuerySQLUnary(ctx context.Context, in *QuerySQLRequest, opts ...grpc.CallOption) (*TableResponse, error) { out := new(TableResponse) err := c.cc.Invoke(ctx, "/proto.Pilosa/QuerySQLUnary", in, out, opts...) if err != nil { return nil, err } return out, nil } func (c *pilosaClient) QueryPQL(ctx context.Context, in *QueryPQLRequest, opts ...grpc.CallOption) (Pilosa_QueryPQLClient, error) { stream, err := c.cc.NewStream(ctx, &_Pilosa_serviceDesc.Streams[1], "/proto.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) QueryPQLUnary(ctx context.Context, in *QueryPQLRequest, opts ...grpc.CallOption) (*TableResponse, error) { out := new(TableResponse) err := c.cc.Invoke(ctx, "/proto.Pilosa/QueryPQLUnary", in, out, opts...) if err != nil { return nil, err } return out, 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[2], "/proto.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 { CreateIndex(context.Context, *CreateIndexRequest) (*CreateIndexResponse, error) GetIndexes(context.Context, *GetIndexesRequest) (*GetIndexesResponse, error) GetIndex(context.Context, *GetIndexRequest) (*GetIndexResponse, error) DeleteIndex(context.Context, *DeleteIndexRequest) (*DeleteIndexResponse, error) QuerySQL(*QuerySQLRequest, Pilosa_QuerySQLServer) error QuerySQLUnary(context.Context, *QuerySQLRequest) (*TableResponse, error) QueryPQL(*QueryPQLRequest, Pilosa_QueryPQLServer) error QueryPQLUnary(context.Context, *QueryPQLRequest) (*TableResponse, error) Inspect(*InspectRequest, Pilosa_InspectServer) error } // UnimplementedPilosaServer can be embedded to have forward compatible implementations. type UnimplementedPilosaServer struct { } func (*UnimplementedPilosaServer) CreateIndex(context.Context, *CreateIndexRequest) (*CreateIndexResponse, error) { return nil, status.Errorf(codes.Unimplemented, "method CreateIndex not implemented") } func (*UnimplementedPilosaServer) GetIndexes(context.Context, *GetIndexesRequest) (*GetIndexesResponse, error) { return nil, status.Errorf(codes.Unimplemented, "method GetIndexes not implemented") } func (*UnimplementedPilosaServer) GetIndex(context.Context, *GetIndexRequest) (*GetIndexResponse, error) { return nil, status.Errorf(codes.Unimplemented, "method GetIndex not implemented") } func (*UnimplementedPilosaServer) DeleteIndex(context.Context, *DeleteIndexRequest) (*DeleteIndexResponse, error) { return nil, status.Errorf(codes.Unimplemented, "method DeleteIndex not implemented") } func (*UnimplementedPilosaServer) QuerySQL(*QuerySQLRequest, Pilosa_QuerySQLServer) error { return status.Errorf(codes.Unimplemented, "method QuerySQL not implemented") } func (*UnimplementedPilosaServer) QuerySQLUnary(context.Context, *QuerySQLRequest) (*TableResponse, error) { return nil, status.Errorf(codes.Unimplemented, "method QuerySQLUnary not implemented") } func (*UnimplementedPilosaServer) QueryPQL(*QueryPQLRequest, Pilosa_QueryPQLServer) error { return status.Errorf(codes.Unimplemented, "method QueryPQL not implemented") } func (*UnimplementedPilosaServer) QueryPQLUnary(context.Context, *QueryPQLRequest) (*TableResponse, error) { return nil, status.Errorf(codes.Unimplemented, "method QueryPQLUnary not implemented") } func (*UnimplementedPilosaServer) Inspect(*InspectRequest, Pilosa_InspectServer) error { return status.Errorf(codes.Unimplemented, "method Inspect not implemented") } func RegisterPilosaServer(s *grpc.Server, srv PilosaServer) { s.RegisterService(&_Pilosa_serviceDesc, srv) } func _Pilosa_CreateIndex_Handler(srv interface{}, ctx context.Context, dec func(interface{}) error, interceptor grpc.UnaryServerInterceptor) (interface{}, error) { in := new(CreateIndexRequest) if err := dec(in); err != nil { return nil, err } if interceptor == nil { return srv.(PilosaServer).CreateIndex(ctx, in) } info := &grpc.UnaryServerInfo{ Server: srv, FullMethod: "/proto.Pilosa/CreateIndex", } handler := func(ctx context.Context, req interface{}) (interface{}, error) { return srv.(PilosaServer).CreateIndex(ctx, req.(*CreateIndexRequest)) } return interceptor(ctx, in, info, handler) } func _Pilosa_GetIndexes_Handler(srv interface{}, ctx context.Context, dec func(interface{}) error, interceptor grpc.UnaryServerInterceptor) (interface{}, error) { in := new(GetIndexesRequest) if err := dec(in); err != nil { return nil, err } if interceptor == nil { return srv.(PilosaServer).GetIndexes(ctx, in) } info := &grpc.UnaryServerInfo{ Server: srv, FullMethod: "/proto.Pilosa/GetIndexes", } handler := func(ctx context.Context, req interface{}) (interface{}, error) { return srv.(PilosaServer).GetIndexes(ctx, req.(*GetIndexesRequest)) } return interceptor(ctx, in, info, handler) } func _Pilosa_GetIndex_Handler(srv interface{}, ctx context.Context, dec func(interface{}) error, interceptor grpc.UnaryServerInterceptor) (interface{}, error) { in := new(GetIndexRequest) if err := dec(in); err != nil { return nil, err } if interceptor == nil { return srv.(PilosaServer).GetIndex(ctx, in) } info := &grpc.UnaryServerInfo{ Server: srv, FullMethod: "/proto.Pilosa/GetIndex", } handler := func(ctx context.Context, req interface{}) (interface{}, error) { return srv.(PilosaServer).GetIndex(ctx, req.(*GetIndexRequest)) } return interceptor(ctx, in, info, handler) } func _Pilosa_DeleteIndex_Handler(srv interface{}, ctx context.Context, dec func(interface{}) error, interceptor grpc.UnaryServerInterceptor) (interface{}, error) { in := new(DeleteIndexRequest) if err := dec(in); err != nil { return nil, err } if interceptor == nil { return srv.(PilosaServer).DeleteIndex(ctx, in) } info := &grpc.UnaryServerInfo{ Server: srv, FullMethod: "/proto.Pilosa/DeleteIndex", } handler := func(ctx context.Context, req interface{}) (interface{}, error) { return srv.(PilosaServer).DeleteIndex(ctx, req.(*DeleteIndexRequest)) } return interceptor(ctx, in, info, handler) } func _Pilosa_QuerySQL_Handler(srv interface{}, stream grpc.ServerStream) error { m := new(QuerySQLRequest) if err := stream.RecvMsg(m); err != nil { return err } return srv.(PilosaServer).QuerySQL(m, &pilosaQuerySQLServer{stream}) } type Pilosa_QuerySQLServer interface { Send(*RowResponse) error grpc.ServerStream } type pilosaQuerySQLServer struct { grpc.ServerStream } func (x *pilosaQuerySQLServer) Send(m *RowResponse) error { return x.ServerStream.SendMsg(m) } func _Pilosa_QuerySQLUnary_Handler(srv interface{}, ctx context.Context, dec func(interface{}) error, interceptor grpc.UnaryServerInterceptor) (interface{}, error) { in := new(QuerySQLRequest) if err := dec(in); err != nil { return nil, err } if interceptor == nil { return srv.(PilosaServer).QuerySQLUnary(ctx, in) } info := &grpc.UnaryServerInfo{ Server: srv, FullMethod: "/proto.Pilosa/QuerySQLUnary", } handler := func(ctx context.Context, req interface{}) (interface{}, error) { return srv.(PilosaServer).QuerySQLUnary(ctx, req.(*QuerySQLRequest)) } return interceptor(ctx, in, info, handler) } 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_QueryPQLUnary_Handler(srv interface{}, ctx context.Context, dec func(interface{}) error, interceptor grpc.UnaryServerInterceptor) (interface{}, error) { in := new(QueryPQLRequest) if err := dec(in); err != nil { return nil, err } if interceptor == nil { return srv.(PilosaServer).QueryPQLUnary(ctx, in) } info := &grpc.UnaryServerInfo{ Server: srv, FullMethod: "/proto.Pilosa/QueryPQLUnary", } handler := func(ctx context.Context, req interface{}) (interface{}, error) { return srv.(PilosaServer).QueryPQLUnary(ctx, req.(*QueryPQLRequest)) } return interceptor(ctx, in, info, handler) } 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: "proto.Pilosa", HandlerType: (*PilosaServer)(nil), Methods: []grpc.MethodDesc{ { MethodName: "CreateIndex", Handler: _Pilosa_CreateIndex_Handler, }, { MethodName: "GetIndexes", Handler: _Pilosa_GetIndexes_Handler, }, { MethodName: "GetIndex", Handler: _Pilosa_GetIndex_Handler, }, { MethodName: "DeleteIndex", Handler: _Pilosa_DeleteIndex_Handler, }, { MethodName: "QuerySQLUnary", Handler: _Pilosa_QuerySQLUnary_Handler, }, { MethodName: "QueryPQLUnary", Handler: _Pilosa_QueryPQLUnary_Handler, }, }, Streams: []grpc.StreamDesc{ { StreamName: "QuerySQL", Handler: _Pilosa_QuerySQL_Handler, ServerStreams: true, }, { StreamName: "QueryPQL", Handler: _Pilosa_QueryPQL_Handler, ServerStreams: true, }, { StreamName: "Inspect", Handler: _Pilosa_Inspect_Handler, ServerStreams: true, }, }, Metadata: "pilosa.proto", }