vdsm

package
v2.9.0 Latest Latest
Warning

This package is not in the latest version of its module.

 Go to latest Published: Mar 4, 2021 License: Apache-2.0 Imports: 8 Imported by: 0

Documentation

Index

Constants

This section is empty.

Variables

This section is empty.

Functions

func RegisterMoleculaServer 

func RegisterMoleculaServer(s *grpc.Server, srv MoleculaServer)

Types

type DataSource 

type DataSource struct {
	Id                   int64             `protobuf:"varint,1,opt,name=id,proto3" json:"id,omitempty"`
	Name                 string            `protobuf:"bytes,2,opt,name=name,proto3" json:"name,omitempty"`
	Description          string            `protobuf:"bytes,3,opt,name=description,proto3" json:"description,omitempty"`
	Type                 string            `protobuf:"bytes,4,opt,name=type,proto3" json:"type,omitempty"`
	Config               map[string]string `` /* 153-byte string literal not displayed */
	Status               string            `protobuf:"bytes,6,opt,name=status,proto3" json:"status,omitempty"`
	XXX_NoUnkeyedLiteral struct{}          `json:"-"`
	XXX_unrecognized     []byte            `json:"-"`
	XXX_sizecache        int32             `json:"-"`
}

deprecated

func (*DataSource) Descriptor 

func (*DataSource) Descriptor() ([]byte, []int)

func (*DataSource) GetConfig 

func (m *DataSource) GetConfig() map[string]string

func (*DataSource) GetDescription 

func (m *DataSource) GetDescription() string

func (*DataSource) GetId 

func (m *DataSource) GetId() int64

func (*DataSource) GetName 

func (m *DataSource) GetName() string

func (*DataSource) GetStatus 

func (m *DataSource) GetStatus() string

func (*DataSource) GetType 

func (m *DataSource) GetType() string

func (*DataSource) ProtoMessage 

func (*DataSource) ProtoMessage()

func (*DataSource) Reset 

func (m *DataSource) Reset()

func (*DataSource) String 

func (m *DataSource) String() string

func (*DataSource) XXX_DiscardUnknown 

func (m *DataSource) XXX_DiscardUnknown()

func (*DataSource) XXX_Marshal 

func (m *DataSource) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)

func (*DataSource) XXX_Merge 

func (m *DataSource) XXX_Merge(src proto.Message)

func (*DataSource) XXX_Size 

func (m *DataSource) XXX_Size() int

func (*DataSource) XXX_Unmarshal 

func (m *DataSource) XXX_Unmarshal(b []byte) error

type DeleteVDSRequest 

type DeleteVDSRequest struct {
	// Types that are valid to be assigned to IdOrName:
	//	*DeleteVDSRequest_Id
	//	*DeleteVDSRequest_Name
	IdOrName             isDeleteVDSRequest_IdOrName `protobuf_oneof:"idOrName"`
	XXX_NoUnkeyedLiteral struct{}                    `json:"-"`
	XXX_unrecognized     []byte                      `json:"-"`
	XXX_sizecache        int32                       `json:"-"`
}

func (*DeleteVDSRequest) Descriptor 

func (*DeleteVDSRequest) Descriptor() ([]byte, []int)

func (*DeleteVDSRequest) GetId 

func (m *DeleteVDSRequest) GetId() string

func (*DeleteVDSRequest) GetIdOrName 

func (m *DeleteVDSRequest) GetIdOrName() isDeleteVDSRequest_IdOrName

func (*DeleteVDSRequest) GetName 

func (m *DeleteVDSRequest) GetName() string

func (*DeleteVDSRequest) ProtoMessage 

func (*DeleteVDSRequest) ProtoMessage()

func (*DeleteVDSRequest) Reset 

func (m *DeleteVDSRequest) Reset()

func (*DeleteVDSRequest) String 

func (m *DeleteVDSRequest) String() string

func (*DeleteVDSRequest) XXX_DiscardUnknown 

func (m *DeleteVDSRequest) XXX_DiscardUnknown()

