featurebase/proto/pilosa.pb.go
CLoZengineer daceee2ab6
merge: featurebase merge updates for 2022-10-28 (#2188)
* use t.Fatal(f) to abort tests, not panic

* make perf_able run at all, make it debug a bit better

switch perf-able to using same node type we use for other spot instances,
because otherwise it never finds any available capacity.

we switch the perf-able script to use the standard get_value function
instead of direct jq calls.

we try to grab server logs if the restore fails in the hopes of finding
out why the restore very occasionally fails.

* Fix some issues with running IDK tests in docker. (#2248)

*Stop running TestKafkaSourceIntegration with t.Parallel()

This test can't be run in parallel as it's currently written. Doing so
allows for interleaving of messages to the same kafka topic between
tests.

I didn't attempt to modify the test so it could be run in parallel. That
could be done, but left for someone more ambitious.

* Remove idk/testenv/certs which got accidentally committed.

also update .gitignore to include those.

* changes to add bool support in idk (#2240)

* initial changes to add bool support in idk

* modifying some default parameters for testing, will revert them later

* adding support for bool in making fragments function

* boolean values implementation without supporting empty or null values at this point

* Implement bool support in batch using a map (and a slice for nulls) (#2247)

* Implement bool support in batch using a map (and a slice for nulls)

* Keep the PackBools default for now

But set it explicity in the ingest tests which rely on it.

* Modify batch to construct bool update like mutex

The code in API.ImportRoaringShard has a switch statement which causes
bool fields to be handled like mutex fields. This means, that the
viewUpdate.Clear value should only contain data in the first "row" of
the fragment, which it will treat as records to clear for *all* rows.
This makes more sense for mutex fields; for bool fields, there's only
one other row to clear. But since the code is currently handling them
the same, we need to construct viewUpdate.Clear such that it conforms to
that pattern.

This commit also adds a test which covers this logic.

* Remove commented code; revert config for testing

This commit also removes the DELETE_SENTINEL case for non-packed bools,
since that isn't supported anyway.

* Revert default setting

* remove inconsistent type scope

* correcting the logic of string converstion to bool

* resolving an error in a test

* adding tests to cover code related to bool support in batch.go file and interface.go files

* modifying interfaces test

* added one more test case

Co-authored-by: Travis Turner <travis@pilosa.com>
Co-authored-by: Travis Turner <travis@molecula.com>

* resolving bool null field ingestion error (#2254)

* resolving bool null field ingestion error

* testing issues

* adding null support for bools

* updating the null bool field ingestion

* trying to resolve issue when ingesting null value for bool type

* adding a clearing support for bool type

* resolving issues with bool null value ingestion

* updating the jwt go package version and removing changes made in docker compose file

* reverting jwt go version

* removing v4 of jwt

* adding a comment in test file to see if sonar cloud accepts this file

* don't obtain stack traces on rbf.Tx creation

We thought stack traces were mildly expensive. We were very wrong.
Due to a complicated issue in the Go runtime, simultaneous requests
for stack traces end up contending on a lock even when they're not
actually contending on any resources. I've filed a ticket in the
Go issue tracker for this:

	https://github.com/golang/go/issues/56400

In the mean time: Under some workloads, we were seeing 85% of all
CPU time go into the stack backtraces, of which 81% went into the
contention on those locks. But even if you take away the contention,
that leaves us with 4/19 of all CPU time in our code going into
building those stack backtraces. That's a lot of overhead for a
feature we virtually never use.

We might consider adding a backtrace functionality here, possibly
using `runtime.Callers` which is much lower overhead, and allows us
to generate a backtrace on demand (no argument values available,
but then, we never read those because they're unformatted hex
values), but I don't think it's actually very informative to know
what the stack traces were of the Tx; they don't necessarily reflect
the current state of any ongoing use of the Tx, so we can't necessarily
correlate them to goroutine stack dumps, and so on.

* fb-1729 Enriched Table Metadata (#2255)

enriched metadata for tables

added support for the concept of a table and field owners in metadata; mechanism to derive owner from http request metadata; metadata for table description

* tightened up is/is not null filter expressions (FB-1741) (#2260)

Covers tightening up handling filter expressions that contain is/is not null ops. These filters may have to be translated into PQL calls to be passed to the executor and even though sql3 language supports nullability for any data type, currently only BSI fields are nullable at the storage engine level (there is a ticket to add support for non-BSI field here FB-1689: IS SQL Argument returns incorrect error) so when these fields are used in filter conditions we need to handle BSI and non-BSI fields differently.

* added a test to cover the keyword replace as being synonymous with insert (#2261)

* update molecula references to featurebase (#2262)

Co-authored-by: Seebs <seebs@molecula.com>
Co-authored-by: Travis Turner <travis@pilosa.com>
Co-authored-by: Pranitha-malae <56414132+Pranitha-malae@users.noreply.github.com>
Co-authored-by: Travis Turner <travis@molecula.com>
Co-authored-by: pokeeffe-molecula <85502298+pokeeffe-molecula@users.noreply.github.com>
Co-authored-by: Stephanie Yang <stephanie@pilosa.com>
2022-10-28 13:08:23 -04:00

2346 lines
73 KiB
Go

// 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",
}