proto

Documentation

Index

• Variables
• func RegisterPeerServiceServer(s grpc.ServiceRegistrar, srv PeerServiceServer)
• type Packet
  • func (*Packet) Descriptor() ([]byte, []int)
  • 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
  • func NewPeerServiceClient(cc grpc.ClientConnInterface) PeerServiceClient
• type PeerServiceServer
• type PeerService_ConnectClient
• type PeerService_ConnectServer
• type UnimplementedPeerServiceServer
  • func (UnimplementedPeerServiceServer) Connect(PeerService_ConnectServer) error
• type UnsafePeerServiceServer

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

func (*Packet) Descriptor() ([]byte, []int)

Deprecated: Use Packet.ProtoReflect.Descriptor instead.

func (*Packet) GetData

func (x *Packet) GetData() []byte

func (*Packet) GetDest

func (x *Packet) GetDest() string

func (*Packet) GetDestID

func (x *Packet) GetDestID() int64

func (*Packet) GetError

func (x *Packet) GetError() string

func (*Packet) GetKind

func (x *Packet) GetKind() int64

func (*Packet) GetSrc

func (x *Packet) GetSrc() string

func (*Packet) GetSrcID

func (x *Packet) GetSrcID() int64

func (*Packet) ProtoMessage

func (*Packet) ProtoMessage()

func (*Packet) ProtoReflect

func (x *Packet) ProtoReflect() protoreflect.Message

func (*Packet) Reset

func (x *Packet) Reset()

func (*Packet) String

func (x *Packet) String() string

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 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.

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.