providers

package

Go to main page

Versions in this module

v0

v0.0.7

Oct 18, 2022

v0.0.6

Oct 5, 2022

Changes in this version

+ var ErrCreatingTmpDir = errors.New("error creating tmp dir")

type Downloader

+ func (c *Downloader) CopyFile(ctx context.Context, fw *config.Firmware) error

+ func (c *Downloader) DstBucket() string

+ func (c *Downloader) DstPath(fw *config.Firmware) string

+ func (c *Downloader) SrcPath(fw *config.Firmware) string

+ func (c *Downloader) VerifyFile(ctx context.Context, fw *config.Firmware) error

v0.0.5

Sep 28, 2022

Changes in this version

+ func UpdateFilesPath(deviceVendor, deviceModel, slug, filename string) string

+ type S3Downloader struct

+ func NewS3Downloader(ctx context.Context, vendor string, srcCfg, dstCfg *config.S3Bucket, ...) (*S3Downloader, error)

+ func (s *S3Downloader) CopyFile(ctx context.Context, fw *config.Firmware) error

+ func (s *S3Downloader) DstBucket() string

+ func (s *S3Downloader) DstPath(fw *config.Firmware) string

+ func (s *S3Downloader) SrcBucket() string

+ func (s *S3Downloader) SrcPath(fw *config.Firmware) string

+ func (s *S3Downloader) VerifyFile(ctx context.Context, fw *config.Firmware) error

type StoreConfig

+ Root string

v0.0.4

Sep 13, 2022

v0.0.3

Sep 7, 2022

v0.0.2

Jul 25, 2022

Changes in this version

type S3Config

+ Region string

v0.0.1

Jul 18, 2022

Changes in this version

+ const ActionSign

+ const ActionSync

+ const ActionVerify

+ const KindHTTP

+ const KindLocal

+ const KindS3

+ const MetricErrorsCount

+ const MetricTransferredBytes

+ const MetricTransferredObjects

+ const SigSuffix

+ const SumSuffix

+ var ErrCheckFileExists = errors.New("error checking file exists")

+ var ErrChecksumGenerate = errors.New("error generate file checksum")

+ var ErrChecksumInvalid = errors.New("file checksum does not match")

+ var ErrChecksumValidate = errors.New("error validating file checksum")

+ var ErrCopy = errors.New("error copying files")

+ var ErrDestPathUndefined = errors.New("destination path is not specified")

+ var ErrDirEmpty = errors.New("directory empty")

+ var ErrDownloadSign = errors.New("error downloading files to sign")

+ var ErrDownloadVerify = errors.New("error downloading files to verify")

+ var ErrFileNotFound = errors.New("file not found")

+ var ErrFileStoreConfig = errors.New("filestore configuration invalid")

+ var ErrInitFSDownloader = errors.New("error initializing filesystem downloader")

+ var ErrInitHTTPDownloader = errors.New("error initializing http downloader")

+ var ErrInitS3Downloader = errors.New("error intializing s3 downloader")

+ var ErrInitS3Fs = errors.New("error initializing s3 vfs")

+ var ErrListingFiles = errors.New("error listing files in directory")

+ var ErrModTimeFile = errors.New("error retrieving file mod time")

+ var ErrRemoteSignFail = errors.New("error in generating checksum and signature for remote file")

+ var ErrRemoteVerifyFail = errors.New("error in verifying signature for remote repofiles")

+ var ErrRootDirUndefined = errors.New("expected a root directory path to mount")

+ var ErrSignerKeyFile = errors.New("open key file error")

+ var ErrSignerPrivateKey = errors.New("signer requires a private key parameter")

+ var ErrSignerPubKey = errors.New("signer requires a public key parameter")

+ var ErrSignerSign = errors.New("error signing file")

+ var ErrSignerVerify = errors.New("error verifying file signature")

+ var ErrSourceURL = errors.New("invalid/unsupported source URL")

+ var ErrStoreConfig = errors.New("error in/invalid FileStore configuration")

+ var ErrSync = errors.New("error syncing files")

+ var ErrURLUnsupported = errors.New("error URL scheme/format unsupported")

+ var ErrUnsupportedFileStore = errors.New("unsupported file store")

+ var ErrUploadSigned = errors.New("error uploading signed file(s)")

+ func FindFileObjectByName(ctx context.Context, fs rcloneFs.Fs, name string) (rcloneFs.Object, error)

+ func SHA256Checksum(filename string) error

+ func SHA256ChecksumValidate(filename, checksum string) error

+ func SignFilestoreFile(ctx context.Context, srcPath, fileSHA256, tmpDir string, ...) error

+ func SplitURLPath(httpURL string) (hostPart, pathPart string, err error)

+ func VerifyFilestoreFile(ctx context.Context, filePath, fileSHA256, tmpDir string, ...) error

+ func VerifyUpdateURL(ctx context.Context, updateURL, filename, fileSHA256, tmpDir string, ...) error

+ type Downloader struct

+ func NewDownloader(ctx context.Context, srcURL string, storeCfg *StoreConfig) (*Downloader, error)

+ func (c *Downloader) CopyFilestoreToLocalTmp(ctx context.Context, tmpFilename, srcFilename string) error

+ func (c *Downloader) CopyLocalTmpToFilestore(ctx context.Context, dstFilename, srcFilename string) error

+ func (c *Downloader) CopyToFilestore(ctx context.Context, dstFilename, srcFilename string) error

+ func (c *Downloader) CopyURLToLocalTmp(ctx context.Context, tmpFilename, srcURL string) error

+ func (c *Downloader) DstURL() string

+ func (c *Downloader) FilestoreFileExists(ctx context.Context, name string) (bool, error)

+ func (c *Downloader) FilestoreFileModTime(ctx context.Context, name string) (time.Time, error)

+ func (c *Downloader) FilestoreRootDir() string

+ func (c *Downloader) FilestoreURL() string

+ func (c *Downloader) SrcFileExists(ctx context.Context, name string) (bool, error)

+ func (c *Downloader) SrcName() string

+ func (c *Downloader) SrcURL() string

+ func (c *Downloader) Stats() *DownloaderStats

+ func (c *Downloader) Sync(ctx context.Context) error

+ type DownloaderStats struct

+ BytesTransferred int64

+ Errors int64

+ ObjectsTransferred int64

+ type LocalFsConfig struct

+ Root string

+ type Metrics struct

+ func NewMetrics() *Metrics

+ func (m *Metrics) AddInt64Value(key string, value int64)

+ func (m *Metrics) Clear()

+ func (m *Metrics) FromDownloader(downloader *Downloader, deviceVendor, actionKind string)

+ func (m *Metrics) GetAllInt64Values() map[string]int64

+ type Provider interface

+ Stats func() *Metrics

+ Sync func(ctx context.Context) error

+ Verify func(ctx context.Context) error

+ type S3Config struct

+ AccessKey string

+ Bucket string

+ Endpoint string

+ Root string

+ SecretKey string

+ type Signer struct

+ func NewSigner(privateKeyFile, publicKeyfile string) (*Signer, error)

+ func (s *Signer) Sign(targetFile, sigFile string) error

+ func (s *Signer) Verify(targetFile, sigFile string) error

+ type StoreConfig struct

+ Local *LocalFsConfig

+ S3 *S3Config

+ Tmp string

+ URL string

+ func FilestoreConfig(rootDir string, cfg *config.Filestore) (*StoreConfig, error)

v0.0.1-staging

Jul 7, 2022

?	: This menu
/	: Search site
f or F	: Jump to
y or Y	: Canonical URL