func (*DeleteVDSRequest) XXX_Marshal 

func (m *DeleteVDSRequest) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)

func (*DeleteVDSRequest) XXX_Merge 

func (m *DeleteVDSRequest) XXX_Merge(src proto.Message)

func (*DeleteVDSRequest) XXX_OneofWrappers 

func (*DeleteVDSRequest) XXX_OneofWrappers() []interface{}

XXX_OneofWrappers is for the internal use of the proto package.

func (*DeleteVDSRequest) XXX_Size 

func (m *DeleteVDSRequest) XXX_Size() int

func (*DeleteVDSRequest) XXX_Unmarshal 

func (m *DeleteVDSRequest) XXX_Unmarshal(b []byte) error

type DeleteVDSRequest_Id 

type DeleteVDSRequest_Id struct {
	Id string `protobuf:"bytes,1,opt,name=id,proto3,oneof"`
}

type DeleteVDSRequest_Name 

type DeleteVDSRequest_Name struct {
	Name string `protobuf:"bytes,2,opt,name=name,proto3,oneof"`
}

type DeleteVDSResponse 

type DeleteVDSResponse struct {
	XXX_NoUnkeyedLiteral struct{} `json:"-"`
	XXX_unrecognized     []byte   `json:"-"`
	XXX_sizecache        int32    `json:"-"`
}

func (*DeleteVDSResponse) Descriptor 

func (*DeleteVDSResponse) Descriptor() ([]byte, []int)

func (*DeleteVDSResponse) ProtoMessage 

func (*DeleteVDSResponse) ProtoMessage()

func (*DeleteVDSResponse) Reset 

func (m *DeleteVDSResponse) Reset()

func (*DeleteVDSResponse) String 

func (m *DeleteVDSResponse) String() string

func (*DeleteVDSResponse) XXX_DiscardUnknown 

func (m *DeleteVDSResponse) XXX_DiscardUnknown()

func (*DeleteVDSResponse) XXX_Marshal 

func (m *DeleteVDSResponse) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)

func (*DeleteVDSResponse) XXX_Merge 

func (m *DeleteVDSResponse) XXX_Merge(src proto.Message)

func (*DeleteVDSResponse) XXX_Size 

func (m *DeleteVDSResponse) XXX_Size() int

func (*DeleteVDSResponse) XXX_Unmarshal 

func (m *DeleteVDSResponse) XXX_Unmarshal(b []byte) error

type GetVDSRequest 

type GetVDSRequest struct {
	// Types that are valid to be assigned to IdOrName:
	//	*GetVDSRequest_Id
	//	*GetVDSRequest_Name
	IdOrName             isGetVDSRequest_IdOrName `protobuf_oneof:"idOrName"`
	XXX_NoUnkeyedLiteral struct{}                 `json:"-"`
	XXX_unrecognized     []byte                   `json:"-"`
	XXX_sizecache        int32                    `json:"-"`
}

func (*GetVDSRequest) Descriptor 

func (*GetVDSRequest) Descriptor() ([]byte, []int)

func (*GetVDSRequest) GetId 

func (m *GetVDSRequest) GetId() string

func (*GetVDSRequest) GetIdOrName 

func (m *GetVDSRequest) GetIdOrName() isGetVDSRequest_IdOrName

func (*GetVDSRequest) GetName 

func (m *GetVDSRequest) GetName() string

func (*GetVDSRequest) ProtoMessage 

func (*GetVDSRequest) ProtoMessage()

func (*GetVDSRequest) Reset 

func (m *GetVDSRequest) Reset()

func (*GetVDSRequest) String 

func (m *GetVDSRequest) String() string

func (*GetVDSRequest) XXX_DiscardUnknown 

func (m *GetVDSRequest) XXX_DiscardUnknown()

func (*GetVDSRequest) XXX_Marshal 

func (m *GetVDSRequest) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)

func (*GetVDSRequest) XXX_Merge 

func (m *GetVDSRequest) XXX_Merge(src proto.Message)

