tunnel

type BrowserTunnelParams struct {
	DevsyConfig      *config.Config
	Client           client2.BaseWorkspaceClient
	User             string
	TargetURL        string
	ForwardPorts     bool
	ExtraPorts       []string
	AuthSockID       string
	GitSSHSigningKey string

	// ExtraListeners holds pre-bound listeners for ExtraPorts entries,
	// keyed by host addr (e.g. "localhost:10800"). Set by the parent so the
	// helper can skip net.Listen and avoid a probe-to-listen TOCTOU race.
	ExtraListeners map[string]net.Listener

	// DaemonStartFunc is called when the client is a DaemonClient.
	// If nil, the SSH tunnel path is always used.
	DaemonStartFunc func(ctx context.Context) error

	// DisableIdleTimeout opts forwarded ports out of the
	// EXIT_AFTER_TIMEOUT idle shutdown. Set by callers whose lifecycle
	// is managed out-of-band (e.g. the detached browser-tunnel helper,
	// reaped by KillBrowserTunnel and devsy stop/delete).
	DisableIdleTimeout bool
}

type ContainerTunnel struct {
	// contains filtered or unexported fields
}

type DialFunc func(ctx context.Context) (io.ReadWriteCloser, error)

type ErrorKind int

type Handler func(ctx context.Context, containerClient *ssh.Client) error

type HandlerFunc func(ctx context.Context, stdout *os.File, stdin *os.File) error

type LocalTunnel struct {
	// contains filtered or unexported fields
}

type LocalTunnelOptions struct {
	// BasePort is the starting port to search from (default: 10800)
	BasePort int
	// DialFunc creates a connection to the remote SSH endpoint
	DialFunc DialFunc
	// HealthCheckInterval overrides the default health check interval (for testing).
	// If zero, defaults to healthCheckInterval (30s).
	HealthCheckInterval time.Duration
}

type PipeBridge struct {
	StdoutReader *os.File
	StdoutWriter *os.File
	StdinReader  *os.File
	StdinWriter  *os.File
}

type PortAttributeResolver func(port string) config2.PortAttribute

type RunServicesOptions struct {
	DevsyConfig                    *config.Config
	ContainerClient                *ssh.Client
	User                           string
	ForwardPorts                   bool
	ExtraPorts                     []string
	PlatformOptions                *devsy.PlatformOptions
	Workspace                      *provider.Workspace
	ConfigureDockerCredentials     bool
	ConfigureGitCredentials        bool
	ConfigureGitSSHSignatureHelper bool
	GitSSHSigningKey               string
	// ExtraListeners holds pre-bound listeners keyed by "host:port" so the
	// helper can skip net.Listen and avoid a probe-to-listen TOCTOU race.
	ExtraListeners map[string]net.Listener
	// DisableIdleTimeout forces a zero idle-shutdown duration regardless of
	// the EXIT_AFTER_TIMEOUT context option. Used by callers reaped
	// out-of-band rather than by idle activity.
	DisableIdleTimeout bool
}

type Tunnel func(ctx context.Context, stdin io.Reader, stdout io.Writer) error

type TunnelFunc func(ctx context.Context, stdin *os.File, stdout *os.File) error

type WorkspaceDialer struct {
	// DevsyBinary is the path to the devsy binary. If empty, os.Executable() is used.
	DevsyBinary string
	// Context is the Devsy context name
	Context string
	// User is the workspace user
	User string
	// Workspace is the workspace name/ID
	Workspace string
	// Workdir is the optional working directory
	Workdir string
	// GPGAgent enables GPG agent forwarding
	GPGAgent bool
}