exec

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

type AttachSessionResult struct {
	Session *sdkexec.Session `json:"session"`
	Buffer  string           `json:"buffer"`
}

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

type Controller interface {
	internaltypes.Controller
	Run(ctx context.Context)
	GetPluginHandlers(plugin string) map[string]exec.Handler
	GetHandlers() map[string]map[string]exec.Handler
	GetHandler(plugin, resource string) *exec.Handler
	CreateSession(plugin, connectionID string, opts exec.SessionOptions) (*exec.Session, error)
	ListSessions() ([]*exec.Session, error)
	GetSession(sessionID string) (*exec.Session, error)
	AttachSession(sessionID string) (*exec.Session, []byte, error)
	DetachSession(sessionID string) (*exec.Session, error)
	WriteSession(sessionID string, data []byte) error
	CloseSession(sessionID string) error
	ResizeSession(sessionID string, rows, cols uint16) error
}

type CreateTerminalOptions struct {
	Labels  map[string]string `json:"labels"`
	Command []string          `json:"command"`
}

type ExecProvider interface {
	GetSupportedResources(ctx *types.PluginContext) []exec.Handler
	GetSession(ctx *types.PluginContext, sessionID string) (*exec.Session, error)
	ListSessions(ctx *types.PluginContext) ([]*exec.Session, error)
	CreateSession(ctx *types.PluginContext, opts exec.SessionOptions) (*exec.Session, error)
	AttachSession(ctx *types.PluginContext, sessionID string) (*exec.Session, []byte, error)
	DetachSession(ctx *types.PluginContext, sessionID string) (*exec.Session, error)
	CloseSession(ctx *types.PluginContext, sessionID string) error
	ResizeSession(ctx *types.PluginContext, sessionID string, cols, rows int32) error
	Stream(ctx context.Context, in chan exec.StreamInput) (chan exec.StreamOutput, error)
	Close()
}