func (*GetVDSRequest) XXX_OneofWrappers 

func (*GetVDSRequest) XXX_OneofWrappers() []interface{}

XXX_OneofWrappers is for the internal use of the proto package.

func (*GetVDSRequest) XXX_Size 

func (m *GetVDSRequest) XXX_Size() int

func (*GetVDSRequest) XXX_Unmarshal 

func (m *GetVDSRequest) XXX_Unmarshal(b []byte) error

type GetVDSRequest_Id 

type GetVDSRequest_Id struct {
	Id string `protobuf:"bytes,1,opt,name=id,proto3,oneof"`
}

type GetVDSRequest_Name 

type GetVDSRequest_Name struct {
	Name string `protobuf:"bytes,2,opt,name=name,proto3,oneof"`
}

type GetVDSResponse 

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 (*GetVDSResponse) Descriptor 

func (*GetVDSResponse) Descriptor() ([]byte, []int)

func (*GetVDSResponse) GetVds 

func (m *GetVDSResponse) GetVds() *VDS

func (*GetVDSResponse) ProtoMessage 

func (*GetVDSResponse) ProtoMessage()

func (*GetVDSResponse) Reset 

func (m *GetVDSResponse) Reset()

func (*GetVDSResponse) String 

func (m *GetVDSResponse) String() string

func (*GetVDSResponse) XXX_DiscardUnknown 

func (m *GetVDSResponse) XXX_DiscardUnknown()

func (*GetVDSResponse) XXX_Marshal 

func (m *GetVDSResponse) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)

func (*GetVDSResponse) XXX_Merge 

func (m *GetVDSResponse) XXX_Merge(src proto.Message)

func (*GetVDSResponse) XXX_Size 

func (m *GetVDSResponse) XXX_Size() int

func (*GetVDSResponse) XXX_Unmarshal 

func (m *GetVDSResponse) XXX_Unmarshal(b []byte) error

type GetVDSsRequest 

type GetVDSsRequest struct {
	XXX_NoUnkeyedLiteral struct{} `json:"-"`
	XXX_unrecognized     []byte   `json:"-"`
	XXX_sizecache        int32    `json:"-"`
}

func (*GetVDSsRequest) Descriptor 

func (*GetVDSsRequest) Descriptor() ([]byte, []int)

func (*GetVDSsRequest) ProtoMessage 

func (*GetVDSsRequest) ProtoMessage()

func (*GetVDSsRequest) Reset 

func (m *GetVDSsRequest) Reset()

func (*GetVDSsRequest) String 

func (m *GetVDSsRequest) String() string

func (*GetVDSsRequest) XXX_DiscardUnknown 

func (m *GetVDSsRequest) XXX_DiscardUnknown()

func (*GetVDSsRequest) XXX_Marshal 

func (m *GetVDSsRequest) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)

func (*GetVDSsRequest) XXX_Merge 

func (m *GetVDSsRequest) XXX_Merge(src proto.Message)

func (*GetVDSsRequest) XXX_Size 

func (m *GetVDSsRequest) XXX_Size() int

func (*GetVDSsRequest) XXX_Unmarshal 

func (m *GetVDSsRequest) XXX_Unmarshal(b []byte) error

type GetVDSsResponse 

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 (*GetVDSsResponse) Descriptor 

func (*GetVDSsResponse) Descriptor() ([]byte, []int)

func (*GetVDSsResponse) GetVdss 

func (m *GetVDSsResponse) GetVdss() []*VDS

func (*GetVDSsResponse) ProtoMessage 

func (*GetVDSsResponse) ProtoMessage()

func (*GetVDSsResponse) Reset 

func (m *GetVDSsResponse) Reset()

func (*GetVDSsResponse) String 

func (m *GetVDSsResponse) String() string

func (*GetVDSsResponse) XXX_DiscardUnknown 

func (m *GetVDSsResponse) XXX_DiscardUnknown()

func (*GetVDSsResponse) XXX_Marshal 

func (m *GetVDSsResponse) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)

func (*GetVDSsResponse) XXX_Merge 

