stream

Documentation

Index

• Constants
• func Handler(recv func() (StdoutStderrResponse, error), send func(chan error), ...) (int32, error)
• func ProxyPktLine(c Conn, stdin io.Reader, stdout, stderr io.Writer) error
• type Conn
• type Sender
• type StdoutStderrResponse

Constants

const (
	BandStdout = 1
	BandStderr = 2
)

BandStdout and BandStderr are the pktline band ID's for stdout and stderr, respectively.

Functions

func Handler

func Handler(recv func() (StdoutStderrResponse, error), send func(chan error), stdout, stderr io.Writer) (int32, error)

Handler takes care of sending and receiving to and from the stream

func ProxyPktLine

func ProxyPktLine(c Conn, stdin io.Reader, stdout, stderr io.Writer) error

ProxyPktLine lets a client de-multiplex and proxy stdin, stdout and stderr streams. Stdout and stderr are interleaved with Git's pktline format.

Types

type Conn

type Conn interface {
	io.Reader
	io.Writer
	CloseWrite() error
}

Conn represents a bi-directional client side connection.

type Sender

type Sender func(chan error)

Sender is a function that sends input data to the stream

type StdoutStderrResponse

type StdoutStderrResponse interface {
	GetExitStatus() *gitalypb.ExitStatus
	GetStderr() []byte
	GetStdout() []byte
}

StdoutStderrResponse is an interface for RPC responses that need to stream stderr and stdout