Documentation
¶
Index ¶
- Variables
- func NewAzureBlobWalker(svc pipeline.Pipeline) (*azureBlobWalker, error)
- func NewFactory(params params.AdapterConfig) *walkerFactory
- func NewGCSWalker(client *storage.Client) *gcsWalker
- func NewS3Walker(sess *session.Session) *s3Walker
- type Mark
- type ObjectStoreEntry
- type WalkOptions
- type Walker
- type WalkerOptions
- type WalkerWrapper
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 (
ErrNotSupported = errors.New("no storage adapter found")
)
Functions ¶
func NewAzureBlobWalker ¶
func NewFactory ¶
func NewFactory(params params.AdapterConfig) *walkerFactory
func NewGCSWalker ¶
func NewS3Walker ¶
Types ¶
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
type WalkOptions ¶
type Walker ¶
type Walker interface {
Walk(ctx context.Context, storageURI *url.URL, op WalkOptions, walkFn func(e ObjectStoreEntry) error) error
Marker() Mark
}
type WalkerOptions ¶
type WalkerWrapper ¶
type WalkerWrapper struct {
// contains filtered or unexported fields
}
func NewWrapper ¶
func NewWrapper(walker Walker, uri *url.URL) *WalkerWrapper
func (*WalkerWrapper) Marker ¶
func (ww *WalkerWrapper) Marker() Mark
func (*WalkerWrapper) Walk ¶
func (ww *WalkerWrapper) Walk(ctx context.Context, opts WalkOptions, walkFn func(e ObjectStoreEntry) error) error
Click to show internal directories.
Click to hide internal directories.