Documentation
¶
Index ¶
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 a reader that talks over RPC.
func NewClient ¶
func NewClient(client readerpb.ReaderClient) *Client
NewClient returns a reader connected to a remote reader
type Server ¶
type Server struct {
readerpb.UnimplementedReaderServer
// contains filtered or unexported fields
}
Server is an io.Reader that is managed over RPC.
func (*Server) Read ¶
func (s *Server) Read(ctx context.Context, req *readerpb.ReadRequest) (*readerpb.ReadResponse, error)
Source Files
Click to show internal directories.
Click to hide internal directories.