qpuapi

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
}

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

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
}

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
}

type ConfigResponse_QPUType int32

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

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

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
}

type OrderBy_Order int32

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)
}

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
}

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

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

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

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

type Query struct {

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

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
}

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

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

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

type RequestStreamRecord struct {

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

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 struct {
	QueryRequest *QueryRequest `protobuf:"bytes,1,opt,name=queryRequest,proto3,oneof"`
}

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
}

type ResponseStreamRecord_StreamRecordType int32

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

type UnimplementedQPUAPIServer struct {
}

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