utils

type BaseReverseTunnelRoutines[T any] struct {
	// contains filtered or unexported fields
}

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

type BundleCmdProvider func(ctx context.Context, node connection.Interface, parentDir, bundleDir string) (connection.Command, error)

type BundleOpt func(*Bundle)

type ByteSequenceMatcher struct {
	// settings
	Pattern string
	// contains filtered or unexported fields
}

type Check struct {
	Session *session.Session
	// contains filtered or unexported fields
}

type CommandConsumer func(*session.Session, string) ssh.Command

type CommandKiller func(connection.Command)

type CommandPreparator func(connection.Command)

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

type EmptyReverseTunnelKiller struct{}

type PassphraseConsumer interface {
	DefaultPassword() []byte
	AskPassword(ctx context.Context, prompt string) ([]byte, error)
}

type PresentCloseHandler func(isPresent bool)

type RunScriptReverseTunnelChecker struct {
	*BaseReverseTunnelRoutines[RunScriptReverseTunnelChecker]
	// contains filtered or unexported fields
}

type RunScriptReverseTunnelKiller struct {
	*BaseReverseTunnelRoutines[RunScriptReverseTunnelKiller]
	// contains filtered or unexported fields
}

type ScriptPath interface {
	IsSudo() bool
	UploadDir() string
	Settings() settings.Settings
}

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

type TunnelBackend interface {
	// StartTunnel brings a tunnel instance up. Implementations must refuse to
	// start (return an error) once ctx is canceled — this is what guarantees
	// nothing is brought up behind a Stop.
	StartTunnel(ctx context.Context) error

	// StopTunnel tears the current tunnel instance down. Must be idempotent
	// and must not block on the supervisor making progress.
	StopTunnel()

	// TunnelDone returns the termination channel of the current instance, or
	// nil when nothing is up. The channel reports the instance's exit at most
	// once and must never block the sender (i.e. it is buffered); it stays
	// valid after the instance dies.
	TunnelDone() <-chan error

	// CheckTunnel probes the tunnel end-to-end, honoring ctx. True = healthy.
	// Retry policy lives in the implementation; it also paces the supervision
	// loop, so a CheckTunnel that fails instantly produces a hot restart loop —
	// keep at least one retry/wait inside.
	CheckTunnel(ctx context.Context) bool
}

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