scriptoriumadmin/featurebase
1
0
Fork 0
mirror of https://github.com/featurebasedb/featurebase.git synced 2026-10-10 21:07:53 +00:00
Code Issues Projects Releases Packages Wiki Activity Actions

Remove VDS references from pilosa proto file, begin porting VDSM service

Browse source
This commit is contained in:
Cody Soyland 2020-09-17 11:20:58 -05:00
parent 82cdffd309
commit c1e50ed909
6 changed files with 2200 additions and 650 deletions
Show stats Download patch file Download diff file Expand all files Collapse all files

1
Makefile
View file

@ -169,6 +169,7 @@ generate-pql: require-peg
# dunno if protoc-gen-gofast is actually needed here
generate-proto-grpc: require-protoc require-protoc-gen-gofast
protoc -I proto proto/pilosa.proto --go_out=plugins=grpc:proto
protoc -I proto proto/vdsm/vdsm.proto --go_out=plugins=grpc:proto
# `go generate` all needed packages
generate: generate-protoc generate-statik generate-stringer generate-pql

626
proto/pilosa.pb.go
View file

@ -24,349 +24,6 @@ var _ = math.Inf
// proto package needs to be updated.
const _ = proto.ProtoPackageIsVersion3 // please upgrade the proto package
type VDS 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 (m *VDS) Reset() { *m = VDS{} }
func (m *VDS) String() string { return proto.CompactTextString(m) }
func (*VDS) ProtoMessage() {}
func (*VDS) Descriptor() ([]byte, []int) {
return fileDescriptor_ef0691a44d1e275c, []int{0}
}
func (m *VDS) XXX_Unmarshal(b []byte) error {
return xxx_messageInfo_VDS.Unmarshal(m, b)
}
func (m *VDS) XXX_Marshal(b []byte, deterministic bool) ([]byte, error) {
return xxx_messageInfo_VDS.Marshal(b, m, deterministic)
}
func (m *VDS) XXX_Merge(src proto.Message) {
xxx_messageInfo_VDS.Merge(m, src)
}
func (m *VDS) XXX_Size() int {
return xxx_messageInfo_VDS.Size(m)
}
func (m *VDS) XXX_DiscardUnknown() {
xxx_messageInfo_VDS.DiscardUnknown(m)
}
var xxx_messageInfo_VDS proto.InternalMessageInfo
func (m *VDS) GetName() string {
if m != nil {
return m.Name
}
return ""
}
type GetVDSsRequest struct {
XXX_NoUnkeyedLiteral struct{} `json:"-"`
XXX_unrecognized []byte `json:"-"`
XXX_sizecache int32 `json:"-"`
}
func (m *GetVDSsRequest) Reset() { *m = GetVDSsRequest{} }
func (m *GetVDSsRequest) String() string { return proto.CompactTextString(m) }
func (*GetVDSsRequest) ProtoMessage() {}
func (*GetVDSsRequest) Descriptor() ([]byte, []int) {
return fileDescriptor_ef0691a44d1e275c, []int{1}
}
func (m *GetVDSsRequest) XXX_Unmarshal(b []byte) error {
return xxx_messageInfo_GetVDSsRequest.Unmarshal(m, b)
}
func (m *GetVDSsRequest) XXX_Marshal(b []byte, deterministic bool) ([]byte, error) {
return xxx_messageInfo_GetVDSsRequest.Marshal(b, m, deterministic)
}
func (m *GetVDSsRequest) XXX_Merge(src proto.Message) {
xxx_messageInfo_GetVDSsRequest.Merge(m, src)
}
func (m *GetVDSsRequest) XXX_Size() int {
return xxx_messageInfo_GetVDSsRequest.Size(m)
}
func (m *GetVDSsRequest) XXX_DiscardUnknown() {
xxx_messageInfo_GetVDSsRequest.DiscardUnknown(m)
}
var xxx_messageInfo_GetVDSsRequest proto.InternalMessageInfo
type GetVDSsResponse struct {
Vdss []*VDS `protobuf:"bytes,1,rep,name=vdss,proto3" json:"vdss,omitempty"`
XXX_NoUnkeyedLiteral struct{} `json:"-"`
XXX_unrecognized []byte `json:"-"`
XXX_sizecache int32 `json:"-"`
}
func (m *GetVDSsResponse) Reset() { *m = GetVDSsResponse{} }
func (m *GetVDSsResponse) String() string { return proto.CompactTextString(m) }
func (*GetVDSsResponse) ProtoMessage() {}
func (*GetVDSsResponse) Descriptor() ([]byte, []int) {
return fileDescriptor_ef0691a44d1e275c, []int{2}
}
func (m *GetVDSsResponse) XXX_Unmarshal(b []byte) error {
return xxx_messageInfo_GetVDSsResponse.Unmarshal(m, b)
}
func (m *GetVDSsResponse) XXX_Marshal(b []byte, deterministic bool) ([]byte, error) {
return xxx_messageInfo_GetVDSsResponse.Marshal(b, m, deterministic)
}
func (m *GetVDSsResponse) XXX_Merge(src proto.Message) {
xxx_messageInfo_GetVDSsResponse.Merge(m, src)
}
func (m *GetVDSsResponse) XXX_Size() int {
return xxx_messageInfo_GetVDSsResponse.Size(m)
}
func (m *GetVDSsResponse) XXX_DiscardUnknown() {
xxx_messageInfo_GetVDSsResponse.DiscardUnknown(m)
}
var xxx_messageInfo_GetVDSsResponse proto.InternalMessageInfo
func (m *GetVDSsResponse) GetVdss() []*VDS {
if m != nil {
return m.Vdss
}
return nil
}
type GetVDSRequest 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 (m *GetVDSRequest) Reset() { *m = GetVDSRequest{} }
func (m *GetVDSRequest) String() string { return proto.CompactTextString(m) }
func (*GetVDSRequest) ProtoMessage() {}
func (*GetVDSRequest) Descriptor() ([]byte, []int) {
return fileDescriptor_ef0691a44d1e275c, []int{3}
}
func (m *GetVDSRequest) XXX_Unmarshal(b []byte) error {
return xxx_messageInfo_GetVDSRequest.Unmarshal(m, b)
}
func (m *GetVDSRequest) XXX_Marshal(b []byte, deterministic bool) ([]byte, error) {
return xxx_messageInfo_GetVDSRequest.Marshal(b, m, deterministic)
}
func (m *GetVDSRequest) XXX_Merge(src proto.Message) {
xxx_messageInfo_GetVDSRequest.Merge(m, src)
}
func (m *GetVDSRequest) XXX_Size() int {
return xxx_messageInfo_GetVDSRequest.Size(m)
}
func (m *GetVDSRequest) XXX_DiscardUnknown() {
xxx_messageInfo_GetVDSRequest.DiscardUnknown(m)
}
var xxx_messageInfo_GetVDSRequest proto.InternalMessageInfo
func (m *GetVDSRequest) GetName() string {
if m != nil {
return m.Name
}
return ""
}
type GetVDSResponse struct {
Vds *VDS `protobuf:"bytes,1,opt,name=vds,proto3" json:"vds,omitempty"`
XXX_NoUnkeyedLiteral struct{} `json:"-"`
XXX_unrecognized []byte `json:"-"`
XXX_sizecache int32 `json:"-"`
}
func (m *GetVDSResponse) Reset() { *m = GetVDSResponse{} }
func (m *GetVDSResponse) String() string { return proto.CompactTextString(m) }
func (*GetVDSResponse) ProtoMessage() {}
func (*GetVDSResponse) Descriptor() ([]byte, []int) {
return fileDescriptor_ef0691a44d1e275c, []int{4}
}
func (m *GetVDSResponse) XXX_Unmarshal(b []byte) error {
return xxx_messageInfo_GetVDSResponse.Unmarshal(m, b)
}
func (m *GetVDSResponse) XXX_Marshal(b []byte, deterministic bool) ([]byte, error) {
return xxx_messageInfo_GetVDSResponse.Marshal(b, m, deterministic)
}
func (m *GetVDSResponse) XXX_Merge(src proto.Message) {
xxx_messageInfo_GetVDSResponse.Merge(m, src)
}
func (m *GetVDSResponse) XXX_Size() int {
return xxx_messageInfo_GetVDSResponse.Size(m)
}
func (m *GetVDSResponse) XXX_DiscardUnknown() {
xxx_messageInfo_GetVDSResponse.DiscardUnknown(m)
}
var xxx_messageInfo_GetVDSResponse proto.InternalMessageInfo
func (m *GetVDSResponse) GetVds() *VDS {
if m != nil {
return m.Vds
}
return nil
}
type PostVDSRequest 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"`
TrackExistence bool `protobuf:"varint,3,opt,name=trackExistence,proto3" json:"trackExistence,omitempty"`
XXX_NoUnkeyedLiteral struct{} `json:"-"`
XXX_unrecognized []byte `json:"-"`
XXX_sizecache int32 `json:"-"`
}
func (m *PostVDSRequest) Reset() { *m = PostVDSRequest{} }
func (m *PostVDSRequest) String() string { return proto.CompactTextString(m) }
func (*PostVDSRequest) ProtoMessage() {}
func (*PostVDSRequest) Descriptor() ([]byte, []int) {
return fileDescriptor_ef0691a44d1e275c, []int{5}
}
func (m *PostVDSRequest) XXX_Unmarshal(b []byte) error {
return xxx_messageInfo_PostVDSRequest.Unmarshal(m, b)
}
func (m *PostVDSRequest) XXX_Marshal(b []byte, deterministic bool) ([]byte, error) {
return xxx_messageInfo_PostVDSRequest.Marshal(b, m, deterministic)
}
func (m *PostVDSRequest) XXX_Merge(src proto.Message) {
xxx_messageInfo_PostVDSRequest.Merge(m, src)
}
func (m *PostVDSRequest) XXX_Size() int {
return xxx_messageInfo_PostVDSRequest.Size(m)
}
func (m *PostVDSRequest) XXX_DiscardUnknown() {
xxx_messageInfo_PostVDSRequest.DiscardUnknown(m)
}
var xxx_messageInfo_PostVDSRequest proto.InternalMessageInfo
func (m *PostVDSRequest) GetName() string {
if m != nil {
return m.Name
}
return ""
}
func (m *PostVDSRequest) GetKeys() bool {
if m != nil {
return m.Keys
}
return false
}
func (m *PostVDSRequest) GetTrackExistence() bool {
if m != nil {
return m.TrackExistence
}
return false
}
type PostVDSResponse struct {
XXX_NoUnkeyedLiteral struct{} `json:"-"`
XXX_unrecognized []byte `json:"-"`
XXX_sizecache int32 `json:"-"`
}
func (m *PostVDSResponse) Reset() { *m = PostVDSResponse{} }
func (m *PostVDSResponse) String() string { return proto.CompactTextString(m) }
func (*PostVDSResponse) ProtoMessage() {}
func (*PostVDSResponse) Descriptor() ([]byte, []int) {
return fileDescriptor_ef0691a44d1e275c, []int{6}
}
func (m *PostVDSResponse) XXX_Unmarshal(b []byte) error {
return xxx_messageInfo_PostVDSResponse.Unmarshal(m, b)
}
func (m *PostVDSResponse) XXX_Marshal(b []byte, deterministic bool) ([]byte, error) {
return xxx_messageInfo_PostVDSResponse.Marshal(b, m, deterministic)
}
func (m *PostVDSResponse) XXX_Merge(src proto.Message) {
xxx_messageInfo_PostVDSResponse.Merge(m, src)
}
func (m *PostVDSResponse) XXX_Size() int {
return xxx_messageInfo_PostVDSResponse.Size(m)
}
func (m *PostVDSResponse) XXX_DiscardUnknown() {
xxx_messageInfo_PostVDSResponse.DiscardUnknown(m)
}
var xxx_messageInfo_PostVDSResponse proto.InternalMessageInfo
type DeleteVDSRequest 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 (m *DeleteVDSRequest) Reset() { *m = DeleteVDSRequest{} }
func (m *DeleteVDSRequest) String() string { return proto.CompactTextString(m) }
func (*DeleteVDSRequest) ProtoMessage() {}
func (*DeleteVDSRequest) Descriptor() ([]byte, []int) {
return fileDescriptor_ef0691a44d1e275c, []int{7}
}
func (m *DeleteVDSRequest) XXX_Unmarshal(b []byte) error {
return xxx_messageInfo_DeleteVDSRequest.Unmarshal(m, b)
}
func (m *DeleteVDSRequest) XXX_Marshal(b []byte, deterministic bool) ([]byte, error) {
return xxx_messageInfo_DeleteVDSRequest.Marshal(b, m, deterministic)
}
func (m *DeleteVDSRequest) XXX_Merge(src proto.Message) {
xxx_messageInfo_DeleteVDSRequest.Merge(m, src)
}
func (m *DeleteVDSRequest) XXX_Size() int {
return xxx_messageInfo_DeleteVDSRequest.Size(m)
}
func (m *DeleteVDSRequest) XXX_DiscardUnknown() {
xxx_messageInfo_DeleteVDSRequest.DiscardUnknown(m)
}
var xxx_messageInfo_DeleteVDSRequest proto.InternalMessageInfo
func (m *DeleteVDSRequest) GetName() string {
if m != nil {
return m.Name
}
return ""
}
type DeleteVDSResponse struct {
XXX_NoUnkeyedLiteral struct{} `json:"-"`
XXX_unrecognized []byte `json:"-"`
XXX_sizecache int32 `json:"-"`
}
func (m *DeleteVDSResponse) Reset() { *m = DeleteVDSResponse{} }
func (m *DeleteVDSResponse) String() string { return proto.CompactTextString(m) }
func (*DeleteVDSResponse) ProtoMessage() {}
func (*DeleteVDSResponse) Descriptor() ([]byte, []int) {
return fileDescriptor_ef0691a44d1e275c, []int{8}
}
func (m *DeleteVDSResponse) XXX_Unmarshal(b []byte) error {
return xxx_messageInfo_DeleteVDSResponse.Unmarshal(m, b)
}
func (m *DeleteVDSResponse) XXX_Marshal(b []byte, deterministic bool) ([]byte, error) {
return xxx_messageInfo_DeleteVDSResponse.Marshal(b, m, deterministic)
}
func (m *DeleteVDSResponse) XXX_Merge(src proto.Message) {
xxx_messageInfo_DeleteVDSResponse.Merge(m, src)
}
func (m *DeleteVDSResponse) XXX_Size() int {
return xxx_messageInfo_DeleteVDSResponse.Size(m)
}
func (m *DeleteVDSResponse) XXX_DiscardUnknown() {
xxx_messageInfo_DeleteVDSResponse.DiscardUnknown(m)
}
var xxx_messageInfo_DeleteVDSResponse proto.InternalMessageInfo
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"`
@ -379,7 +36,7 @@ func (m *QueryPQLRequest) Reset() { *m = QueryPQLRequest{} }
func (m *QueryPQLRequest) String() string { return proto.CompactTextString(m) }
func (*QueryPQLRequest) ProtoMessage() {}
func (*QueryPQLRequest) Descriptor() ([]byte, []int) {
return fileDescriptor_ef0691a44d1e275c, []int{9}
return fileDescriptor_ef0691a44d1e275c, []int{0}
}
func (m *QueryPQLRequest) XXX_Unmarshal(b []byte) error {
@ -425,7 +82,7 @@ func (m *QuerySQLRequest) Reset() { *m = QuerySQLRequest{} }
func (m *QuerySQLRequest) String() string { return proto.CompactTextString(m) }
func (*QuerySQLRequest) ProtoMessage() {}
func (*QuerySQLRequest) Descriptor() ([]byte, []int) {
return fileDescriptor_ef0691a44d1e275c, []int{10}
return fileDescriptor_ef0691a44d1e275c, []int{1}
}
func (m *QuerySQLRequest) XXX_Unmarshal(b []byte) error {
@ -465,7 +122,7 @@ func (m *StatusError) Reset() { *m = StatusError{} }
func (m *StatusError) String() string { return proto.CompactTextString(m) }
func (*StatusError) ProtoMessage() {}
func (*StatusError) Descriptor() ([]byte, []int) {
return fileDescriptor_ef0691a44d1e275c, []int{11}
return fileDescriptor_ef0691a44d1e275c, []int{2}
}
func (m *StatusError) XXX_Unmarshal(b []byte) error {
@ -513,7 +170,7 @@ func (m *RowResponse) Reset() { *m = RowResponse{} }
func (m *RowResponse) String() string { return proto.CompactTextString(m) }
func (*RowResponse) ProtoMessage() {}
func (*RowResponse) Descriptor() ([]byte, []int) {
return fileDescriptor_ef0691a44d1e275c, []int{12}
return fileDescriptor_ef0691a44d1e275c, []int{3}
}
func (m *RowResponse) XXX_Unmarshal(b []byte) error {
@ -566,7 +223,7 @@ func (m *Row) Reset() { *m = Row{} }
func (m *Row) String() string { return proto.CompactTextString(m) }
func (*Row) ProtoMessage() {}
func (*Row) Descriptor() ([]byte, []int) {
return fileDescriptor_ef0691a44d1e275c, []int{13}
return fileDescriptor_ef0691a44d1e275c, []int{4}
}
func (m *Row) XXX_Unmarshal(b []byte) error {
@ -607,7 +264,7 @@ func (m *TableResponse) Reset() { *m = TableResponse{} }
func (m *TableResponse) String() string { return proto.CompactTextString(m) }
func (*TableResponse) ProtoMessage() {}
func (*TableResponse) Descriptor() ([]byte, []int) {
return fileDescriptor_ef0691a44d1e275c, []int{14}
return fileDescriptor_ef0691a44d1e275c, []int{5}
}
func (m *TableResponse) XXX_Unmarshal(b []byte) error {
@ -661,7 +318,7 @@ func (m *ColumnInfo) Reset() { *m = ColumnInfo{} }
func (m *ColumnInfo) String() string { return proto.CompactTextString(m) }
func (*ColumnInfo) ProtoMessage() {}
func (*ColumnInfo) Descriptor() ([]byte, []int) {
return fileDescriptor_ef0691a44d1e275c, []int{15}
return fileDescriptor_ef0691a44d1e275c, []int{6}
}
func (m *ColumnInfo) XXX_Unmarshal(b []byte) error {
@ -717,7 +374,7 @@ func (m *ColumnResponse) Reset() { *m = ColumnResponse{} }
func (m *ColumnResponse) String() string { return proto.CompactTextString(m) }
func (*ColumnResponse) ProtoMessage() {}
func (*ColumnResponse) Descriptor() ([]byte, []int) {
return fileDescriptor_ef0691a44d1e275c, []int{16}
return fileDescriptor_ef0691a44d1e275c, []int{7}
}
func (m *ColumnResponse) XXX_Unmarshal(b []byte) error {
@ -893,7 +550,7 @@ func (m *Decimal) Reset() { *m = Decimal{} }
func (m *Decimal) String() string { return proto.CompactTextString(m) }
func (*Decimal) ProtoMessage() {}
func (*Decimal) Descriptor() ([]byte, []int) {
return fileDescriptor_ef0691a44d1e275c, []int{17}
return fileDescriptor_ef0691a44d1e275c, []int{8}
}
func (m *Decimal) XXX_Unmarshal(b []byte) error {
@ -944,7 +601,7 @@ func (m *InspectRequest) Reset() { *m = InspectRequest{} }
func (m *InspectRequest) String() string { return proto.CompactTextString(m) }
func (*InspectRequest) ProtoMessage() {}
func (*InspectRequest) Descriptor() ([]byte, []int) {
return fileDescriptor_ef0691a44d1e275c, []int{18}
return fileDescriptor_ef0691a44d1e275c, []int{9}
}
func (m *InspectRequest) XXX_Unmarshal(b []byte) error {
@ -1018,7 +675,7 @@ func (m *Uint64Array) Reset() { *m = Uint64Array{} }
func (m *Uint64Array) String() string { return proto.CompactTextString(m) }
func (*Uint64Array) ProtoMessage() {}
func (*Uint64Array) Descriptor() ([]byte, []int) {
return fileDescriptor_ef0691a44d1e275c, []int{19}
return fileDescriptor_ef0691a44d1e275c, []int{10}
}
func (m *Uint64Array) XXX_Unmarshal(b []byte) error {
@ -1057,7 +714,7 @@ func (m *StringArray) Reset() { *m = StringArray{} }
func (m *StringArray) String() string { return proto.CompactTextString(m) }
func (*StringArray) ProtoMessage() {}
func (*StringArray) Descriptor() ([]byte, []int) {
return fileDescriptor_ef0691a44d1e275c, []int{20}
return fileDescriptor_ef0691a44d1e275c, []int{11}
}
func (m *StringArray) XXX_Unmarshal(b []byte) error {
@ -1099,7 +756,7 @@ func (m *IdsOrKeys) Reset() { *m = IdsOrKeys{} }
func (m *IdsOrKeys) String() string { return proto.CompactTextString(m) }
func (*IdsOrKeys) ProtoMessage() {}
func (*IdsOrKeys) Descriptor() ([]byte, []int) {
return fileDescriptor_ef0691a44d1e275c, []int{21}
return fileDescriptor_ef0691a44d1e275c, []int{12}
}
func (m *IdsOrKeys) XXX_Unmarshal(b []byte) error {
@ -1166,15 +823,6 @@ func (*IdsOrKeys) XXX_OneofWrappers() []interface{} {
}
func init() {
proto.RegisterType((*VDS)(nil), "pilosa.VDS")
proto.RegisterType((*GetVDSsRequest)(nil), "pilosa.GetVDSsRequest")
proto.RegisterType((*GetVDSsResponse)(nil), "pilosa.GetVDSsResponse")
proto.RegisterType((*GetVDSRequest)(nil), "pilosa.GetVDSRequest")
proto.RegisterType((*GetVDSResponse)(nil), "pilosa.GetVDSResponse")
proto.RegisterType((*PostVDSRequest)(nil), "pilosa.PostVDSRequest")
proto.RegisterType((*PostVDSResponse)(nil), "pilosa.PostVDSResponse")
proto.RegisterType((*DeleteVDSRequest)(nil), "pilosa.DeleteVDSRequest")
proto.RegisterType((*DeleteVDSResponse)(nil), "pilosa.DeleteVDSResponse")
proto.RegisterType((*QueryPQLRequest)(nil), "pilosa.QueryPQLRequest")
proto.RegisterType((*QuerySQLRequest)(nil), "pilosa.QuerySQLRequest")
proto.RegisterType((*StatusError)(nil), "pilosa.StatusError")
@ -1193,64 +841,52 @@ func init() {
func init() { proto.RegisterFile("pilosa.proto", fileDescriptor_ef0691a44d1e275c) }
var fileDescriptor_ef0691a44d1e275c = []byte{
// 897 bytes of a gzipped FileDescriptorProto
0x1f, 0x8b, 0x08, 0x00, 0x00, 0x00, 0x00, 0x00, 0x02, 0xff, 0x9c, 0x56, 0xdd, 0x72, 0xdb, 0x44,
0x14, 0xb6, 0x90, 0x6a, 0x59, 0xc7, 0x89, 0x93, 0x6c, 0x20, 0xb8, 0x1e, 0xa0, 0x66, 0x3b, 0x53,
0xcc, 0xc0, 0x94, 0x12, 0x28, 0x4c, 0x21, 0x5c, 0x34, 0x75, 0xc1, 0x19, 0x60, 0x70, 0xd7, 0xd4,
0xd7, 0x6c, 0xac, 0x75, 0xd0, 0x54, 0xd1, 0x3a, 0x5a, 0x39, 0xa9, 0x5f, 0x80, 0x37, 0xe0, 0x0d,
0x78, 0x0b, 0xae, 0x78, 0x33, 0x66, 0x7f, 0x25, 0xb9, 0x31, 0x2d, 0xb9, 0xd3, 0x39, 0xdf, 0x77,
0xfe, 0xf6, 0xec, 0x9e, 0x23, 0xd8, 0x5a, 0x24, 0x29, 0x17, 0xf4, 0xfe, 0x22, 0xe7, 0x05, 0x47,
0x4d, 0x2d, 0xe1, 0xdb, 0xe0, 0x4f, 0x87, 0x13, 0x84, 0x20, 0xc8, 0xe8, 0x39, 0xeb, 0x7a, 0x7d,
0x6f, 0x10, 0x11, 0xf5, 0x8d, 0x77, 0xa1, 0xf3, 0x03, 0x2b, 0xa6, 0xc3, 0x89, 0x20, 0xec, 0x62,
0xc9, 0x44, 0x81, 0x0f, 0x61, 0xc7, 0x69, 0xc4, 0x82, 0x67, 0x82, 0xa1, 0x3b, 0x10, 0x5c, 0xc6,
0x42, 0x74, 0xbd, 0xbe, 0x3f, 0x68, 0x1f, 0xb6, 0xef, 0x9b, 0x20, 0xd3, 0xe1, 0x84, 0x28, 0x00,
0xdf, 0x85, 0x6d, 0x6d, 0x63, 0x9c, 0x5c, 0x1b, 0xea, 0x33, 0x1b, 0xca, 0xf9, 0x7d, 0x1f, 0xfc,
0xcb, 0x58, 0x28, 0xd2, 0x9a, 0x5b, 0xa9, 0xc7, 0xbf, 0x41, 0x67, 0xcc, 0xc5, 0x6b, 0xdc, 0x4a,
0xdd, 0x0b, 0xb6, 0x12, 0xdd, 0xb7, 0xfa, 0xde, 0xa0, 0x45, 0xd4, 0x37, 0xba, 0x07, 0x9d, 0x22,
0xa7, 0xb3, 0x17, 0x4f, 0x5f, 0x26, 0xa2, 0x60, 0xd9, 0x8c, 0x75, 0x7d, 0x85, 0xae, 0x69, 0xf1,
0x1e, 0xec, 0xb8, 0x08, 0x3a, 0x27, 0x7c, 0x0f, 0x76, 0x87, 0x2c, 0x65, 0x05, 0x7b, 0x4d, 0x35,
0xfb, 0xb0, 0x57, 0xe1, 0x19, 0xe3, 0x47, 0xb0, 0xf3, 0x6c, 0xc9, 0xf2, 0xd5, 0xf8, 0xd9, 0x4f,
0xd6, 0xf6, 0x6d, 0xb8, 0x95, 0x64, 0x31, 0x7b, 0x69, 0x8c, 0xb5, 0x80, 0x76, 0xc1, 0x5f, 0x5c,
0xa4, 0x2a, 0xe7, 0x88, 0xc8, 0x4f, 0x7c, 0xd7, 0x98, 0x4e, 0x4a, 0xd3, 0x5d, 0xf0, 0xc5, 0x45,
0x6a, 0x0c, 0xe5, 0x27, 0xfe, 0x16, 0xda, 0x93, 0x82, 0x16, 0x4b, 0xf1, 0x34, 0xcf, 0x79, 0x2e,
0xf3, 0x7a, 0xc2, 0x63, 0x9d, 0xd7, 0x36, 0x51, 0xdf, 0xa8, 0x0b, 0xe1, 0xcf, 0x4c, 0x08, 0x7a,
0xc6, 0x8c, 0x77, 0x2b, 0xe2, 0xbf, 0x3c, 0x68, 0x13, 0x7e, 0xe5, 0x4e, 0xff, 0x53, 0x08, 0x7f,
0x67, 0x34, 0x66, 0xb9, 0x6d, 0x2c, 0xb2, 0x1d, 0x78, 0xc2, 0xd3, 0xe5, 0x79, 0x76, 0x92, 0xcd,
0x39, 0xb1, 0x14, 0xf4, 0x00, 0xc2, 0x99, 0x52, 0xcb, 0x93, 0x96, 0xec, 0x83, 0x3a, 0xdb, 0xba,
0x25, 0x96, 0x86, 0x1e, 0xd6, 0x92, 0x55, 0x1d, 0x68, 0x1f, 0xee, 0x5b, 0xab, 0x0a, 0x44, 0xaa,
0x3c, 0xfc, 0x35, 0xf8, 0x84, 0x5f, 0x55, 0xe3, 0x79, 0x6f, 0x14, 0x0f, 0xff, 0xe9, 0xc1, 0xf6,
0xaf, 0xf4, 0x34, 0x65, 0x37, 0xac, 0xf0, 0x0e, 0x04, 0x39, 0xbf, 0xb2, 0xe5, 0xb9, 0xeb, 0x28,
0x8f, 0x4c, 0x01, 0x37, 0x2d, 0xe8, 0x08, 0xa0, 0x0c, 0x77, 0xed, 0x15, 0xee, 0x41, 0x2b, 0xa6,
0x05, 0x2d, 0x56, 0x0b, 0xdb, 0x34, 0x27, 0xe3, 0x3f, 0x7c, 0xe8, 0xd4, 0x2b, 0x46, 0x1f, 0x40,
0x24, 0x8a, 0x3c, 0xc9, 0xce, 0xa6, 0xd4, 0xdc, 0x8e, 0x51, 0x83, 0x94, 0x2a, 0x89, 0x2f, 0x93,
0xac, 0xf8, 0xea, 0x4b, 0x89, 0x4b, 0x7f, 0x81, 0xc4, 0x9d, 0x0a, 0xbd, 0x07, 0x2d, 0x07, 0xcb,
0x22, 0xfc, 0x51, 0x83, 0x38, 0x0d, 0xea, 0x41, 0x78, 0xca, 0x79, 0x2a, 0xc1, 0x40, 0x3e, 0x9a,
0x51, 0x83, 0x58, 0x85, 0xc2, 0x52, 0x7e, 0x2a, 0xb1, 0x5b, 0x7d, 0x6f, 0xb0, 0xa5, 0x30, 0xad,
0x40, 0xdf, 0x41, 0x47, 0x87, 0x78, 0x9c, 0xe7, 0x74, 0x25, 0x29, 0xcd, 0xfa, 0x01, 0x3d, 0x2f,
0xd1, 0x51, 0x83, 0xac, 0x91, 0xa5, 0xb9, 0xae, 0xc0, 0x99, 0x87, 0xeb, 0xe7, 0xeb, 0x50, 0x69,
0x5e, 0x27, 0xa3, 0x3e, 0xc0, 0x3c, 0xe5, 0xd4, 0x54, 0xd5, 0xea, 0x7b, 0x03, 0x6f, 0xd4, 0x20,
0x15, 0x1d, 0xfa, 0x1c, 0x20, 0x66, 0xb3, 0xe4, 0x9c, 0xaa, 0xd2, 0x22, 0xe5, 0x7c, 0xc7, 0x3a,
0x1f, 0x6a, 0x44, 0x9a, 0x94, 0xa4, 0xe3, 0x36, 0x44, 0xfa, 0x72, 0x4d, 0x69, 0x8a, 0x1f, 0x42,
0x68, 0x58, 0xf2, 0x4d, 0x5f, 0xd2, 0x74, 0xa9, 0x9b, 0xe8, 0x13, 0x2d, 0x48, 0xad, 0x98, 0xd1,
0x54, 0xb7, 0xd0, 0x27, 0x5a, 0xc0, 0x7f, 0x7b, 0xd0, 0x39, 0xc9, 0xc4, 0x82, 0xcd, 0x8a, 0xff,
0x1e, 0x09, 0x9f, 0x54, 0x1f, 0x98, 0x4c, 0x6e, 0xcf, 0x26, 0x77, 0x12, 0x8b, 0x5f, 0xf2, 0x1f,
0xd9, 0x4a, 0x94, 0x6f, 0x0b, 0xc3, 0xd6, 0x3c, 0x49, 0x0b, 0x96, 0x7f, 0x9f, 0xb0, 0x34, 0x16,
0x5d, 0xbf, 0xef, 0x0f, 0x22, 0x52, 0xd3, 0xc9, 0x30, 0x69, 0x72, 0x9e, 0x14, 0xaa, 0x8d, 0x01,
0xd1, 0x02, 0x3a, 0x80, 0x26, 0x9f, 0xcf, 0x05, 0x2b, 0x54, 0x07, 0x03, 0x62, 0x24, 0xc9, 0xbe,
0x90, 0xf3, 0x47, 0x75, 0x2d, 0x22, 0x5a, 0xc0, 0x1f, 0x42, 0xbb, 0xd2, 0x36, 0x79, 0x79, 0x2f,
0x69, 0xaa, 0x5f, 0x53, 0x40, 0xd4, 0xb7, 0xa4, 0x54, 0x5a, 0x53, 0xa3, 0x44, 0x86, 0x72, 0x06,
0x91, 0xab, 0x01, 0x7d, 0x04, 0x7e, 0xe2, 0x86, 0xfe, 0x86, 0xcb, 0x21, 0x19, 0xe8, 0xe3, 0xca,
0x60, 0xdf, 0x78, 0x0f, 0x14, 0xe5, 0xb8, 0x09, 0x81, 0x7c, 0x2c, 0x87, 0xff, 0x04, 0xd0, 0x1c,
0x2b, 0x1a, 0x3a, 0x82, 0xd0, 0xac, 0x31, 0xe4, 0x26, 0x47, 0x7d, 0xd3, 0xf5, 0xde, 0x7d, 0x45,
0x6f, 0xc6, 0x78, 0x03, 0x3d, 0x82, 0xa6, 0x56, 0xa2, 0x77, 0xea, 0x24, 0x6b, 0x7b, 0xb0, 0xae,
0x76, 0xa6, 0x47, 0x10, 0x9a, 0x9d, 0x52, 0x06, 0xae, 0xaf, 0xb1, 0x32, 0xf0, 0xfa, 0xf2, 0x69,
0xa0, 0x63, 0x88, 0xdc, 0x5a, 0x41, 0xdd, 0xf2, 0x7a, 0xd6, 0x37, 0x52, 0xef, 0xf6, 0x35, 0x48,
0x25, 0x83, 0x96, 0x5d, 0x25, 0xc8, 0x85, 0x5a, 0x5b, 0x2e, 0xbd, 0xfd, 0xea, 0x7c, 0x73, 0xb6,
0x0f, 0x3c, 0xf4, 0x18, 0xb6, 0x2d, 0xf7, 0x79, 0x46, 0xf3, 0xd5, 0x66, 0x17, 0xee, 0x68, 0x6a,
0x53, 0xb7, 0x92, 0xc0, 0xf8, 0x95, 0x04, 0xc6, 0xff, 0x23, 0x81, 0xf1, 0xf5, 0x09, 0x8c, 0xdf,
0x20, 0x81, 0x6f, 0x20, 0x34, 0x6f, 0xae, 0xec, 0x41, 0xfd, 0x11, 0x6e, 0x0c, 0x7f, 0xda, 0x54,
0xff, 0x4e, 0x5f, 0xfc, 0x1b, 0x00, 0x00, 0xff, 0xff, 0x1e, 0xff, 0x07, 0x47, 0x4b, 0x09, 0x00,
0x00,
// 718 bytes of a gzipped FileDescriptorProto
0x1f, 0x8b, 0x08, 0x00, 0x00, 0x00, 0x00, 0x00, 0x02, 0xff, 0x9c, 0x55, 0xdd, 0x52, 0xd3, 0x4e,
0x14, 0x6f, 0x48, 0x68, 0x9b, 0x53, 0xbe, 0xfe, 0xcb, 0x5f, 0xcc, 0x30, 0x8e, 0xc6, 0x78, 0x61,
0x1c, 0x1d, 0x06, 0x51, 0x74, 0x54, 0xbc, 0x00, 0xd4, 0x29, 0xa3, 0x8e, 0x65, 0x11, 0xee, 0xb7,
0xcd, 0x16, 0x33, 0x6e, 0xb3, 0x6d, 0x36, 0x05, 0xfb, 0x02, 0xbe, 0x81, 0x6f, 0xe0, 0x5b, 0x78,
0xef, 0x73, 0x39, 0xbb, 0x9b, 0x4d, 0x13, 0xb4, 0x0e, 0x72, 0xb7, 0xe7, 0xfc, 0x7e, 0xe7, 0x2b,
0xe7, 0x23, 0xb0, 0x30, 0x8c, 0x19, 0x17, 0x64, 0x63, 0x98, 0xf2, 0x8c, 0xa3, 0xba, 0x96, 0x82,
0x67, 0xb0, 0x7c, 0x38, 0xa6, 0xe9, 0xa4, 0x73, 0xf8, 0x0e, 0xd3, 0xd1, 0x98, 0x8a, 0x0c, 0xfd,
0x0f, 0xf3, 0x71, 0x12, 0xd1, 0x2f, 0x9e, 0xe5, 0x5b, 0xa1, 0x8b, 0xb5, 0x80, 0x56, 0xc0, 0x1e,
0x8e, 0x98, 0x37, 0xa7, 0x74, 0xf2, 0x19, 0xdc, 0xc9, 0x4d, 0x8f, 0xa6, 0xa6, 0x2b, 0x60, 0x8b,
0x11, 0xcb, 0x0d, 0xe5, 0x33, 0x78, 0x01, 0xad, 0xa3, 0x8c, 0x64, 0x63, 0xf1, 0x3a, 0x4d, 0x79,
0x8a, 0x10, 0x38, 0xfb, 0x3c, 0xa2, 0x8a, 0xb1, 0x88, 0xd5, 0x1b, 0x79, 0xd0, 0x78, 0x4f, 0x85,
0x20, 0xa7, 0x34, 0xf7, 0x6e, 0xc4, 0xe0, 0xbb, 0x05, 0x2d, 0xcc, 0xcf, 0x31, 0x15, 0x43, 0x9e,
0x08, 0x8a, 0x1e, 0x40, 0xe3, 0x13, 0x25, 0x11, 0x4d, 0x85, 0x67, 0xf9, 0x76, 0xd8, 0xda, 0x42,
0x1b, 0x79, 0x51, 0xfb, 0x9c, 0x8d, 0x07, 0xc9, 0x41, 0xd2, 0xe7, 0xd8, 0x50, 0xd0, 0x26, 0x34,
0x7a, 0x4a, 0x2d, 0xbc, 0x39, 0xc5, 0x5e, 0xab, 0xb2, 0x8d, 0x5b, 0x6c, 0x68, 0x68, 0xbb, 0x92,
0xac, 0x67, 0xfb, 0x56, 0xd8, 0xda, 0x5a, 0x35, 0x56, 0x25, 0x08, 0x97, 0x79, 0xc1, 0x53, 0xb0,
0x31, 0x3f, 0x2f, 0xc7, 0xb3, 0x2e, 0x15, 0x2f, 0xf8, 0x66, 0xc1, 0xe2, 0x47, 0xd2, 0x65, 0xf4,
0x8a, 0x15, 0xde, 0x02, 0x27, 0xe5, 0xe7, 0xa6, 0xbc, 0x96, 0xa1, 0xca, 0x4f, 0xa6, 0x80, 0xab,
0x16, 0xb4, 0x03, 0x30, 0x0d, 0x27, 0x7b, 0x96, 0x90, 0x01, 0xcd, 0xbb, 0xaa, 0xde, 0x68, 0x1d,
0x9a, 0x11, 0xc9, 0x48, 0x36, 0x19, 0x9a, 0xa6, 0x15, 0x72, 0xf0, 0xd5, 0x86, 0xa5, 0x6a, 0xc5,
0xe8, 0x26, 0xb8, 0x22, 0x4b, 0xe3, 0xe4, 0xf4, 0x84, 0xe4, 0xd3, 0xd1, 0xae, 0xe1, 0xa9, 0x4a,
0xe2, 0xe3, 0x38, 0xc9, 0x9e, 0x3c, 0x96, 0xb8, 0xf4, 0xe7, 0x48, 0xbc, 0x50, 0xa1, 0x1b, 0xd0,
0x2c, 0x60, 0x59, 0x84, 0xdd, 0xae, 0xe1, 0x42, 0x83, 0xd6, 0xa1, 0xd1, 0xe5, 0x9c, 0x49, 0xd0,
0xf1, 0xad, 0xb0, 0xd9, 0xae, 0x61, 0xa3, 0x50, 0x18, 0xe3, 0x5d, 0x89, 0xcd, 0xfb, 0x56, 0xb8,
0xa0, 0x30, 0xad, 0x40, 0x2f, 0x61, 0x49, 0x87, 0xd8, 0x4d, 0x53, 0x32, 0x91, 0x94, 0x7a, 0xf5,
0x03, 0x1d, 0x4f, 0xd1, 0x76, 0x0d, 0x5f, 0x20, 0x4b, 0x73, 0x5d, 0x41, 0x61, 0xde, 0xb8, 0xf8,
0x7d, 0x0b, 0x54, 0x9a, 0x57, 0xc9, 0xc8, 0x07, 0xe8, 0x33, 0x4e, 0xf2, 0xaa, 0x9a, 0xbe, 0x15,
0x5a, 0xed, 0x1a, 0x2e, 0xe9, 0xd0, 0x43, 0x80, 0x88, 0xf6, 0xe2, 0x01, 0x51, 0xa5, 0xb9, 0xca,
0xf9, 0xb2, 0x71, 0xfe, 0x4a, 0x23, 0xd2, 0x64, 0x4a, 0xda, 0x6b, 0x81, 0xab, 0x87, 0xeb, 0x84,
0xb0, 0x60, 0x1b, 0x1a, 0x39, 0x4b, 0xee, 0xf4, 0x19, 0x61, 0x63, 0xdd, 0x44, 0x1b, 0x6b, 0x41,
0x6a, 0x45, 0x8f, 0x30, 0xdd, 0x42, 0x1b, 0x6b, 0x21, 0xf8, 0x61, 0xc1, 0xd2, 0x41, 0x22, 0x86,
0xb4, 0x97, 0xfd, 0xfd, 0x24, 0xdc, 0x2f, 0x2f, 0x98, 0x4c, 0xee, 0x3f, 0x93, 0xdc, 0x41, 0x24,
0x3e, 0xa4, 0x6f, 0xe9, 0x44, 0x4c, 0x77, 0x2b, 0x80, 0x85, 0x7e, 0xcc, 0x32, 0x9a, 0xbe, 0x89,
0x29, 0x8b, 0x84, 0x67, 0xfb, 0x76, 0xe8, 0xe2, 0x8a, 0x4e, 0x86, 0x61, 0xf1, 0x20, 0xce, 0x54,
0x1b, 0x1d, 0xac, 0x05, 0xb4, 0x06, 0x75, 0xde, 0xef, 0x0b, 0x9a, 0xa9, 0x0e, 0x3a, 0x38, 0x97,
0x24, 0x7b, 0x24, 0xef, 0x8f, 0xea, 0x9a, 0x8b, 0xb5, 0x10, 0xdc, 0x86, 0x56, 0xa9, 0x6d, 0x72,
0x78, 0xcf, 0x08, 0xd3, 0xdb, 0xe4, 0x60, 0xf5, 0x96, 0x94, 0x52, 0x6b, 0x2a, 0x14, 0x37, 0xa7,
0x9c, 0x82, 0x5b, 0xd4, 0x80, 0xee, 0x82, 0x1d, 0x47, 0x42, 0xd5, 0x3e, 0x73, 0x38, 0x24, 0x03,
0xdd, 0x03, 0xe7, 0x33, 0x9d, 0x98, 0xaf, 0x31, 0x63, 0x0e, 0x14, 0x65, 0xaf, 0x0e, 0x8e, 0x5c,
0x96, 0xad, 0x9f, 0x73, 0x50, 0xef, 0x28, 0x1a, 0xda, 0x81, 0xa6, 0xb9, 0xa7, 0xe8, 0xba, 0xb1,
0xbd, 0x70, 0x61, 0xd7, 0x57, 0xcb, 0x4b, 0x9e, 0xaf, 0x57, 0x50, 0xdb, 0xb4, 0xd0, 0x2e, 0x2c,
0x1a, 0xee, 0x71, 0x42, 0xd2, 0xc9, 0x6c, 0x17, 0xd7, 0x0c, 0x50, 0x39, 0x3d, 0x41, 0xad, 0x48,
0xa0, 0xf3, 0x5b, 0x02, 0x9d, 0x7f, 0x48, 0xa0, 0xf3, 0xe7, 0x04, 0x3a, 0x97, 0x48, 0xe0, 0x39,
0x34, 0xf2, 0xc1, 0x43, 0xc5, 0xed, 0xac, 0x4e, 0xe2, 0xcc, 0xf0, 0xdd, 0xba, 0xfa, 0xaf, 0x3d,
0xfa, 0x15, 0x00, 0x00, 0xff, 0xff, 0x7e, 0x8d, 0x53, 0x0b, 0xe7, 0x06, 0x00, 0x00,
}
// Reference imports to suppress errors if they are not otherwise used.
@ -1265,10 +901,6 @@ const _ = grpc.SupportPackageIsVersion4
//
// 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 {
GetVDSs(ctx context.Context, in *GetVDSsRequest, opts ...grpc.CallOption) (*GetVDSsResponse, error)
GetVDS(ctx context.Context, in *GetVDSRequest, opts ...grpc.CallOption) (*GetVDSResponse, error)
PostVDS(ctx context.Context, in *PostVDSRequest, opts ...grpc.CallOption) (*PostVDSResponse, error)
DeleteVDS(ctx context.Context, in *DeleteVDSRequest, opts ...grpc.CallOption) (*DeleteVDSResponse, 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)
@ -1284,42 +916,6 @@ func NewPilosaClient(cc *grpc.ClientConn) PilosaClient {
return &pilosaClient{cc}
}
func (c *pilosaClient) GetVDSs(ctx context.Context, in *GetVDSsRequest, opts ...grpc.CallOption) (*GetVDSsResponse, error) {
out := new(GetVDSsResponse)
err := c.cc.Invoke(ctx, "/pilosa.Pilosa/GetVDSs", in, out, opts...)
if err != nil {
return nil, err
}
return out, nil
}
func (c *pilosaClient) GetVDS(ctx context.Context, in *GetVDSRequest, opts ...grpc.CallOption) (*GetVDSResponse, error) {
out := new(GetVDSResponse)
err := c.cc.Invoke(ctx, "/pilosa.Pilosa/GetVDS", in, out, opts...)
if err != nil {
return nil, err
}
return out, nil
}
func (c *pilosaClient) PostVDS(ctx context.Context, in *PostVDSRequest, opts ...grpc.CallOption) (*PostVDSResponse, error) {
out := new(PostVDSResponse)
err := c.cc.Invoke(ctx, "/pilosa.Pilosa/PostVDS", in, out, opts...)
if err != nil {
return nil, err
}
return out, nil
}
func (c *pilosaClient) DeleteVDS(ctx context.Context, in *DeleteVDSRequest, opts ...grpc.CallOption) (*DeleteVDSResponse, error) {
out := new(DeleteVDSResponse)
err := c.cc.Invoke(ctx, "/pilosa.Pilosa/DeleteVDS", 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], "/pilosa.Pilosa/QuerySQL", opts...)
if err != nil {
@ -1436,10 +1032,6 @@ func (x *pilosaInspectClient) Recv() (*RowResponse, error) {
// PilosaServer is the server API for Pilosa service.
type PilosaServer interface {
GetVDSs(context.Context, *GetVDSsRequest) (*GetVDSsResponse, error)
GetVDS(context.Context, *GetVDSRequest) (*GetVDSResponse, error)
PostVDS(context.Context, *PostVDSRequest) (*PostVDSResponse, error)
DeleteVDS(context.Context, *DeleteVDSRequest) (*DeleteVDSResponse, error)
QuerySQL(*QuerySQLRequest, Pilosa_QuerySQLServer) error
QuerySQLUnary(context.Context, *QuerySQLRequest) (*TableResponse, error)
QueryPQL(*QueryPQLRequest, Pilosa_QueryPQLServer) error
@ -1451,18 +1043,6 @@ type PilosaServer interface {
type UnimplementedPilosaServer struct {
}
func (*UnimplementedPilosaServer) GetVDSs(ctx context.Context, req *GetVDSsRequest) (*GetVDSsResponse, error) {
return nil, status.Errorf(codes.Unimplemented, "method GetVDSs not implemented")
}
func (*UnimplementedPilosaServer) GetVDS(ctx context.Context, req *GetVDSRequest) (*GetVDSResponse, error) {
return nil, status.Errorf(codes.Unimplemented, "method GetVDS not implemented")
}
func (*UnimplementedPilosaServer) PostVDS(ctx context.Context, req *PostVDSRequest) (*PostVDSResponse, error) {
return nil, status.Errorf(codes.Unimplemented, "method PostVDS not implemented")
}
func (*UnimplementedPilosaServer) DeleteVDS(ctx context.Context, req *DeleteVDSRequest) (*DeleteVDSResponse, error) {
return nil, status.Errorf(codes.Unimplemented, "method DeleteVDS not implemented")
}
func (*UnimplementedPilosaServer) QuerySQL(req *QuerySQLRequest, srv Pilosa_QuerySQLServer) error {
return status.Errorf(codes.Unimplemented, "method QuerySQL not implemented")
}
@ -1483,78 +1063,6 @@ func RegisterPilosaServer(s *grpc.Server, srv PilosaServer) {
s.RegisterService(&_Pilosa_serviceDesc, srv)
}
func _Pilosa_GetVDSs_Handler(srv interface{}, ctx context.Context, dec func(interface{}) error, interceptor grpc.UnaryServerInterceptor) (interface{}, error) {
in := new(GetVDSsRequest)
if err := dec(in); err != nil {
return nil, err
}
if interceptor == nil {
return srv.(PilosaServer).GetVDSs(ctx, in)
}
info := &grpc.UnaryServerInfo{
Server: srv,
FullMethod: "/pilosa.Pilosa/GetVDSs",
}
handler := func(ctx context.Context, req interface{}) (interface{}, error) {
return srv.(PilosaServer).GetVDSs(ctx, req.(*GetVDSsRequest))
}
return interceptor(ctx, in, info, handler)
}
func _Pilosa_GetVDS_Handler(srv interface{}, ctx context.Context, dec func(interface{}) error, interceptor grpc.UnaryServerInterceptor) (interface{}, error) {
in := new(GetVDSRequest)
if err := dec(in); err != nil {
return nil, err
}
if interceptor == nil {
return srv.(PilosaServer).GetVDS(ctx, in)
}
info := &grpc.UnaryServerInfo{
Server: srv,
FullMethod: "/pilosa.Pilosa/GetVDS",
}
handler := func(ctx context.Context, req interface{}) (interface{}, error) {
return srv.(PilosaServer).GetVDS(ctx, req.(*GetVDSRequest))
}
return interceptor(ctx, in, info, handler)
}
func _Pilosa_PostVDS_Handler(srv interface{}, ctx context.Context, dec func(interface{}) error, interceptor grpc.UnaryServerInterceptor) (interface{}, error) {
in := new(PostVDSRequest)
if err := dec(in); err != nil {
return nil, err
}
if interceptor == nil {
return srv.(PilosaServer).PostVDS(ctx, in)
}
info := &grpc.UnaryServerInfo{
Server: srv,
FullMethod: "/pilosa.Pilosa/PostVDS",
}
handler := func(ctx context.Context, req interface{}) (interface{}, error) {
return srv.(PilosaServer).PostVDS(ctx, req.(*PostVDSRequest))
}
return interceptor(ctx, in, info, handler)
}
func _Pilosa_DeleteVDS_Handler(srv interface{}, ctx context.Context, dec func(interface{}) error, interceptor grpc.UnaryServerInterceptor) (interface{}, error) {
in := new(DeleteVDSRequest)
if err := dec(in); err != nil {
return nil, err
}
if interceptor == nil {
return srv.(PilosaServer).DeleteVDS(ctx, in)
}
info := &grpc.UnaryServerInfo{
Server: srv,
FullMethod: "/pilosa.Pilosa/DeleteVDS",
}
handler := func(ctx context.Context, req interface{}) (interface{}, error) {
return srv.(PilosaServer).DeleteVDS(ctx, req.(*DeleteVDSRequest))
}
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 {
@ -1658,22 +1166,6 @@ var _Pilosa_serviceDesc = grpc.ServiceDesc{
ServiceName: "pilosa.Pilosa",
HandlerType: (*PilosaServer)(nil),
Methods: []grpc.MethodDesc{
{
MethodName: "GetVDSs",
Handler: _Pilosa_GetVDSs_Handler,
},
{
MethodName: "GetVDS",
Handler: _Pilosa_GetVDS_Handler,
},
{
MethodName: "PostVDS",
Handler: _Pilosa_PostVDS_Handler,
},
{
MethodName: "DeleteVDS",
Handler: _Pilosa_DeleteVDS_Handler,
},
{
MethodName: "QuerySQLUnary",
Handler: _Pilosa_QuerySQLUnary_Handler,

43
proto/pilosa.proto
View file

@ -1,42 +1,7 @@
syntax = "proto3";
package pilosa;
import "public.proto";
message VDS {
string name = 1;
}
message GetVDSsRequest {
}
message GetVDSsResponse {
repeated VDS vdss = 1;
}
message GetVDSRequest {
string name = 1;
}
message GetVDSResponse {
VDS vds = 1;
}
message PostVDSRequest {
string name = 1;
bool keys = 2;
bool trackExistence = 3;
}
message PostVDSResponse {
}
message DeleteVDSRequest {
string name = 1;
}
message DeleteVDSResponse {
}
//import "public.proto";
message QueryPQLRequest {
string index = 1;
@ -117,14 +82,10 @@ message IdsOrKeys {
}
service Pilosa {
rpc GetVDSs(GetVDSsRequest) returns (GetVDSsResponse) {};
rpc GetVDS(GetVDSRequest) returns (GetVDSResponse) {};
rpc PostVDS(PostVDSRequest) returns (PostVDSResponse) {};
rpc DeleteVDS(DeleteVDSRequest) returns (DeleteVDSResponse) {};
rpc QuerySQL(QuerySQLRequest) returns (stream RowResponse) {};
rpc QuerySQLUnary(QuerySQLRequest) returns (TableResponse) {};
rpc QueryPQL(QueryPQLRequest) returns (stream RowResponse) {};
rpc QueryPQLUnary(QueryPQLRequest) returns (TableResponse) {};
rpc Inspect(InspectRequest) returns (stream RowResponse) {};
rpc ImportAtomicRecord(stream AtomicRecord) returns (AtomicImportResponse) {};
//rpc ImportAtomicRecord(stream AtomicRecord) returns (AtomicImportResponse) {};
}

1902
proto/vdsm/vdsm.pb.go Normal file
View file

File diff suppressed because it is too large Load diff

146
proto/vdsm/vdsm.proto Normal file
View file

@ -0,0 +1,146 @@
syntax = "proto3";
package vdsm;
// deprecated
message DataSource {
int64 id = 1;
string name = 2;
string description = 3;
string type = 4;
map<string, string> config = 5;
string status = 6;
}
message VDS {
string id = 1;
string name = 2;
string description = 3;
string pilosa_index = 4;
repeated DataSource datasources = 5;
}
message GetVDSsRequest {
}
message GetVDSsResponse {
repeated VDS vdss = 1;
}
message GetVDSRequest {
oneof idOrName {
string id = 1;
string name = 2;
}
}
message GetVDSResponse {
VDS vds = 1;
}
message PostVDSRequest {
string definition = 1;
}
message PostVDSResponse {
string id = 1;
string uri = 2;
}
message DeleteVDSRequest {
oneof idOrName {
string id = 1;
string name = 2;
}
}
message DeleteVDSResponse {
}
message QueryPQLRequest {
string vds = 1;
string pql = 2;
}
message QuerySQLRequest {
string sql = 1;
}
message StatusError{
uint32 Code = 1;
string Message = 2;
}
message RowResponse{
repeated ColumnInfo headers = 1;
repeated ColumnResponse columns = 2;
StatusError StatusError = 3;
}
message Row {
repeated ColumnResponse columns = 1;
}
message TableResponse{
repeated ColumnInfo headers = 1;
repeated Row rows = 2;
}
message ColumnInfo {
string name = 1;
string datatype = 2;
}
message ColumnResponse{
oneof columnVal {
string stringVal = 1;
uint64 uint64Val = 2;
int64 int64Val = 3;
bool boolVal = 4;
bytes blobVal = 5;
Uint64Array uint64ArrayVal = 6;
StringArray stringArrayVal = 7;
double float64Val = 8;
Decimal decimalVal = 9;
}
}
message Decimal {
int64 value = 1;
int64 scale = 2;
}
message InspectRequest {
string vds = 1;
IdsOrKeys records = 2;
repeated string filterFields = 3;
uint64 limit = 4;
uint64 offset = 5;
string query = 6;
}
message Uint64Array {
repeated uint64 vals = 1;
}
message StringArray {
repeated string vals = 1;
}
message IdsOrKeys {
oneof type {
Uint64Array ids = 1;
StringArray keys = 2;
}
}
service Molecula {
rpc GetVDSs(GetVDSsRequest) returns (GetVDSsResponse) {};
rpc GetVDS(GetVDSRequest) returns (GetVDSResponse) {};
rpc PostVDS(PostVDSRequest) returns (PostVDSResponse) {};
rpc DeleteVDS(DeleteVDSRequest) returns (DeleteVDSResponse) {};
rpc QuerySQL(QuerySQLRequest) returns (stream RowResponse) {};
rpc QuerySQLUnary(QuerySQLRequest) returns (TableResponse) {};
rpc QueryPQL(QueryPQLRequest) returns (stream RowResponse) {};
rpc QueryPQLUnary(QueryPQLRequest) returns (TableResponse) {};
rpc Inspect(InspectRequest) returns (stream RowResponse) {};
}

132
server/grpc.go
View file

@ -26,6 +26,7 @@ import (
"github.com/pilosa/pilosa/v2"
"github.com/pilosa/pilosa/v2/logger"
pb "github.com/pilosa/pilosa/v2/proto"
vdsm_pb "github.com/pilosa/pilosa/v2/proto/vdsm"
"github.com/pilosa/pilosa/v2/stats"
"github.com/pkg/errors"
"google.golang.org/grpc"
@ -125,48 +126,6 @@ func errToStatusError(err error) error {
return status.Error(codes.Unknown, err.Error())
}
// GetVDSs returns a single VDS given a name
func (h *GRPCHandler) GetVDS(ctx context.Context, req *pb.GetVDSRequest) (*pb.GetVDSResponse, error) {
// TODO: Return all schema information associated with the VDS.
// It's obviously not very useful to return the same data as given.
schema := h.api.Schema(ctx)
for _, index := range schema {
if req.Name == index.Name {
return &pb.GetVDSResponse{Vds: &pb.VDS{Name: index.Name}}, nil
}
}
return nil, status.Error(codes.NotFound, fmt.Sprintf("VDS with name %s not found", req.Name))
}
// GetVDSs returns a list of all VDSs
func (h *GRPCHandler) GetVDSs(ctx context.Context, req *pb.GetVDSsRequest) (*pb.GetVDSsResponse, error) {
schema := h.api.Schema(ctx)
vdss := make([]*pb.VDS, len(schema))
for i, index := range schema {
vdss[i] = &pb.VDS{Name: index.Name}
}
return &pb.GetVDSsResponse{Vdss: vdss}, nil
}
// PostVDS creates a new VDS
func (h *GRPCHandler) PostVDS(ctx context.Context, req *pb.PostVDSRequest) (*pb.PostVDSResponse, error) {
opts := pilosa.IndexOptions{Keys: req.Keys, TrackExistence: req.TrackExistence}
_, err := h.api.CreateIndex(ctx, req.Name, opts)
if err != nil {
return nil, errToStatusError(err)
}
return &pb.PostVDSResponse{}, nil
}
// DeleteVDS deletes a VDS
func (h *GRPCHandler) DeleteVDS(ctx context.Context, req *pb.DeleteVDSRequest) (*pb.DeleteVDSResponse, error) {
err := h.api.DeleteIndex(ctx, req.Name)
if err != nil {
return nil, errToStatusError(err)
}
return &pb.DeleteVDSResponse{}, nil
}
func (h *GRPCHandler) execSQL(ctx context.Context, queryStr string) (pb.ToRowser, error) {
h.stats.Count(pilosa.MetricSqlQueries, 1, 1)
return execSQL(ctx, h.api, h.logger, queryStr)
@ -292,6 +251,94 @@ func (h *GRPCHandler) QueryPQLUnary(ctx context.Context, req *pb.QueryPQLRequest
return table, errToStatusError(nil)
}
// VDSMGRPCHandler contains methods which handle the various gRPC requests, ported from VDSM.
type VDSMGRPCHandler struct {
api *pilosa.API
logger logger.Logger
stats stats.StatsClient
}
func NewVDSMGRPCHandler(api *pilosa.API) *VDSMGRPCHandler {
return &VDSMGRPCHandler{api: api, logger: logger.NopLogger, stats: stats.NopStatsClient}
}
func (h *VDSMGRPCHandler) WithLogger(logger logger.Logger) *VDSMGRPCHandler {
h.logger = logger
return h
}
func (h *VDSMGRPCHandler) WithStats(stats stats.StatsClient) *VDSMGRPCHandler {
h.stats = stats
return h
}
// GetVDSs returns a single VDS given a name
func (h *VDSMGRPCHandler) GetVDS(ctx context.Context, req *vdsm_pb.GetVDSRequest) (*vdsm_pb.GetVDSResponse, error) {
typedIdOrName := req.GetIdOrName()
switch idOrName := typedIdOrName.(type) {
case *vdsm_pb.GetVDSRequest_Id:
return nil, status.Error(codes.InvalidArgument, "VDS IDs are no longer supported")
case *vdsm_pb.GetVDSRequest_Name:
schema := h.api.Schema(ctx)
for _, index := range schema {
if idOrName.Name == index.Name {
return &vdsm_pb.GetVDSResponse{Vds: &vdsm_pb.VDS{Name: index.Name}}, nil
}
}
return nil, status.Error(codes.NotFound, fmt.Sprintf("VDS with name %s not found", idOrName.Name))
default:
return nil, status.Error(codes.NotFound, "VDS not found")
}
}
// GetVDSs returns a list of all VDSs
func (h *VDSMGRPCHandler) GetVDSs(ctx context.Context, req *vdsm_pb.GetVDSsRequest) (*vdsm_pb.GetVDSsResponse, error) {
schema := h.api.Schema(ctx)
vdss := make([]*vdsm_pb.VDS, len(schema))
for i, index := range schema {
vdss[i] = &vdsm_pb.VDS{Name: index.Name}
}
return &vdsm_pb.GetVDSsResponse{Vdss: vdss}, nil
}
// PostVDS creates a new VDS
func (*VDSMGRPCHandler) PostVDS(ctx context.Context, req *vdsm_pb.PostVDSRequest) (*vdsm_pb.PostVDSResponse, error) {
return nil, status.Errorf(codes.Unimplemented, "method PostVDS not implemented")
}
// DeleteVDS deletes a VDS
func (h *VDSMGRPCHandler) DeleteVDS(ctx context.Context, req *vdsm_pb.DeleteVDSRequest) (*vdsm_pb.DeleteVDSResponse, error) {
typedIdOrName := req.GetIdOrName()
switch idOrName := typedIdOrName.(type) {
case *vdsm_pb.DeleteVDSRequest_Id:
return nil, status.Error(codes.InvalidArgument, "VDS IDs are no longer supported")
case *vdsm_pb.DeleteVDSRequest_Name:
err := h.api.DeleteIndex(ctx, idOrName.Name)
if err != nil {
return nil, errToStatusError(err)
}
return &vdsm_pb.DeleteVDSResponse{}, nil
default:
return nil, status.Error(codes.NotFound, "")
}
}
func (*VDSMGRPCHandler) QuerySQL(req *vdsm_pb.QuerySQLRequest, srv vdsm_pb.Molecula_QuerySQLServer) error {
return status.Errorf(codes.Unimplemented, "method QuerySQL not implemented")
}
func (*VDSMGRPCHandler) QuerySQLUnary(ctx context.Context, req *vdsm_pb.QuerySQLRequest) (*vdsm_pb.TableResponse, error) {
return nil, status.Errorf(codes.Unimplemented, "method QuerySQLUnary not implemented")
}
func (*VDSMGRPCHandler) QueryPQL(req *vdsm_pb.QueryPQLRequest, srv vdsm_pb.Molecula_QueryPQLServer) error {
return status.Errorf(codes.Unimplemented, "method QueryPQL not implemented")
}
func (*VDSMGRPCHandler) QueryPQLUnary(ctx context.Context, req *vdsm_pb.QueryPQLRequest) (*vdsm_pb.TableResponse, error) {
return nil, status.Errorf(codes.Unimplemented, "method QueryPQLUnary not implemented")
}
func (*VDSMGRPCHandler) Inspect(req *vdsm_pb.InspectRequest, srv vdsm_pb.Molecula_InspectServer) error {
return status.Errorf(codes.Unimplemented, "method Inspect not implemented")
}
// ResultUint64 is a wrapper around a uint64 result type
// so that we can implement the ToTabler and ToRowser
// interfaces.
@ -1145,6 +1192,7 @@ func (s *grpcServer) Serve(tlsConfig *tls.Config) error {
s.mu.Lock()
s.grpcServer = grpc.NewServer(opts...)
pb.RegisterPilosaServer(s.grpcServer, NewGRPCHandler(s.api).WithLogger(s.logger).WithStats(s.stats))
vdsm_pb.RegisterMoleculaServer(s.grpcServer, NewVDSMGRPCHandler(s.api).WithLogger(s.logger).WithStats(s.stats))
// register the server so its services are available to grpc_cli and others
reflection.Register(s.grpcServer)