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) 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://pkg.go.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 UnimplementedPeerServiceServer ¶
type UnimplementedPeerServiceServer struct { }
UnimplementedPeerServiceServer must be embedded to have forward compatible implementations.
func (UnimplementedPeerServiceServer) Connect ¶
func (UnimplementedPeerServiceServer) Connect(PeerService_ConnectServer) error
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.