Documentation
¶
Index ¶
- Variables
- func RegisterPeerServiceServer(s grpc.ServiceRegistrar, srv PeerServiceServer)
- type Packet
- func (*Packet) Descriptor() ([]byte, []int)deprecated
- func (x *Packet) GetData() []byte
- func (x *Packet) GetDest() string
- func (x *Packet) GetDestID() int64
- func (x *Packet) GetError() string
- func (x *Packet) GetKind() int64
- func (x *Packet) GetSrc() string
- func (x *Packet) GetSrcID() int64
- func (*Packet) ProtoMessage()
- func (x *Packet) ProtoReflect() protoreflect.Message
- func (x *Packet) Reset()
- func (x *Packet) String() string
- type PeerServiceClient
- type PeerServiceServer
- type PeerService_ConnectClient
- type PeerService_ConnectServer
- type UnimplementedPeerServiceServer
- type UnsafePeerServiceServer
Constants ¶
This section is empty.
Variables ¶
var File_pkg_edge_tunnel_proto_tunnel_proto protoreflect.FileDescriptor
var PeerService_ServiceDesc = grpc.ServiceDesc{
ServiceName: "PeerService",
HandlerType: (*PeerServiceServer)(nil),
Methods: []grpc.MethodDesc{},
Streams: []grpc.StreamDesc{
{
StreamName: "Connect",
Handler: _PeerService_Connect_Handler,
ServerStreams: true,
ClientStreams: true,
},
},
Metadata: "pkg/edge/tunnel/proto/tunnel.proto",
}
PeerService_ServiceDesc is the grpc.ServiceDesc for PeerService service. It's only intended for direct use with grpc.RegisterService, and not to be introspected or modified (even as a copy)
Functions ¶
func RegisterPeerServiceServer ¶
func RegisterPeerServiceServer(s grpc.ServiceRegistrar, srv PeerServiceServer)
Types ¶
type Packet ¶
type Packet struct {
Src string `protobuf:"bytes,1,opt,name=src,proto3" json:"src,omitempty"`
SrcID int64 `protobuf:"varint,2,opt,name=srcID,proto3" json:"srcID,omitempty"`
Dest string `protobuf:"bytes,3,opt,name=dest,proto3" json:"dest,omitempty"`
DestID int64 `protobuf:"varint,4,opt,name=destID,proto3" json:"destID,omitempty"`
Kind int64 `protobuf:"varint,5,opt,name=kind,proto3" json:"kind,omitempty"`
Data []byte `protobuf:"bytes,6,opt,name=data,proto3" json:"data,omitempty"`
Error string `protobuf:"bytes,7,opt,name=error,proto3" json:"error,omitempty"`
// contains filtered or unexported fields
}
func (*Packet) Descriptor
deprecated
func (*Packet) Descriptor() ([]byte, []int)
Deprecated: Use Packet.ProtoReflect.Descriptor instead.
func (*Packet) ProtoMessage ¶
func (*Packet) ProtoMessage()
func (*Packet) ProtoReflect ¶
func (x *Packet) ProtoReflect() protoreflect.Message
type PeerServiceClient ¶
type PeerServiceClient interface {
Connect(ctx context.Context, opts ...grpc.CallOption) (PeerService_ConnectClient, error)
}
PeerServiceClient is the client API for PeerService service.
For semantics around ctx use and closing/ending streaming RPCs, please refer to https://pkgo.dev/google.golang.org/grpc/?tab=doc#ClientConn.NewStream.
func NewPeerServiceClient ¶
func NewPeerServiceClient(cc grpc.ClientConnInterface) PeerServiceClient
type PeerServiceServer ¶
type PeerServiceServer interface {
Connect(PeerService_ConnectServer) error
// contains filtered or unexported methods
}
PeerServiceServer is the server API for PeerService service. All implementations must embed UnimplementedPeerServiceServer for forward compatibility
type PeerService_ConnectClient ¶
type PeerService_ConnectClient interface {
Send(*Packet) error
Recv() (*Packet, error)
grpc.ClientStream
}
type PeerService_ConnectServer ¶
type PeerService_ConnectServer interface {
Send(*Packet) error
Recv() (*Packet, error)
grpc.ServerStream
}
type UnimplementedPeerServiceServer ¶
type UnimplementedPeerServiceServer struct {
}
UnimplementedPeerServiceServer must be embedded to have forward compatible implementations.
type UnsafePeerServiceServer ¶
type UnsafePeerServiceServer interface {
// contains filtered or unexported methods
}
UnsafePeerServiceServer may be embedded to opt out of forward compatibility for this service. Use of this interface is not recommended, as added methods to PeerServiceServer will result in compilation errors.
Source Files