func (m *GetVDSsResponse) XXX_Merge(src proto.Message)

func (*GetVDSsResponse) XXX_Size 

func (m *GetVDSsResponse) XXX_Size() int

func (*GetVDSsResponse) XXX_Unmarshal 

func (m *GetVDSsResponse) XXX_Unmarshal(b []byte) error

type InspectRequest 

type InspectRequest struct {
	Vds                  string            `protobuf:"bytes,1,opt,name=vds,proto3" json:"vds,omitempty"`
	Records              *proto1.IdsOrKeys `protobuf:"bytes,2,opt,name=records,proto3" json:"records,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:"-"`
}

copied from pilosa.proto to use "vds" instead of "index" and "records" instead of "columns"

func (*InspectRequest) Descriptor 

func (*InspectRequest) Descriptor() ([]byte, []int)

func (*InspectRequest) GetFilterFields 

func (m *InspectRequest) GetFilterFields() []string

func (*InspectRequest) GetLimit 

func (m *InspectRequest) GetLimit() uint64

func (*InspectRequest) GetOffset 

func (m *InspectRequest) GetOffset() uint64

func (*InspectRequest) GetQuery 

func (m *InspectRequest) GetQuery() string

func (*InspectRequest) GetRecords 

func (m *InspectRequest) GetRecords() *proto1.IdsOrKeys

func (*InspectRequest) GetVds 

func (m *InspectRequest) GetVds() 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 MoleculaClient 

type MoleculaClient 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 *proto1.QuerySQLRequest, opts ...grpc.CallOption) (Molecula_QuerySQLClient, error)
	QuerySQLUnary(ctx context.Context, in *proto1.QuerySQLRequest, opts ...grpc.CallOption) (*proto1.TableResponse, error)
	QueryPQL(ctx context.Context, in *QueryPQLRequest, opts ...grpc.CallOption) (Molecula_QueryPQLClient, error)
	QueryPQLUnary(ctx context.Context, in *QueryPQLRequest, opts ...grpc.CallOption) (*proto1.TableResponse, error)
	Inspect(ctx context.Context, in *InspectRequest, opts ...grpc.CallOption) (Molecula_InspectClient, error)
}

MoleculaClient is the client API for Molecula service.

For semantics around ctx use and closing/ending streaming RPCs, please refer to https://godoc.org/google.golang.org/grpc#ClientConn.NewStream.

func NewMoleculaClient 

func NewMoleculaClient(cc *grpc.ClientConn) MoleculaClient

type MoleculaServer 

type MoleculaServer 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(*proto1.QuerySQLRequest, Molecula_QuerySQLServer) error
	QuerySQLUnary(context.Context, *proto1.QuerySQLRequest) (*proto1.TableResponse, error)
	QueryPQL(*QueryPQLRequest, Molecula_QueryPQLServer) error
	QueryPQLUnary(context.Context, *QueryPQLRequest) (*proto1.TableResponse, error)
	Inspect(*InspectRequest, Molecula_InspectServer) error
}

MoleculaServer is the server API for Molecula service.

type Molecula_InspectClient 

type Molecula_InspectClient interface {
	Recv() (*proto1.RowResponse, error)
	grpc.ClientStream
}

type Molecula_InspectServer 

type Molecula_InspectServer interface {
	Send(*proto1.RowResponse) error
	grpc.ServerStream
}

type Molecula_QueryPQLClient 

type Molecula_QueryPQLClient interface {
	Recv() (*proto1.RowResponse, error)
	grpc.ClientStream
}

type Molecula_QueryPQLServer 

type Molecula_QueryPQLServer interface {
	Send(*proto1.RowResponse) error
	grpc.ServerStream
}

type Molecula_QuerySQLClient 

type Molecula_QuerySQLClient interface {
	Recv() (*proto1.RowResponse, error)
	grpc.ClientStream
}

type Molecula_QuerySQLServer 

type Molecula_QuerySQLServer interface {
	Send(*proto1.RowResponse) error
	grpc.ServerStream
}

