connector

Oct 11, 2015

Changes in this version

+ const KEEPALIVE_INTERVAL

+ const TIMEOUT

+ func DialSSHTimeout(network, addr string, config *ssh.ClientConfig, timeout time.Duration) (*ssh.Client, error)

+ func KeyAuth(file string) (ssh.AuthMethod, error)

type Connection

+ Close func() error

type GoogleCloudStorageConnection

+ func (c GoogleCloudStorageConnection) Close() error

type S3Connection

+ func (c S3Connection) Close() error

+ type SFTPConnection struct

+ CacheDirectory string

+ RemotePath string

+ SFTPClient *sftp.Client

+ SSHClient *ssh.Client

+ func NewSFTPConnection(host string, port int, remotePath string, username string, password *string, ...) (*SFTPConnection, error)

+ func (c SFTPConnection) Close() error

+ func (c SFTPConnection) GetCacheDirectory() string

+ func (c SFTPConnection) String() string

+ func (conn SFTPConnection) CachedGet(key string) (string, error)

+ func (conn SFTPConnection) Get(key string) (string, error)

+ func (conn SFTPConnection) ListObjectsAsAll(prefix string) ([]Object, error)

+ func (conn SFTPConnection) ListObjectsAsFolders(prefix string) ([]Object, error)

+ type SFTPObject struct

+ Fullpath string

+ func (o SFTPObject) GetPath() string

+ func (o SFTPObject) String() string

+ type SSHConn struct

+ ReadTimeout time.Duration

+ WriteTimeout time.Duration

+ func (c *SSHConn) Read(b []byte) (int, error)

+ func (c *SSHConn) Write(b []byte) (int, error)

Oct 10, 2015

Changes in this version

+ type Connection interface

+ CachedGet func(key string) (string, error)

+ Get func(key string) (string, error)

+ GetCacheDirectory func() string

+ ListObjectsAsAll func(prefix string) ([]Object, error)

+ ListObjectsAsFolders func(prefix string) ([]Object, error)

+ String func() string

+ type GoogleCloudStorageConnection struct

+ BucketName string

+ CacheDirectory string

+ Context context.Context

+ func NewGoogleCloudStorageConnection(jsonPrivateKeyFilepath string, projectID string, bucketName string, ...) (GoogleCloudStorageConnection, error)

+ func (c GoogleCloudStorageConnection) GetCacheDirectory() string

+ func (c GoogleCloudStorageConnection) String() string

+ func (conn GoogleCloudStorageConnection) CachedGet(name string) (string, error)

+ func (conn GoogleCloudStorageConnection) Get(name string) (string, error)

+ func (conn GoogleCloudStorageConnection) ListObjectsAsAll(prefix string) ([]Object, error)

+ func (conn GoogleCloudStorageConnection) ListObjectsAsFolders(prefix string) ([]Object, error)

+ type GoogleCloudStorageObject struct

+ Name string

+ func (o GoogleCloudStorageObject) GetPath() string

+ func (o GoogleCloudStorageObject) String() string

+ type Object interface

+ GetPath func() string

+ type S3Connection struct

+ BucketName string

+ CacheDirectory string

+ Connection *s3.S3

+ Downloader *s3manager.Downloader

+ func NewS3Connection(connection *s3.S3, cacheDirectory string, s3BucketName string, ...) S3Connection

+ func (c S3Connection) GetCacheDirectory() string

+ func (c S3Connection) String() string

+ func (conn S3Connection) CachedGet(key string) (string, error)

+ func (conn S3Connection) Get(key string) (string, error)

+ func (conn S3Connection) ListObjectsAsAll(prefix string) ([]Object, error)

+ func (conn S3Connection) ListObjectsAsFolders(prefix string) ([]Object, error)

+ type S3Object struct

+ S3FullPath string

+ func (s3Obj S3Object) GetPath() string

+ func (s3Obj S3Object) String() string