qpuapi

package
v0.0.0-...-726f7ef Latest Latest
Warning

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

 Go to latest Published: Feb 12, 2022 License: Apache-2.0 Imports: 10 Imported by: 0

Documentation

Index

Constants

This section is empty.

Variables

View Source 
var (
	OrderBy_Order_name = map[int32]string{
		0: "ASC",
		1: "DESC",
	}
	OrderBy_Order_value = map[string]int32{
		"ASC":  0,
		"DESC": 1,
	}
)

Enum value maps for OrderBy_Order.

View Source 
var (
	ResponseStreamRecord_StreamRecordType_name = map[int32]string{
		0: "UPDATEOP",
		1: "UPDATEDELTA",
		2: "STATE",
		3: "HEARTBEAT",
		4: "END_OF_STREAM",
	}
	ResponseStreamRecord_StreamRecordType_value = map[string]int32{
		"UPDATEOP":      0,
		"UPDATEDELTA":   1,
		"STATE":         2,
		"HEARTBEAT":     3,
		"END_OF_STREAM": 4,
	}
)

Enum value maps for ResponseStreamRecord_StreamRecordType.

View Source 
var (
	ConfigResponse_QPUType_name = map[int32]string{
		0: "DATASTORE_DRIVER",
		1: "SUM",
		2: "JOIN",
		3: "INDEX",
		4: "CACHE",
	}
	ConfigResponse_QPUType_value = map[string]int32{
		"DATASTORE_DRIVER": 0,
		"SUM":              1,
		"JOIN":             2,
		"INDEX":            3,
		"CACHE":            4,
	}
)

Enum value maps for ConfigResponse_QPUType.

View Source 
var File_qpuapi_proto protoreflect.FileDescriptor
View Source 
var QPUAPI_ServiceDesc = grpc.ServiceDesc{
	ServiceName: "qpuapi.QPUAPI",
	HandlerType: (*QPUAPIServer)(nil),
	Methods: []grpc.MethodDesc{
		{
			MethodName: "QueryUnary",
			Handler:    _QPUAPI_QueryUnary_Handler,
		},
		{
			MethodName: "GetConfig",
			Handler:    _QPUAPI_GetConfig_Handler,
		},
	},
	Streams: []grpc.StreamDesc{
		{
			StreamName:    "Query",
			Handler:       _QPUAPI_Query_Handler,
			ServerStreams: true,
			ClientStreams: true,
		},
		{
			StreamName:    "QuerySubscribe",
			Handler:       _QPUAPI_QuerySubscribe_Handler,
			ServerStreams: true,
		},
	},
	Metadata: "qpuapi.proto",
}

QPUAPI_ServiceDesc is the grpc.ServiceDesc for QPUAPI service. It's only intended for direct use with grpc.RegisterService, and not to be introspected or modified (even as a copy)

Functions

func RegisterQPUAPIServer 

func RegisterQPUAPIServer(s grpc.ServiceRegistrar, srv QPUAPIServer)

Types

type ASTQuery 

type ASTQuery struct {
	Table string `protobuf:"bytes,1,opt,name=table,proto3" json:"table,omitempty"`
	// Like the SQL PROJECTION.
	Projection []string `protobuf:"bytes,2,rep,name=projection,proto3" json:"projection,omitempty"`
	// Like the SQL WHERE statement.
	Predicate []*qpu.AttributePredicate `protobuf:"bytes,3,rep,name=predicate,proto3" json:"predicate,omitempty"`
	// Timespamp predicate.
	// Has the same form as AttributePredicate, but it is separate simply
	// to allow as to refer to this with a specific name (tsPredicate).
	TsPredicate *qpu.SnapshotTimePredicate `protobuf:"bytes,4,opt,name=tsPredicate,proto3" json:"tsPredicate,omitempty"`
	OrderBy     *OrderBy                   `protobuf:"bytes,5,opt,name=orderBy,proto3" json:"orderBy,omitempty"`
	// Like the SQL LIMIT
	Limit int64 `protobuf:"varint,6,opt,name=limit,proto3" json:"limit,omitempty"`
	// contains filtered or unexported fields
}

