local

package
v1.28.2 Latest Latest
Warning

This package is not in the latest version of its module.

 Go to latest Published: Jul 8, 2024 License: Apache-2.0 Imports: 22 Imported by: 0

Documentation

Index

Constants

View Source 
const DefaultNamespacePrefix = block.BlockstoreTypeLocal + "://"

Variables

View Source 
var (
	ErrPathNotWritable       = errors.New("path provided is not writable")
	ErrInvalidUploadIDFormat = errors.New("invalid upload id format")
	ErrBadPath               = errors.New("bad path traversal blocked")
)

Functions

func VerifyAbsPath added in v0.97.0 

func VerifyAbsPath(absPath, adapterPath string, allowedPrefixes []string) error

func WithAllowedExternalPrefixes added in v0.94.0 

func WithAllowedExternalPrefixes(prefixes []string) func(a *Adapter)

func WithImportEnabled added in v0.94.0 

func WithImportEnabled(b bool) func(a *Adapter)

func WithRemoveEmptyDir 

func WithRemoveEmptyDir(b bool) func(a *Adapter)

Types

type Adapter 

type Adapter struct {
	// contains filtered or unexported fields
}

func NewAdapter 

func NewAdapter(path string, opts ...func(a *Adapter)) (*Adapter, error)

func (*Adapter) AbortMultiPartUpload 

func (l *Adapter) AbortMultiPartUpload(_ context.Context, obj block.ObjectPointer, uploadID string) error

func (*Adapter) BlockstoreMetadata added in v1.26.0 

func (l *Adapter) BlockstoreMetadata(ctx context.Context) (*block.BlockstoreMetadata, error)

func (*Adapter) BlockstoreType 

func (l *Adapter) BlockstoreType() string

func (*Adapter) CompleteMultiPartUpload 

func (l *Adapter) CompleteMultiPartUpload(_ context.Context, obj block.ObjectPointer, uploadID string, multipartList *block.MultipartUploadCompletion) (*block.CompleteMultiPartUploadResponse, error)

func (*Adapter) Copy 

func (l *Adapter) Copy(_ context.Context, sourceObj, destinationObj block.ObjectPointer) error

func (*Adapter) CreateMultiPartUpload 

func (l *Adapter) CreateMultiPartUpload(_ context.Context, obj block.ObjectPointer, _ *http.Request, _ block.CreateMultiPartUploadOpts) (*block.CreateMultiPartUploadResponse, error)

func (*Adapter) Exists 

func (l *Adapter) Exists(_ context.Context, obj block.ObjectPointer) (bool, error)

func (*Adapter) Get 

func (l *Adapter) Get(_ context.Context, obj block.ObjectPointer) (reader io.ReadCloser, err error)

func (*Adapter) GetPreSignedURL added in v0.90.0 

func (l *Adapter) GetPreSignedURL(_ context.Context, _ block.ObjectPointer, _ block.PreSignMode) (string, time.Time, error)

func (*Adapter) GetPresignUploadPartURL added in v1.7.0 

func (l *Adapter) GetPresignUploadPartURL(_ context.Context, _ block.ObjectPointer, _ string, _ int) (string, error)

func (*Adapter) GetProperties 

func (l *Adapter) GetProperties(_ context.Context, obj block.ObjectPointer) (block.Properties, error)

func (*Adapter) GetRange 

func (l *Adapter) GetRange(_ context.Context, obj block.ObjectPointer, start int64, end int64) (io.ReadCloser, error)

func (*Adapter) GetRegion added in v1.26.0 

func (l *Adapter) GetRegion(_ context.Context, _ string) (string, error)

func (*Adapter) GetStorageNamespaceInfo 

func (l *Adapter) GetStorageNamespaceInfo() block.StorageNamespaceInfo

func (*Adapter) GetWalker added in v0.97.0 

func (l *Adapter) GetWalker(uri *url.URL) (block.Walker, error)

func (*Adapter) ListParts added in v1.19.0 

func (l *Adapter) ListParts(_ context.Context, _ block.ObjectPointer, _ string, _ block.ListPartsOpts) (*block.ListPartsResponse, error)

func (*Adapter) Path 

func (l *Adapter) Path() string

func (*Adapter) Put 

func (l *Adapter) Put(_ context.Context, obj block.ObjectPointer, _ int64, reader io.Reader, _ block.PutOpts) error

func (*Adapter) Remove 

func (l *Adapter) Remove(_ context.Context, obj block.ObjectPointer) error

func (*Adapter) ResolveNamespace added in v0.97.0 

func (l *Adapter) ResolveNamespace(storageNamespace, key string, identifierType block.IdentifierType) (block.QualifiedKey, error)

func (*Adapter) RuntimeStats added in v0.41.1 

func (l *Adapter) RuntimeStats() map[string]string

func (*Adapter) UploadCopyPart 

func (l *Adapter) UploadCopyPart(ctx context.Context, sourceObj, destinationObj block.ObjectPointer, uploadID string, partNumber int) (*block.UploadPartResponse, error)

func (*Adapter) UploadCopyPartRange 

func (l *Adapter) UploadCopyPartRange(ctx context.Context, sourceObj, destinationObj block.ObjectPointer, uploadID string, partNumber int, startPosition, endPosition int64) (*block.UploadPartResponse, error)

func (*Adapter) UploadPart 

func (l *Adapter) UploadPart(ctx context.Context, obj block.ObjectPointer, _ int64, reader io.Reader, uploadID string, partNumber int) (*block.UploadPartResponse, error)

type QualifiedKey added in v0.97.0 

type QualifiedKey struct {
	block.CommonQualifiedKey
	// contains filtered or unexported fields
}

func (QualifiedKey) Format added in v0.97.0 

func (qk QualifiedKey) Format() string

func (QualifiedKey) GetKey added in v0.97.0 

func (qk QualifiedKey) GetKey() string

func (QualifiedKey) GetStorageNamespace added in v0.97.0 

func (qk QualifiedKey) GetStorageNamespace() string

func (QualifiedKey) GetStorageType added in v0.97.0 

func (qk QualifiedKey) GetStorageType() block.StorageType

type Walker added in v0.97.0 

type Walker struct {
	// contains filtered or unexported fields
}

func NewLocalWalker added in v0.97.0 

func NewLocalWalker(params params.Local) *Walker

func (*Walker) GetSkippedEntries added in v0.98.0 

func (l *Walker) GetSkippedEntries() []block.ObjectStoreEntry

func (*Walker) Marker added in v0.97.0 

func (l *Walker) Marker() block.Mark

func (*Walker) Walk added in v0.97.0 

func (l *Walker) Walk(_ context.Context, storageURI *url.URL, options block.WalkOptions, walkFn func(e block.ObjectStoreEntry) error) error

Source Files

View all Source files

Jump to

Keyboard shortcuts

? : This menu
/ : Search site
f or F : Jump to
y or Y : Canonical URL
go.dev uses cookies from Google to deliver and enhance the quality of its services and to analyze traffic. Learn more.