Documentation
¶
Index ¶
- Variables
- func RegisterQPUAPIServer(s grpc.ServiceRegistrar, srv QPUAPIServer)
- type Payload
- type Payload_PayloadType
- func (Payload_PayloadType) Descriptor() protoreflect.EnumDescriptor
- func (x Payload_PayloadType) Enum() *Payload_PayloadType
- func (Payload_PayloadType) EnumDescriptor() ([]byte, []int)deprecated
- func (x Payload_PayloadType) Number() protoreflect.EnumNumber
- func (x Payload_PayloadType) String() string
- func (Payload_PayloadType) Type() protoreflect.EnumType
- type QPUAPIClient
- type QPUAPIServer
- type QueryReq
- type QueryResp
- type QueryRespRecord
- func (*QueryRespRecord) Descriptor() ([]byte, []int)deprecated
- func (x *QueryRespRecord) GetAttributes() map[string]string
- func (x *QueryRespRecord) GetRecordId() string
- func (x *QueryRespRecord) GetTimestamp() map[string]*timestamp.Timestamp
- func (x *QueryRespRecord) GetTimestampReceived() *timestamp.Timestamp
- func (*QueryRespRecord) ProtoMessage()
- func (x *QueryRespRecord) ProtoReflect() protoreflect.Message
- func (x *QueryRespRecord) Reset()
- func (x *QueryRespRecord) String() string
- type UnimplementedQPUAPIServer
- type UnsafeQPUAPIServer
Constants ¶
This section is empty.
Variables ¶
var ( Payload_PayloadType_name = map[int32]string{ 0: "STRING", 1: "INT", 2: "FLOAT", } Payload_PayloadType_value = map[string]int32{ "STRING": 0, "INT": 1, "FLOAT": 2, } )
Enum value maps for Payload_PayloadType.
var File_qpuextapi_proto protoreflect.FileDescriptor
var QPUAPI_ServiceDesc = grpc.ServiceDesc{ ServiceName: "qpuextapi.QPUAPI", HandlerType: (*QPUAPIServer)(nil), Methods: []grpc.MethodDesc{ { MethodName: "QueryUnary", Handler: _QPUAPI_QueryUnary_Handler, }, }, Streams: []grpc.StreamDesc{}, Metadata: "qpuextapi.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 Payload ¶
type Payload struct { Type Payload_PayloadType `protobuf:"varint,1,opt,name=type,proto3,enum=qpuextapi.Payload_PayloadType" json:"type,omitempty"` Value []byte `protobuf:"bytes,2,opt,name=value,proto3" json:"value,omitempty"` // contains filtered or unexported fields }
func (*Payload) Descriptor
deprecated
func (*Payload) GetType ¶
func (x *Payload) GetType() Payload_PayloadType
func (*Payload) ProtoMessage ¶
func (*Payload) ProtoMessage()
func (*Payload) ProtoReflect ¶
func (x *Payload) ProtoReflect() protoreflect.Message
type Payload_PayloadType ¶
type Payload_PayloadType int32
const ( Payload_STRING Payload_PayloadType = 0 Payload_INT Payload_PayloadType = 1 Payload_FLOAT Payload_PayloadType = 2 )
func (Payload_PayloadType) Descriptor ¶
func (Payload_PayloadType) Descriptor() protoreflect.EnumDescriptor
func (Payload_PayloadType) Enum ¶
func (x Payload_PayloadType) Enum() *Payload_PayloadType
func (Payload_PayloadType) EnumDescriptor
deprecated
func (Payload_PayloadType) EnumDescriptor() ([]byte, []int)
Deprecated: Use Payload_PayloadType.Descriptor instead.
func (Payload_PayloadType) Number ¶
func (x Payload_PayloadType) Number() protoreflect.EnumNumber
func (Payload_PayloadType) String ¶
func (x Payload_PayloadType) String() string
func (Payload_PayloadType) Type ¶
func (Payload_PayloadType) Type() protoreflect.EnumType
type QPUAPIClient ¶
type QPUAPIClient interface {
QueryUnary(ctx context.Context, in *QueryReq, opts ...grpc.CallOption) (*QueryResp, 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 { QueryUnary(context.Context, *QueryReq) (*QueryResp, error) // contains filtered or unexported methods }
QPUAPIServer is the server API for QPUAPI service. All implementations must embed UnimplementedQPUAPIServer for forward compatibility
type QueryReq ¶
type QueryReq struct { QueryStr string `protobuf:"bytes,1,opt,name=queryStr,proto3" json:"queryStr,omitempty"` // contains filtered or unexported fields }
func (*QueryReq) Descriptor
deprecated
func (*QueryReq) GetQueryStr ¶
func (*QueryReq) ProtoMessage ¶
func (*QueryReq) ProtoMessage()
func (*QueryReq) ProtoReflect ¶
func (x *QueryReq) ProtoReflect() protoreflect.Message
type QueryResp ¶
type QueryResp struct { RespRecord []*QueryRespRecord `protobuf:"bytes,1,rep,name=respRecord,proto3" json:"respRecord,omitempty"` // contains filtered or unexported fields }
func (*QueryResp) Descriptor
deprecated
func (*QueryResp) GetRespRecord ¶
func (x *QueryResp) GetRespRecord() []*QueryRespRecord
func (*QueryResp) ProtoMessage ¶
func (*QueryResp) ProtoMessage()
func (*QueryResp) ProtoReflect ¶
func (x *QueryResp) ProtoReflect() protoreflect.Message
type QueryRespRecord ¶
type QueryRespRecord struct { RecordId string `protobuf:"bytes,1,opt,name=record_id,json=recordId,proto3" json:"record_id,omitempty"` Attributes map[string]string `` /* 161-byte string literal not displayed */ Timestamp map[string]*timestamp.Timestamp `` /* 159-byte string literal not displayed */ TimestampReceived *timestamp.Timestamp `protobuf:"bytes,4,opt,name=timestampReceived,proto3" json:"timestampReceived,omitempty"` // contains filtered or unexported fields }
func (*QueryRespRecord) Descriptor
deprecated
func (*QueryRespRecord) Descriptor() ([]byte, []int)
Deprecated: Use QueryRespRecord.ProtoReflect.Descriptor instead.
func (*QueryRespRecord) GetAttributes ¶
func (x *QueryRespRecord) GetAttributes() map[string]string
func (*QueryRespRecord) GetRecordId ¶
func (x *QueryRespRecord) GetRecordId() string
func (*QueryRespRecord) GetTimestamp ¶
func (x *QueryRespRecord) GetTimestamp() map[string]*timestamp.Timestamp
func (*QueryRespRecord) GetTimestampReceived ¶
func (x *QueryRespRecord) GetTimestampReceived() *timestamp.Timestamp
func (*QueryRespRecord) ProtoMessage ¶
func (*QueryRespRecord) ProtoMessage()
func (*QueryRespRecord) ProtoReflect ¶
func (x *QueryRespRecord) ProtoReflect() protoreflect.Message
func (*QueryRespRecord) Reset ¶
func (x *QueryRespRecord) Reset()
func (*QueryRespRecord) String ¶
func (x *QueryRespRecord) String() string
type UnimplementedQPUAPIServer ¶
type UnimplementedQPUAPIServer struct { }
UnimplementedQPUAPIServer must be embedded to have forward compatible implementations.
func (UnimplementedQPUAPIServer) QueryUnary ¶
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.