Documentation
¶
Index ¶
- Constants
- Variables
- func RegisterGatewayConnectorHandlerServer(s grpc.ServiceRegistrar, srv GatewayConnectorHandlerServer)
- func RegisterGatewayConnectorServer(s grpc.ServiceRegistrar, srv GatewayConnectorServer)
- type AddHandlerRequest
- func (*AddHandlerRequest) Descriptor() ([]byte, []int)deprecated
- func (x *AddHandlerRequest) GetHandlerId() uint32
- func (x *AddHandlerRequest) GetMethods() []string
- func (*AddHandlerRequest) ProtoMessage()
- func (x *AddHandlerRequest) ProtoReflect() protoreflect.Message
- func (x *AddHandlerRequest) Reset()
- func (x *AddHandlerRequest) String() string
- type DonIDReply
- type GatewayConnectorClient
- type GatewayConnectorHandlerClient
- type GatewayConnectorHandlerInfo
- func (*GatewayConnectorHandlerInfo) Descriptor() ([]byte, []int)deprecated
- func (x *GatewayConnectorHandlerInfo) GetId() string
- func (*GatewayConnectorHandlerInfo) ProtoMessage()
- func (x *GatewayConnectorHandlerInfo) ProtoReflect() protoreflect.Message
- func (x *GatewayConnectorHandlerInfo) Reset()
- func (x *GatewayConnectorHandlerInfo) String() string
- type GatewayConnectorHandlerServer
- type GatewayConnectorServer
- type GatewayIDRequest
- type GatewayIDsReply
- type RemoveHandlerRequest
- func (*RemoveHandlerRequest) Descriptor() ([]byte, []int)deprecated
- func (x *RemoveHandlerRequest) GetMethods() []string
- func (*RemoveHandlerRequest) ProtoMessage()
- func (x *RemoveHandlerRequest) ProtoReflect() protoreflect.Message
- func (x *RemoveHandlerRequest) Reset()
- func (x *RemoveHandlerRequest) String() string
- type SendMessageRequest
- func (*SendMessageRequest) Descriptor() ([]byte, []int)deprecated
- func (x *SendMessageRequest) GetGatewayId() string
- func (x *SendMessageRequest) GetMessage() []byte
- func (*SendMessageRequest) ProtoMessage()
- func (x *SendMessageRequest) ProtoReflect() protoreflect.Message
- func (x *SendMessageRequest) Reset()
- func (x *SendMessageRequest) String() string
- type SignMessageReply
- type SignMessageRequest
- func (*SignMessageRequest) Descriptor() ([]byte, []int)deprecated
- func (x *SignMessageRequest) GetMessage() []byte
- func (*SignMessageRequest) ProtoMessage()
- func (x *SignMessageRequest) ProtoReflect() protoreflect.Message
- func (x *SignMessageRequest) Reset()
- func (x *SignMessageRequest) String() string
- type UnimplementedGatewayConnectorHandlerServer
- type UnimplementedGatewayConnectorServer
- func (UnimplementedGatewayConnectorServer) AddHandler(context.Context, *AddHandlerRequest) (*emptypb.Empty, error)
- func (UnimplementedGatewayConnectorServer) AwaitConnection(context.Context, *GatewayIDRequest) (*emptypb.Empty, error)
- func (UnimplementedGatewayConnectorServer) DonID(context.Context, *emptypb.Empty) (*DonIDReply, error)
- func (UnimplementedGatewayConnectorServer) GatewayIDs(context.Context, *emptypb.Empty) (*GatewayIDsReply, error)
- func (UnimplementedGatewayConnectorServer) RemoveHandler(context.Context, *RemoveHandlerRequest) (*emptypb.Empty, error)
- func (UnimplementedGatewayConnectorServer) SendToGateway(context.Context, *SendMessageRequest) (*emptypb.Empty, error)
- func (UnimplementedGatewayConnectorServer) SignMessage(context.Context, *SignMessageRequest) (*SignMessageReply, error)
- type UnsafeGatewayConnectorHandlerServer
- type UnsafeGatewayConnectorServer
Constants ¶
const ( GatewayConnector_AddHandler_FullMethodName = "/loop.GatewayConnector/AddHandler" GatewayConnector_RemoveHandler_FullMethodName = "/loop.GatewayConnector/RemoveHandler" GatewayConnector_SendToGateway_FullMethodName = "/loop.GatewayConnector/SendToGateway" GatewayConnector_SignMessage_FullMethodName = "/loop.GatewayConnector/SignMessage" GatewayConnector_GatewayIDs_FullMethodName = "/loop.GatewayConnector/GatewayIDs" GatewayConnector_DonID_FullMethodName = "/loop.GatewayConnector/DonID" GatewayConnector_AwaitConnection_FullMethodName = "/loop.GatewayConnector/AwaitConnection" )
const ( GatewayConnectorHandler_Id_FullMethodName = "/loop.GatewayConnectorHandler/Id" GatewayConnectorHandler_HandleGatewayMessage_FullMethodName = "/loop.GatewayConnectorHandler/HandleGatewayMessage" )
Variables ¶
var File_gateway_common_proto protoreflect.FileDescriptor
var File_gateway_connector_handler_proto protoreflect.FileDescriptor
var File_gateway_connector_proto protoreflect.FileDescriptor
var GatewayConnectorHandler_ServiceDesc = grpc.ServiceDesc{ ServiceName: "loop.GatewayConnectorHandler", HandlerType: (*GatewayConnectorHandlerServer)(nil), Methods: []grpc.MethodDesc{ { MethodName: "Id", Handler: _GatewayConnectorHandler_Id_Handler, }, { MethodName: "HandleGatewayMessage", Handler: _GatewayConnectorHandler_HandleGatewayMessage_Handler, }, }, Streams: []grpc.StreamDesc{}, Metadata: "gateway_connector_handler.proto", }
GatewayConnectorHandler_ServiceDesc is the grpc.ServiceDesc for GatewayConnectorHandler service. It's only intended for direct use with grpc.RegisterService, and not to be introspected or modified (even as a copy)
var GatewayConnector_ServiceDesc = grpc.ServiceDesc{ ServiceName: "loop.GatewayConnector", HandlerType: (*GatewayConnectorServer)(nil), Methods: []grpc.MethodDesc{ { MethodName: "AddHandler", Handler: _GatewayConnector_AddHandler_Handler, }, { MethodName: "RemoveHandler", Handler: _GatewayConnector_RemoveHandler_Handler, }, { MethodName: "SendToGateway", Handler: _GatewayConnector_SendToGateway_Handler, }, { MethodName: "SignMessage", Handler: _GatewayConnector_SignMessage_Handler, }, { MethodName: "GatewayIDs", Handler: _GatewayConnector_GatewayIDs_Handler, }, { MethodName: "DonID", Handler: _GatewayConnector_DonID_Handler, }, { MethodName: "AwaitConnection", Handler: _GatewayConnector_AwaitConnection_Handler, }, }, Streams: []grpc.StreamDesc{}, Metadata: "gateway_connector.proto", }
GatewayConnector_ServiceDesc is the grpc.ServiceDesc for GatewayConnector service. It's only intended for direct use with grpc.RegisterService, and not to be introspected or modified (even as a copy)
Functions ¶
func RegisterGatewayConnectorHandlerServer ¶
func RegisterGatewayConnectorHandlerServer(s grpc.ServiceRegistrar, srv GatewayConnectorHandlerServer)
func RegisterGatewayConnectorServer ¶
func RegisterGatewayConnectorServer(s grpc.ServiceRegistrar, srv GatewayConnectorServer)
Types ¶
type AddHandlerRequest ¶
type AddHandlerRequest struct {
Methods []string `protobuf:"bytes,1,rep,name=methods,proto3" json:"methods,omitempty"`
HandlerId uint32 `protobuf:"varint,2,opt,name=handler_id,json=handlerId,proto3" json:"handler_id,omitempty"`
// contains filtered or unexported fields
}
func (*AddHandlerRequest) Descriptor
deprecated
func (*AddHandlerRequest) Descriptor() ([]byte, []int)
Deprecated: Use AddHandlerRequest.ProtoReflect.Descriptor instead.
func (*AddHandlerRequest) GetHandlerId ¶
func (x *AddHandlerRequest) GetHandlerId() uint32
func (*AddHandlerRequest) GetMethods ¶
func (x *AddHandlerRequest) GetMethods() []string
func (*AddHandlerRequest) ProtoMessage ¶
func (*AddHandlerRequest) ProtoMessage()
func (*AddHandlerRequest) ProtoReflect ¶
func (x *AddHandlerRequest) ProtoReflect() protoreflect.Message
func (*AddHandlerRequest) Reset ¶
func (x *AddHandlerRequest) Reset()
func (*AddHandlerRequest) String ¶
func (x *AddHandlerRequest) String() string
type DonIDReply ¶
type DonIDReply struct {
DonId string `protobuf:"bytes,1,opt,name=don_id,json=donId,proto3" json:"don_id,omitempty"`
// contains filtered or unexported fields
}
func (*DonIDReply) Descriptor
deprecated
func (*DonIDReply) Descriptor() ([]byte, []int)
Deprecated: Use DonIDReply.ProtoReflect.Descriptor instead.
func (*DonIDReply) GetDonId ¶
func (x *DonIDReply) GetDonId() string
func (*DonIDReply) ProtoMessage ¶
func (*DonIDReply) ProtoMessage()
func (*DonIDReply) ProtoReflect ¶
func (x *DonIDReply) ProtoReflect() protoreflect.Message
func (*DonIDReply) Reset ¶
func (x *DonIDReply) Reset()
func (*DonIDReply) String ¶
func (x *DonIDReply) String() string
type GatewayConnectorClient ¶
type GatewayConnectorClient interface {
AddHandler(ctx context.Context, in *AddHandlerRequest, opts ...grpc.CallOption) (*emptypb.Empty, error)
RemoveHandler(ctx context.Context, in *RemoveHandlerRequest, opts ...grpc.CallOption) (*emptypb.Empty, error)
SendToGateway(ctx context.Context, in *SendMessageRequest, opts ...grpc.CallOption) (*emptypb.Empty, error)
SignMessage(ctx context.Context, in *SignMessageRequest, opts ...grpc.CallOption) (*SignMessageReply, error)
GatewayIDs(ctx context.Context, in *emptypb.Empty, opts ...grpc.CallOption) (*GatewayIDsReply, error)
DonID(ctx context.Context, in *emptypb.Empty, opts ...grpc.CallOption) (*DonIDReply, error)
AwaitConnection(ctx context.Context, in *GatewayIDRequest, opts ...grpc.CallOption) (*emptypb.Empty, error)
}
GatewayConnectorClient is the client API for GatewayConnector 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 NewGatewayConnectorClient ¶
func NewGatewayConnectorClient(cc grpc.ClientConnInterface) GatewayConnectorClient
type GatewayConnectorHandlerClient ¶
type GatewayConnectorHandlerClient interface {
Id(ctx context.Context, in *emptypb.Empty, opts ...grpc.CallOption) (*GatewayConnectorHandlerInfo, error)
HandleGatewayMessage(ctx context.Context, in *SendMessageRequest, opts ...grpc.CallOption) (*emptypb.Empty, error)
}
GatewayConnectorHandlerClient is the client API for GatewayConnectorHandler 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 NewGatewayConnectorHandlerClient ¶
func NewGatewayConnectorHandlerClient(cc grpc.ClientConnInterface) GatewayConnectorHandlerClient
type GatewayConnectorHandlerInfo ¶
type GatewayConnectorHandlerInfo struct {
Id string `protobuf:"bytes,1,opt,name=id,proto3" json:"id,omitempty"`
// contains filtered or unexported fields
}
func (*GatewayConnectorHandlerInfo) Descriptor
deprecated
func (*GatewayConnectorHandlerInfo) Descriptor() ([]byte, []int)
Deprecated: Use GatewayConnectorHandlerInfo.ProtoReflect.Descriptor instead.
func (*GatewayConnectorHandlerInfo) GetId ¶
func (x *GatewayConnectorHandlerInfo) GetId() string
func (*GatewayConnectorHandlerInfo) ProtoMessage ¶
func (*GatewayConnectorHandlerInfo) ProtoMessage()
func (*GatewayConnectorHandlerInfo) ProtoReflect ¶
func (x *GatewayConnectorHandlerInfo) ProtoReflect() protoreflect.Message
func (*GatewayConnectorHandlerInfo) Reset ¶
func (x *GatewayConnectorHandlerInfo) Reset()
func (*GatewayConnectorHandlerInfo) String ¶
func (x *GatewayConnectorHandlerInfo) String() string
type GatewayConnectorHandlerServer ¶
type GatewayConnectorHandlerServer interface {
Id(context.Context, *emptypb.Empty) (*GatewayConnectorHandlerInfo, error)
HandleGatewayMessage(context.Context, *SendMessageRequest) (*emptypb.Empty, error)
// contains filtered or unexported methods
}
GatewayConnectorHandlerServer is the server API for GatewayConnectorHandler service. All implementations must embed UnimplementedGatewayConnectorHandlerServer for forward compatibility.
type GatewayConnectorServer ¶
type GatewayConnectorServer interface {
AddHandler(context.Context, *AddHandlerRequest) (*emptypb.Empty, error)
RemoveHandler(context.Context, *RemoveHandlerRequest) (*emptypb.Empty, error)
SendToGateway(context.Context, *SendMessageRequest) (*emptypb.Empty, error)
SignMessage(context.Context, *SignMessageRequest) (*SignMessageReply, error)
GatewayIDs(context.Context, *emptypb.Empty) (*GatewayIDsReply, error)
DonID(context.Context, *emptypb.Empty) (*DonIDReply, error)
AwaitConnection(context.Context, *GatewayIDRequest) (*emptypb.Empty, error)
// contains filtered or unexported methods
}
GatewayConnectorServer is the server API for GatewayConnector service. All implementations must embed UnimplementedGatewayConnectorServer for forward compatibility.
type GatewayIDRequest ¶
type GatewayIDRequest struct {
GatewayId string `protobuf:"bytes,1,opt,name=gateway_id,json=gatewayId,proto3" json:"gateway_id,omitempty"`
// contains filtered or unexported fields
}
func (*GatewayIDRequest) Descriptor
deprecated
func (*GatewayIDRequest) Descriptor() ([]byte, []int)
Deprecated: Use GatewayIDRequest.ProtoReflect.Descriptor instead.
func (*GatewayIDRequest) GetGatewayId ¶
func (x *GatewayIDRequest) GetGatewayId() string
func (*GatewayIDRequest) ProtoMessage ¶
func (*GatewayIDRequest) ProtoMessage()
func (*GatewayIDRequest) ProtoReflect ¶
func (x *GatewayIDRequest) ProtoReflect() protoreflect.Message
func (*GatewayIDRequest) Reset ¶
func (x *GatewayIDRequest) Reset()
func (*GatewayIDRequest) String ¶
func (x *GatewayIDRequest) String() string
type GatewayIDsReply ¶
type GatewayIDsReply struct {
GatewayIds []string `protobuf:"bytes,1,rep,name=gateway_ids,json=gatewayIds,proto3" json:"gateway_ids,omitempty"`
// contains filtered or unexported fields
}
func (*GatewayIDsReply) Descriptor
deprecated
func (*GatewayIDsReply) Descriptor() ([]byte, []int)
Deprecated: Use GatewayIDsReply.ProtoReflect.Descriptor instead.
func (*GatewayIDsReply) GetGatewayIds ¶
func (x *GatewayIDsReply) GetGatewayIds() []string
func (*GatewayIDsReply) ProtoMessage ¶
func (*GatewayIDsReply) ProtoMessage()
func (*GatewayIDsReply) ProtoReflect ¶
func (x *GatewayIDsReply) ProtoReflect() protoreflect.Message
func (*GatewayIDsReply) Reset ¶
func (x *GatewayIDsReply) Reset()
func (*GatewayIDsReply) String ¶
func (x *GatewayIDsReply) String() string
type RemoveHandlerRequest ¶ added in v0.9.5
type RemoveHandlerRequest struct {
Methods []string `protobuf:"bytes,1,rep,name=methods,proto3" json:"methods,omitempty"`
// contains filtered or unexported fields
}
func (*RemoveHandlerRequest) Descriptor
deprecated
added in
v0.9.5
func (*RemoveHandlerRequest) Descriptor() ([]byte, []int)
Deprecated: Use RemoveHandlerRequest.ProtoReflect.Descriptor instead.
func (*RemoveHandlerRequest) GetMethods ¶ added in v0.9.5
func (x *RemoveHandlerRequest) GetMethods() []string
func (*RemoveHandlerRequest) ProtoMessage ¶ added in v0.9.5
func (*RemoveHandlerRequest) ProtoMessage()
func (*RemoveHandlerRequest) ProtoReflect ¶ added in v0.9.5
func (x *RemoveHandlerRequest) ProtoReflect() protoreflect.Message
func (*RemoveHandlerRequest) Reset ¶ added in v0.9.5
func (x *RemoveHandlerRequest) Reset()
func (*RemoveHandlerRequest) String ¶ added in v0.9.5
func (x *RemoveHandlerRequest) String() string
type SendMessageRequest ¶
type SendMessageRequest struct {
GatewayId string `protobuf:"bytes,1,opt,name=gateway_id,json=gatewayId,proto3" json:"gateway_id,omitempty"`
Message []byte `protobuf:"bytes,2,opt,name=message,proto3" json:"message,omitempty"`
// contains filtered or unexported fields
}
func (*SendMessageRequest) Descriptor
deprecated
func (*SendMessageRequest) Descriptor() ([]byte, []int)
Deprecated: Use SendMessageRequest.ProtoReflect.Descriptor instead.
func (*SendMessageRequest) GetGatewayId ¶
func (x *SendMessageRequest) GetGatewayId() string
func (*SendMessageRequest) GetMessage ¶
func (x *SendMessageRequest) GetMessage() []byte
func (*SendMessageRequest) ProtoMessage ¶
func (*SendMessageRequest) ProtoMessage()
func (*SendMessageRequest) ProtoReflect ¶
func (x *SendMessageRequest) ProtoReflect() protoreflect.Message
func (*SendMessageRequest) Reset ¶
func (x *SendMessageRequest) Reset()
func (*SendMessageRequest) String ¶
func (x *SendMessageRequest) String() string
type SignMessageReply ¶
type SignMessageReply struct {
Signature []byte `protobuf:"bytes,1,opt,name=signature,proto3" json:"signature,omitempty"`
// contains filtered or unexported fields
}
func (*SignMessageReply) Descriptor
deprecated
func (*SignMessageReply) Descriptor() ([]byte, []int)
Deprecated: Use SignMessageReply.ProtoReflect.Descriptor instead.
func (*SignMessageReply) GetSignature ¶
func (x *SignMessageReply) GetSignature() []byte
func (*SignMessageReply) ProtoMessage ¶
func (*SignMessageReply) ProtoMessage()
func (*SignMessageReply) ProtoReflect ¶
func (x *SignMessageReply) ProtoReflect() protoreflect.Message
func (*SignMessageReply) Reset ¶
func (x *SignMessageReply) Reset()
func (*SignMessageReply) String ¶
func (x *SignMessageReply) String() string
type SignMessageRequest ¶
type SignMessageRequest struct {
Message []byte `protobuf:"bytes,1,opt,name=message,proto3" json:"message,omitempty"`
// contains filtered or unexported fields
}
func (*SignMessageRequest) Descriptor
deprecated
func (*SignMessageRequest) Descriptor() ([]byte, []int)
Deprecated: Use SignMessageRequest.ProtoReflect.Descriptor instead.
func (*SignMessageRequest) GetMessage ¶
func (x *SignMessageRequest) GetMessage() []byte
func (*SignMessageRequest) ProtoMessage ¶
func (*SignMessageRequest) ProtoMessage()
func (*SignMessageRequest) ProtoReflect ¶
func (x *SignMessageRequest) ProtoReflect() protoreflect.Message
func (*SignMessageRequest) Reset ¶
func (x *SignMessageRequest) Reset()
func (*SignMessageRequest) String ¶
func (x *SignMessageRequest) String() string
type UnimplementedGatewayConnectorHandlerServer ¶
type UnimplementedGatewayConnectorHandlerServer struct{}
UnimplementedGatewayConnectorHandlerServer must be embedded to have forward compatible implementations.
NOTE: this should be embedded by value instead of pointer to avoid a nil pointer dereference when methods are called.
func (UnimplementedGatewayConnectorHandlerServer) HandleGatewayMessage ¶
func (UnimplementedGatewayConnectorHandlerServer) HandleGatewayMessage(context.Context, *SendMessageRequest) (*emptypb.Empty, error)
type UnimplementedGatewayConnectorServer ¶
type UnimplementedGatewayConnectorServer struct{}
UnimplementedGatewayConnectorServer must be embedded to have forward compatible implementations.
NOTE: this should be embedded by value instead of pointer to avoid a nil pointer dereference when methods are called.
func (UnimplementedGatewayConnectorServer) AddHandler ¶
func (UnimplementedGatewayConnectorServer) AddHandler(context.Context, *AddHandlerRequest) (*emptypb.Empty, error)
func (UnimplementedGatewayConnectorServer) AwaitConnection ¶
func (UnimplementedGatewayConnectorServer) AwaitConnection(context.Context, *GatewayIDRequest) (*emptypb.Empty, error)
func (UnimplementedGatewayConnectorServer) DonID ¶
func (UnimplementedGatewayConnectorServer) DonID(context.Context, *emptypb.Empty) (*DonIDReply, error)
func (UnimplementedGatewayConnectorServer) GatewayIDs ¶
func (UnimplementedGatewayConnectorServer) GatewayIDs(context.Context, *emptypb.Empty) (*GatewayIDsReply, error)
func (UnimplementedGatewayConnectorServer) RemoveHandler ¶ added in v0.9.5
func (UnimplementedGatewayConnectorServer) RemoveHandler(context.Context, *RemoveHandlerRequest) (*emptypb.Empty, error)
func (UnimplementedGatewayConnectorServer) SendToGateway ¶
func (UnimplementedGatewayConnectorServer) SendToGateway(context.Context, *SendMessageRequest) (*emptypb.Empty, error)
func (UnimplementedGatewayConnectorServer) SignMessage ¶
func (UnimplementedGatewayConnectorServer) SignMessage(context.Context, *SignMessageRequest) (*SignMessageReply, error)
type UnsafeGatewayConnectorHandlerServer ¶
type UnsafeGatewayConnectorHandlerServer interface {
// contains filtered or unexported methods
}
UnsafeGatewayConnectorHandlerServer may be embedded to opt out of forward compatibility for this service. Use of this interface is not recommended, as added methods to GatewayConnectorHandlerServer will result in compilation errors.
type UnsafeGatewayConnectorServer ¶
type UnsafeGatewayConnectorServer interface {
// contains filtered or unexported methods
}
UnsafeGatewayConnectorServer may be embedded to opt out of forward compatibility for this service. Use of this interface is not recommended, as added methods to GatewayConnectorServer will result in compilation errors.