Internal query representation.

func (*ASTQuery) Descriptor deprecated 

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

Deprecated: Use ASTQuery.ProtoReflect.Descriptor instead.

func (*ASTQuery) GetLimit 

func (x *ASTQuery) GetLimit() int64

func (*ASTQuery) GetOrderBy 

func (x *ASTQuery) GetOrderBy() *OrderBy

func (*ASTQuery) GetPredicate 

func (x *ASTQuery) GetPredicate() []*qpu.AttributePredicate

func (*ASTQuery) GetProjection 

func (x *ASTQuery) GetProjection() []string

func (*ASTQuery) GetTable 

func (x *ASTQuery) GetTable() string

func (*ASTQuery) GetTsPredicate 

func (x *ASTQuery) GetTsPredicate() *qpu.SnapshotTimePredicate

func (*ASTQuery) ProtoMessage 

func (*ASTQuery) ProtoMessage()

func (*ASTQuery) ProtoReflect 

func (x *ASTQuery) ProtoReflect() protoreflect.Message

func (*ASTQuery) Reset 

func (x *ASTQuery) Reset()

func (*ASTQuery) String 

func (x *ASTQuery) String() string

type AckMsg 

type AckMsg struct {
	SequenceId int64 `protobuf:"varint,1,opt,name=sequence_id,json=sequenceId,proto3" json:"sequence_id,omitempty"`
	// contains filtered or unexported fields
}

func (*AckMsg) Descriptor deprecated 

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

Deprecated: Use AckMsg.ProtoReflect.Descriptor instead.

func (*AckMsg) GetSequenceId 

func (x *AckMsg) GetSequenceId() int64

func (*AckMsg) ProtoMessage 

func (*AckMsg) ProtoMessage()

func (*AckMsg) ProtoReflect 

func (x *AckMsg) ProtoReflect() protoreflect.Message

func (*AckMsg) Reset 

func (x *AckMsg) Reset()

func (*AckMsg) String 

func (x *AckMsg) String() string

type ConfigRequest 

type ConfigRequest struct {

	// Just here for future use, not actually used.
	Clock *qpu.SnapshotTimePredicate `protobuf:"bytes,1,opt,name=clock,proto3" json:"clock,omitempty"`
	// contains filtered or unexported fields
}

func (*ConfigRequest) Descriptor deprecated 

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

Deprecated: Use ConfigRequest.ProtoReflect.Descriptor instead.

func (*ConfigRequest) GetClock 

func (x *ConfigRequest) GetClock() *qpu.SnapshotTimePredicate

func (*ConfigRequest) ProtoMessage 

func (*ConfigRequest) ProtoMessage()

func (*ConfigRequest) ProtoReflect 

func (x *ConfigRequest) ProtoReflect() protoreflect.Message

func (*ConfigRequest) Reset 

func (x *ConfigRequest) Reset()

func (*ConfigRequest) String 

func (x *ConfigRequest) String() string

type ConfigResponse 

type ConfigResponse struct {
	QpuType          ConfigResponse_QPUType    `protobuf:"varint,1,opt,name=qpu_type,json=qpuType,proto3,enum=qpuapi.ConfigResponse_QPUType" json:"qpu_type,omitempty"`
	Schema           []string                  `protobuf:"bytes,2,rep,name=schema,proto3" json:"schema,omitempty"`
	SupportedQueries []*qpu.AttributePredicate `protobuf:"bytes,3,rep,name=supportedQueries,proto3" json:"supportedQueries,omitempty"`
	// contains filtered or unexported fields
}

func (*ConfigResponse) Descriptor deprecated 

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

Deprecated: Use ConfigResponse.ProtoReflect.Descriptor instead.

func (*ConfigResponse) GetQpuType 

func (x *ConfigResponse) GetQpuType() ConfigResponse_QPUType

func (*ConfigResponse) GetSchema 

func (x *ConfigResponse) GetSchema() []string

func (*ConfigResponse) GetSupportedQueries 

