v2raygrpc

Documentation

Index

• Variables
• func NewClient(ctx context.Context, dialer N.Dialer, serverAddr M.Socksaddr, ...) adapter.V2RayClientTransport
• func RegisterGunServiceCustomNameServer(s *grpc.Server, srv GunServiceServer, name string)
• func RegisterGunServiceServer(s grpc.ServiceRegistrar, srv GunServiceServer)
• func ServerDesc(name string) grpc.ServiceDesc
• type Client
  • func (c *Client) Close() error
  • func (c *Client) DialContext(ctx context.Context) (net.Conn, error)
• type GRPCConn
  • func NewGRPCConn(service GunService, cancel context.CancelFunc) *GRPCConn
  • func (c *GRPCConn) Close() error
  • func (c *GRPCConn) LocalAddr() net.Addr
  • func (c *GRPCConn) Read(b []byte) (n int, err error)
  • func (c *GRPCConn) RemoteAddr() net.Addr
  • func (c *GRPCConn) SetDeadline(t time.Time) error
  • func (c *GRPCConn) SetReadDeadline(t time.Time) error
  • func (c *GRPCConn) SetWriteDeadline(t time.Time) error
  • func (c *GRPCConn) Upstream() any
  • func (c *GRPCConn) Write(b []byte) (n int, err error)
• type GunService
• type GunServiceClient
  • func NewGunServiceClient(cc grpc.ClientConnInterface) GunServiceClient
• type GunServiceCustomNameClient
• type GunServiceServer
• type GunService_TunClient
• type GunService_TunServer
• type Hunk
  • func (*Hunk) Descriptor() ([]byte, []int)
  • func (x *Hunk) GetData() []byte
  • func (*Hunk) ProtoMessage()
  • func (x *Hunk) ProtoReflect() protoreflect.Message
  • func (x *Hunk) Reset()
  • func (x *Hunk) String() string
• type Server
  • func NewServer(ctx context.Context, options option.V2RayGRPCOptions, tlsConfig *tls.Config, ...) *Server
  • func (s *Server) Close() error
  • func (s *Server) Network() []string
  • func (s *Server) Serve(listener net.Listener) error
  • func (s *Server) ServePacket(listener net.PacketConn) error
  • func (s *Server) Tun(server GunService_TunServer) error
• type UnimplementedGunServiceServer
  • func (UnimplementedGunServiceServer) Tun(GunService_TunServer) error
• type UnsafeGunServiceServer

Variables

var File_transport_v2raygrpc_stream_proto protoreflect.FileDescriptor

var GunService_ServiceDesc = grpc.ServiceDesc{
	ServiceName: "transport.v2raygrpc.GunService",
	HandlerType: (*GunServiceServer)(nil),
	Methods:     []grpc.MethodDesc{},
	Streams: []grpc.StreamDesc{
		{
			StreamName:    "Tun",
			Handler:       _GunService_Tun_Handler,
			ServerStreams: true,
			ClientStreams: true,
		},
	},
	Metadata: "transport/v2raygrpc/stream.proto",
}

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

Functions

func NewClient

func NewClient(ctx context.Context, dialer N.Dialer, serverAddr M.Socksaddr, options option.V2RayGRPCOptions, tlsConfig *tls.Config) adapter.V2RayClientTransport

func RegisterGunServiceCustomNameServer

func RegisterGunServiceCustomNameServer(s *grpc.Server, srv GunServiceServer, name string)

func RegisterGunServiceServer

func RegisterGunServiceServer(s grpc.ServiceRegistrar, srv GunServiceServer)

func ServerDesc

func ServerDesc(name string) grpc.ServiceDesc

Types

type Client

type Client struct {
	// contains filtered or unexported fields
}

func (*Client) Close

func (c *Client) Close() error

func (*Client) DialContext

func (c *Client) DialContext(ctx context.Context) (net.Conn, error)

type GRPCConn

type GRPCConn struct {
	GunService
	// contains filtered or unexported fields
}

func NewGRPCConn

func NewGRPCConn(service GunService, cancel context.CancelFunc) *GRPCConn

func (*GRPCConn) Close

func (c *GRPCConn) Close() error

func (*GRPCConn) LocalAddr

func (c *GRPCConn) LocalAddr() net.Addr

func (*GRPCConn) Read

func (c *GRPCConn) Read(b []byte) (n int, err error)

func (*GRPCConn) RemoteAddr

func (c *GRPCConn) RemoteAddr() net.Addr

func (*GRPCConn) SetDeadline

func (c *GRPCConn) SetDeadline(t time.Time) error

func (*GRPCConn) SetReadDeadline

func (c *GRPCConn) SetReadDeadline(t time.Time) error

func (*GRPCConn) SetWriteDeadline

func (c *GRPCConn) SetWriteDeadline(t time.Time) error

func (*GRPCConn) Upstream

func (c *GRPCConn) Upstream() any

func (*GRPCConn) Write

func (c *GRPCConn) Write(b []byte) (n int, err error)

type GunService

type GunService interface {
	Context() context.Context
	Send(*Hunk) error
	Recv() (*Hunk, error)
}

type GunServiceClient

type GunServiceClient interface {
	Tun(ctx context.Context, opts ...grpc.CallOption) (GunService_TunClient, error)
}

GunServiceClient is the client API for GunService 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 NewGunServiceClient

func NewGunServiceClient(cc grpc.ClientConnInterface) GunServiceClient

type GunServiceCustomNameClient

type GunServiceCustomNameClient interface {
	TunCustomName(ctx context.Context, name string, opts ...grpc.CallOption) (GunService_TunClient, error)
	Tun(ctx context.Context, opts ...grpc.CallOption) (GunService_TunClient, error)
}

type GunServiceServer

type GunServiceServer interface {
	Tun(GunService_TunServer) error
	// contains filtered or unexported methods
}

GunServiceServer is the server API for GunService service. All implementations must embed UnimplementedGunServiceServer for forward compatibility

type GunService_TunClient

type GunService_TunClient interface {
	Send(*Hunk) error
	Recv() (*Hunk, error)
	grpc.ClientStream
}

type GunService_TunServer

type GunService_TunServer interface {
	Send(*Hunk) error
	Recv() (*Hunk, error)
	grpc.ServerStream
}

type Hunk

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

func (*Hunk) Descriptor

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

Deprecated: Use Hunk.ProtoReflect.Descriptor instead.

func (*Hunk) GetData

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

func (*Hunk) ProtoMessage

func (*Hunk) ProtoMessage()

func (*Hunk) ProtoReflect

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

func (*Hunk) Reset

func (x *Hunk) Reset()

func (*Hunk) String

func (x *Hunk) String() string

type Server

type Server struct {
	// contains filtered or unexported fields
}

func NewServer

func NewServer(ctx context.Context, options option.V2RayGRPCOptions, tlsConfig *tls.Config, handler N.TCPConnectionHandler) *Server

func (*Server) Close

func (s *Server) Close() error

func (*Server) Network

func (s *Server) Network() []string

func (*Server) Serve

func (s *Server) Serve(listener net.Listener) error

func (*Server) ServePacket

func (s *Server) ServePacket(listener net.PacketConn) error

func (*Server) Tun

func (s *Server) Tun(server GunService_TunServer) error

type UnimplementedGunServiceServer

type UnimplementedGunServiceServer struct{}

UnimplementedGunServiceServer must be embedded to have forward compatible implementations.

func (UnimplementedGunServiceServer) Tun

func (UnimplementedGunServiceServer) Tun(GunService_TunServer) error

type UnsafeGunServiceServer

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

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