Documentation
¶
Index ¶
- Variables
- func GetAzureClient() (pipeline.Pipeline, error)
- func GetGCSClient(ctx context.Context) (*storage.Client, error)
- func GetS3Client() (*s3.S3, error)
- func Walk(ctx context.Context, storageURI string, walkFn func(e ObjectStoreEntry) error) error
- type AzureBlobWalker
- type GCSWalker
- type ObjectStoreEntry
- type S3Walker
- type Walker
Constants ¶
This section is empty.
Variables ¶
View Source
var ( ErrAzureInvalidURL = errors.New("invalid Azure storage URL") ErrAzureCredentials = errors.New("azure credentials error") )
View Source
var (
ErrNoStorageAdapter = errors.New("no storage adapter found")
)
Functions ¶
func GetAzureClient ¶
func GetS3Client ¶
Types ¶
type AzureBlobWalker ¶
type AzureBlobWalker struct {
// contains filtered or unexported fields
}
func (*AzureBlobWalker) Walk ¶
func (a *AzureBlobWalker) Walk(ctx context.Context, storageURI *url.URL, walkFn func(e ObjectStoreEntry) error) error
type ObjectStoreEntry ¶
type ObjectStoreEntry struct {
// FullKey represents the fully qualified path in the object store namespace for the given entry
FullKey string
// RelativeKey represents a path relative to prefix (or directory). If none specified, will be identical to FullKey
RelativeKey string
// Address is a full URI for the entry, including the storage namespace (i.e. s3://bucket/path/to/key)
Address string
// ETag represents a hash of the entry's content. Generally as hex encoded MD5,
// but depends on the underlying object store
ETag string
// Mtime is the last-modified datetime of the entry
Mtime time.Time
// Size in bytes
Size int64
}
func (ObjectStoreEntry) String ¶
func (e ObjectStoreEntry) String() string
Click to show internal directories.
Click to hide internal directories.