func (x *ConfigResponse) GetSupportedQueries() []*qpu.AttributePredicate

func (*ConfigResponse) ProtoMessage 

func (*ConfigResponse) ProtoMessage()

func (*ConfigResponse) ProtoReflect 

func (x *ConfigResponse) ProtoReflect() protoreflect.Message

func (*ConfigResponse) Reset 

func (x *ConfigResponse) Reset()

func (*ConfigResponse) String 

func (x *ConfigResponse) String() string

type ConfigResponse_QPUType 

type ConfigResponse_QPUType int32
const (
	ConfigResponse_DATASTORE_DRIVER ConfigResponse_QPUType = 0
	ConfigResponse_SUM              ConfigResponse_QPUType = 1
	ConfigResponse_JOIN             ConfigResponse_QPUType = 2
	ConfigResponse_INDEX            ConfigResponse_QPUType = 3
	ConfigResponse_CACHE            ConfigResponse_QPUType = 4
)

func (ConfigResponse_QPUType) Descriptor 

func (ConfigResponse_QPUType) Descriptor() protoreflect.EnumDescriptor

func (ConfigResponse_QPUType) Enum 

func (x ConfigResponse_QPUType) Enum() *ConfigResponse_QPUType

func (ConfigResponse_QPUType) EnumDescriptor deprecated 

func (ConfigResponse_QPUType) EnumDescriptor() ([]byte, []int)

Deprecated: Use ConfigResponse_QPUType.Descriptor instead.

func (ConfigResponse_QPUType) Number 

func (x ConfigResponse_QPUType) Number() protoreflect.EnumNumber

func (ConfigResponse_QPUType) String 

func (x ConfigResponse_QPUType) String() string

func (ConfigResponse_QPUType) Type 

func (ConfigResponse_QPUType) Type() protoreflect.EnumType

type NoOpReq 

type NoOpReq struct {
	Str string `protobuf:"bytes,1,opt,name=str,proto3" json:"str,omitempty"`
	// contains filtered or unexported fields
}

func (*NoOpReq) Descriptor deprecated 

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

Deprecated: Use NoOpReq.ProtoReflect.Descriptor instead.

func (*NoOpReq) GetStr 

func (x *NoOpReq) GetStr() string

func (*NoOpReq) ProtoMessage 

func (*NoOpReq) ProtoMessage()

func (*NoOpReq) ProtoReflect 

func (x *NoOpReq) ProtoReflect() protoreflect.Message

func (*NoOpReq) Reset 

func (x *NoOpReq) Reset()

func (*NoOpReq) String 

func (x *NoOpReq) String() string

type NoOpResp 

type NoOpResp struct {
	Str string `protobuf:"bytes,1,opt,name=str,proto3" json:"str,omitempty"`
	// contains filtered or unexported fields
}

func (*NoOpResp) Descriptor deprecated 

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

Deprecated: Use NoOpResp.ProtoReflect.Descriptor instead.

func (*NoOpResp) GetStr 

func (x *NoOpResp) GetStr() string

func (*NoOpResp) ProtoMessage 

func (*NoOpResp) ProtoMessage()

func (*NoOpResp) ProtoReflect 

func (x *NoOpResp) ProtoReflect() protoreflect.Message

func (*NoOpResp) Reset 

func (x *NoOpResp) Reset()

func (*NoOpResp) String 

func (x *NoOpResp) String() string

type OrderBy 

type OrderBy struct {
	AttributeName string        `protobuf:"bytes,1,opt,name=attributeName,proto3" json:"attributeName,omitempty"`
	Direction     OrderBy_Order `protobuf:"varint,2,opt,name=direction,proto3,enum=qpuapi.OrderBy_Order" json:"direction,omitempty"`
	// contains filtered or unexported fields
}

func (*OrderBy) Descriptor deprecated 

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

Deprecated: Use OrderBy.ProtoReflect.Descriptor instead.

func (*OrderBy) GetAttributeName 

func (x *OrderBy) GetAttributeName() string

func (*OrderBy) GetDirection 

