testutils

Documentation

Index

• Constants
• type FakeEntryIterator
  • func NewFakeEntryIterator(entries []*catalog.EntryRecord) *FakeEntryIterator
  • func (f *FakeEntryIterator) Close()
  • func (f *FakeEntryIterator) Err() error
  • func (f *FakeEntryIterator) Next() bool
  • func (f *FakeEntryIterator) SeekGE(id catalog.Path)
  • func (f *FakeEntryIterator) Value() *catalog.EntryRecord
• type FakeFactory
  • func (f FakeFactory) GetWalker(_ context.Context, op store.WalkerOptions) (*store.WalkerWrapper, error)
• type FakeKVEntryIterator
  • func NewFakeKVEntryIterator(entries []*kv.Entry) *FakeKVEntryIterator
  • func (f *FakeKVEntryIterator) Close()
  • func (f *FakeKVEntryIterator) Entry() *kv.Entry
  • func (f *FakeKVEntryIterator) Err() error
  • func (f *FakeKVEntryIterator) Next() bool
• type FakeValueIterator
  • func NewFakeValueIterator(records []*graveler.ValueRecord) *FakeValueIterator
  • func (f *FakeValueIterator) Close()
  • func (f *FakeValueIterator) Err() error
  • func (f *FakeValueIterator) Next() bool
  • func (f *FakeValueIterator) SeekGE(id graveler.Key)
  • func (f *FakeValueIterator) Value() *graveler.ValueRecord
• type FakeWalker
  • func NewFakeWalker(count, max int, ...) *FakeWalker
  • func (w *FakeWalker) GetSkippedEntries() []block.ObjectStoreEntry
  • func (w *FakeWalker) Marker() block.Mark
  • func (w *FakeWalker) Walk(_ context.Context, storageURI *url.URL, op block.WalkOptions, ...) error

Constants

const ContinuationTokenOpaque = "FakeContToken"

Types

type FakeEntryIterator

type FakeEntryIterator struct {
	Entries []*catalog.EntryRecord
	Error   error
	// contains filtered or unexported fields
}

func NewFakeEntryIterator

func NewFakeEntryIterator(entries []*catalog.EntryRecord) *FakeEntryIterator

func (*FakeEntryIterator) Close

func (f *FakeEntryIterator) Close()

func (*FakeEntryIterator) Err

func (f *FakeEntryIterator) Err() error

func (*FakeEntryIterator) Next

func (f *FakeEntryIterator) Next() bool

func (*FakeEntryIterator) SeekGE

func (f *FakeEntryIterator) SeekGE(id catalog.Path)

func (*FakeEntryIterator) Value

func (f *FakeEntryIterator) Value() *catalog.EntryRecord

type FakeFactory

type FakeFactory struct {
	Walker *FakeWalker
}

func (FakeFactory) GetWalker

func (f FakeFactory) GetWalker(_ context.Context, op store.WalkerOptions) (*store.WalkerWrapper, error)

type FakeKVEntryIterator

type FakeKVEntryIterator struct {
	Entries []*kv.Entry
	Error   error
	// contains filtered or unexported fields
}

func NewFakeKVEntryIterator

func NewFakeKVEntryIterator(entries []*kv.Entry) *FakeKVEntryIterator

func (*FakeKVEntryIterator) Close

func (f *FakeKVEntryIterator) Close()

func (*FakeKVEntryIterator) Entry

func (f *FakeKVEntryIterator) Entry() *kv.Entry

func (*FakeKVEntryIterator) Err

func (f *FakeKVEntryIterator) Err() error

func (*FakeKVEntryIterator) Next

func (f *FakeKVEntryIterator) Next() bool

type FakeValueIterator

type FakeValueIterator struct {
	Records []*graveler.ValueRecord
	Error   error
	// contains filtered or unexported fields
}

func NewFakeValueIterator

func NewFakeValueIterator(records []*graveler.ValueRecord) *FakeValueIterator

func (*FakeValueIterator) Close

func (f *FakeValueIterator) Close()

func (*FakeValueIterator) Err

func (f *FakeValueIterator) Err() error

func (*FakeValueIterator) Next

func (f *FakeValueIterator) Next() bool

func (*FakeValueIterator) SeekGE

func (f *FakeValueIterator) SeekGE(id graveler.Key)

func (*FakeValueIterator) Value

func (f *FakeValueIterator) Value() *graveler.ValueRecord

type FakeWalker

type FakeWalker struct {
	Entries []block.ObjectStoreEntry

	Max int
	// contains filtered or unexported fields
}

func NewFakeWalker

func NewFakeWalker(count, max int, uriPrefix, expectedAfter, expectedContinuationToken, expectedFromSourceURIWithPrefix string, err error) *FakeWalker

func (*FakeWalker) GetSkippedEntries

func (w *FakeWalker) GetSkippedEntries() []block.ObjectStoreEntry

func (*FakeWalker) Marker

func (w *FakeWalker) Marker() block.Mark

func (*FakeWalker) Walk

func (w *FakeWalker) Walk(_ context.Context, storageURI *url.URL, op block.WalkOptions, walkFn func(e block.ObjectStoreEntry) error) error