Documentation ¶
Index ¶
Constants ¶
This section is empty.
Variables ¶
View Source
var ( ErrNotSupported = errors.New("no storage adapter found") ErrForbidden = errors.New("forbidden") ErrBadPath = errors.New("bad path traversal blocked") )
View Source
var ErrAzureInvalidURL = errors.New("invalid Azure storage URL")
Functions ¶
This section is empty.
Types ¶
type AzureBlobWalker ¶ added in v0.91.0
type AzureBlobWalker struct {
// contains filtered or unexported fields
}
func NewAzureBlobWalker ¶
func NewAzureBlobWalker(svc *service.Client) (*AzureBlobWalker, error)
func (*AzureBlobWalker) Marker ¶ added in v0.91.0
func (a *AzureBlobWalker) Marker() Mark
func (*AzureBlobWalker) Walk ¶ added in v0.91.0
func (a *AzureBlobWalker) Walk(ctx context.Context, storageURI *url.URL, op WalkOptions, walkFn func(e ObjectStoreEntry) error) error
type GCSWalker ¶ added in v0.91.0
type GCSWalker struct {
// contains filtered or unexported fields
}
func NewGCSWalker ¶
type LocalWalker ¶ added in v0.94.0
type LocalWalker struct {
// contains filtered or unexported fields
}
func NewLocalWalker ¶ added in v0.94.0
func NewLocalWalker(params params.Local) *LocalWalker
func (*LocalWalker) Marker ¶ added in v0.94.0
func (l *LocalWalker) Marker() Mark
func (*LocalWalker) Walk ¶ added in v0.94.0
func (l *LocalWalker) Walk(_ context.Context, storageURI *url.URL, options WalkOptions, 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 `json:"full_key,omitempty"` // RelativeKey represents a path relative to prefix (or directory). If none specified, will be identical to FullKey RelativeKey string `json:"relative_key,omitempty"` // Address is a full URI for the entry, including the storage namespace (i.e. s3://bucket/path/to/key) Address string `json:"address,omitempty"` // ETag represents a hash of the entry's content. Generally as hex encoded MD5, // but depends on the underlying object store ETag string `json:"etag,omitempty"` // Mtime is the last-modified datetime of the entry Mtime time.Time `json:"mtime,omitempty"` // Size in bytes Size int64 `json:"size"` }
func (ObjectStoreEntry) String ¶
func (e ObjectStoreEntry) String() string
type S3Walker ¶ added in v0.91.0
type S3Walker struct {
// contains filtered or unexported fields
}
func NewS3Walker ¶
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 WalkerFactory ¶ added in v0.91.0
type WalkerFactory struct {
// contains filtered or unexported fields
}
func NewFactory ¶
func NewFactory(params params.AdapterConfig) *WalkerFactory
func (*WalkerFactory) GetWalker ¶ added in v0.91.0
func (f *WalkerFactory) GetWalker(ctx context.Context, opts WalkerOptions) (*WalkerWrapper, error)
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.