Documentation ¶
Index ¶
- Variables
- func RegisterConverterServer(s grpc.ServiceRegistrar, srv ConverterServer)
- type ConverterClient
- type ConverterServer
- type GetDeviceIssueRequest
- func (*GetDeviceIssueRequest) Descriptor() ([]byte, []int)deprecated
- func (x *GetDeviceIssueRequest) GetConvertedDeviceFeatureMap() string
- func (x *GetDeviceIssueRequest) GetDeviceId() string
- func (x *GetDeviceIssueRequest) GetFeatureId() string
- func (x *GetDeviceIssueRequest) GetModelId() string
- func (x *GetDeviceIssueRequest) GetValues() map[string]string
- func (*GetDeviceIssueRequest) ProtoMessage()
- func (x *GetDeviceIssueRequest) ProtoReflect() protoreflect.Message
- func (x *GetDeviceIssueRequest) Reset()
- func (x *GetDeviceIssueRequest) String() string
- type GetDeviceIssueResponse
- func (*GetDeviceIssueResponse) Descriptor() ([]byte, []int)deprecated
- func (x *GetDeviceIssueResponse) GetInputMessages() []string
- func (x *GetDeviceIssueResponse) GetIssueResponseTopic() string
- func (x *GetDeviceIssueResponse) GetIssueTopic() string
- func (x *GetDeviceIssueResponse) GetOutputMessages() []string
- func (*GetDeviceIssueResponse) ProtoMessage()
- func (x *GetDeviceIssueResponse) ProtoReflect() protoreflect.Message
- func (x *GetDeviceIssueResponse) Reset()
- func (x *GetDeviceIssueResponse) String() string
- type GetMQFormatRequest
- func (*GetMQFormatRequest) Descriptor() ([]byte, []int)deprecated
- func (x *GetMQFormatRequest) GetConvertedDeviceFeatureMap() string
- func (x *GetMQFormatRequest) GetMessages() []string
- func (*GetMQFormatRequest) ProtoMessage()
- func (x *GetMQFormatRequest) ProtoReflect() protoreflect.Message
- func (x *GetMQFormatRequest) Reset()
- func (x *GetMQFormatRequest) String() string
- type GetMQFormatResponse
- func (*GetMQFormatResponse) Descriptor() ([]byte, []int)deprecated
- func (x *GetMQFormatResponse) GetRabbitMQMsgBody() []byte
- func (x *GetMQFormatResponse) GetRoutingKey() string
- func (*GetMQFormatResponse) ProtoMessage()
- func (x *GetMQFormatResponse) ProtoReflect() protoreflect.Message
- func (x *GetMQFormatResponse) Reset()
- func (x *GetMQFormatResponse) String() string
- type UnimplementedConverterServer
- type UnsafeConverterServer
Constants ¶
This section is empty.
Variables ¶
var Converter_ServiceDesc = grpc.ServiceDesc{ ServiceName: "proto.Converter", HandlerType: (*ConverterServer)(nil), Methods: []grpc.MethodDesc{ { MethodName: "ConvertIssueMessage2Device", Handler: _Converter_ConvertIssueMessage2Device_Handler, }, { MethodName: "ConvertDeviceMessages2MQFormat", Handler: _Converter_ConvertDeviceMessages2MQFormat_Handler, }, }, Streams: []grpc.StreamDesc{}, Metadata: "proto/converter.proto", }
Converter_ServiceDesc is the grpc.ServiceDesc for Converter service. It's only intended for direct use with grpc.RegisterService, and not to be introspected or modified (even as a copy)
var File_proto_converter_proto protoreflect.FileDescriptor
Functions ¶
func RegisterConverterServer ¶
func RegisterConverterServer(s grpc.ServiceRegistrar, srv ConverterServer)
Types ¶
type ConverterClient ¶
type ConverterClient interface { ConvertIssueMessage2Device(ctx context.Context, in *GetDeviceIssueRequest, opts ...grpc.CallOption) (*GetDeviceIssueResponse, error) ConvertDeviceMessages2MQFormat(ctx context.Context, in *GetMQFormatRequest, opts ...grpc.CallOption) (*GetMQFormatResponse, error) }
ConverterClient is the client API for Converter 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 NewConverterClient ¶
func NewConverterClient(cc grpc.ClientConnInterface) ConverterClient
type ConverterServer ¶
type ConverterServer interface { ConvertIssueMessage2Device(context.Context, *GetDeviceIssueRequest) (*GetDeviceIssueResponse, error) ConvertDeviceMessages2MQFormat(context.Context, *GetMQFormatRequest) (*GetMQFormatResponse, error) }
ConverterServer is the server API for Converter service. All implementations should embed UnimplementedConverterServer for forward compatibility
type GetDeviceIssueRequest ¶
type GetDeviceIssueRequest struct { DeviceId string `protobuf:"bytes,1,opt,name=deviceId,proto3" json:"deviceId,omitempty"` ModelId string `protobuf:"bytes,2,opt,name=modelId,proto3" json:"modelId,omitempty"` FeatureId string `protobuf:"bytes,3,opt,name=featureId,proto3" json:"featureId,omitempty"` Values map[string]string `` /* 153-byte string literal not displayed */ ConvertedDeviceFeatureMap string `protobuf:"bytes,5,opt,name=convertedDeviceFeatureMap,proto3" json:"convertedDeviceFeatureMap,omitempty"` // contains filtered or unexported fields }
func (*GetDeviceIssueRequest) Descriptor
deprecated
func (*GetDeviceIssueRequest) Descriptor() ([]byte, []int)
Deprecated: Use GetDeviceIssueRequest.ProtoReflect.Descriptor instead.
func (*GetDeviceIssueRequest) GetConvertedDeviceFeatureMap ¶
func (x *GetDeviceIssueRequest) GetConvertedDeviceFeatureMap() string
func (*GetDeviceIssueRequest) GetDeviceId ¶
func (x *GetDeviceIssueRequest) GetDeviceId() string
func (*GetDeviceIssueRequest) GetFeatureId ¶
func (x *GetDeviceIssueRequest) GetFeatureId() string
func (*GetDeviceIssueRequest) GetModelId ¶
func (x *GetDeviceIssueRequest) GetModelId() string
func (*GetDeviceIssueRequest) GetValues ¶
func (x *GetDeviceIssueRequest) GetValues() map[string]string
func (*GetDeviceIssueRequest) ProtoMessage ¶
func (*GetDeviceIssueRequest) ProtoMessage()
func (*GetDeviceIssueRequest) ProtoReflect ¶
func (x *GetDeviceIssueRequest) ProtoReflect() protoreflect.Message
func (*GetDeviceIssueRequest) Reset ¶
func (x *GetDeviceIssueRequest) Reset()
func (*GetDeviceIssueRequest) String ¶
func (x *GetDeviceIssueRequest) String() string
type GetDeviceIssueResponse ¶
type GetDeviceIssueResponse struct { InputMessages []string `protobuf:"bytes,1,rep,name=inputMessages,proto3" json:"inputMessages,omitempty"` OutputMessages []string `protobuf:"bytes,2,rep,name=outputMessages,proto3" json:"outputMessages,omitempty"` IssueTopic string `protobuf:"bytes,3,opt,name=issueTopic,proto3" json:"issueTopic,omitempty"` IssueResponseTopic string `protobuf:"bytes,4,opt,name=issueResponseTopic,proto3" json:"issueResponseTopic,omitempty"` // contains filtered or unexported fields }
func (*GetDeviceIssueResponse) Descriptor
deprecated
func (*GetDeviceIssueResponse) Descriptor() ([]byte, []int)
Deprecated: Use GetDeviceIssueResponse.ProtoReflect.Descriptor instead.
func (*GetDeviceIssueResponse) GetInputMessages ¶
func (x *GetDeviceIssueResponse) GetInputMessages() []string
func (*GetDeviceIssueResponse) GetIssueResponseTopic ¶
func (x *GetDeviceIssueResponse) GetIssueResponseTopic() string
func (*GetDeviceIssueResponse) GetIssueTopic ¶
func (x *GetDeviceIssueResponse) GetIssueTopic() string
func (*GetDeviceIssueResponse) GetOutputMessages ¶
func (x *GetDeviceIssueResponse) GetOutputMessages() []string
func (*GetDeviceIssueResponse) ProtoMessage ¶
func (*GetDeviceIssueResponse) ProtoMessage()
func (*GetDeviceIssueResponse) ProtoReflect ¶
func (x *GetDeviceIssueResponse) ProtoReflect() protoreflect.Message
func (*GetDeviceIssueResponse) Reset ¶
func (x *GetDeviceIssueResponse) Reset()
func (*GetDeviceIssueResponse) String ¶
func (x *GetDeviceIssueResponse) String() string
type GetMQFormatRequest ¶
type GetMQFormatRequest struct { Messages []string `protobuf:"bytes,1,rep,name=messages,proto3" json:"messages,omitempty"` ConvertedDeviceFeatureMap string `protobuf:"bytes,2,opt,name=convertedDeviceFeatureMap,proto3" json:"convertedDeviceFeatureMap,omitempty"` // contains filtered or unexported fields }
func (*GetMQFormatRequest) Descriptor
deprecated
func (*GetMQFormatRequest) Descriptor() ([]byte, []int)
Deprecated: Use GetMQFormatRequest.ProtoReflect.Descriptor instead.
func (*GetMQFormatRequest) GetConvertedDeviceFeatureMap ¶
func (x *GetMQFormatRequest) GetConvertedDeviceFeatureMap() string
func (*GetMQFormatRequest) GetMessages ¶
func (x *GetMQFormatRequest) GetMessages() []string
func (*GetMQFormatRequest) ProtoMessage ¶
func (*GetMQFormatRequest) ProtoMessage()
func (*GetMQFormatRequest) ProtoReflect ¶
func (x *GetMQFormatRequest) ProtoReflect() protoreflect.Message
func (*GetMQFormatRequest) Reset ¶
func (x *GetMQFormatRequest) Reset()
func (*GetMQFormatRequest) String ¶
func (x *GetMQFormatRequest) String() string
type GetMQFormatResponse ¶
type GetMQFormatResponse struct { RoutingKey string `protobuf:"bytes,1,opt,name=routingKey,proto3" json:"routingKey,omitempty"` RabbitMQMsgBody []byte `protobuf:"bytes,2,opt,name=rabbitMQMsgBody,proto3" json:"rabbitMQMsgBody,omitempty"` // contains filtered or unexported fields }
func (*GetMQFormatResponse) Descriptor
deprecated
func (*GetMQFormatResponse) Descriptor() ([]byte, []int)
Deprecated: Use GetMQFormatResponse.ProtoReflect.Descriptor instead.
func (*GetMQFormatResponse) GetRabbitMQMsgBody ¶
func (x *GetMQFormatResponse) GetRabbitMQMsgBody() []byte
func (*GetMQFormatResponse) GetRoutingKey ¶
func (x *GetMQFormatResponse) GetRoutingKey() string
func (*GetMQFormatResponse) ProtoMessage ¶
func (*GetMQFormatResponse) ProtoMessage()
func (*GetMQFormatResponse) ProtoReflect ¶
func (x *GetMQFormatResponse) ProtoReflect() protoreflect.Message
func (*GetMQFormatResponse) Reset ¶
func (x *GetMQFormatResponse) Reset()
func (*GetMQFormatResponse) String ¶
func (x *GetMQFormatResponse) String() string
type UnimplementedConverterServer ¶
type UnimplementedConverterServer struct { }
UnimplementedConverterServer should be embedded to have forward compatible implementations.
func (UnimplementedConverterServer) ConvertDeviceMessages2MQFormat ¶
func (UnimplementedConverterServer) ConvertDeviceMessages2MQFormat(context.Context, *GetMQFormatRequest) (*GetMQFormatResponse, error)
func (UnimplementedConverterServer) ConvertIssueMessage2Device ¶
func (UnimplementedConverterServer) ConvertIssueMessage2Device(context.Context, *GetDeviceIssueRequest) (*GetDeviceIssueResponse, error)
type UnsafeConverterServer ¶
type UnsafeConverterServer interface {
// contains filtered or unexported methods
}
UnsafeConverterServer may be embedded to opt out of forward compatibility for this service. Use of this interface is not recommended, as added methods to ConverterServer will result in compilation errors.