Versions in this module Expand all Collapse all v1 v1.1.1 Dec 18, 2024 Changes in this version + type Client struct + func NewClient(client connpb.ConnClient, local, remote net.Addr, toClose ...io.Closer) *Client + func (c *Client) Close() error + func (c *Client) LocalAddr() net.Addr + func (c *Client) Read(p []byte) (int, error) + func (c *Client) RemoteAddr() net.Addr + func (c *Client) SetDeadline(t time.Time) error + func (c *Client) SetReadDeadline(t time.Time) error + func (c *Client) SetWriteDeadline(t time.Time) error + func (c *Client) Write(b []byte) (int, error) + type Server struct + func NewServer(conn net.Conn, closer *grpcutils.ServerCloser) *Server + func (s *Server) Close(context.Context, *emptypb.Empty) (*emptypb.Empty, error) + func (s *Server) Read(_ context.Context, req *connpb.ReadRequest) (*connpb.ReadResponse, error) + func (s *Server) SetDeadline(_ context.Context, req *connpb.SetDeadlineRequest) (*emptypb.Empty, error) + func (s *Server) SetReadDeadline(_ context.Context, req *connpb.SetDeadlineRequest) (*emptypb.Empty, error) + func (s *Server) SetWriteDeadline(_ context.Context, req *connpb.SetDeadlineRequest) (*emptypb.Empty, error) + func (s *Server) Write(_ context.Context, req *connpb.WriteRequest) (*connpb.WriteResponse, error)
Go to main page