connectorruntime

type Dialer interface {
	DialContext(ctx context.Context, network, address string) (net.Conn, error)
}

type DialerFunc func(ctx context.Context, network, address string) (net.Conn, error)

type ExecRequest struct {
	Server string
	Plan   providerapi.ConnectorPlan
	Dialer Dialer
	Stream StreamConfig
}

type Executor interface {
	RunShell(ctx context.Context, request ShellRequest) error
	RunExec(ctx context.Context, request ExecRequest) (int, error)
}

type InteractiveSession interface {
	Run(ctx context.Context, stream StreamConfig) error
	Resize(ctx context.Context, size TerminalSize) error
	Close() error
}

type ShellRequest struct {
	Server         string
	Plan           providerapi.ConnectorPlan
	LocalRCCommand string
	StartupMarker  string
	Dialer         Dialer
	Stream         StreamConfig
}

type StreamConfig struct {
	Stdin  io.Reader
	Stdout io.Writer
	Stderr io.Writer
}

type StreamSession interface {
	Run(ctx context.Context, stream StreamConfig) (int, error)
	Close() error
}

type TerminalSize struct {
	Cols int
	Rows int
}