Versions in this module Expand all Collapse all v0 v0.0.15 Sep 23, 2022 v0.0.14 Sep 23, 2022 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(ctx context.Context, req *emptypb.Empty) (*emptypb.Empty, error) + func (s *Server) Read(ctx context.Context, req *connpb.ReadRequest) (*connpb.ReadResponse, error) + func (s *Server) SetDeadline(ctx context.Context, req *connpb.SetDeadlineRequest) (*emptypb.Empty, error) + func (s *Server) SetReadDeadline(ctx context.Context, req *connpb.SetDeadlineRequest) (*emptypb.Empty, error) + func (s *Server) SetWriteDeadline(ctx context.Context, req *connpb.SetDeadlineRequest) (*emptypb.Empty, error) + func (s *Server) Write(ctx context.Context, req *connpb.WriteRequest) (*connpb.WriteResponse, error)
Go to main page