gatewayconnector

package
v0.9.4 Latest Latest
Warning

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

 Go to latest Published: Sep 2, 2025 License: MIT Imports: 10 Imported by: 0

Documentation

Index

Constants

View Source 
const (
	GatewayConnector_AddHandler_FullMethodName      = "/loop.GatewayConnector/AddHandler"
	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"
)
View Source 
const (
	GatewayConnectorHandler_Id_FullMethodName                   = "/loop.GatewayConnectorHandler/Id"
	GatewayConnectorHandler_HandleGatewayMessage_FullMethodName = "/loop.GatewayConnectorHandler/HandleGatewayMessage"
)

Variables

View Source 
var File_gateway_common_proto protoreflect.FileDescriptor
View Source 
var File_gateway_connector_handler_proto protoreflect.FileDescriptor
View Source 
var File_gateway_connector_proto protoreflect.FileDescriptor
View Source 
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)

View Source 
var GatewayConnector_ServiceDesc = grpc.ServiceDesc{
	ServiceName: "loop.GatewayConnector",
	HandlerType: (*GatewayConnectorServer)(nil),
	Methods: []grpc.MethodDesc{
		{
			MethodName: "AddHandler",
			Handler:    _GatewayConnector_AddHandler_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)
	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)
	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 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)

func (UnimplementedGatewayConnectorHandlerServer) Id 

func (UnimplementedGatewayConnectorHandlerServer) Id(context.Context, *emptypb.Empty) (*GatewayConnectorHandlerInfo, 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) 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.

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.