server

package

Go to main page

Versions in this module

v0

v0.8.0

May 1, 2026

Changes in this version

type ConnectInput

+ Command string

v0.7.0

Apr 21, 2026

Changes in this version

type ConnectInput

+ Insecure bool

+ UseTLS bool

type Core

+ ParsePS func(string) (*parser.Pipeline, error)

+ ReconstructPS func(*parser.Pipeline) string

+ WinRMRunner Executor

type ServerEntry

+ Shell ShellType

type ServerStatus

+ Shell ShellType

+ type ShellType string

+ const ShellBash

+ const ShellPowerShell

type TransportType

+ const TransportWinRM

v0.6.0

Mar 6, 2026

Changes in this version

type ConnectInput

+ Passphrase string

+ Password string

+ Transport string

type Core

+ DisabledTools map[string]bool

+ LocalRunner Executor

+ func (c *Core) ConnectedHostsSnapshot() []string

+ func (c *Core) ServersSnapshot() StatusResult

+ func (c *Core) Status(_ context.Context, _ StatusInput) (StatusResult, error)

+ func (c *Core) ValidateCommand(_ context.Context, in ValidateInput) (ValidateResult, error)

type CoreOption

+ func WithDisabledTools(tools []string) CoreOption

+ type LocalExecutor struct

+ func NewLocalExecutor() *LocalExecutor

+ func (l *LocalExecutor) Connect(_ context.Context, _ ssh.ConnectionParams) error

+ func (l *LocalExecutor) Disconnect(_ context.Context, _ string) error

+ func (l *LocalExecutor) Execute(ctx context.Context, _, command string, timeout time.Duration) (ssh.ExecResult, error)

+ func (l *LocalExecutor) ExecuteRaw(ctx context.Context, _, command string, timeout time.Duration) (ssh.ExecResult, error)

+ func (l *LocalExecutor) SFTPSession(_ string) (ssh.SFTPClient, error)

+ type ServerEntry struct

+ Connected bool

+ Transport TransportType

type ServerOptions

+ AutoConnect *ConnectInput

+ type ServerStatus struct

+ Connected bool

+ Transport TransportType

+ type StatusInput struct

+ type StatusResult map[string]ServerStatus

+ type TransportType string

+ const TransportLocal

+ const TransportSSH

+ type ValidateInput struct

+ Command string

+ type ValidateResult struct

+ Command string

+ Detail string

+ OK bool

+ Reason string

v0.5.2

Feb 15, 2026

v0.5.1

Feb 15, 2026

Changes in this version

+ func NewHTTPHandler(core *Core, opts ...ServerOptions) http.Handler

+ func NewMCPServer(core *Core, opts ...ServerOptions) *mcp.Server

+ func RunStdio(ctx context.Context, core *Core, opts ...ServerOptions) error

+ type ConnectInput struct

+ Host string

+ IdentityFile string

+ Port int

+ User string

+ type Core struct

+ DefaultTimeout int

+ DownloadDir string

+ MaxDownloadBytes int

+ MaxOutputBytes int

+ MaxSleepSeconds int

+ Parse func(string) (*parser.Pipeline, error)

+ Reconstruct func(*parser.Pipeline, bool, bool) string

+ Registry map[string]*manifest.Manifest

+ Runner Executor

+ Truncate func(string, string, int, int, ...int) output.CommandResult

+ Validate func(*parser.Pipeline, map[string]*manifest.Manifest) error

+ func NewCore(registry map[string]*manifest.Manifest, runner Executor, logger *slog.Logger, ...) *Core

+ func (c *Core) Close(ctx context.Context) error

+ func (c *Core) Connect(ctx context.Context, in ConnectInput) (map[string]any, error)

+ func (c *Core) Disconnect(ctx context.Context, in DisconnectInput) (map[string]any, error)

+ func (c *Core) DownloadFile(ctx context.Context, in DownloadInput) (DownloadResult, error)

+ func (c *Core) Execute(ctx context.Context, in ExecuteInput) (output.CommandResult, error)

+ func (c *Core) Logger() *slog.Logger

+ func (c *Core) Provision(ctx context.Context, in ProvisionInput) (map[string]any, error)

+ func (c *Core) Sleep(ctx context.Context, in SleepInput) (map[string]any, error)

+ type CoreOption func(*Core)

+ func WithDefaultTimeout(seconds int) CoreOption

+ func WithDownloadDir(dir string) CoreOption

+ func WithMaxDownloadBytes(bytes int) CoreOption

+ func WithMaxOutputBytes(bytes int) CoreOption

+ func WithMaxSleepSeconds(seconds int) CoreOption

+ type DisconnectInput struct

+ Host string

+ type DownloadInput struct

+ Host string

+ LocalDir string

+ RemotePath string

+ type DownloadResult struct

+ Filename string

+ LocalPath string

+ SizeBytes int64

+ type ExecuteInput struct

+ Command string

+ Host string

+ type Executor interface

+ Connect func(ctx context.Context, params ssh.ConnectionParams) error

+ Disconnect func(ctx context.Context, host string) error

+ Execute func(ctx context.Context, host, command string, timeout time.Duration) (ssh.ExecResult, error)

+ ExecuteRaw func(ctx context.Context, host, command string, timeout time.Duration) (ssh.ExecResult, error)

+ SFTPSession func(host string) (ssh.SFTPClient, error)

+ type ProbeResult struct

+ Arch string

+ Missing []string

+ type ProvisionInput struct

+ Host string

+ type ServerOptions struct

+ Name string

+ Version string

+ type SleepInput struct

+ Seconds float64

?	: This menu
/	: Search site
f or F	: Jump to
y or Y	: Canonical URL