type PostVDSRequest 

type PostVDSRequest struct {
	Definition           string   `protobuf:"bytes,1,opt,name=definition,proto3" json:"definition,omitempty"`
	XXX_NoUnkeyedLiteral struct{} `json:"-"`
	XXX_unrecognized     []byte   `json:"-"`
	XXX_sizecache        int32    `json:"-"`
}

func (*PostVDSRequest) Descriptor 

func (*PostVDSRequest) Descriptor() ([]byte, []int)

func (*PostVDSRequest) GetDefinition 

func (m *PostVDSRequest) GetDefinition() string

func (*PostVDSRequest) ProtoMessage 

func (*PostVDSRequest) ProtoMessage()

func (*PostVDSRequest) Reset 

func (m *PostVDSRequest) Reset()

func (*PostVDSRequest) String 

func (m *PostVDSRequest) String() string

func (*PostVDSRequest) XXX_DiscardUnknown 

func (m *PostVDSRequest) XXX_DiscardUnknown()

func (*PostVDSRequest) XXX_Marshal 

func (m *PostVDSRequest) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)

func (*PostVDSRequest) XXX_Merge 

func (m *PostVDSRequest) XXX_Merge(src proto.Message)

func (*PostVDSRequest) XXX_Size 

func (m *PostVDSRequest) XXX_Size() int

func (*PostVDSRequest) XXX_Unmarshal 

func (m *PostVDSRequest) XXX_Unmarshal(b []byte) error

type PostVDSResponse 

type PostVDSResponse struct {
	Id                   string   `protobuf:"bytes,1,opt,name=id,proto3" json:"id,omitempty"`
	Uri                  string   `protobuf:"bytes,2,opt,name=uri,proto3" json:"uri,omitempty"`
	XXX_NoUnkeyedLiteral struct{} `json:"-"`
	XXX_unrecognized     []byte   `json:"-"`
	XXX_sizecache        int32    `json:"-"`
}

func (*PostVDSResponse) Descriptor 

func (*PostVDSResponse) Descriptor() ([]byte, []int)

func (*PostVDSResponse) GetId 

func (m *PostVDSResponse) GetId() string

func (*PostVDSResponse) GetUri 

func (m *PostVDSResponse) GetUri() string

func (*PostVDSResponse) ProtoMessage 

func (*PostVDSResponse) ProtoMessage()

func (*PostVDSResponse) Reset 

func (m *PostVDSResponse) Reset()

func (*PostVDSResponse) String 

func (m *PostVDSResponse) String() string

func (*PostVDSResponse) XXX_DiscardUnknown 

func (m *PostVDSResponse) XXX_DiscardUnknown()

func (*PostVDSResponse) XXX_Marshal 

func (m *PostVDSResponse) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)

func (*PostVDSResponse) XXX_Merge 

func (m *PostVDSResponse) XXX_Merge(src proto.Message)

func (*PostVDSResponse) XXX_Size 

func (m *PostVDSResponse) XXX_Size() int

func (*PostVDSResponse) XXX_Unmarshal 

func (m *PostVDSResponse) XXX_Unmarshal(b []byte) error

type QueryPQLRequest 

type QueryPQLRequest struct {
	Vds                  string   `protobuf:"bytes,1,opt,name=vds,proto3" json:"vds,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:"-"`
}

copied from pilosa.proto to use "vds" instead of "index"

func (*QueryPQLRequest) Descriptor 

func (*QueryPQLRequest) Descriptor() ([]byte, []int)

func (*QueryPQLRequest) GetPql 

func (m *QueryPQLRequest) GetPql() string

func (*QueryPQLRequest) GetVds 

func (m *QueryPQLRequest) GetVds() 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 UnimplementedMoleculaServer 

type UnimplementedMoleculaServer struct {
}

UnimplementedMoleculaServer can be embedded to have forward compatible implementations.

func (*UnimplementedMoleculaServer) DeleteVDS 

