ssh

package
v6.4.1+incompatible Latest Latest
Warning

This package is not in the latest version of its module.

 Go to latest Published: Oct 17, 2020 License: Apache-2.0 Imports: 25 Imported by: 115

Documentation

Index

Constants

This section is empty.

Variables

This section is empty.

Functions

This section is empty.

Types

type Client added in v0.0.146 

type Client interface {
	Start() error
	Stop() error

	Dial(net, addr string) (net.Conn, error)
	Listen(net, addr string) (net.Listener, error)
}

type ClientConnectRetryStrategy added in v0.0.146 

type ClientConnectRetryStrategy struct {
	ConnectionRefusedTimeout time.Duration
	AuthFailureTimeout       time.Duration
	TimeService              clock.Clock
	// contains filtered or unexported fields
}

func (*ClientConnectRetryStrategy) IsRetryable added in v0.0.146 

func (s *ClientConnectRetryStrategy) IsRetryable(err error) bool

type ClientFactory added in v0.0.146 

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

func NewClientFactory added in v0.0.146 

func NewClientFactory(logger boshlog.Logger) ClientFactory

func (ClientFactory) New added in v0.0.146 

func (f ClientFactory) New(opts ClientOpts) Client

type ClientImpl added in v0.0.146 

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

func (*ClientImpl) Dial added in v0.0.146 

func (s *ClientImpl) Dial(n, addr string) (net.Conn, error)

func (*ClientImpl) Listen added in v0.0.146 

func (s *ClientImpl) Listen(n, addr string) (net.Listener, error)

func (*ClientImpl) Start added in v0.0.146 

func (s *ClientImpl) Start() error

func (*ClientImpl) Stop added in v0.0.146 

func (s *ClientImpl) Stop() error

type ClientOpts added in v0.0.146 

type ClientOpts struct {
	Host string
	Port int

	User       string
	Password   string
	PrivateKey string

	DisableSOCKS bool
}

type ComboRunner 

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

func NewComboRunner 

func NewComboRunner(
	cmdRunner boshsys.CmdRunner,
	sessionFactory func(ConnectionOpts, boshdir.SSHResult) Session,
	signalNotifyFunc func(chan<- os.Signal, ...os.Signal),
	writer Writer,
	fs boshsys.FileSystem,
	ui boshui.UI,
	logger boshlog.Logger,
) ComboRunner

func (ComboRunner) Run 

func (r ComboRunner) Run(connOpts ConnectionOpts, result boshdir.SSHResult, cmdFactory func(boshdir.Host, SSHArgs) boshsys.Command) error

type ConnectionOpts 

type ConnectionOpts struct {
	PrivateKey string

	GatewayDisable bool

	GatewayUsername       string
	GatewayHost           string
	GatewayPrivateKeyPath string

	SOCKS5Proxy string

	RawOpts []string
}

type DeploymentFetcher 

type DeploymentFetcher func() (boshdir.Deployment, error)

type HostBuilder 

type HostBuilder interface {
	BuildHost(slug boshdir.AllOrInstanceGroupOrInstanceSlug, username string, deploymentFetcher DeploymentFetcher) (boshdir.Host, error)
}

func NewHostBuilder 

func NewHostBuilder() HostBuilder

type InstanceWriter 

type InstanceWriter interface {
	Stdout() io.Writer
	Stderr() io.Writer
	End(exitStatus int, err error)
}

type InteractiveRunner 

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

func NewInteractiveRunner 

func NewInteractiveRunner(comboRunner ComboRunner) InteractiveRunner

func (InteractiveRunner) Run 

func (r InteractiveRunner) Run(connOpts ConnectionOpts, result boshdir.SSHResult, rawCmd []string) error

type NonInteractiveRunner 

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

func NewNonInteractiveRunner 

func NewNonInteractiveRunner(comboRunner ComboRunner) NonInteractiveRunner

func (NonInteractiveRunner) Run 

func (r NonInteractiveRunner) Run(connOpts ConnectionOpts, result boshdir.SSHResult, rawCmd []string) error

type Provider 

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

func NewProvider 

