tunnelserver

func New(log log.Logger, options ...Option) *tunnelServer

func NewStreamReader(stream tunnel.Tunnel_StreamWorkspaceClient, log log.Logger) io.Reader

func NewStreamWriter(stream tunnel.Tunnel_StreamWorkspaceServer, log log.Logger) io.Writer

func NewTunnelClient(
	reader io.Reader,
	writer io.WriteCloser,
	exitOnClose bool,
	exitCode int,
) (tunnel.TunnelClient, error)

func NewTunnelLogger(ctx context.Context, client tunnel.TunnelClient, debug bool) log.Logger

func RunServicesServer(
	ctx context.Context,
	reader io.Reader,
	writer io.WriteCloser,
	allowGitCredentials, allowDockerCredentials bool,
	forwarder netstat.Forwarder,
	workspace *provider2.Workspace,
	log log.Logger,
	options ...Option,
) error

func RunSetupServer(
	ctx context.Context,
	reader io.Reader,
	writer io.WriteCloser,
	allowGitCredentials, allowDockerCredentials bool,
	mounts []*config.Mount,
	log log.Logger,
	options ...Option,
) (*config.Result, error)

func RunUpServer(
	ctx context.Context,
	reader io.Reader,
	writer io.WriteCloser,
	allowGitCredentials, allowDockerCredentials bool,
	workspace *provider2.Workspace,
	log log.Logger,
	options ...Option,
) (*config.Result, error)