upload

type DataStore struct {
	DataDir string `arg:"--data-dir,env:DATA_DIR" help:"Directory to store output data" default:"data" placeholder:"DIR"`
}

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

type FTPConfig struct {
	Host     string `arg:"--upload-ftp-host,env:UPLOAD_FTP_HOST" help:"FTP hostname" placeholder:"HOST"`
	Port     uint16 `arg:"--upload-ftp-port,env:UPLOAD_FTP_PORT" help:"FTP port" default:"21" placeholder:"PORT"`
	User     string `arg:"--upload-ftp-user,env:UPLOAD_FTP_USER" help:"FTP username" placeholder:"USER"`
	Password string `arg:"--upload-ftp-password,env:UPLOAD_FTP_PASSWORD" help:"FTP password" placeholder:"PASS"`
	PWD      string `` /* 132-byte string literal not displayed */
}

type Uploader interface {
	// Upload uploads a file.
	Upload(ctx context.Context, remotePath string, contents io.Reader) error
	// AtomicUpload uploads a file, trying to swap out the file in an atomic operation.
	AtomicUpload(ctx context.Context, remotePath string, contents io.Reader) error
	// ListFiles lists all regular files in a remote directory.
	// Any non-regular files (e.g. directories) are to be ignored.
	ListFiles(ctx context.Context, remotePath string) ([]string, error)
	// DeleteFile deletes a regular file at the given remote path.
	DeleteFile(ctx context.Context, remotePath string) error
	// Close terminates the connection and frees any resources.
	Close() error
}