func NewProvider(cmdRunner boshsys.CmdRunner, fs boshsys.FileSystem, ui boshui.UI, logger boshlog.Logger) Provider

func (Provider) NewResultsSSHRunner 

func (p Provider) NewResultsSSHRunner(interactive bool) Runner

func (Provider) NewSCPRunner 

func (p Provider) NewSCPRunner() SCPRunner

func (Provider) NewSSHRunner 

func (p Provider) NewSSHRunner(interactive bool) Runner

type ResultsWriter 

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

func NewResultsWriter 

func NewResultsWriter(ui boshui.UI) *ResultsWriter

func (*ResultsWriter) Flush 

func (w *ResultsWriter) Flush()

func (*ResultsWriter) ForInstance 

func (w *ResultsWriter) ForInstance(jobName, indexOrID string) InstanceWriter

type Runner 

type Runner interface {
	Run(ConnectionOpts, boshdir.SSHResult, []string) error
}

type SCPArgs 

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

func NewSCPArgs 

func NewSCPArgs(rawArgs []string, recursive bool) SCPArgs

func (SCPArgs) AllOrInstanceGroupOrInstanceSlug added in v0.0.102 

func (a SCPArgs) AllOrInstanceGroupOrInstanceSlug() (boshdir.AllOrInstanceGroupOrInstanceSlug, error)

func (SCPArgs) ForHost 

func (a SCPArgs) ForHost(host boshdir.Host) []string

type SCPRunner 

type SCPRunner interface {
	Run(ConnectionOpts, boshdir.SSHResult, SCPArgs) error
}

type SCPRunnerImpl 

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

func NewSCPRunner 

func NewSCPRunner(comboRunner ComboRunner) SCPRunnerImpl

func (SCPRunnerImpl) Run 

func (r SCPRunnerImpl) Run(connOpts ConnectionOpts, result boshdir.SSHResult, scpArgs SCPArgs) error

type SSHArgs 

type SSHArgs struct {
	ConnOpts ConnectionOpts
	Result   boshdir.SSHResult

	ForceTTY bool

	PrivKeyFile         boshsys.File
	KnownHostsFile      boshsys.File
	CmdExistenceChecker cmdExistenceChecker

	Socks5Proxy *proxy.Socks5Proxy
	// contains filtered or unexported fields
}

func NewSSHArgs 

func NewSSHArgs(connOpts ConnectionOpts, result boshdir.SSHResult, forceTTY bool, privKeyFile boshsys.File, knownHostsFile boshsys.File) SSHArgs

func (SSHArgs) LoginForHost 

func (a SSHArgs) LoginForHost(host boshdir.Host) []string

func (SSHArgs) OptsForHost 

func (a SSHArgs) OptsForHost(host boshdir.Host) []string

type Session 

type Session interface {
	Start() (SSHArgs, error)
	Finish() error
}

type SessionImpl 

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

func NewSessionImpl 

func NewSessionImpl(
	connOpts ConnectionOpts,
	sessOpts SessionImplOpts,
	result boshdir.SSHResult,
	fs boshsys.FileSystem,
) *SessionImpl

func (*SessionImpl) Finish 

func (r *SessionImpl) Finish() error

func (*SessionImpl) Start 

func (r *SessionImpl) Start() (SSHArgs, error)

type SessionImplOpts 

type SessionImplOpts struct {
	ForceTTY bool
}

type StreamingWriter 

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

func NewStreamingWriter 

func NewStreamingWriter(comboWriter *boshui.ComboWriter) *StreamingWriter

func (StreamingWriter) Flush 

func (w StreamingWriter) Flush()

func (StreamingWriter) ForInstance 

func (w StreamingWriter) ForInstance(jobName, indexOrID string) InstanceWriter

type Writer 

type Writer interface {
	ForInstance(jobName, indexOrID string) InstanceWriter
	Flush()
}

Source Files

View all Source files

Directories

Path Synopsis
Code generated by counterfeiter.
 Code generated by counterfeiter.

Jump to

Keyboard shortcuts

? : This menu
/ : Search site
f or F : Jump to
y or Y : Canonical URL
go.dev uses cookies from Google to deliver and enhance the quality of its services and to analyze traffic. Learn more.