grpc_tunnel

Documentation

Index

• Variables
• func RegisterGRPCTunnelServer(s grpc.ServiceRegistrar, srv GRPCTunnelServer)
• func RegisterGRPCTunnelServerAddon(s grpc.ServiceRegistrar, srv GRPCTunnelServer, serviceName string)
• type Bytes
  • func (*Bytes) Descriptor() ([]byte, []int)
  • func (x *Bytes) GetB() []byte
  • func (*Bytes) ProtoMessage()
  • func (x *Bytes) ProtoReflect() protoreflect.Message
  • func (x *Bytes) Reset()
  • func (x *Bytes) String() string
• type GRPCTunnelClient
  • func NewGRPCTunnelClient(cc grpc.ClientConnInterface) GRPCTunnelClient
  • func NewGRPCTunnelClientAddon(cc grpc.ClientConnInterface, serviceName string) GRPCTunnelClient
• type GRPCTunnelServer
• type GRPCTunnel_ConnectClient
• type GRPCTunnel_ConnectServer
• type TunnelPeer
• type UnimplementedGRPCTunnelServer
  • func (UnimplementedGRPCTunnelServer) Connect(GRPCTunnel_ConnectServer) error
• type UnsafeGRPCTunnelServer

Variables

var File_core_grpc_tunnel_grpc_tunnel_proto protoreflect.FileDescriptor

var GRPCTunnel_ServiceDesc = grpc.ServiceDesc{
	ServiceName: "grpc_tunnel.GRPCTunnel",
	HandlerType: (*GRPCTunnelServer)(nil),
	Methods:     []grpc.MethodDesc{},
	Streams: []grpc.StreamDesc{
		{
			StreamName:    "Connect",
			Handler:       _GRPCTunnel_Connect_Handler,
			ServerStreams: true,
			ClientStreams: true,
		},
	},
	Metadata: "core/grpc_tunnel/grpc_tunnel.proto",
}

GRPCTunnel_ServiceDesc is the grpc.ServiceDesc for GRPCTunnel service. It's only intended for direct use with grpc.RegisterService, and not to be introspected or modified (even as a copy)

Functions

func RegisterGRPCTunnelServer

func RegisterGRPCTunnelServer(s grpc.ServiceRegistrar, srv GRPCTunnelServer)

func RegisterGRPCTunnelServerAddon

func RegisterGRPCTunnelServerAddon(s grpc.ServiceRegistrar, srv GRPCTunnelServer, serviceName string)

Types

type Bytes

type Bytes struct {
	B []byte `protobuf:"bytes,1,opt,name=b,proto3" json:"b,omitempty"`
	// contains filtered or unexported fields
}

func (*Bytes) Descriptor

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

Deprecated: Use Bytes.ProtoReflect.Descriptor instead.

func (*Bytes) GetB

func (x *Bytes) GetB() []byte

func (*Bytes) ProtoMessage

func (*Bytes) ProtoMessage()

func (*Bytes) ProtoReflect

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

func (*Bytes) Reset

func (x *Bytes) Reset()

func (*Bytes) String

func (x *Bytes) String() string

type GRPCTunnelClient

type GRPCTunnelClient interface {
	Connect(ctx context.Context, opts ...grpc.CallOption) (GRPCTunnel_ConnectClient, error)
}

GRPCTunnelClient is the client API for GRPCTunnel 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 NewGRPCTunnelClient

func NewGRPCTunnelClient(cc grpc.ClientConnInterface) GRPCTunnelClient

func NewGRPCTunnelClientAddon

func NewGRPCTunnelClientAddon(cc grpc.ClientConnInterface, serviceName string) GRPCTunnelClient

type GRPCTunnelServer

type GRPCTunnelServer interface {
	Connect(GRPCTunnel_ConnectServer) error
	// contains filtered or unexported methods
}

GRPCTunnelServer is the server API for GRPCTunnel service. All implementations must embed UnimplementedGRPCTunnelServer for forward compatibility

type GRPCTunnel_ConnectClient

type GRPCTunnel_ConnectClient interface {
	Send(*Bytes) error
	Recv() (*Bytes, error)
	grpc.ClientStream
}

type GRPCTunnel_ConnectServer

type GRPCTunnel_ConnectServer interface {
	Send(*Bytes) error
	Recv() (*Bytes, error)
	grpc.ServerStream
}

type TunnelPeer

type TunnelPeer interface {
	Send(*Bytes) error
	Recv() (*Bytes, error)
	Context() context.Context
}

TunnelPeer is a abbr for both gRPC client and server.

type UnimplementedGRPCTunnelServer

type UnimplementedGRPCTunnelServer struct {
}

UnimplementedGRPCTunnelServer must be embedded to have forward compatible implementations.

func (UnimplementedGRPCTunnelServer) Connect

func (UnimplementedGRPCTunnelServer) Connect(GRPCTunnel_ConnectServer) error

type UnsafeGRPCTunnelServer

type UnsafeGRPCTunnelServer interface {
	// contains filtered or unexported methods
}

UnsafeGRPCTunnelServer may be embedded to opt out of forward compatibility for this service. Use of this interface is not recommended, as added methods to GRPCTunnelServer will result in compilation errors.