Documentation
¶
Index ¶
- Variables
- type DynamicMultiWriter
- type Event
- type EventType
- type Exec
- func (sr *Exec) Attach(supervisorID *api.ID, response *api.ResponseWithFD) error
- func (sr *Exec) Close(reason error) error
- func (sr *Exec) CreateMetadata() error
- func (sr *Exec) CreateNewClient(supervisorID *api.ID) (int, error)
- func (sr *Exec) Detach(id *api.ID) error
- func (sr *Exec) ID() api.ID
- func (sr *Exec) Metadata() (*api.TerminalDoc, error)
- func (sr *Exec) OnInitShell() error
- func (sr *Exec) OpenSocketCtrl() error
- func (sr *Exec) PostAttachShell() error
- func (sr *Exec) Resize(args api.ResizeArgs)
- func (sr *Exec) SetupShell() error
- func (sr *Exec) StartServer(_ context.Context, sc *terminalrpc.TerminalControllerRPC, readyCh chan error, ...)
- func (sr *Exec) StartTerminal(evCh chan<- Event) error
- func (sr *Exec) Write(p []byte) (int, error)
- type TerminalRunner
- type Test
- func (sr *Test) Attach(id *api.ID, response *api.ResponseWithFD) error
- func (sr *Test) Close(reason error) error
- func (sr *Test) CreateMetadata() error
- func (sr *Test) Detach(id *api.ID) error
- func (sr *Test) ID() api.ID
- func (sr *Test) Metadata() (*api.TerminalDoc, error)
- func (sr *Test) OnInitShell() error
- func (sr *Test) OpenSocketCtrl() error
- func (sr *Test) PostAttachShell() error
- func (sr *Test) Resize(args api.ResizeArgs)
- func (sr *Test) SetupShell() error
- func (sr *Test) StartServer(ctx context.Context, sc *terminalrpc.TerminalControllerRPC, readyCh chan error, ...)
- func (sr *Test) StartTerminal(evCh chan<- Event) error
Constants ¶
This section is empty.
Variables ¶
Functions ¶
This section is empty.
Types ¶
type DynamicMultiWriter ¶
type DynamicMultiWriter struct {
// contains filtered or unexported fields
}
func NewDynamicMultiWriter ¶
func NewDynamicMultiWriter(logger *slog.Logger, writers ...io.Writer) *DynamicMultiWriter
func (*DynamicMultiWriter) Add ¶
func (dmw *DynamicMultiWriter) Add(w io.Writer)
func (*DynamicMultiWriter) Remove ¶
func (dmw *DynamicMultiWriter) Remove(w io.Writer)
type Exec ¶
type Exec struct {
// contains filtered or unexported fields
}
func (*Exec) CreateMetadata ¶
func (*Exec) OnInitShell ¶
func (*Exec) OpenSocketCtrl ¶
func (*Exec) PostAttachShell ¶
func (*Exec) Resize ¶
func (sr *Exec) Resize(args api.ResizeArgs)
func (*Exec) SetupShell ¶
func (*Exec) StartServer ¶
func (sr *Exec) StartServer( _ context.Context, sc *terminalrpc.TerminalControllerRPC, readyCh chan error, doneCh chan error, )
func (*Exec) StartTerminal ¶
type TerminalRunner ¶
type TerminalRunner interface {
OpenSocketCtrl() error
StartServer(ctx context.Context, sc *terminalrpc.TerminalControllerRPC, readyCh chan error, doneCh chan error)
StartTerminal(evCh chan<- Event) error
ID() api.ID
Close(reason error) error
Resize(args api.ResizeArgs)
CreateMetadata() error
Detach(id *api.ID) error
Attach(id *api.ID, response *api.ResponseWithFD) error
SetupShell() error
OnInitShell() error
PostAttachShell() error
Metadata() (*api.TerminalDoc, error)
}
func NewTerminalRunnerExec ¶
func NewTerminalRunnerExec(ctx context.Context, logger *slog.Logger, spec *api.TerminalSpec) TerminalRunner
func NewTerminalRunnerTest ¶
func NewTerminalRunnerTest(_ context.Context) TerminalRunner
type Test ¶
type Test struct {
OpenSocketCtrlFunc func() error
StartServerFunc func(ctx context.Context, sc *terminalrpc.TerminalControllerRPC, readyCh chan error, doneCh chan error)
StartTerminalFunc func(evCh chan<- Event) error
CloseFunc func(reason error) error
ResizeFunc func(args api.ResizeArgs)
IDFunc func() api.ID
CreateMetadataFunc func() error
AttachFunc func(id *api.ID, response *api.ResponseWithFD) error
DetachFunc func(id *api.ID) error
SetupShellFunc func() error
OnInitShellFunc func() error
MetadataFunc func() (*api.TerminalDoc, error)
PostAttachShellFunc func() error
// contains filtered or unexported fields
}
func (*Test) CreateMetadata ¶
func (*Test) OnInitShell ¶
func (*Test) OpenSocketCtrl ¶
func (*Test) PostAttachShell ¶
func (*Test) Resize ¶
func (sr *Test) Resize(args api.ResizeArgs)
func (*Test) SetupShell ¶
func (*Test) StartServer ¶
func (sr *Test) StartServer( ctx context.Context, sc *terminalrpc.TerminalControllerRPC, readyCh chan error, doneCh chan error, )
func (*Test) StartTerminal ¶
Click to show internal directories.
Click to hide internal directories.