Documentation ¶
Index ¶
- func RegisterPilosaServer(s *grpc.Server, srv PilosaServer)
- type ColumnInfo
- func (*ColumnInfo) Descriptor() ([]byte, []int)
- func (m *ColumnInfo) GetDatatype() string
- func (m *ColumnInfo) GetName() string
- func (*ColumnInfo) ProtoMessage()
- func (m *ColumnInfo) Reset()
- func (m *ColumnInfo) String() string
- func (m *ColumnInfo) XXX_DiscardUnknown()
- func (m *ColumnInfo) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)
- func (m *ColumnInfo) XXX_Merge(src proto.Message)
- func (m *ColumnInfo) XXX_Size() int
- func (m *ColumnInfo) XXX_Unmarshal(b []byte) error
- type ColumnResponse
- func (*ColumnResponse) Descriptor() ([]byte, []int)
- func (m *ColumnResponse) GetBlobVal() []byte
- func (m *ColumnResponse) GetBoolVal() bool
- func (m *ColumnResponse) GetColumnVal() isColumnResponse_ColumnVal
- func (m *ColumnResponse) GetDecimalVal() *Decimal
- func (m *ColumnResponse) GetFloat64Val() float64
- func (m *ColumnResponse) GetInt64Val() int64
- func (m *ColumnResponse) GetStringArrayVal() *StringArray
- func (m *ColumnResponse) GetStringVal() string
- func (m *ColumnResponse) GetUint64ArrayVal() *Uint64Array
- func (m *ColumnResponse) GetUint64Val() uint64
- func (*ColumnResponse) ProtoMessage()
- func (m *ColumnResponse) Reset()
- func (m *ColumnResponse) String() string
- func (m *ColumnResponse) XXX_DiscardUnknown()
- func (m *ColumnResponse) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)
- func (m *ColumnResponse) XXX_Merge(src proto.Message)
- func (*ColumnResponse) XXX_OneofWrappers() []interface{}
- func (m *ColumnResponse) XXX_Size() int
- func (m *ColumnResponse) XXX_Unmarshal(b []byte) error
- type ColumnResponse_BlobVal
- type ColumnResponse_BoolVal
- type ColumnResponse_DecimalVal
- type ColumnResponse_Float64Val
- type ColumnResponse_Int64Val
- type ColumnResponse_StringArrayVal
- type ColumnResponse_StringVal
- type ColumnResponse_Uint64ArrayVal
- type ColumnResponse_Uint64Val
- type ConstRowser
- type CreateIndexRequest
- func (*CreateIndexRequest) Descriptor() ([]byte, []int)
- func (m *CreateIndexRequest) GetKeys() bool
- func (m *CreateIndexRequest) GetName() string
- func (*CreateIndexRequest) ProtoMessage()
- func (m *CreateIndexRequest) Reset()
- func (m *CreateIndexRequest) String() string
- func (m *CreateIndexRequest) XXX_DiscardUnknown()
- func (m *CreateIndexRequest) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)
- func (m *CreateIndexRequest) XXX_Merge(src proto.Message)
- func (m *CreateIndexRequest) XXX_Size() int
- func (m *CreateIndexRequest) XXX_Unmarshal(b []byte) error
- type CreateIndexResponse
- func (*CreateIndexResponse) Descriptor() ([]byte, []int)
- func (*CreateIndexResponse) ProtoMessage()
- func (m *CreateIndexResponse) Reset()
- func (m *CreateIndexResponse) String() string
- func (m *CreateIndexResponse) XXX_DiscardUnknown()
- func (m *CreateIndexResponse) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)
- func (m *CreateIndexResponse) XXX_Merge(src proto.Message)
- func (m *CreateIndexResponse) XXX_Size() int
- func (m *CreateIndexResponse) XXX_Unmarshal(b []byte) error
- type Decimal
- func (*Decimal) Descriptor() ([]byte, []int)
- func (m *Decimal) GetScale() int64
- func (m *Decimal) GetValue() int64
- func (*Decimal) ProtoMessage()
- func (m *Decimal) Reset()
- func (m *Decimal) String() string
- func (m *Decimal) XXX_DiscardUnknown()
- func (m *Decimal) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)
- func (m *Decimal) XXX_Merge(src proto.Message)
- func (m *Decimal) XXX_Size() int
- func (m *Decimal) XXX_Unmarshal(b []byte) error
- type DeleteIndexRequest
- func (*DeleteIndexRequest) Descriptor() ([]byte, []int)
- func (m *DeleteIndexRequest) GetName() string
- func (*DeleteIndexRequest) ProtoMessage()
- func (m *DeleteIndexRequest) Reset()
- func (m *DeleteIndexRequest) String() string
- func (m *DeleteIndexRequest) XXX_DiscardUnknown()
- func (m *DeleteIndexRequest) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)
- func (m *DeleteIndexRequest) XXX_Merge(src proto.Message)
- func (m *DeleteIndexRequest) XXX_Size() int
- func (m *DeleteIndexRequest) XXX_Unmarshal(b []byte) error
- type DeleteIndexResponse
- func (*DeleteIndexResponse) Descriptor() ([]byte, []int)
- func (*DeleteIndexResponse) ProtoMessage()
- func (m *DeleteIndexResponse) Reset()
- func (m *DeleteIndexResponse) String() string
- func (m *DeleteIndexResponse) XXX_DiscardUnknown()
- func (m *DeleteIndexResponse) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)
- func (m *DeleteIndexResponse) XXX_Merge(src proto.Message)
- func (m *DeleteIndexResponse) XXX_Size() int
- func (m *DeleteIndexResponse) XXX_Unmarshal(b []byte) error
- type EmptyStream
- type GetIndexRequest
- func (*GetIndexRequest) Descriptor() ([]byte, []int)
- func (m *GetIndexRequest) GetName() string
- func (*GetIndexRequest) ProtoMessage()
- func (m *GetIndexRequest) Reset()
- func (m *GetIndexRequest) String() string
- func (m *GetIndexRequest) XXX_DiscardUnknown()
- func (m *GetIndexRequest) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)
- func (m *GetIndexRequest) XXX_Merge(src proto.Message)
- func (m *GetIndexRequest) XXX_Size() int
- func (m *GetIndexRequest) XXX_Unmarshal(b []byte) error
- type GetIndexResponse
- func (*GetIndexResponse) Descriptor() ([]byte, []int)
- func (m *GetIndexResponse) GetIndex() *Index
- func (*GetIndexResponse) ProtoMessage()
- func (m *GetIndexResponse) Reset()
- func (m *GetIndexResponse) String() string
- func (m *GetIndexResponse) XXX_DiscardUnknown()
- func (m *GetIndexResponse) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)
- func (m *GetIndexResponse) XXX_Merge(src proto.Message)
- func (m *GetIndexResponse) XXX_Size() int
- func (m *GetIndexResponse) XXX_Unmarshal(b []byte) error
- type GetIndexesRequest
- func (*GetIndexesRequest) Descriptor() ([]byte, []int)
- func (*GetIndexesRequest) ProtoMessage()
- func (m *GetIndexesRequest) Reset()
- func (m *GetIndexesRequest) String() string
- func (m *GetIndexesRequest) XXX_DiscardUnknown()
- func (m *GetIndexesRequest) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)
- func (m *GetIndexesRequest) XXX_Merge(src proto.Message)
- func (m *GetIndexesRequest) XXX_Size() int
- func (m *GetIndexesRequest) XXX_Unmarshal(b []byte) error
- type GetIndexesResponse
- func (*GetIndexesResponse) Descriptor() ([]byte, []int)
- func (m *GetIndexesResponse) GetIndexes() []*Index
- func (*GetIndexesResponse) ProtoMessage()
- func (m *GetIndexesResponse) Reset()
- func (m *GetIndexesResponse) String() string
- func (m *GetIndexesResponse) XXX_DiscardUnknown()
- func (m *GetIndexesResponse) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)
- func (m *GetIndexesResponse) XXX_Merge(src proto.Message)
- func (m *GetIndexesResponse) XXX_Size() int
- func (m *GetIndexesResponse) XXX_Unmarshal(b []byte) error
- type IdsOrKeys
- func (*IdsOrKeys) Descriptor() ([]byte, []int)
- func (m *IdsOrKeys) GetIds() *Uint64Array
- func (m *IdsOrKeys) GetKeys() *StringArray
- func (m *IdsOrKeys) GetType() isIdsOrKeys_Type
- func (*IdsOrKeys) ProtoMessage()
- func (m *IdsOrKeys) Reset()
- func (m *IdsOrKeys) String() string
- func (m *IdsOrKeys) XXX_DiscardUnknown()
- func (m *IdsOrKeys) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)
- func (m *IdsOrKeys) XXX_Merge(src proto.Message)
- func (*IdsOrKeys) XXX_OneofWrappers() []interface{}
- func (m *IdsOrKeys) XXX_Size() int
- func (m *IdsOrKeys) XXX_Unmarshal(b []byte) error
- type IdsOrKeys_Ids
- type IdsOrKeys_Keys
- type Index
- func (*Index) Descriptor() ([]byte, []int)
- func (m *Index) GetName() string
- func (*Index) ProtoMessage()
- func (m *Index) Reset()
- func (m *Index) String() string
- func (m *Index) XXX_DiscardUnknown()
- func (m *Index) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)
- func (m *Index) XXX_Merge(src proto.Message)
- func (m *Index) XXX_Size() int
- func (m *Index) XXX_Unmarshal(b []byte) error
- type InspectRequest
- func (*InspectRequest) Descriptor() ([]byte, []int)
- func (m *InspectRequest) GetColumns() *IdsOrKeys
- func (m *InspectRequest) GetFilterFields() []string
- func (m *InspectRequest) GetIndex() string
- func (m *InspectRequest) GetLimit() uint64
- func (m *InspectRequest) GetOffset() uint64
- func (m *InspectRequest) GetQuery() string
- func (*InspectRequest) ProtoMessage()
- func (m *InspectRequest) Reset()
- func (m *InspectRequest) String() string
- func (m *InspectRequest) XXX_DiscardUnknown()
- func (m *InspectRequest) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)
- func (m *InspectRequest) XXX_Merge(src proto.Message)
- func (m *InspectRequest) XXX_Size() int
- func (m *InspectRequest) XXX_Unmarshal(b []byte) error
- type PilosaClient
- type PilosaServer
- type Pilosa_InspectClient
- type Pilosa_InspectServer
- type Pilosa_QueryPQLClient
- type Pilosa_QueryPQLServer
- type Pilosa_QuerySQLClient
- type Pilosa_QuerySQLServer
- type QueryPQLRequest
- func (*QueryPQLRequest) Descriptor() ([]byte, []int)
- func (m *QueryPQLRequest) GetIndex() string
- func (m *QueryPQLRequest) GetPql() string
- func (*QueryPQLRequest) ProtoMessage()
- func (m *QueryPQLRequest) Reset()
- func (m *QueryPQLRequest) String() string
- func (m *QueryPQLRequest) XXX_DiscardUnknown()
- func (m *QueryPQLRequest) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)
- func (m *QueryPQLRequest) XXX_Merge(src proto.Message)
- func (m *QueryPQLRequest) XXX_Size() int
- func (m *QueryPQLRequest) XXX_Unmarshal(b []byte) error
- type QuerySQLRequest
- func (*QuerySQLRequest) Descriptor() ([]byte, []int)
- func (m *QuerySQLRequest) GetSql() string
- func (*QuerySQLRequest) ProtoMessage()
- func (m *QuerySQLRequest) Reset()
- func (m *QuerySQLRequest) String() string
- func (m *QuerySQLRequest) XXX_DiscardUnknown()
- func (m *QuerySQLRequest) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)
- func (m *QuerySQLRequest) XXX_Merge(src proto.Message)
- func (m *QuerySQLRequest) XXX_Size() int
- func (m *QuerySQLRequest) XXX_Unmarshal(b []byte) error
- type Row
- func (*Row) Descriptor() ([]byte, []int)
- func (m *Row) GetColumns() []*ColumnResponse
- func (*Row) ProtoMessage()
- func (m *Row) Reset()
- func (m *Row) String() string
- func (m *Row) XXX_DiscardUnknown()
- func (m *Row) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)
- func (m *Row) XXX_Merge(src proto.Message)
- func (m *Row) XXX_Size() int
- func (m *Row) XXX_Unmarshal(b []byte) error
- type RowResponse
- func (*RowResponse) Descriptor() ([]byte, []int)
- func (m *RowResponse) GetColumns() []*ColumnResponse
- func (m *RowResponse) GetDuration() int64
- func (m *RowResponse) GetHeaders() []*ColumnInfo
- func (m *RowResponse) GetStatusError() *StatusError
- func (*RowResponse) ProtoMessage()
- func (m *RowResponse) Reset()
- func (m *RowResponse) String() string
- func (m *RowResponse) XXX_DiscardUnknown()
- func (m *RowResponse) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)
- func (m *RowResponse) XXX_Merge(src proto.Message)
- func (m *RowResponse) XXX_Size() int
- func (m *RowResponse) XXX_Unmarshal(b []byte) error
- type RowResponseSorter
- type StatusError
- func (*StatusError) Descriptor() ([]byte, []int)
- func (m *StatusError) GetCode() uint32
- func (m *StatusError) GetMessage() string
- func (*StatusError) ProtoMessage()
- func (m *StatusError) Reset()
- func (m *StatusError) String() string
- func (m *StatusError) XXX_DiscardUnknown()
- func (m *StatusError) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)
- func (m *StatusError) XXX_Merge(src proto.Message)
- func (m *StatusError) XXX_Size() int
- func (m *StatusError) XXX_Unmarshal(b []byte) error
- type StreamClient
- type StreamServer
- type StringArray
- func (*StringArray) Descriptor() ([]byte, []int)
- func (m *StringArray) GetVals() []string
- func (*StringArray) ProtoMessage()
- func (m *StringArray) Reset()
- func (m *StringArray) String() string
- func (m *StringArray) XXX_DiscardUnknown()
- func (m *StringArray) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)
- func (m *StringArray) XXX_Merge(src proto.Message)
- func (m *StringArray) XXX_Size() int
- func (m *StringArray) XXX_Unmarshal(b []byte) error
- type TableResponse
- func (*TableResponse) Descriptor() ([]byte, []int)
- func (m *TableResponse) GetDuration() int64
- func (m *TableResponse) GetHeaders() []*ColumnInfo
- func (m *TableResponse) GetRows() []*Row
- func (m *TableResponse) GetStatusError() *StatusError
- func (*TableResponse) ProtoMessage()
- func (m *TableResponse) Reset()
- func (m *TableResponse) String() string
- func (m *TableResponse) XXX_DiscardUnknown()
- func (m *TableResponse) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)
- func (m *TableResponse) XXX_Merge(src proto.Message)
- func (m *TableResponse) XXX_Size() int
- func (m *TableResponse) XXX_Unmarshal(b []byte) error
- type ToRowser
- type ToTabler
- type Uint64Array
- func (*Uint64Array) Descriptor() ([]byte, []int)
- func (m *Uint64Array) GetVals() []uint64
- func (*Uint64Array) ProtoMessage()
- func (m *Uint64Array) Reset()
- func (m *Uint64Array) String() string
- func (m *Uint64Array) XXX_DiscardUnknown()
- func (m *Uint64Array) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)
- func (m *Uint64Array) XXX_Merge(src proto.Message)
- func (m *Uint64Array) XXX_Size() int
- func (m *Uint64Array) XXX_Unmarshal(b []byte) error
- type UnimplementedPilosaServer
- func (*UnimplementedPilosaServer) CreateIndex(ctx context.Context, req *CreateIndexRequest) (*CreateIndexResponse, error)
- func (*UnimplementedPilosaServer) DeleteIndex(ctx context.Context, req *DeleteIndexRequest) (*DeleteIndexResponse, error)
- func (*UnimplementedPilosaServer) GetIndex(ctx context.Context, req *GetIndexRequest) (*GetIndexResponse, error)
- func (*UnimplementedPilosaServer) GetIndexes(ctx context.Context, req *GetIndexesRequest) (*GetIndexesResponse, error)
- func (*UnimplementedPilosaServer) Inspect(req *InspectRequest, srv Pilosa_InspectServer) error
- func (*UnimplementedPilosaServer) QueryPQL(req *QueryPQLRequest, srv Pilosa_QueryPQLServer) error
- func (*UnimplementedPilosaServer) QueryPQLUnary(ctx context.Context, req *QueryPQLRequest) (*TableResponse, error)
- func (*UnimplementedPilosaServer) QuerySQL(req *QuerySQLRequest, srv Pilosa_QuerySQLServer) error
- func (*UnimplementedPilosaServer) QuerySQLUnary(ctx context.Context, req *QuerySQLRequest) (*TableResponse, error)
Constants ¶
This section is empty.
Variables ¶
This section is empty.
Functions ¶
func RegisterPilosaServer ¶
func RegisterPilosaServer(s *grpc.Server, srv PilosaServer)
Types ¶
type ColumnInfo ¶
type ColumnInfo struct { Name string `protobuf:"bytes,1,opt,name=name,proto3" json:"name,omitempty"` Datatype string `protobuf:"bytes,2,opt,name=datatype,proto3" json:"datatype,omitempty"` XXX_NoUnkeyedLiteral struct{} `json:"-"` XXX_unrecognized []byte `json:"-"` XXX_sizecache int32 `json:"-"` }
func (*ColumnInfo) Descriptor ¶
func (*ColumnInfo) Descriptor() ([]byte, []int)
func (*ColumnInfo) GetDatatype ¶
func (m *ColumnInfo) GetDatatype() string
func (*ColumnInfo) GetName ¶
func (m *ColumnInfo) GetName() string
func (*ColumnInfo) ProtoMessage ¶
func (*ColumnInfo) ProtoMessage()
func (*ColumnInfo) Reset ¶
func (m *ColumnInfo) Reset()
func (*ColumnInfo) String ¶
func (m *ColumnInfo) String() string
func (*ColumnInfo) XXX_DiscardUnknown ¶
func (m *ColumnInfo) XXX_DiscardUnknown()
func (*ColumnInfo) XXX_Marshal ¶
func (m *ColumnInfo) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)
func (*ColumnInfo) XXX_Merge ¶
func (m *ColumnInfo) XXX_Merge(src proto.Message)
func (*ColumnInfo) XXX_Size ¶
func (m *ColumnInfo) XXX_Size() int
func (*ColumnInfo) XXX_Unmarshal ¶
func (m *ColumnInfo) XXX_Unmarshal(b []byte) error
type ColumnResponse ¶
type ColumnResponse struct { // Types that are valid to be assigned to ColumnVal: // *ColumnResponse_StringVal // *ColumnResponse_Uint64Val // *ColumnResponse_Int64Val // *ColumnResponse_BoolVal // *ColumnResponse_BlobVal // *ColumnResponse_Uint64ArrayVal // *ColumnResponse_StringArrayVal // *ColumnResponse_Float64Val // *ColumnResponse_DecimalVal ColumnVal isColumnResponse_ColumnVal `protobuf_oneof:"columnVal"` XXX_NoUnkeyedLiteral struct{} `json:"-"` XXX_unrecognized []byte `json:"-"` XXX_sizecache int32 `json:"-"` }
func (*ColumnResponse) Descriptor ¶
func (*ColumnResponse) Descriptor() ([]byte, []int)
func (*ColumnResponse) GetBlobVal ¶
func (m *ColumnResponse) GetBlobVal() []byte
func (*ColumnResponse) GetBoolVal ¶
func (m *ColumnResponse) GetBoolVal() bool
func (*ColumnResponse) GetColumnVal ¶
func (m *ColumnResponse) GetColumnVal() isColumnResponse_ColumnVal
func (*ColumnResponse) GetDecimalVal ¶
func (m *ColumnResponse) GetDecimalVal() *Decimal
func (*ColumnResponse) GetFloat64Val ¶
func (m *ColumnResponse) GetFloat64Val() float64
func (*ColumnResponse) GetInt64Val ¶
func (m *ColumnResponse) GetInt64Val() int64
func (*ColumnResponse) GetStringArrayVal ¶
func (m *ColumnResponse) GetStringArrayVal() *StringArray
func (*ColumnResponse) GetStringVal ¶
func (m *ColumnResponse) GetStringVal() string
func (*ColumnResponse) GetUint64ArrayVal ¶
func (m *ColumnResponse) GetUint64ArrayVal() *Uint64Array
func (*ColumnResponse) GetUint64Val ¶
func (m *ColumnResponse) GetUint64Val() uint64
func (*ColumnResponse) ProtoMessage ¶
func (*ColumnResponse) ProtoMessage()
func (*ColumnResponse) Reset ¶
func (m *ColumnResponse) Reset()
func (*ColumnResponse) String ¶
func (m *ColumnResponse) String() string
func (*ColumnResponse) XXX_DiscardUnknown ¶
func (m *ColumnResponse) XXX_DiscardUnknown()
func (*ColumnResponse) XXX_Marshal ¶
func (m *ColumnResponse) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)
func (*ColumnResponse) XXX_Merge ¶
func (m *ColumnResponse) XXX_Merge(src proto.Message)
func (*ColumnResponse) XXX_OneofWrappers ¶
func (*ColumnResponse) XXX_OneofWrappers() []interface{}
XXX_OneofWrappers is for the internal use of the proto package.
func (*ColumnResponse) XXX_Size ¶
func (m *ColumnResponse) XXX_Size() int
func (*ColumnResponse) XXX_Unmarshal ¶
func (m *ColumnResponse) XXX_Unmarshal(b []byte) error
type ColumnResponse_BlobVal ¶
type ColumnResponse_BlobVal struct {
BlobVal []byte `protobuf:"bytes,5,opt,name=blobVal,proto3,oneof"`
}
type ColumnResponse_BoolVal ¶
type ColumnResponse_BoolVal struct {
BoolVal bool `protobuf:"varint,4,opt,name=boolVal,proto3,oneof"`
}
type ColumnResponse_DecimalVal ¶
type ColumnResponse_DecimalVal struct {
DecimalVal *Decimal `protobuf:"bytes,9,opt,name=decimalVal,proto3,oneof"`
}
type ColumnResponse_Float64Val ¶
type ColumnResponse_Float64Val struct {
Float64Val float64 `protobuf:"fixed64,8,opt,name=float64Val,proto3,oneof"`
}
type ColumnResponse_Int64Val ¶
type ColumnResponse_Int64Val struct {
Int64Val int64 `protobuf:"varint,3,opt,name=int64Val,proto3,oneof"`
}
type ColumnResponse_StringArrayVal ¶
type ColumnResponse_StringArrayVal struct {
StringArrayVal *StringArray `protobuf:"bytes,7,opt,name=stringArrayVal,proto3,oneof"`
}
type ColumnResponse_StringVal ¶
type ColumnResponse_StringVal struct {
StringVal string `protobuf:"bytes,1,opt,name=stringVal,proto3,oneof"`
}
type ColumnResponse_Uint64ArrayVal ¶
type ColumnResponse_Uint64ArrayVal struct {
Uint64ArrayVal *Uint64Array `protobuf:"bytes,6,opt,name=uint64ArrayVal,proto3,oneof"`
}
type ColumnResponse_Uint64Val ¶
type ColumnResponse_Uint64Val struct {
Uint64Val uint64 `protobuf:"varint,2,opt,name=uint64Val,proto3,oneof"`
}
type ConstRowser ¶ added in v2.2.0
type ConstRowser []RowResponse
ConstRowser implements ToRowser with a slice of row responses.
func (ConstRowser) ToRows ¶ added in v2.2.0
func (c ConstRowser) ToRows(fn func(*RowResponse) error) error
ToRows calls a function with a pointer to each element of the slice.
type CreateIndexRequest ¶ added in v2.8.0
type CreateIndexRequest struct { Name string `protobuf:"bytes,1,opt,name=name,proto3" json:"name,omitempty"` Keys bool `protobuf:"varint,2,opt,name=keys,proto3" json:"keys,omitempty"` XXX_NoUnkeyedLiteral struct{} `json:"-"` XXX_unrecognized []byte `json:"-"` XXX_sizecache int32 `json:"-"` }
func (*CreateIndexRequest) Descriptor ¶ added in v2.8.0
func (*CreateIndexRequest) Descriptor() ([]byte, []int)
func (*CreateIndexRequest) GetKeys ¶ added in v2.8.0
func (m *CreateIndexRequest) GetKeys() bool
func (*CreateIndexRequest) GetName ¶ added in v2.8.0
func (m *CreateIndexRequest) GetName() string
func (*CreateIndexRequest) ProtoMessage ¶ added in v2.8.0
func (*CreateIndexRequest) ProtoMessage()
func (*CreateIndexRequest) Reset ¶ added in v2.8.0
func (m *CreateIndexRequest) Reset()
func (*CreateIndexRequest) String ¶ added in v2.8.0
func (m *CreateIndexRequest) String() string
func (*CreateIndexRequest) XXX_DiscardUnknown ¶ added in v2.8.0
func (m *CreateIndexRequest) XXX_DiscardUnknown()
func (*CreateIndexRequest) XXX_Marshal ¶ added in v2.8.0
func (m *CreateIndexRequest) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)
func (*CreateIndexRequest) XXX_Merge ¶ added in v2.8.0
func (m *CreateIndexRequest) XXX_Merge(src proto.Message)
func (*CreateIndexRequest) XXX_Size ¶ added in v2.8.0
func (m *CreateIndexRequest) XXX_Size() int
func (*CreateIndexRequest) XXX_Unmarshal ¶ added in v2.8.0
func (m *CreateIndexRequest) XXX_Unmarshal(b []byte) error
type CreateIndexResponse ¶ added in v2.8.0
type CreateIndexResponse struct { XXX_NoUnkeyedLiteral struct{} `json:"-"` XXX_unrecognized []byte `json:"-"` XXX_sizecache int32 `json:"-"` }
func (*CreateIndexResponse) Descriptor ¶ added in v2.8.0
func (*CreateIndexResponse) Descriptor() ([]byte, []int)
func (*CreateIndexResponse) ProtoMessage ¶ added in v2.8.0
func (*CreateIndexResponse) ProtoMessage()
func (*CreateIndexResponse) Reset ¶ added in v2.8.0
func (m *CreateIndexResponse) Reset()
func (*CreateIndexResponse) String ¶ added in v2.8.0
func (m *CreateIndexResponse) String() string
func (*CreateIndexResponse) XXX_DiscardUnknown ¶ added in v2.8.0
func (m *CreateIndexResponse) XXX_DiscardUnknown()
func (*CreateIndexResponse) XXX_Marshal ¶ added in v2.8.0
func (m *CreateIndexResponse) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)
func (*CreateIndexResponse) XXX_Merge ¶ added in v2.8.0
func (m *CreateIndexResponse) XXX_Merge(src proto.Message)
func (*CreateIndexResponse) XXX_Size ¶ added in v2.8.0
func (m *CreateIndexResponse) XXX_Size() int
func (*CreateIndexResponse) XXX_Unmarshal ¶ added in v2.8.0
func (m *CreateIndexResponse) XXX_Unmarshal(b []byte) error
type Decimal ¶
type Decimal struct { Value int64 `protobuf:"varint,1,opt,name=value,proto3" json:"value,omitempty"` Scale int64 `protobuf:"varint,2,opt,name=scale,proto3" json:"scale,omitempty"` XXX_NoUnkeyedLiteral struct{} `json:"-"` XXX_unrecognized []byte `json:"-"` XXX_sizecache int32 `json:"-"` }
func (*Decimal) Descriptor ¶
func (*Decimal) ProtoMessage ¶
func (*Decimal) ProtoMessage()
func (*Decimal) XXX_DiscardUnknown ¶
func (m *Decimal) XXX_DiscardUnknown()
func (*Decimal) XXX_Marshal ¶
func (*Decimal) XXX_Unmarshal ¶
type DeleteIndexRequest ¶ added in v2.8.0
type DeleteIndexRequest struct { Name string `protobuf:"bytes,1,opt,name=name,proto3" json:"name,omitempty"` XXX_NoUnkeyedLiteral struct{} `json:"-"` XXX_unrecognized []byte `json:"-"` XXX_sizecache int32 `json:"-"` }
func (*DeleteIndexRequest) Descriptor ¶ added in v2.8.0
func (*DeleteIndexRequest) Descriptor() ([]byte, []int)
func (*DeleteIndexRequest) GetName ¶ added in v2.8.0
func (m *DeleteIndexRequest) GetName() string
func (*DeleteIndexRequest) ProtoMessage ¶ added in v2.8.0
func (*DeleteIndexRequest) ProtoMessage()
func (*DeleteIndexRequest) Reset ¶ added in v2.8.0
func (m *DeleteIndexRequest) Reset()
func (*DeleteIndexRequest) String ¶ added in v2.8.0
func (m *DeleteIndexRequest) String() string
func (*DeleteIndexRequest) XXX_DiscardUnknown ¶ added in v2.8.0
func (m *DeleteIndexRequest) XXX_DiscardUnknown()
func (*DeleteIndexRequest) XXX_Marshal ¶ added in v2.8.0
func (m *DeleteIndexRequest) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)
func (*DeleteIndexRequest) XXX_Merge ¶ added in v2.8.0
func (m *DeleteIndexRequest) XXX_Merge(src proto.Message)
func (*DeleteIndexRequest) XXX_Size ¶ added in v2.8.0
func (m *DeleteIndexRequest) XXX_Size() int
func (*DeleteIndexRequest) XXX_Unmarshal ¶ added in v2.8.0
func (m *DeleteIndexRequest) XXX_Unmarshal(b []byte) error
type DeleteIndexResponse ¶ added in v2.8.0
type DeleteIndexResponse struct { XXX_NoUnkeyedLiteral struct{} `json:"-"` XXX_unrecognized []byte `json:"-"` XXX_sizecache int32 `json:"-"` }
func (*DeleteIndexResponse) Descriptor ¶ added in v2.8.0
func (*DeleteIndexResponse) Descriptor() ([]byte, []int)
func (*DeleteIndexResponse) ProtoMessage ¶ added in v2.8.0
func (*DeleteIndexResponse) ProtoMessage()
func (*DeleteIndexResponse) Reset ¶ added in v2.8.0
func (m *DeleteIndexResponse) Reset()
func (*DeleteIndexResponse) String ¶ added in v2.8.0
func (m *DeleteIndexResponse) String() string
func (*DeleteIndexResponse) XXX_DiscardUnknown ¶ added in v2.8.0
func (m *DeleteIndexResponse) XXX_DiscardUnknown()
func (*DeleteIndexResponse) XXX_Marshal ¶ added in v2.8.0
func (m *DeleteIndexResponse) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)
func (*DeleteIndexResponse) XXX_Merge ¶ added in v2.8.0
func (m *DeleteIndexResponse) XXX_Merge(src proto.Message)
func (*DeleteIndexResponse) XXX_Size ¶ added in v2.8.0
func (m *DeleteIndexResponse) XXX_Size() int
func (*DeleteIndexResponse) XXX_Unmarshal ¶ added in v2.8.0
func (m *DeleteIndexResponse) XXX_Unmarshal(b []byte) error
type EmptyStream ¶ added in v2.2.0
type EmptyStream struct{}
EmptyStream implements StreamClient interface. It always returns empty RowResponse
func (EmptyStream) Recv ¶ added in v2.2.0
func (EmptyStream) Recv() (*RowResponse, error)
Recv returns io.EOF
type GetIndexRequest ¶ added in v2.8.0
type GetIndexRequest struct { Name string `protobuf:"bytes,1,opt,name=name,proto3" json:"name,omitempty"` XXX_NoUnkeyedLiteral struct{} `json:"-"` XXX_unrecognized []byte `json:"-"` XXX_sizecache int32 `json:"-"` }
func (*GetIndexRequest) Descriptor ¶ added in v2.8.0
func (*GetIndexRequest) Descriptor() ([]byte, []int)
func (*GetIndexRequest) GetName ¶ added in v2.8.0
func (m *GetIndexRequest) GetName() string
func (*GetIndexRequest) ProtoMessage ¶ added in v2.8.0
func (*GetIndexRequest) ProtoMessage()
func (*GetIndexRequest) Reset ¶ added in v2.8.0
func (m *GetIndexRequest) Reset()
func (*GetIndexRequest) String ¶ added in v2.8.0
func (m *GetIndexRequest) String() string
func (*GetIndexRequest) XXX_DiscardUnknown ¶ added in v2.8.0
func (m *GetIndexRequest) XXX_DiscardUnknown()
func (*GetIndexRequest) XXX_Marshal ¶ added in v2.8.0
func (m *GetIndexRequest) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)
func (*GetIndexRequest) XXX_Merge ¶ added in v2.8.0
func (m *GetIndexRequest) XXX_Merge(src proto.Message)
func (*GetIndexRequest) XXX_Size ¶ added in v2.8.0
func (m *GetIndexRequest) XXX_Size() int
func (*GetIndexRequest) XXX_Unmarshal ¶ added in v2.8.0
func (m *GetIndexRequest) XXX_Unmarshal(b []byte) error
type GetIndexResponse ¶ added in v2.8.0
type GetIndexResponse struct { Index *Index `protobuf:"bytes,1,opt,name=index,proto3" json:"index,omitempty"` XXX_NoUnkeyedLiteral struct{} `json:"-"` XXX_unrecognized []byte `json:"-"` XXX_sizecache int32 `json:"-"` }
func (*GetIndexResponse) Descriptor ¶ added in v2.8.0
func (*GetIndexResponse) Descriptor() ([]byte, []int)
func (*GetIndexResponse) GetIndex ¶ added in v2.8.0
func (m *GetIndexResponse) GetIndex() *Index
func (*GetIndexResponse) ProtoMessage ¶ added in v2.8.0
func (*GetIndexResponse) ProtoMessage()
func (*GetIndexResponse) Reset ¶ added in v2.8.0
func (m *GetIndexResponse) Reset()
func (*GetIndexResponse) String ¶ added in v2.8.0
func (m *GetIndexResponse) String() string
func (*GetIndexResponse) XXX_DiscardUnknown ¶ added in v2.8.0
func (m *GetIndexResponse) XXX_DiscardUnknown()
func (*GetIndexResponse) XXX_Marshal ¶ added in v2.8.0
func (m *GetIndexResponse) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)
func (*GetIndexResponse) XXX_Merge ¶ added in v2.8.0
func (m *GetIndexResponse) XXX_Merge(src proto.Message)
func (*GetIndexResponse) XXX_Size ¶ added in v2.8.0
func (m *GetIndexResponse) XXX_Size() int
func (*GetIndexResponse) XXX_Unmarshal ¶ added in v2.8.0
func (m *GetIndexResponse) XXX_Unmarshal(b []byte) error
type GetIndexesRequest ¶ added in v2.8.0
type GetIndexesRequest struct { XXX_NoUnkeyedLiteral struct{} `json:"-"` XXX_unrecognized []byte `json:"-"` XXX_sizecache int32 `json:"-"` }
func (*GetIndexesRequest) Descriptor ¶ added in v2.8.0
func (*GetIndexesRequest) Descriptor() ([]byte, []int)
func (*GetIndexesRequest) ProtoMessage ¶ added in v2.8.0
func (*GetIndexesRequest) ProtoMessage()
func (*GetIndexesRequest) Reset ¶ added in v2.8.0
func (m *GetIndexesRequest) Reset()
func (*GetIndexesRequest) String ¶ added in v2.8.0
func (m *GetIndexesRequest) String() string
func (*GetIndexesRequest) XXX_DiscardUnknown ¶ added in v2.8.0
func (m *GetIndexesRequest) XXX_DiscardUnknown()
func (*GetIndexesRequest) XXX_Marshal ¶ added in v2.8.0
func (m *GetIndexesRequest) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)
func (*GetIndexesRequest) XXX_Merge ¶ added in v2.8.0
func (m *GetIndexesRequest) XXX_Merge(src proto.Message)
func (*GetIndexesRequest) XXX_Size ¶ added in v2.8.0
func (m *GetIndexesRequest) XXX_Size() int
func (*GetIndexesRequest) XXX_Unmarshal ¶ added in v2.8.0
func (m *GetIndexesRequest) XXX_Unmarshal(b []byte) error
type GetIndexesResponse ¶ added in v2.8.0
type GetIndexesResponse struct { Indexes []*Index `protobuf:"bytes,1,rep,name=indexes,proto3" json:"indexes,omitempty"` XXX_NoUnkeyedLiteral struct{} `json:"-"` XXX_unrecognized []byte `json:"-"` XXX_sizecache int32 `json:"-"` }
func (*GetIndexesResponse) Descriptor ¶ added in v2.8.0
func (*GetIndexesResponse) Descriptor() ([]byte, []int)
func (*GetIndexesResponse) GetIndexes ¶ added in v2.8.0
func (m *GetIndexesResponse) GetIndexes() []*Index
func (*GetIndexesResponse) ProtoMessage ¶ added in v2.8.0
func (*GetIndexesResponse) ProtoMessage()
func (*GetIndexesResponse) Reset ¶ added in v2.8.0
func (m *GetIndexesResponse) Reset()
func (*GetIndexesResponse) String ¶ added in v2.8.0
func (m *GetIndexesResponse) String() string
func (*GetIndexesResponse) XXX_DiscardUnknown ¶ added in v2.8.0
func (m *GetIndexesResponse) XXX_DiscardUnknown()
func (*GetIndexesResponse) XXX_Marshal ¶ added in v2.8.0
func (m *GetIndexesResponse) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)
func (*GetIndexesResponse) XXX_Merge ¶ added in v2.8.0
func (m *GetIndexesResponse) XXX_Merge(src proto.Message)
func (*GetIndexesResponse) XXX_Size ¶ added in v2.8.0
func (m *GetIndexesResponse) XXX_Size() int
func (*GetIndexesResponse) XXX_Unmarshal ¶ added in v2.8.0
func (m *GetIndexesResponse) XXX_Unmarshal(b []byte) error
type IdsOrKeys ¶
type IdsOrKeys struct { // Types that are valid to be assigned to Type: // *IdsOrKeys_Ids // *IdsOrKeys_Keys Type isIdsOrKeys_Type `protobuf_oneof:"type"` XXX_NoUnkeyedLiteral struct{} `json:"-"` XXX_unrecognized []byte `json:"-"` XXX_sizecache int32 `json:"-"` }
func (*IdsOrKeys) Descriptor ¶
func (*IdsOrKeys) GetIds ¶
func (m *IdsOrKeys) GetIds() *Uint64Array
func (*IdsOrKeys) GetKeys ¶
func (m *IdsOrKeys) GetKeys() *StringArray
func (*IdsOrKeys) ProtoMessage ¶
func (*IdsOrKeys) ProtoMessage()
func (*IdsOrKeys) XXX_DiscardUnknown ¶
func (m *IdsOrKeys) XXX_DiscardUnknown()
func (*IdsOrKeys) XXX_Marshal ¶
func (*IdsOrKeys) XXX_OneofWrappers ¶
func (*IdsOrKeys) XXX_OneofWrappers() []interface{}
XXX_OneofWrappers is for the internal use of the proto package.
func (*IdsOrKeys) XXX_Unmarshal ¶
type IdsOrKeys_Ids ¶
type IdsOrKeys_Ids struct {
Ids *Uint64Array `protobuf:"bytes,1,opt,name=ids,proto3,oneof"`
}
type IdsOrKeys_Keys ¶
type IdsOrKeys_Keys struct {
Keys *StringArray `protobuf:"bytes,2,opt,name=keys,proto3,oneof"`
}
type Index ¶ added in v2.8.0
type Index struct { Name string `protobuf:"bytes,1,opt,name=name,proto3" json:"name,omitempty"` XXX_NoUnkeyedLiteral struct{} `json:"-"` XXX_unrecognized []byte `json:"-"` XXX_sizecache int32 `json:"-"` }
func (*Index) Descriptor ¶ added in v2.8.0
func (*Index) ProtoMessage ¶ added in v2.8.0
func (*Index) ProtoMessage()
func (*Index) XXX_DiscardUnknown ¶ added in v2.8.0
func (m *Index) XXX_DiscardUnknown()
func (*Index) XXX_Marshal ¶ added in v2.8.0
func (*Index) XXX_Unmarshal ¶ added in v2.8.0
type InspectRequest ¶
type InspectRequest struct { Index string `protobuf:"bytes,1,opt,name=index,proto3" json:"index,omitempty"` Columns *IdsOrKeys `protobuf:"bytes,2,opt,name=columns,proto3" json:"columns,omitempty"` FilterFields []string `protobuf:"bytes,3,rep,name=filterFields,proto3" json:"filterFields,omitempty"` Limit uint64 `protobuf:"varint,4,opt,name=limit,proto3" json:"limit,omitempty"` Offset uint64 `protobuf:"varint,5,opt,name=offset,proto3" json:"offset,omitempty"` Query string `protobuf:"bytes,6,opt,name=query,proto3" json:"query,omitempty"` XXX_NoUnkeyedLiteral struct{} `json:"-"` XXX_unrecognized []byte `json:"-"` XXX_sizecache int32 `json:"-"` }
func (*InspectRequest) Descriptor ¶
func (*InspectRequest) Descriptor() ([]byte, []int)
func (*InspectRequest) GetColumns ¶
func (m *InspectRequest) GetColumns() *IdsOrKeys
func (*InspectRequest) GetFilterFields ¶
func (m *InspectRequest) GetFilterFields() []string
func (*InspectRequest) GetIndex ¶
func (m *InspectRequest) GetIndex() string
func (*InspectRequest) GetLimit ¶
func (m *InspectRequest) GetLimit() uint64
func (*InspectRequest) GetOffset ¶
func (m *InspectRequest) GetOffset() uint64
func (*InspectRequest) GetQuery ¶ added in v2.2.0
func (m *InspectRequest) GetQuery() string
func (*InspectRequest) ProtoMessage ¶
func (*InspectRequest) ProtoMessage()
func (*InspectRequest) Reset ¶
func (m *InspectRequest) Reset()
func (*InspectRequest) String ¶
func (m *InspectRequest) String() string
func (*InspectRequest) XXX_DiscardUnknown ¶
func (m *InspectRequest) XXX_DiscardUnknown()
func (*InspectRequest) XXX_Marshal ¶
func (m *InspectRequest) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)
func (*InspectRequest) XXX_Merge ¶
func (m *InspectRequest) XXX_Merge(src proto.Message)
func (*InspectRequest) XXX_Size ¶
func (m *InspectRequest) XXX_Size() int
func (*InspectRequest) XXX_Unmarshal ¶
func (m *InspectRequest) XXX_Unmarshal(b []byte) error
type PilosaClient ¶
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) }
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.
func NewPilosaClient ¶
func NewPilosaClient(cc *grpc.ClientConn) PilosaClient
type PilosaServer ¶
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 }
PilosaServer is the server API for Pilosa service.
type Pilosa_InspectClient ¶
type Pilosa_InspectClient interface { Recv() (*RowResponse, error) grpc.ClientStream }
type Pilosa_InspectServer ¶
type Pilosa_InspectServer interface { Send(*RowResponse) error grpc.ServerStream }
type Pilosa_QueryPQLClient ¶
type Pilosa_QueryPQLClient interface { Recv() (*RowResponse, error) grpc.ClientStream }
type Pilosa_QueryPQLServer ¶
type Pilosa_QueryPQLServer interface { Send(*RowResponse) error grpc.ServerStream }
type Pilosa_QuerySQLClient ¶ added in v2.2.0
type Pilosa_QuerySQLClient interface { Recv() (*RowResponse, error) grpc.ClientStream }
type Pilosa_QuerySQLServer ¶ added in v2.2.0
type Pilosa_QuerySQLServer interface { Send(*RowResponse) error grpc.ServerStream }
type QueryPQLRequest ¶
type QueryPQLRequest struct { Index string `protobuf:"bytes,1,opt,name=index,proto3" json:"index,omitempty"` Pql string `protobuf:"bytes,2,opt,name=pql,proto3" json:"pql,omitempty"` XXX_NoUnkeyedLiteral struct{} `json:"-"` XXX_unrecognized []byte `json:"-"` XXX_sizecache int32 `json:"-"` }
func (*QueryPQLRequest) Descriptor ¶
func (*QueryPQLRequest) Descriptor() ([]byte, []int)
func (*QueryPQLRequest) GetIndex ¶
func (m *QueryPQLRequest) GetIndex() string
func (*QueryPQLRequest) GetPql ¶
func (m *QueryPQLRequest) GetPql() string
func (*QueryPQLRequest) ProtoMessage ¶
func (*QueryPQLRequest) ProtoMessage()
func (*QueryPQLRequest) Reset ¶
func (m *QueryPQLRequest) Reset()
func (*QueryPQLRequest) String ¶
func (m *QueryPQLRequest) String() string
func (*QueryPQLRequest) XXX_DiscardUnknown ¶
func (m *QueryPQLRequest) XXX_DiscardUnknown()
func (*QueryPQLRequest) XXX_Marshal ¶
func (m *QueryPQLRequest) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)
func (*QueryPQLRequest) XXX_Merge ¶
func (m *QueryPQLRequest) XXX_Merge(src proto.Message)
func (*QueryPQLRequest) XXX_Size ¶
func (m *QueryPQLRequest) XXX_Size() int
func (*QueryPQLRequest) XXX_Unmarshal ¶
func (m *QueryPQLRequest) XXX_Unmarshal(b []byte) error
type QuerySQLRequest ¶ added in v2.2.0
type QuerySQLRequest struct { Sql string `protobuf:"bytes,1,opt,name=sql,proto3" json:"sql,omitempty"` XXX_NoUnkeyedLiteral struct{} `json:"-"` XXX_unrecognized []byte `json:"-"` XXX_sizecache int32 `json:"-"` }
func (*QuerySQLRequest) Descriptor ¶ added in v2.2.0
func (*QuerySQLRequest) Descriptor() ([]byte, []int)
func (*QuerySQLRequest) GetSql ¶ added in v2.2.0
func (m *QuerySQLRequest) GetSql() string
func (*QuerySQLRequest) ProtoMessage ¶ added in v2.2.0
func (*QuerySQLRequest) ProtoMessage()
func (*QuerySQLRequest) Reset ¶ added in v2.2.0
func (m *QuerySQLRequest) Reset()
func (*QuerySQLRequest) String ¶ added in v2.2.0
func (m *QuerySQLRequest) String() string
func (*QuerySQLRequest) XXX_DiscardUnknown ¶ added in v2.2.0
func (m *QuerySQLRequest) XXX_DiscardUnknown()
func (*QuerySQLRequest) XXX_Marshal ¶ added in v2.2.0
func (m *QuerySQLRequest) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)
func (*QuerySQLRequest) XXX_Merge ¶ added in v2.2.0
func (m *QuerySQLRequest) XXX_Merge(src proto.Message)
func (*QuerySQLRequest) XXX_Size ¶ added in v2.2.0
func (m *QuerySQLRequest) XXX_Size() int
func (*QuerySQLRequest) XXX_Unmarshal ¶ added in v2.2.0
func (m *QuerySQLRequest) XXX_Unmarshal(b []byte) error
type Row ¶
type Row struct { Columns []*ColumnResponse `protobuf:"bytes,1,rep,name=columns,proto3" json:"columns,omitempty"` XXX_NoUnkeyedLiteral struct{} `json:"-"` XXX_unrecognized []byte `json:"-"` XXX_sizecache int32 `json:"-"` }
func (*Row) Descriptor ¶
func (*Row) GetColumns ¶
func (m *Row) GetColumns() []*ColumnResponse
func (*Row) ProtoMessage ¶
func (*Row) ProtoMessage()
func (*Row) XXX_DiscardUnknown ¶
func (m *Row) XXX_DiscardUnknown()
func (*Row) XXX_Unmarshal ¶
type RowResponse ¶
type RowResponse struct { Headers []*ColumnInfo `protobuf:"bytes,1,rep,name=headers,proto3" json:"headers,omitempty"` Columns []*ColumnResponse `protobuf:"bytes,2,rep,name=columns,proto3" json:"columns,omitempty"` StatusError *StatusError `protobuf:"bytes,3,opt,name=StatusError,proto3" json:"StatusError,omitempty"` Duration int64 `protobuf:"varint,4,opt,name=duration,proto3" json:"duration,omitempty"` XXX_NoUnkeyedLiteral struct{} `json:"-"` XXX_unrecognized []byte `json:"-"` XXX_sizecache int32 `json:"-"` }
func Error ¶
func Error(err error) *RowResponse
Error is a helper function to create a RowResponse based on an error message. If the error is a grpc Status, then the status code is passed through.
func ErrorCode ¶
func ErrorCode(err error, c codes.Code) *RowResponse
ErrorCode is a helper function to create a RowResponse based on a grpc status code and an error message.
func ErrorWrap ¶
func ErrorWrap(err error, message string) *RowResponse
ErrorWrap prepends a message to the existing status error message.
func ErrorWrapf ¶
func ErrorWrapf(err error, format string, args ...interface{}) *RowResponse
ErrorWrapf prepends a message to the existing status error message with the format specifier.
func (*RowResponse) Descriptor ¶
func (*RowResponse) Descriptor() ([]byte, []int)
func (*RowResponse) GetColumns ¶
func (m *RowResponse) GetColumns() []*ColumnResponse
func (*RowResponse) GetDuration ¶ added in v2.5.0
func (m *RowResponse) GetDuration() int64
func (*RowResponse) GetHeaders ¶
func (m *RowResponse) GetHeaders() []*ColumnInfo
func (*RowResponse) GetStatusError ¶
func (m *RowResponse) GetStatusError() *StatusError
func (*RowResponse) ProtoMessage ¶
func (*RowResponse) ProtoMessage()
func (*RowResponse) Reset ¶
func (m *RowResponse) Reset()
func (*RowResponse) String ¶
func (m *RowResponse) String() string
func (*RowResponse) XXX_DiscardUnknown ¶
func (m *RowResponse) XXX_DiscardUnknown()
func (*RowResponse) XXX_Marshal ¶
func (m *RowResponse) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)
func (*RowResponse) XXX_Merge ¶
func (m *RowResponse) XXX_Merge(src proto.Message)
func (*RowResponse) XXX_Size ¶
func (m *RowResponse) XXX_Size() int
func (*RowResponse) XXX_Unmarshal ¶
func (m *RowResponse) XXX_Unmarshal(b []byte) error
type RowResponseSorter ¶
type RowResponseSorter struct {
// contains filtered or unexported fields
}
RowResponseSorter implements the sort interface for a provided []RowResponse based on the column index, type, and sort direction.
func NewRowResponseSorter ¶
func NewRowResponseSorter(idxs []int, dirs []bool, typs []string, rrs []*RowResponse) (*RowResponseSorter, error)
NewRowResponseSorter return a new RowResponseSorter. It does input validation and returns an error if the inputs aren't compatible.
func (RowResponseSorter) Len ¶
func (r RowResponseSorter) Len() int
func (RowResponseSorter) Less ¶
func (r RowResponseSorter) Less(i, j int) bool
func (RowResponseSorter) Swap ¶
func (r RowResponseSorter) Swap(i, j int)
type StatusError ¶
type StatusError struct { Code uint32 `protobuf:"varint,1,opt,name=Code,proto3" json:"Code,omitempty"` Message string `protobuf:"bytes,2,opt,name=Message,proto3" json:"Message,omitempty"` XXX_NoUnkeyedLiteral struct{} `json:"-"` XXX_unrecognized []byte `json:"-"` XXX_sizecache int32 `json:"-"` }
func (*StatusError) Descriptor ¶
func (*StatusError) Descriptor() ([]byte, []int)
func (*StatusError) GetCode ¶
func (m *StatusError) GetCode() uint32
func (*StatusError) GetMessage ¶
func (m *StatusError) GetMessage() string
func (*StatusError) ProtoMessage ¶
func (*StatusError) ProtoMessage()
func (*StatusError) Reset ¶
func (m *StatusError) Reset()
func (*StatusError) String ¶
func (m *StatusError) String() string
func (*StatusError) XXX_DiscardUnknown ¶
func (m *StatusError) XXX_DiscardUnknown()
func (*StatusError) XXX_Marshal ¶
func (m *StatusError) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)
func (*StatusError) XXX_Merge ¶
func (m *StatusError) XXX_Merge(src proto.Message)
func (*StatusError) XXX_Size ¶
func (m *StatusError) XXX_Size() int
func (*StatusError) XXX_Unmarshal ¶
func (m *StatusError) XXX_Unmarshal(b []byte) error
type StreamClient ¶
type StreamClient interface {
Recv() (*RowResponse, error)
}
StreamClient is an interface for a stream which can return a RowResponse sent to a stream via Send().
type StreamServer ¶
type StreamServer interface {
Send(*RowResponse) error
}
StreamServer is an interface for a stream which can accept a RowResponse to be later returned by the stream via Recv().
type StringArray ¶
type StringArray struct { Vals []string `protobuf:"bytes,1,rep,name=vals,proto3" json:"vals,omitempty"` XXX_NoUnkeyedLiteral struct{} `json:"-"` XXX_unrecognized []byte `json:"-"` XXX_sizecache int32 `json:"-"` }
func (*StringArray) Descriptor ¶
func (*StringArray) Descriptor() ([]byte, []int)
func (*StringArray) GetVals ¶
func (m *StringArray) GetVals() []string
func (*StringArray) ProtoMessage ¶
func (*StringArray) ProtoMessage()
func (*StringArray) Reset ¶
func (m *StringArray) Reset()
func (*StringArray) String ¶
func (m *StringArray) String() string
func (*StringArray) XXX_DiscardUnknown ¶
func (m *StringArray) XXX_DiscardUnknown()
func (*StringArray) XXX_Marshal ¶
func (m *StringArray) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)
func (*StringArray) XXX_Merge ¶
func (m *StringArray) XXX_Merge(src proto.Message)
func (*StringArray) XXX_Size ¶
func (m *StringArray) XXX_Size() int
func (*StringArray) XXX_Unmarshal ¶
func (m *StringArray) XXX_Unmarshal(b []byte) error
type TableResponse ¶
type TableResponse struct { 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"` XXX_NoUnkeyedLiteral struct{} `json:"-"` XXX_unrecognized []byte `json:"-"` XXX_sizecache int32 `json:"-"` }
func RowsToTable ¶
func RowsToTable(tr ToRowser, n int) (*TableResponse, error)
RowsToTable is a helper function which takes a ToRowser, along with the number of rows, and returns a TableResponse. The number of rows is treated as a hint.
func (*TableResponse) Descriptor ¶
func (*TableResponse) Descriptor() ([]byte, []int)
func (*TableResponse) GetDuration ¶ added in v2.5.0
func (m *TableResponse) GetDuration() int64
func (*TableResponse) GetHeaders ¶
func (m *TableResponse) GetHeaders() []*ColumnInfo
func (*TableResponse) GetRows ¶
func (m *TableResponse) GetRows() []*Row
func (*TableResponse) GetStatusError ¶
func (m *TableResponse) GetStatusError() *StatusError
func (*TableResponse) ProtoMessage ¶
func (*TableResponse) ProtoMessage()
func (*TableResponse) Reset ¶
func (m *TableResponse) Reset()
func (*TableResponse) String ¶
func (m *TableResponse) String() string
func (*TableResponse) XXX_DiscardUnknown ¶
func (m *TableResponse) XXX_DiscardUnknown()
func (*TableResponse) XXX_Marshal ¶
func (m *TableResponse) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)
func (*TableResponse) XXX_Merge ¶
func (m *TableResponse) XXX_Merge(src proto.Message)
func (*TableResponse) XXX_Size ¶
func (m *TableResponse) XXX_Size() int
func (*TableResponse) XXX_Unmarshal ¶
func (m *TableResponse) XXX_Unmarshal(b []byte) error
type ToRowser ¶
type ToRowser interface {
ToRows(func(*RowResponse) error) error
}
ToRowser is an interface for any type that can represent itself as one or more RowResponses. ToRows takes a callback function which should be called for each row in the response.
type ToTabler ¶
type ToTabler interface {
ToTable() (*TableResponse, error)
}
ToTabler is an interface for any type that can represent itself as a TableResponse.
type Uint64Array ¶
type Uint64Array struct { Vals []uint64 `protobuf:"varint,1,rep,packed,name=vals,proto3" json:"vals,omitempty"` XXX_NoUnkeyedLiteral struct{} `json:"-"` XXX_unrecognized []byte `json:"-"` XXX_sizecache int32 `json:"-"` }
func (*Uint64Array) Descriptor ¶
func (*Uint64Array) Descriptor() ([]byte, []int)
func (*Uint64Array) GetVals ¶
func (m *Uint64Array) GetVals() []uint64
func (*Uint64Array) ProtoMessage ¶
func (*Uint64Array) ProtoMessage()
func (*Uint64Array) Reset ¶
func (m *Uint64Array) Reset()
func (*Uint64Array) String ¶
func (m *Uint64Array) String() string
func (*Uint64Array) XXX_DiscardUnknown ¶
func (m *Uint64Array) XXX_DiscardUnknown()
func (*Uint64Array) XXX_Marshal ¶
func (m *Uint64Array) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)
func (*Uint64Array) XXX_Merge ¶
func (m *Uint64Array) XXX_Merge(src proto.Message)
func (*Uint64Array) XXX_Size ¶
func (m *Uint64Array) XXX_Size() int
func (*Uint64Array) XXX_Unmarshal ¶
func (m *Uint64Array) XXX_Unmarshal(b []byte) error
type UnimplementedPilosaServer ¶
type UnimplementedPilosaServer struct { }
UnimplementedPilosaServer can be embedded to have forward compatible implementations.
func (*UnimplementedPilosaServer) CreateIndex ¶ added in v2.8.0
func (*UnimplementedPilosaServer) CreateIndex(ctx context.Context, req *CreateIndexRequest) (*CreateIndexResponse, error)
func (*UnimplementedPilosaServer) DeleteIndex ¶ added in v2.8.0
func (*UnimplementedPilosaServer) DeleteIndex(ctx context.Context, req *DeleteIndexRequest) (*DeleteIndexResponse, error)
func (*UnimplementedPilosaServer) GetIndex ¶ added in v2.8.0
func (*UnimplementedPilosaServer) GetIndex(ctx context.Context, req *GetIndexRequest) (*GetIndexResponse, error)
func (*UnimplementedPilosaServer) GetIndexes ¶ added in v2.8.0
func (*UnimplementedPilosaServer) GetIndexes(ctx context.Context, req *GetIndexesRequest) (*GetIndexesResponse, error)
func (*UnimplementedPilosaServer) Inspect ¶
func (*UnimplementedPilosaServer) Inspect(req *InspectRequest, srv Pilosa_InspectServer) error
func (*UnimplementedPilosaServer) QueryPQL ¶
func (*UnimplementedPilosaServer) QueryPQL(req *QueryPQLRequest, srv Pilosa_QueryPQLServer) error
func (*UnimplementedPilosaServer) QueryPQLUnary ¶
func (*UnimplementedPilosaServer) QueryPQLUnary(ctx context.Context, req *QueryPQLRequest) (*TableResponse, error)
func (*UnimplementedPilosaServer) QuerySQL ¶ added in v2.2.0
func (*UnimplementedPilosaServer) QuerySQL(req *QuerySQLRequest, srv Pilosa_QuerySQLServer) error
func (*UnimplementedPilosaServer) QuerySQLUnary ¶ added in v2.2.0
func (*UnimplementedPilosaServer) QuerySQLUnary(ctx context.Context, req *QuerySQLRequest) (*TableResponse, error)