Versions in this module Expand all Collapse all v0 v0.2.0 Feb 10, 2026 v0.1.0 Feb 9, 2026 Changes in this version + type Bundler interface + Execute func(ctx context.Context, parentDir, bundleDir string) ([]byte, error) + type BundlerOption func(*BundlerOptions) + func BundlerWithNoLogStepOutOnError(v bool) BundlerOption + func BundlerWithRetries(retries int) BundlerOption + func BundlerWithStepDelimiter(delimiter string) BundlerOption + func BundlerWithStepHeaderRegex(regex *regexp.Regexp) BundlerOption + type BundlerOptions struct + NoLogStepOutOnError bool + Retries int + StepHeaderRegex *regexp.Regexp + StepsDelimiter string + func (o *BundlerOptions) IsValid() error + type Check interface + AwaitAvailability func(context.Context, retry.Params) error + CheckAvailability func(context.Context) error + ExpectAvailable func(context.Context) ([]byte, error) + String func() string + WithDelaySeconds func(seconds int) Check + type Command interface + Cmd func(ctx context.Context) + CombinedOutput func(context.Context) ([]byte, error) + OnCommandStart func(fn func()) + Output func(context.Context) ([]byte, []byte, error) + Run func(ctx context.Context) error + StderrBytes func() []byte + StdoutBytes func() []byte + Sudo func(ctx context.Context) + WithEnv func(env map[string]string) + WithSSHArgs func(args ...string) + WithStderrHandler func(h func(line string)) + WithStdoutHandler func(h func(line string)) + WithTimeout func(timeout time.Duration) + type File interface + Download func(ctx context.Context, srcPath, dstPath string) error + DownloadBytes func(ctx context.Context, remotePath string) ([]byte, error) + Upload func(ctx context.Context, srcPath, dstPath string) error + UploadBytes func(ctx context.Context, data []byte, remotePath string) error + type Interface interface + Command func(name string, args ...string) Command + File func() File + UploadScript func(scriptPath string, args ...string) Script + type KubeClient interface + APIResource func(apiVersion, kind string) (*metav1.APIResource, error) + APIResourceList func(apiVersion string) ([]*metav1.APIResourceList, error) + Dynamic func() dynamic.Interface + GroupVersionResource func(apiVersion, kind string) (schema.GroupVersionResource, error) + InvalidateDiscoveryCache func() + type KubeProvider interface + Cleanup func(ctx context.Context) error + Client func(ctx context.Context) (KubeClient, error) + NewAdditionalClient func(ctx context.Context) (KubeClient, error) + NewAdditionalClientWithoutInitialize func(ctx context.Context) (KubeClient, error) + type KubeProxy interface + Start func(useLocalPort int) (port string, err error) + Stop func(startID int) + StopAll func() + type KubeProxyCommand interface + Stop func() + WaitError func() error + type ReverseTunnel interface + StartHealthMonitor func(ctx context.Context, checker ReverseTunnelChecker, killer ReverseTunnelKiller) + Stop func() + String func() string + Up func() error + type ReverseTunnelChecker interface + CheckTunnel func(context.Context) (string, error) + type ReverseTunnelKiller interface + KillTunnel func(context.Context) (string, error) + type SSHClient interface + Check func() Check + Command func(name string, arg ...string) Command + File func() File + IsStopped func() bool + KubeProxy func() KubeProxy + Loop func(fn SSHLoopHandler) error + OnlyPreparePrivateKeys func() error + PrivateKeys func() []session.AgentPrivateKey + RefreshPrivateKeys func() error + ReverseTunnel func(address string) ReverseTunnel + Session func() *session.Session + Start func() error + Stop func() + Tunnel func(address string) Tunnel + UploadScript func(scriptPath string, args ...string) Script + type SSHLoopHandler func(s SSHClient) error + type SSHProvider interface + Cleanup func(ctx context.Context) error + Client func(ctx context.Context) (SSHClient, error) + NewAdditionalClient func(ctx context.Context) (SSHClient, error) + NewStandaloneClient func(ctx context.Context, sess *session.Session, ...) (SSHClient, error) + SwitchClient func(ctx context.Context, sess *session.Session, ...) (SSHClient, error) + SwitchToDefault func(ctx context.Context) (SSHClient, error) + type Script interface + Execute func(context.Context) (stdout []byte, err error) + ExecuteBundle func(ctx context.Context, parentDir, bundleDir string) (stdout []byte, err error) + Sudo func() + WithBundlerOpts func(opts ...BundlerOption) + WithCleanupAfterExec func(doCleanup bool) + WithEnvs func(envs map[string]string) + WithExecuteUploadDir func(dir string) + WithNoLogStepOutOnError func(enabled bool) + WithStdoutHandler func(handler func(string)) + WithTimeout func(timeout time.Duration) + type StandaloneClientOpt func(*StandaloneClientOpts) + func SSHClientWithSetFromDefaultsIfNeeded() StandaloneClientOpt + type StandaloneClientOpts struct + SetSettingsFromDefaultsIfNeeded bool + type Tunnel interface + HealthMonitor func(errorOutCh chan<- error) + Stop func() + String func() string + Up func(ctx context.Context) error
Go to main page