Documentation
¶
Index ¶
- type Connection
- type ConnectionPool
- type SFTP
- func (s *SFTP) Get(uri *url.URL, w io.Writer) (int64, error)
- func (s *SFTP) GetConnection(address *url.URL) (*Connection, error)
- func (s *SFTP) GetFile(uri *url.URL, user string, target string) (int64, error)
- func (s *SFTP) Put(uri *url.URL, r io.Reader) (int64, error)
- func (s *SFTP) PutFile(uri *url.URL, source string) (int64, error)
- type SFTPConnection
Constants ¶
This section is empty.
Variables ¶
This section is empty.
Functions ¶
This section is empty.
Types ¶
type Connection ¶
type Connection struct {
Client *ssh.Client
Address *url.URL
Log *logging.Logger
// contains filtered or unexported fields
}
func NewConnection ¶
func NewConnection(address *url.URL, config *ssh.ClientConfig, log *logging.Logger) (*Connection, error)
func (*Connection) Close ¶
func (sc *Connection) Close()
func (*Connection) Connect ¶
func (sc *Connection) Connect() error
type ConnectionPool ¶
type ConnectionPool struct {
// contains filtered or unexported fields
}
func NewConnectionPool ¶
func NewConnectionPool(log *logging.Logger) *ConnectionPool
func (*ConnectionPool) GetConnection ¶
func (cp *ConnectionPool) GetConnection(address *url.URL, config *ssh.ClientConfig) (*Connection, error)
type SFTP ¶
type SFTP struct {
// contains filtered or unexported fields
}
func (*SFTP) GetConnection ¶
func (s *SFTP) GetConnection(address *url.URL) (*Connection, error)
type SFTPConnection ¶
type SFTPConnection struct {
*Connection
// contains filtered or unexported fields
}
func NewSFTPConnection ¶
func NewSFTPConnection(sshConn *Connection, concurrency, maxClientConcurrency, maxPacketSize int) (*SFTPConnection, error)
func (*SFTPConnection) GetSFTPClient ¶
func (sc *SFTPConnection) GetSFTPClient() (*sftp.Client, error)
Source Files
Click to show internal directories.
Click to hide internal directories.