Documentation
¶
Index ¶
Constants ¶
This section is empty.
Variables ¶
This section is empty.
Functions ¶
func PipeStdin ¶
func PipeStdin(stream StdinStreamClient, stdin io.Reader) error
PipeStdin reads input from Stdin and writes it to the grpc stream
func PipeStdout ¶
func PipeStdout(stream StdoutStreamClient, stdout, stderr io.Writer) error
PipeStdout reads stdout from grpc stream and writes it to stdout/stderr
Types ¶
type EmptyStdin ¶
type EmptyStdin struct{}
EmptyStdin is io.Read implementation what is empty, i.e. first read return EOF
func (*EmptyStdin) Read ¶
func (*EmptyStdin) Read(p []byte) (n int, err error)
type Reader ¶
type Reader struct {
// contains filtered or unexported fields
}
Reader is io.Reader implementation what reads bytes from RPC stream
func NewReader ¶
func NewReader(stream StdinStreamServer) *Reader
NewReader creates new Reader instance
type StdinStreamClient ¶
type StdinStreamClient interface {
Send(*containers.StdinStreamRequest) error
}
StdinStreamClient interface for the client what sends stdin stream messages
type StdinStreamServer ¶
type StdinStreamServer interface {
Recv() (*containers.StdinStreamRequest, error)
}
StdinStreamServer interface for the endpoint what takes stdin stream in
type StdoutStreamClient ¶
type StdoutStreamClient interface {
Recv() (*containers.StdoutStreamResponse, error)
CloseSend() error
}
StdoutStreamClient interface for the client what reads stream of log lines
type StdoutStreamServer ¶
type StdoutStreamServer interface {
Send(*containers.StdoutStreamResponse) error
}
StdoutStreamServer interface for the endpoint what returns stream of log lines
type Writer ¶
type Writer struct {
// contains filtered or unexported fields
}
Writer is io.Writer implementation what writes stdout/stderr bytes to RPC stream
func NewWriter ¶
func NewWriter(stream StdoutStreamServer, stderr bool) *Writer
NewWriter creates new Writer instance
Source Files
¶
- emptystdin.go
- pipes.go
- reader.go
- writer.go