func (x *OrderBy) GetDirection() OrderBy_Order

func (*OrderBy) ProtoMessage 

func (*OrderBy) ProtoMessage()

func (*OrderBy) ProtoReflect 

func (x *OrderBy) ProtoReflect() protoreflect.Message

func (*OrderBy) Reset 

func (x *OrderBy) Reset()

func (*OrderBy) String 

func (x *OrderBy) String() string

type OrderBy_Order 

type OrderBy_Order int32
const (
	OrderBy_ASC  OrderBy_Order = 0
	OrderBy_DESC OrderBy_Order = 1
)

func (OrderBy_Order) Descriptor 

func (OrderBy_Order) Descriptor() protoreflect.EnumDescriptor

func (OrderBy_Order) Enum 

func (x OrderBy_Order) Enum() *OrderBy_Order

func (OrderBy_Order) EnumDescriptor deprecated 

func (OrderBy_Order) EnumDescriptor() ([]byte, []int)

Deprecated: Use OrderBy_Order.Descriptor instead.

func (OrderBy_Order) Number 

func (x OrderBy_Order) Number() protoreflect.EnumNumber

func (OrderBy_Order) String 

func (x OrderBy_Order) String() string

func (OrderBy_Order) Type 

func (OrderBy_Order) Type() protoreflect.EnumType

type QPUAPIClient 

type QPUAPIClient interface {
	// The QPU Query API.
	Query(ctx context.Context, opts ...grpc.CallOption) (QPUAPI_QueryClient, error)
	// QueryUnary is a simplification of Query that returns a single response
	// instead of a stream.
	// It is used to simplify the client code for clients that have queries
	// that look like SELECT .. FROM .. WHERE .. LIMIT N
	// and so do not care about streaming anyways.
	QueryUnary(ctx context.Context, in *qpuextapi.QueryReq, opts ...grpc.CallOption) (*qpuextapi.QueryResp, error)
	QuerySubscribe(ctx context.Context, in *qpuextapi.QueryReq, opts ...grpc.CallOption) (QPUAPI_QuerySubscribeClient, error)
	// The QPU GetConfig API.
	// Used by a 'parent' QPU to request the configuration and query processing
	// capabilities of a 'child` QPU.
	GetConfig(ctx context.Context, in *ConfigRequest, opts ...grpc.CallOption) (*ConfigResponse, error)
}

QPUAPIClient is the client API for QPUAPI service.

For semantics around ctx use and closing/ending streaming RPCs, please refer to https://pkg.go.dev/google.golang.org/grpc/?tab=doc#ClientConn.NewStream.

func NewQPUAPIClient 

func NewQPUAPIClient(cc grpc.ClientConnInterface) QPUAPIClient

type QPUAPIServer 

type QPUAPIServer interface {
	// The QPU Query API.
	Query(QPUAPI_QueryServer) error
	// QueryUnary is a simplification of Query that returns a single response
	// instead of a stream.
	// It is used to simplify the client code for clients that have queries
	// that look like SELECT .. FROM .. WHERE .. LIMIT N
	// and so do not care about streaming anyways.
	QueryUnary(context.Context, *qpuextapi.QueryReq) (*qpuextapi.QueryResp, error)
	QuerySubscribe(*qpuextapi.QueryReq, QPUAPI_QuerySubscribeServer) error
	// The QPU GetConfig API.
	// Used by a 'parent' QPU to request the configuration and query processing
	// capabilities of a 'child` QPU.
	GetConfig(context.Context, *ConfigRequest) (*ConfigResponse, error)
	// contains filtered or unexported methods
}

QPUAPIServer is the server API for QPUAPI service. All implementations must embed UnimplementedQPUAPIServer for forward compatibility

type QPUAPI_QueryClient 

type QPUAPI_QueryClient interface {
	Send(*RequestStreamRecord) error
	Recv() (*ResponseStreamRecord, error)
	grpc.ClientStream
}

type QPUAPI_QueryServer 

type QPUAPI_QueryServer interface {
	Send(*ResponseStreamRecord) error
	Recv() (*RequestStreamRecord, error)
	grpc.ServerStream
}

