Documentation ¶
Index ¶
Constants ¶
This section is empty.
Variables ¶
This section is empty.
Functions ¶
This section is empty.
Types ¶
type StreamInputClient ¶
type StreamInputClient struct{}
func NewStreamInputClient ¶
func NewStreamInputClient() *StreamInputClient
func (*StreamInputClient) StreamInput ¶
func (*StreamInputClient) StreamInput(cl grpcInputClient, stdin io.Reader) error
type StreamInputServer ¶
type StreamInputServer struct {
// contains filtered or unexported fields
}
func NewStreamInputServer ¶
func NewStreamInputServer() *StreamInputServer
func (*StreamInputServer) Close ¶
func (s *StreamInputServer) Close()
func (*StreamInputServer) ReceiveFrom ¶
func (s *StreamInputServer) ReceiveFrom(srv grpcInputServer) error
func (*StreamInputServer) WriteTo ¶
func (s *StreamInputServer) WriteTo(stdin io.WriteCloser) error
type StreamOutputClient ¶
type StreamOutputClient struct{}
func NewStreamOutputClient ¶
func NewStreamOutputClient() *StreamOutputClient
func (*StreamOutputClient) StreamOutput ¶
func (*StreamOutputClient) StreamOutput(cl grpcOutputClient, stdout, stderr io.Writer) error
type StreamOutputServer ¶
type StreamOutputServer struct {
// contains filtered or unexported fields
}
func NewStreamOutputServer ¶
func NewStreamOutputServer() *StreamOutputServer
func (*StreamOutputServer) ReadFrom ¶
func (s *StreamOutputServer) ReadFrom(stdout, stderr io.Reader) error
func (*StreamOutputServer) SendTo ¶
func (s *StreamOutputServer) SendTo(srv grpcOutputServer) error
Click to show internal directories.
Click to hide internal directories.