encoding

Documentation

Index

• Variables
• func RegisterGunServiceServer(s grpc.ServiceRegistrar, srv GunServiceServer)
• func RegisterGunServiceServerX(s *grpc.Server, srv GunServiceServer, name string)
• func ServerDesc(name string) grpc.ServiceDesc
• type ClientConn
  • func NewClientConn(client GunService_TunClient) *ClientConn
  • func (s *ClientConn) Close() error
  • func (*ClientConn) LocalAddr() net.Addr
  • func (s *ClientConn) Read(b []byte) (n int, err error)
  • func (*ClientConn) RemoteAddr() net.Addr
  • func (*ClientConn) SetDeadline(time.Time) error
  • func (*ClientConn) SetReadDeadline(time.Time) error
  • func (*ClientConn) SetWriteDeadline(time.Time) error
  • func (s *ClientConn) Write(b []byte) (n int, err error)
• type GunServiceClient
  • func NewGunServiceClient(cc grpc.ClientConnInterface) GunServiceClient
• type GunServiceClientX
• 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 ServerConn
  • func NewServerConn(server GunService_TunServer, over context.CancelFunc) *ServerConn
  • func (s *ServerConn) Close() error
  • func (*ServerConn) LocalAddr() net.Addr
  • func (s *ServerConn) Read(b []byte) (n int, err error)
  • func (*ServerConn) RemoteAddr() net.Addr
  • func (*ServerConn) SetDeadline(time.Time) error
  • func (*ServerConn) SetReadDeadline(time.Time) error
  • func (*ServerConn) SetWriteDeadline(time.Time) error
  • func (s *ServerConn) Write(b []byte) (n int, err error)
• type UnimplementedGunServiceServer
  • func (UnimplementedGunServiceServer) Tun(GunService_TunServer) error
• type UnsafeGunServiceServer

Variables

var File_transport_internet_grpc_encoding_stream_proto protoreflect.FileDescriptor

var GunService_ServiceDesc = grpc.ServiceDesc{
	ServiceName: "v2ray.core.transport.internet.grpc.encoding.GunService",
	HandlerType: (*GunServiceServer)(nil),
	Methods:     []grpc.MethodDesc{},
	Streams: []grpc.StreamDesc{
		{
			StreamName:    "Tun",
			Handler:       _GunService_Tun_Handler,
			ServerStreams: true,
			ClientStreams: true,
		},
	},
	Metadata: "transport/internet/grpc/encoding/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 RegisterGunServiceServer

func RegisterGunServiceServer(s grpc.ServiceRegistrar, srv GunServiceServer)

func RegisterGunServiceServerX

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

func ServerDesc

func ServerDesc(name string) grpc.ServiceDesc

Types

type ClientConn

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

func NewClientConn

func NewClientConn(client GunService_TunClient) *ClientConn

func (*ClientConn) Close

func (s *ClientConn) Close() error

func (*ClientConn) LocalAddr

func (*ClientConn) LocalAddr() net.Addr

func (*ClientConn) Read

func (s *ClientConn) Read(b []byte) (n int, err error)

func (*ClientConn) RemoteAddr

func (*ClientConn) RemoteAddr() net.Addr

func (*ClientConn) SetDeadline

func (*ClientConn) SetDeadline(time.Time) error

func (*ClientConn) SetReadDeadline

func (*ClientConn) SetReadDeadline(time.Time) error

func (*ClientConn) SetWriteDeadline

func (*ClientConn) SetWriteDeadline(time.Time) error

func (*ClientConn) Write

func (s *ClientConn) Write(b []byte) (n int, err 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 GunServiceClientX

type GunServiceClientX 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 ServerConn

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

func NewServerConn

func NewServerConn(server GunService_TunServer, over context.CancelFunc) *ServerConn

func (*ServerConn) Close

func (s *ServerConn) Close() error

func (*ServerConn) LocalAddr

func (*ServerConn) LocalAddr() net.Addr

func (*ServerConn) Read

func (s *ServerConn) Read(b []byte) (n int, err error)

func (*ServerConn) RemoteAddr

func (*ServerConn) RemoteAddr() net.Addr

func (*ServerConn) SetDeadline

func (*ServerConn) SetDeadline(time.Time) error

func (*ServerConn) SetReadDeadline

func (*ServerConn) SetReadDeadline(time.Time) error

func (*ServerConn) SetWriteDeadline

func (*ServerConn) SetWriteDeadline(time.Time) error

func (*ServerConn) Write

func (s *ServerConn) Write(b []byte) (n int, err 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.