type QPUAPI_QuerySubscribeClient 

type QPUAPI_QuerySubscribeClient interface {
	Recv() (*ResponseStreamRecord, error)
	grpc.ClientStream
}

type QPUAPI_QuerySubscribeServer 

type QPUAPI_QuerySubscribeServer interface {
	Send(*ResponseStreamRecord) error
	grpc.ServerStream
}

type Query 

type Query struct {

	// Types that are assignable to Query:
	//	*Query_QueryAst
	//	*Query_QuerySql
	Query isQuery_Query `protobuf_oneof:"query"`
	// contains filtered or unexported fields
}

func (*Query) Descriptor deprecated 

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

Deprecated: Use Query.ProtoReflect.Descriptor instead.

func (*Query) GetQuery 

func (m *Query) GetQuery() isQuery_Query

func (*Query) GetQueryAst 

func (x *Query) GetQueryAst() *ASTQuery

func (*Query) GetQuerySql 

func (x *Query) GetQuerySql() *SQLQuery

func (*Query) ProtoMessage 

func (*Query) ProtoMessage()

func (*Query) ProtoReflect 

func (x *Query) ProtoReflect() protoreflect.Message

func (*Query) Reset 

func (x *Query) Reset()

func (*Query) String 

func (x *Query) String() string

type QueryRequest 

type QueryRequest struct {
	Query    *Query            `protobuf:"bytes,1,opt,name=query,proto3" json:"query,omitempty"`
	Metadata map[string]string `` /* 157-byte string literal not displayed */
	// Synchronous or asynhronous mode.
	// Only makes sence to use synchronous mode when the underlying datastore'
	// subscribe API has the ability to block updates waiting for acks.
	Sync                bool `protobuf:"varint,3,opt,name=sync,proto3" json:"sync,omitempty"`
	MeasureDataTransfer bool `protobuf:"varint,4,opt,name=measureDataTransfer,proto3" json:"measureDataTransfer,omitempty"`
	// contains filtered or unexported fields
}

func (*QueryRequest) Descriptor deprecated 

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

Deprecated: Use QueryRequest.ProtoReflect.Descriptor instead.

func (*QueryRequest) GetMeasureDataTransfer 

func (x *QueryRequest) GetMeasureDataTransfer() bool

func (*QueryRequest) GetMetadata 

func (x *QueryRequest) GetMetadata() map[string]string

func (*QueryRequest) GetQuery 

func (x *QueryRequest) GetQuery() *Query

func (*QueryRequest) GetSync 

func (x *QueryRequest) GetSync() bool

func (*QueryRequest) ProtoMessage 

func (*QueryRequest) ProtoMessage()

func (*QueryRequest) ProtoReflect 

func (x *QueryRequest) ProtoReflect() protoreflect.Message

func (*QueryRequest) Reset 

func (x *QueryRequest) Reset()

func (*QueryRequest) String 

func (x *QueryRequest) String() string

type QueryResponse 

type QueryResponse struct {
	Results []*qpu.LogOperation `protobuf:"bytes,1,rep,name=results,proto3" json:"results,omitempty"`
	// contains filtered or unexported fields
}

Simplification of ResponseStreamRecord used for QueryUnary.

func (*QueryResponse) Descriptor deprecated 

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

Deprecated: Use QueryResponse.ProtoReflect.Descriptor instead.

func (*QueryResponse) GetResults 

func (x *QueryResponse) GetResults() []*qpu.LogOperation

func (*QueryResponse) ProtoMessage 

func (*QueryResponse) ProtoMessage()

func (*QueryResponse) ProtoReflect 

func (x *QueryResponse) ProtoReflect() protoreflect.Message

func (*QueryResponse) Reset 

func (x *QueryResponse) Reset()

func (*QueryResponse) String 

func (x *QueryResponse) String() string

type Query_QueryAst 

type Query_QueryAst struct {
	QueryAst *ASTQuery `protobuf:"bytes,1,opt,name=query_ast,json=queryAst,proto3,oneof"`
}

