Documentation
¶
Index ¶
- func CopyWorker(source <-chan string, destpath string, downloader *s3manager.Downloader, ...)
- func DirectoryContentsWorker(ticker <-chan time.Time, destdir string, ignoreFiles map[string]bool, ...)
- func S3ListWorker(ticker <-chan time.Time, toCopy chan<- string, SourceBucket string, ...)
- type Syncer
Constants ¶
This section is empty.
Variables ¶
This section is empty.
Functions ¶
func CopyWorker ¶
func CopyWorker(source <-chan string, destpath string, downloader *s3manager.Downloader, bucket string, ignoreFiles map[string]bool, wg *sync.WaitGroup)
CopyWorker - go routine worker for doing copies from s3 to fs
Types ¶
type Syncer ¶
type Syncer struct {
S3SVC *s3.S3
SourceBucket string
DestDir string
// contains filtered or unexported fields
}
Syncer struct
func NewSyncer ¶
func NewSyncer(srcBkt, destDir, endpointURL, awsregion, awsaccessid, awsaccesskey string, disableSSL, s3ForcePathStyle bool) (syncer *Syncer, err error)
NewSyncer returns a Syncer or an error if construction fails
Source Files
Click to show internal directories.
Click to hide internal directories.