Documentation ¶
Index ¶
- type 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
- 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)
Constants ¶
This section is empty.
Variables ¶
This section is empty.
Functions ¶
This section is empty.
Types ¶
type Client ¶
type Client struct {
// contains filtered or unexported fields
}
Client is an implementation of a connection that talks over RPC.
func (*Client) RemoteAddr ¶
type Server ¶
type Server struct { connpb.UnsafeConnServer // contains filtered or unexported fields }
Server is an http.Conn that is managed over RPC.
func NewServer ¶
func NewServer(conn net.Conn, closer *grpcutils.ServerCloser) *Server
NewServer returns an http.Conn managed remotely
func (*Server) Read ¶
func (s *Server) Read(_ context.Context, req *connpb.ReadRequest) (*connpb.ReadResponse, error)
func (*Server) SetDeadline ¶
func (*Server) SetReadDeadline ¶
func (*Server) SetWriteDeadline ¶
func (*Server) Write ¶
func (s *Server) Write(_ context.Context, req *connpb.WriteRequest) (*connpb.WriteResponse, error)
Click to show internal directories.
Click to hide internal directories.