pipe

type Client struct {
	// Logger is the logger used by the client.
	Logger *slog.Logger

	// Info is the connection information.
	Info *SSHClientInfo

	// SSHClient is the underlying SSH client.
	SSHClient *ssh.Client

	// Sessions is a map of all sessions.
	Sessions *syncmap.Map[string, *Session]

	// ctx is the context of the client. If the context is canceled, the client will close
	// all sessions and the SSH connection. No reconnect will be attempted.
	Context context.Context
	// contains filtered or unexported fields
}

type ReconnectReadWriteCloser struct {
	Context       context.Context
	Logger        *slog.Logger
	SSHClientInfo *SSHClientInfo
	Buffer        int
	Timeout       time.Duration

	ID      string
	Command string

	Client  *Client
	Session *Session
	// contains filtered or unexported fields
}

type SSHClientInfo struct {
	RemoteHost          string
	RemoteHostname      string
	RemoteUser          string
	KeyLocation         string
	KeyPassphrase       string
	CertificateLocation string
}

type SendData struct {
	Data  []byte
	Error error
	N     int
}

type Session struct {
	Context context.Context
	CtxDone chan time.Time
	Logger  *slog.Logger
	Client  *Client

	Done chan struct{}
	In   chan SendData
	Out  chan SendData

	ReadTimeout  time.Duration
	WriteTimeout time.Duration

	ID         string
	Command    string
	BufferSize int

	Session    *ssh.Session
	StdinPipe  io.WriteCloser
	StdoutPipe io.Reader
	// contains filtered or unexported fields
}