func (*UnimplementedMoleculaServer) DeleteVDS(ctx context.Context, req *DeleteVDSRequest) (*DeleteVDSResponse, error)

func (*UnimplementedMoleculaServer) GetVDS 

func (*UnimplementedMoleculaServer) GetVDS(ctx context.Context, req *GetVDSRequest) (*GetVDSResponse, error)

func (*UnimplementedMoleculaServer) GetVDSs 

func (*UnimplementedMoleculaServer) GetVDSs(ctx context.Context, req *GetVDSsRequest) (*GetVDSsResponse, error)

func (*UnimplementedMoleculaServer) Inspect 

func (*UnimplementedMoleculaServer) Inspect(req *InspectRequest, srv Molecula_InspectServer) error

func (*UnimplementedMoleculaServer) PostVDS 

func (*UnimplementedMoleculaServer) PostVDS(ctx context.Context, req *PostVDSRequest) (*PostVDSResponse, error)

func (*UnimplementedMoleculaServer) QueryPQL 

func (*UnimplementedMoleculaServer) QueryPQL(req *QueryPQLRequest, srv Molecula_QueryPQLServer) error

func (*UnimplementedMoleculaServer) QueryPQLUnary 

func (*UnimplementedMoleculaServer) QueryPQLUnary(ctx context.Context, req *QueryPQLRequest) (*proto1.TableResponse, error)

func (*UnimplementedMoleculaServer) QuerySQL 

func (*UnimplementedMoleculaServer) QuerySQL(req *proto1.QuerySQLRequest, srv Molecula_QuerySQLServer) error

func (*UnimplementedMoleculaServer) QuerySQLUnary 

func (*UnimplementedMoleculaServer) QuerySQLUnary(ctx context.Context, req *proto1.QuerySQLRequest) (*proto1.TableResponse, error)

type VDS 

type VDS struct {
	Id                   string        `protobuf:"bytes,1,opt,name=id,proto3" json:"id,omitempty"`
	Name                 string        `protobuf:"bytes,2,opt,name=name,proto3" json:"name,omitempty"`
	Description          string        `protobuf:"bytes,3,opt,name=description,proto3" json:"description,omitempty"`
	PilosaIndex          string        `protobuf:"bytes,4,opt,name=pilosa_index,json=pilosaIndex,proto3" json:"pilosa_index,omitempty"`
	Datasources          []*DataSource `protobuf:"bytes,5,rep,name=datasources,proto3" json:"datasources,omitempty"`
	XXX_NoUnkeyedLiteral struct{}      `json:"-"`
	XXX_unrecognized     []byte        `json:"-"`
	XXX_sizecache        int32         `json:"-"`
}

func (*VDS) Descriptor 

func (*VDS) Descriptor() ([]byte, []int)

func (*VDS) GetDatasources 

func (m *VDS) GetDatasources() []*DataSource

func (*VDS) GetDescription 

func (m *VDS) GetDescription() string

func (*VDS) GetId 

func (m *VDS) GetId() string

func (*VDS) GetName 

func (m *VDS) GetName() string

func (*VDS) GetPilosaIndex 

func (m *VDS) GetPilosaIndex() string

func (*VDS) ProtoMessage 

func (*VDS) ProtoMessage()

func (*VDS) Reset 

func (m *VDS) Reset()

func (*VDS) String 

func (m *VDS) String() string

func (*VDS) XXX_DiscardUnknown 

func (m *VDS) XXX_DiscardUnknown()

func (*VDS) XXX_Marshal 

func (m *VDS) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)

func (*VDS) XXX_Merge 

func (m *VDS) XXX_Merge(src proto.Message)

func (*VDS) XXX_Size 

func (m *VDS) XXX_Size() int

func (*VDS) XXX_Unmarshal 

func (m *VDS) XXX_Unmarshal(b []byte) error

Source Files

View all Source files

Jump to

Keyboard shortcuts

? : This menu
/ : Search site
f or F : Jump to
y or Y : Canonical URL
go.dev uses cookies from Google to deliver and enhance the quality of its services and to analyze traffic. Learn more.