Versions in this module Expand all Collapse all v1 v1.0.1 Jun 26, 2022 Changes in this version + var File_transport_internet_grpc_encoding_stream_proto protoreflect.FileDescriptor + var GRPCService_ServiceDesc = grpc.ServiceDesc + func NewHunkConn(hc HunkConn, cancel context.CancelFunc) net.Conn + func NewMultiHunkConn(hc MultiHunkConn, cancel context.CancelFunc) net.Conn + func RegisterGRPCServiceServer(s grpc.ServiceRegistrar, srv GRPCServiceServer) + func RegisterGRPCServiceServerX(s *grpc.Server, srv GRPCServiceServer, name string) + func ServerDesc(name string) grpc.ServiceDesc + type GRPCServiceClient interface + Tun func(ctx context.Context, opts ...grpc.CallOption) (GRPCService_TunClient, error) + TunMulti func(ctx context.Context, opts ...grpc.CallOption) (GRPCService_TunMultiClient, error) + func NewGRPCServiceClient(cc grpc.ClientConnInterface) GRPCServiceClient + type GRPCServiceClientX interface + Tun func(ctx context.Context, opts ...grpc.CallOption) (GRPCService_TunClient, error) + TunCustomName func(ctx context.Context, name string, opts ...grpc.CallOption) (GRPCService_TunClient, error) + TunMulti func(ctx context.Context, opts ...grpc.CallOption) (GRPCService_TunMultiClient, error) + TunMultiCustomName func(ctx context.Context, name string, opts ...grpc.CallOption) (GRPCService_TunMultiClient, error) + type GRPCServiceServer interface + Tun func(GRPCService_TunServer) error + TunMulti func(GRPCService_TunMultiServer) error + type GRPCService_TunClient interface + Recv func() (*Hunk, error) + Send func(*Hunk) error + type GRPCService_TunMultiClient interface + Recv func() (*MultiHunk, error) + Send func(*MultiHunk) error + type GRPCService_TunMultiServer interface + Recv func() (*MultiHunk, error) + Send func(*MultiHunk) error + type GRPCService_TunServer interface + Recv func() (*Hunk, error) + Send func(*Hunk) error + type Hunk struct + Data []byte + func (*Hunk) Descriptor() ([]byte, []int) + func (*Hunk) ProtoMessage() + func (x *Hunk) GetData() []byte + func (x *Hunk) ProtoReflect() protoreflect.Message + func (x *Hunk) Reset() + func (x *Hunk) String() string + type HunkConn interface + Context func() context.Context + Recv func() (*Hunk, error) + RecvMsg func(m interface{}) error + Send func(*Hunk) error + SendMsg func(m interface{}) error + type HunkReaderWriter struct + func NewHunkReadWriter(hc HunkConn, cancel context.CancelFunc) *HunkReaderWriter + func (h *HunkReaderWriter) Close() error + func (h *HunkReaderWriter) Read(buf []byte) (int, error) + func (h *HunkReaderWriter) ReadMultiBuffer() (buf.MultiBuffer, error) + func (h *HunkReaderWriter) Write(buf []byte) (int, error) + type MultiHunk struct + Data [][]byte + func (*MultiHunk) Descriptor() ([]byte, []int) + func (*MultiHunk) ProtoMessage() + func (x *MultiHunk) GetData() [][]byte + func (x *MultiHunk) ProtoReflect() protoreflect.Message + func (x *MultiHunk) Reset() + func (x *MultiHunk) String() string + type MultiHunkConn interface + Context func() context.Context + Recv func() (*MultiHunk, error) + RecvMsg func(m interface{}) error + Send func(*MultiHunk) error + SendMsg func(m interface{}) error + type MultiHunkReaderWriter struct + func NewMultiHunkReadWriter(hc MultiHunkConn, cancel context.CancelFunc) *MultiHunkReaderWriter + func (h *MultiHunkReaderWriter) Close() error + func (h *MultiHunkReaderWriter) ReadMultiBuffer() (buf.MultiBuffer, error) + func (h *MultiHunkReaderWriter) WriteMultiBuffer(mb buf.MultiBuffer) error + type StreamCloser interface + CloseSend func() error + type UnimplementedGRPCServiceServer struct + func (UnimplementedGRPCServiceServer) Tun(GRPCService_TunServer) error + func (UnimplementedGRPCServiceServer) TunMulti(GRPCService_TunMultiServer) error + type UnsafeGRPCServiceServer interface