store

Documentation

Index

• Variables
• type WalkerFactory
  • func NewFactory(params params.AdapterConfig) *WalkerFactory
  • func (f *WalkerFactory) GetWalker(ctx context.Context, opts WalkerOptions) (*WalkerWrapper, error)
• type WalkerOptions
• type WalkerWrapper
  • func NewWrapper(walker block.Walker, uri *url.URL) *WalkerWrapper
  • func (ww *WalkerWrapper) GetSkippedEntries() []block.ObjectStoreEntry
  • func (ww *WalkerWrapper) Marker() block.Mark
  • func (ww *WalkerWrapper) Walk(ctx context.Context, opts block.WalkOptions, ...) error

Variables

var ErrNotSupported = errors.New("no storage adapter found")

Types

type WalkerFactory

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

func NewFactory

func NewFactory(params params.AdapterConfig) *WalkerFactory

func (*WalkerFactory) GetWalker

func (f *WalkerFactory) GetWalker(ctx context.Context, opts WalkerOptions) (*WalkerWrapper, error)

type WalkerOptions

type WalkerOptions struct {
	S3EndpointURL  string
	StorageURI     string
	SkipOutOfOrder bool
}

type WalkerWrapper

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

func NewWrapper

func NewWrapper(walker block.Walker, uri *url.URL) *WalkerWrapper

func (*WalkerWrapper) GetSkippedEntries

func (ww *WalkerWrapper) GetSkippedEntries() []block.ObjectStoreEntry

func (*WalkerWrapper) Marker

func (ww *WalkerWrapper) Marker() block.Mark

func (*WalkerWrapper) Walk

func (ww *WalkerWrapper) Walk(ctx context.Context, opts block.WalkOptions, walkFn func(e block.ObjectStoreEntry) error) error