Versions in this module Expand all Collapse all v0 v0.1.0 Oct 24, 2023 Changes in this version + const DefaultPrefix + const HTTPHeaderLastModified + var DefileDialTimeOut = "5s" + var ErrNotExist = fmt.Errorf("not exist!") + var ErrNotExistEndpoints = fmt.Errorf("endpoints cannot connect !") + var TimeStampKey = "timestamp" + type AlibabaCloudOSSBackend struct + Bucket *oss.Bucket + Client *oss.Client + Prefix string + SSE string + func NewAlibabaCloudOSSBackend(bucket string, prefix string, endpoint string, sse string) *AlibabaCloudOSSBackend + func (b AlibabaCloudOSSBackend) DeleteObject(path string) error + func (b AlibabaCloudOSSBackend) GetObject(path string) (Object, error) + func (b AlibabaCloudOSSBackend) ListObjects(prefix string) ([]Object, error) + func (b AlibabaCloudOSSBackend) PutObject(path string, content []byte) error + type AmazonS3Backend struct + Bucket string + Client *s3.S3 + Downloader *s3manager.Downloader + Prefix string + SSE string + Uploader *s3manager.Uploader + func NewAmazonS3Backend(bucket string, prefix string, region string, endpoint string, sse string) *AmazonS3Backend + func NewAmazonS3BackendWithCredentials(bucket string, prefix string, region string, endpoint string, sse string, ...) *AmazonS3Backend + func NewAmazonS3BackendWithOptions(bucket string, prefix string, region string, endpoint string, sse string, ...) *AmazonS3Backend + func (b AmazonS3Backend) DeleteObject(path string) error + func (b AmazonS3Backend) GetObject(path string) (Object, error) + func (b AmazonS3Backend) ListObjects(prefix string) ([]Object, error) + func (b AmazonS3Backend) PutObject(path string, content []byte) error + type AmazonS3Options struct + S3ForcePathStyle *bool + type Backend interface + DeleteObject func(path string) error + GetObject func(path string) (Object, error) + ListObjects func(prefix string) ([]Object, error) + PutObject func(path string, content []byte) error + func NewEtcdCSBackend(endpoints string, cafile, certfile, keyfile string, prefix string) Backend + type BaiduBOSBackend struct + Bucket string + Client *bos.Client + Prefix string + func NewBaiDuBOSBackend(bucket string, prefix string, endpoint string) *BaiduBOSBackend + func (b BaiduBOSBackend) DeleteObject(path string) error + func (b BaiduBOSBackend) GetObject(path string) (Object, error) + func (b BaiduBOSBackend) ListObjects(prefix string) ([]Object, error) + func (b BaiduBOSBackend) PutObject(path string, content []byte) error + type GoogleCSBackend struct + Client *storage.BucketHandle + Context context.Context + Prefix string + func NewGoogleCSBackend(bucket string, prefix string) *GoogleCSBackend + func (b GoogleCSBackend) DeleteObject(path string) error + func (b GoogleCSBackend) GetObject(path string) (Object, error) + func (b GoogleCSBackend) ListObjects(prefix string) ([]Object, error) + func (b GoogleCSBackend) PutObject(path string, content []byte) error + type LocalFilesystemBackend struct + RootDirectory string + func NewLocalFilesystemBackend(rootDirectory string) *LocalFilesystemBackend + func (b LocalFilesystemBackend) DeleteObject(path string) error + func (b LocalFilesystemBackend) GetObject(path string) (Object, error) + func (b LocalFilesystemBackend) ListObjects(prefix string) ([]Object, error) + func (b LocalFilesystemBackend) PutObject(path string, content []byte) error + type Metadata struct + Name string + Version string + type MicrosoftBlobBackend struct + Container *microsoft_storage.Container + Prefix string + func NewMicrosoftBlobBackend(container string, prefix string) *MicrosoftBlobBackend + func (b MicrosoftBlobBackend) DeleteObject(path string) error + func (b MicrosoftBlobBackend) GetObject(path string) (Object, error) + func (b MicrosoftBlobBackend) ListObjects(prefix string) ([]Object, error) + func (b MicrosoftBlobBackend) PutObject(path string, content []byte) error + type Object struct + Content []byte + LastModified time.Time + Meta Metadata + Path string + func (object Object) HasExtension(extension string) bool + type ObjectSliceDiff struct + Added []Object + Change bool + Removed []Object + Updated []Object + func GetObjectSliceDiff(prev []Object, curr []Object, timestampTolerance time.Duration) ObjectSliceDiff + type OpenstackOSBackend struct + CACert string + Client *gophercloud.ServiceClient + Container string + Prefix string + Region string + func NewOpenstackOSBackend(container string, prefix string, region string, caCert string) *OpenstackOSBackend + func NewOpenstackOSBackendV1Auth(container string, prefix string, caCert string) *OpenstackOSBackend + func (b OpenstackOSBackend) DeleteObject(path string) error + func (b OpenstackOSBackend) GetObject(path string) (Object, error) + func (b OpenstackOSBackend) ListObjects(prefix string) ([]Object, error) + func (b OpenstackOSBackend) PutObject(path string, content []byte) error + type OracleCSBackend struct + Bucket string + Client objectstorage.ObjectStorageClient + CompartmentId string + Context context.Context + Namespace string + Prefix string + func NewOracleCSBackend(bucket string, prefix string, region string, compartmentId string) *OracleCSBackend + func (b OracleCSBackend) DeleteObject(path string) error + func (b OracleCSBackend) GetObject(path string) (Object, error) + func (b OracleCSBackend) ListObjects(prefix string) ([]Object, error) + func (b OracleCSBackend) PutObject(path string, content []byte) error + type ReauthRoundTripper struct + func (rrt *ReauthRoundTripper) RoundTrip(request *http.Request) (*http.Response, error) + type TencentCloudCOSBackend struct + Bucket *cos.BucketService + Client *cos.Client + Object *cos.ObjectService + Prefix string + func NewTencentCloudCOSBackend(bucket string, prefix string, endpoint string) *TencentCloudCOSBackend + func (t TencentCloudCOSBackend) DeleteObject(path string) error + func (t TencentCloudCOSBackend) GetObject(path string) (Object, error) + func (t TencentCloudCOSBackend) ListObjects(prefix string) ([]Object, error) + func (t TencentCloudCOSBackend) PutObject(path string, content []byte) error