type Query_QuerySql 

type Query_QuerySql struct {
	QuerySql *SQLQuery `protobuf:"bytes,2,opt,name=query_sql,json=querySql,proto3,oneof"`
}

type RequestStreamRecord 

type RequestStreamRecord struct {

	// Types that are assignable to Request:
	//	*RequestStreamRecord_QueryRequest
	//	*RequestStreamRecord_Ack
	Request isRequestStreamRecord_Request `protobuf_oneof:"request"`
	// contains filtered or unexported fields
}

func (*RequestStreamRecord) Descriptor deprecated 

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

Deprecated: Use RequestStreamRecord.ProtoReflect.Descriptor instead.

func (*RequestStreamRecord) GetAck 

func (x *RequestStreamRecord) GetAck() *AckMsg

func (*RequestStreamRecord) GetQueryRequest 

func (x *RequestStreamRecord) GetQueryRequest() *QueryRequest

func (*RequestStreamRecord) GetRequest 

func (m *RequestStreamRecord) GetRequest() isRequestStreamRecord_Request

func (*RequestStreamRecord) ProtoMessage 

func (*RequestStreamRecord) ProtoMessage()

func (*RequestStreamRecord) ProtoReflect 

func (x *RequestStreamRecord) ProtoReflect() protoreflect.Message

func (*RequestStreamRecord) Reset 

func (x *RequestStreamRecord) Reset()

func (*RequestStreamRecord) String 

func (x *RequestStreamRecord) String() string

type RequestStreamRecord_Ack 

type RequestStreamRecord_Ack struct {
	// Used to implement synchronous streams.
	// (synchronous stream : the sender blocks until it receives an ack for
	// each record)
	Ack *AckMsg `protobuf:"bytes,2,opt,name=ack,proto3,oneof"`
}

type RequestStreamRecord_QueryRequest 

type RequestStreamRecord_QueryRequest struct {
	QueryRequest *QueryRequest `protobuf:"bytes,1,opt,name=queryRequest,proto3,oneof"`
}

type ResponseStreamRecord 

type ResponseStreamRecord struct {

	// This is here to be used for checking for gaps in the stream and for
	// ordering records per stream
	// (not yet implemented)
	SequenceId int64                                 `protobuf:"varint,1,opt,name=sequence_id,json=sequenceId,proto3" json:"sequence_id,omitempty"`
	Type       ResponseStreamRecord_StreamRecordType `protobuf:"varint,2,opt,name=type,proto3,enum=qpuapi.ResponseStreamRecord_StreamRecordType" json:"type,omitempty"`
	LogOp      *qpu.LogOperation                     `protobuf:"bytes,3,opt,name=logOp,proto3" json:"logOp,omitempty"`
	// contains filtered or unexported fields
}

A record for the stream returned by Query.

func (*ResponseStreamRecord) Descriptor deprecated 

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

Deprecated: Use ResponseStreamRecord.ProtoReflect.Descriptor instead.

func (*ResponseStreamRecord) GetLogOp 

func (x *ResponseStreamRecord) GetLogOp() *qpu.LogOperation

func (*ResponseStreamRecord) GetSequenceId 

func (x *ResponseStreamRecord) GetSequenceId() int64

func (*ResponseStreamRecord) GetType 

func (x *ResponseStreamRecord) GetType() ResponseStreamRecord_StreamRecordType

func (*ResponseStreamRecord) ProtoMessage 

func (*ResponseStreamRecord) ProtoMessage()

func (*ResponseStreamRecord) ProtoReflect 

func (x *ResponseStreamRecord) ProtoReflect() protoreflect.Message

func (*ResponseStreamRecord) Reset 

func (x *ResponseStreamRecord) Reset()

func (*ResponseStreamRecord) String 

func (x *ResponseStreamRecord) String() string

type ResponseStreamRecord_StreamRecordType 

