exec

type ClientFactory[ClientT any] interface {
	CreateClient(ctx *types.PluginContext) (*ClientT, error)
	RefreshClient(ctx *types.PluginContext, client *ClientT) error
	StartClient(ctx *types.PluginContext, client *ClientT) error
	StopClient(ctx *types.PluginContext, client *ClientT) error
}

type CommandHandler func(ctx *types.PluginContext, opts SessionOptions) (
	stdout io.Reader,
	stderr io.Reader,
	err error,
)

type Handler struct {
	Plugin         string                          `json:"plugin"`
	Resource       string                          `json:"resource"`
	TargetBuilder  sdkresource.ActionTargetBuilder `json:"target_builder"`
	TTYHandler     TTYHandler                      `json:"-"`
	CommandHandler CommandHandler                  `json:"-"`
	// if the handler supports resizing, it will be sent through the channel instead of the pty file
	HandlesResize bool `json:"-"`
}

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

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

type Plugin struct {
	plugin.Plugin
	Impl Provider
}

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

type PluginOpts struct {
	Handlers []Handler `json:"handlers"`
}

type PluginServer struct {
	Impl Provider
	// contains filtered or unexported fields
}

type Provider interface {
	// GetSupportedResources returns the supported resource types
	GetSupportedResources(ctx *types.PluginContext) []Handler
	// GetSession returns a session by ID
	GetSession(ctx *types.PluginContext, sessionID string) (*Session, error)
	// ListSessions returns all of the sessions
	ListSessions(ctx *types.PluginContext) ([]*Session, error)
	// CreateSession creates a new session
	CreateSession(ctx *types.PluginContext, opts SessionOptions) (*Session, error)
	// AttachSession attaches a session
	AttachSession(ctx *types.PluginContext, sessionID string) (*Session, []byte, error)
	// DetachSession detaches a session
	DetachSession(ctx *types.PluginContext, sessionID string) (*Session, error)
	// CloseSession closes a session
	CloseSession(ctx *types.PluginContext, sessionID string) error
	// ResizeSession resizes a session
	ResizeSession(ctx *types.PluginContext, sessionID string, cols, rows int32) error
	// Stream starts a new stream to multiplex sessions
	Stream(context.Context, chan StreamInput) (chan StreamOutput, error)
}

type Session struct {
	CreatedAt time.Time `json:"created_at"`

	Labels   map[string]string `json:"labels"`
	Params   map[string]string `json:"params"`
	ID       string            `json:"id"`
	Command  []string          `json:"command"`
	Attached bool              `json:"attached"`
	// contains filtered or unexported fields
}

type SessionHandler func(ctx *types.PluginContext, opts SessionOptions) (
	stdin io.Writer,
	stdout io.Reader,
	stderr io.Reader,
	err error,
)

type SessionOptions struct {
	Params         map[string]string      `json:"params"`
	Labels         map[string]string      `json:"labels"`
	ID             string                 `json:"id"`
	ResourcePlugin string                 `json:"resource_plugin"`
	ResourceKey    string                 `json:"resource_key"`
	ResourceData   map[string]interface{} `json:"resource_data"`
	Command        []string               `json:"command"`
	TTY            bool                   `json:"tty"`
}

type SessionResizeInput struct {
	Rows int32 `json:"rows"`
	Cols int32 `json:"cols"`
}

type StreamInput struct {
	// SessionID
	SessionID string `json:"session_id"`
	// Data
	Data []byte `json:"data"`
}

type StreamOutput struct {
	SessionID string       `json:"session_id"`
	Data      []byte       `json:"data"`
	Target    StreamTarget `json:"target"`
	Signal    StreamSignal `json:"signal"`
}

type StreamResize struct {
	SessionID string `json:"session_id"`
	Cols      uint16 `json:"cols"`
	Rows      uint16 `json:"rows"`
}

type StreamSignal int

type StreamTarget int

type TTYHandler func(ctx *types.PluginContext, opts SessionOptions, tty *os.File, stopCh chan struct{}, resize <-chan SessionResizeInput) error