Versions in this module Expand all Collapse all v1 v1.8.26 Sep 5, 2024 v1.8.25 Sep 5, 2024 Changes in this version + const GRPCService_TunMulti_FullMethodName + const GRPCService_Tun_FullMethodName + 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, tun, tunMulti string) + func ServerDesc(name, tun, tunMulti string) grpc.ServiceDesc + type GRPCServiceClient interface + Tun func(ctx context.Context, opts ...grpc.CallOption) (grpc.BidiStreamingClient[Hunk, Hunk], error) + TunMulti func(ctx context.Context, opts ...grpc.CallOption) (grpc.BidiStreamingClient[MultiHunk, MultiHunk], 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, tun string, opts ...grpc.CallOption) (GRPCService_TunClient, error) + TunMulti func(ctx context.Context, opts ...grpc.CallOption) (GRPCService_TunMultiClient, error) + TunMultiCustomName func(ctx context.Context, name, tunMulti string, opts ...grpc.CallOption) (GRPCService_TunMultiClient, error) + type GRPCServiceServer interface + Tun func(grpc.BidiStreamingServer[Hunk, Hunk]) error + TunMulti func(grpc.BidiStreamingServer[MultiHunk, MultiHunk]) error + type GRPCService_TunClient = grpc.BidiStreamingClient[Hunk, Hunk] + type GRPCService_TunMultiClient = grpc.BidiStreamingClient[MultiHunk, MultiHunk] + type GRPCService_TunMultiServer = grpc.BidiStreamingServer[MultiHunk, MultiHunk] + type GRPCService_TunServer = grpc.BidiStreamingServer[Hunk, Hunk] + 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(grpc.BidiStreamingServer[Hunk, Hunk]) error + func (UnimplementedGRPCServiceServer) TunMulti(grpc.BidiStreamingServer[MultiHunk, MultiHunk]) error + type UnsafeGRPCServiceServer interface
Go to main page