type ResponseStreamRecord_StreamRecordType int32
const (
	// Not used for now.
	ResponseStreamRecord_UPDATEOP ResponseStreamRecord_StreamRecordType = 0
	// Respresents an update.
	// udpate = (value_before_update, value_after_update)
	ResponseStreamRecord_UPDATEDELTA ResponseStreamRecord_StreamRecordType = 1
	// Represents the state of a data item.
	ResponseStreamRecord_STATE ResponseStreamRecord_StreamRecordType = 2
	// Sometimes we exchange heartbeats in long-lived streams to make sure
	// the two parts are still alive and the connection is open.
	ResponseStreamRecord_HEARTBEAT ResponseStreamRecord_StreamRecordType = 3
	// It informs the receiver of the stream for the end of a 'getSnapshot'
	// query (all STATE records will be sent, but more UPDATEDELTA may follow).
	// It is missleading:
	// an END_OF_STREAM can be send in a steam, and the stream may then
	// continue being used (for UPDATEDELTA records).
	ResponseStreamRecord_END_OF_STREAM ResponseStreamRecord_StreamRecordType = 4
)

func (ResponseStreamRecord_StreamRecordType) Descriptor 

func (ResponseStreamRecord_StreamRecordType) Descriptor() protoreflect.EnumDescriptor

func (ResponseStreamRecord_StreamRecordType) Enum 

func (x ResponseStreamRecord_StreamRecordType) Enum() *ResponseStreamRecord_StreamRecordType

func (ResponseStreamRecord_StreamRecordType) EnumDescriptor deprecated 

func (ResponseStreamRecord_StreamRecordType) EnumDescriptor() ([]byte, []int)

Deprecated: Use ResponseStreamRecord_StreamRecordType.Descriptor instead.

func (ResponseStreamRecord_StreamRecordType) Number 

func (x ResponseStreamRecord_StreamRecordType) Number() protoreflect.EnumNumber

func (ResponseStreamRecord_StreamRecordType) String 

func (x ResponseStreamRecord_StreamRecordType) String() string

func (ResponseStreamRecord_StreamRecordType) Type 

func (ResponseStreamRecord_StreamRecordType) Type() protoreflect.EnumType

type SQLQuery 

type SQLQuery struct {
	QueryStr string `protobuf:"bytes,1,opt,name=queryStr,proto3" json:"queryStr,omitempty"`
	// contains filtered or unexported fields
}

func (*SQLQuery) Descriptor deprecated 

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

Deprecated: Use SQLQuery.ProtoReflect.Descriptor instead.

func (*SQLQuery) GetQueryStr 

func (x *SQLQuery) GetQueryStr() string

func (*SQLQuery) ProtoMessage 

func (*SQLQuery) ProtoMessage()

func (*SQLQuery) ProtoReflect 

func (x *SQLQuery) ProtoReflect() protoreflect.Message

func (*SQLQuery) Reset 

func (x *SQLQuery) Reset()

func (*SQLQuery) String 

func (x *SQLQuery) String() string

type UnimplementedQPUAPIServer 

type UnimplementedQPUAPIServer struct {
}

UnimplementedQPUAPIServer must be embedded to have forward compatible implementations.

func (UnimplementedQPUAPIServer) GetConfig 

func (UnimplementedQPUAPIServer) GetConfig(context.Context, *ConfigRequest) (*ConfigResponse, error)

func (UnimplementedQPUAPIServer) Query 

func (UnimplementedQPUAPIServer) Query(QPUAPI_QueryServer) error

func (UnimplementedQPUAPIServer) QuerySubscribe 

func (UnimplementedQPUAPIServer) QuerySubscribe(*qpuextapi.QueryReq, QPUAPI_QuerySubscribeServer) error

func (UnimplementedQPUAPIServer) QueryUnary 

func (UnimplementedQPUAPIServer) QueryUnary(context.Context, *qpuextapi.QueryReq) (*qpuextapi.QueryResp, error)

type UnsafeQPUAPIServer 

type UnsafeQPUAPIServer interface {
	// contains filtered or unexported methods
}

UnsafeQPUAPIServer may be embedded to opt out of forward compatibility for this service. Use of this interface is not recommended, as added methods to QPUAPIServer will result in compilation errors.

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.