mocks

package
v1.18.1 Latest Latest
Warning

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

 Go to latest Published: Jan 13, 2026 License: BSD-2-Clause Imports: 3 Imported by: 0

Documentation

Overview

Code generated by counterfeiter. DO NOT EDIT.

Code generated by counterfeiter. DO NOT EDIT.

Code generated by counterfeiter. DO NOT EDIT.

Code generated by counterfeiter. DO NOT EDIT.

Code generated by counterfeiter. DO NOT EDIT.

Code generated by counterfeiter. DO NOT EDIT.

Code generated by counterfeiter. DO NOT EDIT.

Code generated by counterfeiter. DO NOT EDIT.

Code generated by counterfeiter. DO NOT EDIT.

Index

Constants

This section is empty.

Variables

This section is empty.

Functions

This section is empty.

Types

type Bucket 

type Bucket struct {
	DeleteStub func(context.Context, []byte) error

	GetStub func(context.Context, []byte) (kv.Item, error)

	IteratorStub func() kv.Iterator

	IteratorReverseStub func() kv.Iterator

	PutStub func(context.Context, []byte, []byte) error
	// contains filtered or unexported fields
}

func (*Bucket) Delete 

func (fake *Bucket) Delete(arg1 context.Context, arg2 []byte) error

func (*Bucket) DeleteArgsForCall 

func (fake *Bucket) DeleteArgsForCall(i int) (context.Context, []byte)

func (*Bucket) DeleteCallCount 

func (fake *Bucket) DeleteCallCount() int

func (*Bucket) DeleteCalls 

func (fake *Bucket) DeleteCalls(stub func(context.Context, []byte) error)

func (*Bucket) DeleteReturns 

func (fake *Bucket) DeleteReturns(result1 error)

func (*Bucket) DeleteReturnsOnCall 

func (fake *Bucket) DeleteReturnsOnCall(i int, result1 error)

func (*Bucket) Get 

func (fake *Bucket) Get(arg1 context.Context, arg2 []byte) (kv.Item, error)

func (*Bucket) GetArgsForCall 

func (fake *Bucket) GetArgsForCall(i int) (context.Context, []byte)

func (*Bucket) GetCallCount 

func (fake *Bucket) GetCallCount() int

func (*Bucket) GetCalls 

func (fake *Bucket) GetCalls(stub func(context.Context, []byte) (kv.Item, error))

func (*Bucket) GetReturns 

func (fake *Bucket) GetReturns(result1 kv.Item, result2 error)

func (*Bucket) GetReturnsOnCall 

func (fake *Bucket) GetReturnsOnCall(i int, result1 kv.Item, result2 error)

func (*Bucket) Invocations 

func (fake *Bucket) Invocations() map[string][][]interface{}

func (*Bucket) Iterator 

func (fake *Bucket) Iterator() kv.Iterator

func (*Bucket) IteratorCallCount 

func (fake *Bucket) IteratorCallCount() int

func (*Bucket) IteratorCalls 

func (fake *Bucket) IteratorCalls(stub func() kv.Iterator)

func (*Bucket) IteratorReturns 

func (fake *Bucket) IteratorReturns(result1 kv.Iterator)

func (*Bucket) IteratorReturnsOnCall 

func (fake *Bucket) IteratorReturnsOnCall(i int, result1 kv.Iterator)

func (*Bucket) IteratorReverse 

func (fake *Bucket) IteratorReverse() kv.Iterator

func (*Bucket) IteratorReverseCallCount 

func (fake *Bucket) IteratorReverseCallCount() int

func (*Bucket) IteratorReverseCalls 

func (fake *Bucket) IteratorReverseCalls(stub func() kv.Iterator)

func (*Bucket) IteratorReverseReturns 

func (fake *Bucket) IteratorReverseReturns(result1 kv.Iterator)

func (*Bucket) IteratorReverseReturnsOnCall 

func (fake *Bucket) IteratorReverseReturnsOnCall(i int, result1 kv.Iterator)

func (*Bucket) Put 

func (fake *Bucket) Put(arg1 context.Context, arg2 []byte, arg3 []byte) error

func (*Bucket) PutArgsForCall 

func (fake *Bucket) PutArgsForCall(i int) (context.Context, []byte, []byte)

func (*Bucket) PutCallCount 

func (fake *Bucket) PutCallCount() int

func (*Bucket) PutCalls 

func (fake *Bucket) PutCalls(stub func(context.Context, []byte, []byte) error)

func (*Bucket) PutReturns 

func (fake *Bucket) PutReturns(result1 error)

func (*Bucket) PutReturnsOnCall 

func (fake *Bucket) PutReturnsOnCall(i int, result1 error)

type DB 

type DB struct {
	CloseStub func() error

	RemoveStub func() error

	SyncStub func() error

	UpdateStub func(context.Context, func(ctx context.Context, tx kv.Tx) error) error

	ViewStub func(context.Context, func(ctx context.Context, tx kv.Tx) error) error
	// contains filtered or unexported fields
}

func (*DB) Close 

func (fake *DB) Close() error

func (*DB) CloseCallCount 

func (fake *DB) CloseCallCount() int

func (*DB) CloseCalls 

func (fake *DB) CloseCalls(stub func() error)

func (*DB) CloseReturns 

func (fake *DB) CloseReturns(result1 error)

func (*DB) CloseReturnsOnCall 

func (fake *DB) CloseReturnsOnCall(i int, result1 error)

func (*DB) Invocations 

func (fake *DB) Invocations() map[string][][]interface{}

func (*DB) Remove 

func (fake *DB) Remove() error

func (*DB) RemoveCallCount 

func (fake *DB) RemoveCallCount() int

func (*DB) RemoveCalls 

func (fake *DB) RemoveCalls(stub func() error)

func (*DB) RemoveReturns 

func (fake *DB) RemoveReturns(result1 error)

func (*DB) RemoveReturnsOnCall 

func (fake *DB) RemoveReturnsOnCall(i int, result1 error)

func (*DB) Sync 

func (fake *DB) Sync() error

func (*DB) SyncCallCount 

func (fake *DB) SyncCallCount() int

func (*DB) SyncCalls 

func (fake *DB) SyncCalls(stub func() error)

func (*DB) SyncReturns 

func (fake *DB) SyncReturns(result1 error)

func (*DB) SyncReturnsOnCall 

func (fake *DB) SyncReturnsOnCall(i int, result1 error)

func (*DB) Update 

func (fake *DB) Update(arg1 context.Context, arg2 func(ctx context.Context, tx kv.Tx) error) error

func (*DB) UpdateArgsForCall 

func (fake *DB) UpdateArgsForCall(i int) (context.Context, func(ctx context.Context, tx kv.Tx) error)

func (*DB) UpdateCallCount 

func (fake *DB) UpdateCallCount() int

func (*DB) UpdateCalls 

func (fake *DB) UpdateCalls(stub func(context.Context, func(ctx context.Context, tx kv.Tx) error) error)

func (*DB) UpdateReturns 

func (fake *DB) UpdateReturns(result1 error)

func (*DB) UpdateReturnsOnCall 

func (fake *DB) UpdateReturnsOnCall(i int, result1 error)

func (*DB) View 

func (fake *DB) View(arg1 context.Context, arg2 func(ctx context.Context, tx kv.Tx) error) error

func (*DB) ViewArgsForCall 

func (fake *DB) ViewArgsForCall(i int) (context.Context, func(ctx context.Context, tx kv.Tx) error)

func (*DB) ViewCallCount 

func (fake *DB) ViewCallCount() int

func (*DB) ViewCalls 

func (fake *DB) ViewCalls(stub func(context.Context, func(ctx context.Context, tx kv.Tx) error) error)

func (*DB) ViewReturns 

func (fake *DB) ViewReturns(result1 error)

func (*DB) ViewReturnsOnCall 

func (fake *DB) ViewReturnsOnCall(i int, result1 error)

type Item 

type Item struct {
	ExistsStub func() bool

	KeyStub func() []byte

	ValueStub func(func(val []byte) error) error
	// contains filtered or unexported fields
}

func (*Item) Exists 

func (fake *Item) Exists() bool

func (*Item) ExistsCallCount 

func (fake *Item) ExistsCallCount() int

func (*Item) ExistsCalls 

func (fake *Item) ExistsCalls(stub func() bool)

func (*Item) ExistsReturns 

func (fake *Item) ExistsReturns(result1 bool)

func (*Item) ExistsReturnsOnCall 

func (fake *Item) ExistsReturnsOnCall(i int, result1 bool)

func (*Item) Invocations 

func (fake *Item) Invocations() map[string][][]interface{}

func (*Item) Key 

func (fake *Item) Key() []byte

func (*Item) KeyCallCount 

func (fake *Item) KeyCallCount() int

func (*Item) KeyCalls 

func (fake *Item) KeyCalls(stub func() []byte)

func (*Item) KeyReturns 

func (fake *Item) KeyReturns(result1 []byte)

func (*Item) KeyReturnsOnCall 

func (fake *Item) KeyReturnsOnCall(i int, result1 []byte)

func (*Item) Value 

func (fake *Item) Value(arg1 func(val []byte) error) error

func (*Item) ValueArgsForCall 

func (fake *Item) ValueArgsForCall(i int) func(val []byte) error

func (*Item) ValueCallCount 

func (fake *Item) ValueCallCount() int

func (*Item) ValueCalls 

func (fake *Item) ValueCalls(stub func(func(val []byte) error) error)

func (*Item) ValueReturns 

func (fake *Item) ValueReturns(result1 error)

func (*Item) ValueReturnsOnCall 

func (fake *Item) ValueReturnsOnCall(i int, result1 error)

type Iterator 

type Iterator struct {
	CloseStub func()

	ItemStub func() kv.Item

	NextStub func()

	RewindStub func()

	SeekStub func([]byte)

	ValidStub func() bool
	// contains filtered or unexported fields
}

func (*Iterator) Close 

func (fake *Iterator) Close()

func (*Iterator) CloseCallCount 

func (fake *Iterator) CloseCallCount() int

func (*Iterator) CloseCalls 

func (fake *Iterator) CloseCalls(stub func())

func (*Iterator) Invocations 

func (fake *Iterator) Invocations() map[string][][]interface{}

func (*Iterator) Item 

func (fake *Iterator) Item() kv.Item

func (*Iterator) ItemCallCount 

func (fake *Iterator) ItemCallCount() int

func (*Iterator) ItemCalls 

func (fake *Iterator) ItemCalls(stub func() kv.Item)

func (*Iterator) ItemReturns 

func (fake *Iterator) ItemReturns(result1 kv.Item)

func (*Iterator) ItemReturnsOnCall 

func (fake *Iterator) ItemReturnsOnCall(i int, result1 kv.Item)

func (*Iterator) Next 

func (fake *Iterator) Next()

func (*Iterator) NextCallCount 

func (fake *Iterator) NextCallCount() int

func (*Iterator) NextCalls 

func (fake *Iterator) NextCalls(stub func())

func (*Iterator) Rewind 

func (fake *Iterator) Rewind()

func (*Iterator) RewindCallCount 

func (fake *Iterator) RewindCallCount() int

func (*Iterator) RewindCalls 

func (fake *Iterator) RewindCalls(stub func())

func (*Iterator) Seek 

func (fake *Iterator) Seek(arg1 []byte)

func (*Iterator) SeekArgsForCall 

func (fake *Iterator) SeekArgsForCall(i int) []byte

func (*Iterator) SeekCallCount 

func (fake *Iterator) SeekCallCount() int

func (*Iterator) SeekCalls 

func (fake *Iterator) SeekCalls(stub func([]byte))

func (*Iterator) Valid 

func (fake *Iterator) Valid() bool

func (*Iterator) ValidCallCount 

func (fake *Iterator) ValidCallCount() int

func (*Iterator) ValidCalls 

func (fake *Iterator) ValidCalls(stub func() bool)

func (*Iterator) ValidReturns 

func (fake *Iterator) ValidReturns(result1 bool)

func (*Iterator) ValidReturnsOnCall 

func (fake *Iterator) ValidReturnsOnCall(i int, result1 bool)

type Provider 

type Provider struct {
	GetStub func(context.Context) (kv.DB, error)
	// contains filtered or unexported fields
}

func (*Provider) Get 

func (fake *Provider) Get(arg1 context.Context) (kv.DB, error)

func (*Provider) GetArgsForCall 

func (fake *Provider) GetArgsForCall(i int) context.Context

func (*Provider) GetCallCount 

func (fake *Provider) GetCallCount() int

func (*Provider) GetCalls 

func (fake *Provider) GetCalls(stub func(context.Context) (kv.DB, error))

func (*Provider) GetReturns 

func (fake *Provider) GetReturns(result1 kv.DB, result2 error)

func (*Provider) GetReturnsOnCall 

func (fake *Provider) GetReturnsOnCall(i int, result1 kv.DB, result2 error)

func (*Provider) Invocations 

func (fake *Provider) Invocations() map[string][][]interface{}

type RelationStoreString added in v1.12.1 

type RelationStoreString struct {
	AddStub func(context.Context, string, []string) error

	DeleteStub func(context.Context, string) error

	IDsStub func(context.Context, string) ([]string, error)

	InvertStub func() kv.RelationStore[string, string]

	MapIDRelationsStub func(context.Context, func(ctx context.Context, key string, relatedIDs []string) error) error

	MapRelationIDsStub func(context.Context, func(ctx context.Context, key string, ids []string) error) error

	RelatedIDsStub func(context.Context, string) ([]string, error)

	RemoveStub func(context.Context, string, []string) error

	ReplaceStub func(context.Context, string, []string) error

	StreamIDsStub func(context.Context, chan<- string) error

	StreamRelatedIDsStub func(context.Context, chan<- string) error
	// contains filtered or unexported fields
}

func (*RelationStoreString) Add added in v1.12.1 

func (fake *RelationStoreString) Add(arg1 context.Context, arg2 string, arg3 []string) error

func (*RelationStoreString) AddArgsForCall added in v1.12.1 

func (fake *RelationStoreString) AddArgsForCall(i int) (context.Context, string, []string)

func (*RelationStoreString) AddCallCount added in v1.12.1 

func (fake *RelationStoreString) AddCallCount() int

func (*RelationStoreString) AddCalls added in v1.12.1 

func (fake *RelationStoreString) AddCalls(stub func(context.Context, string, []string) error)

func (*RelationStoreString) AddReturns added in v1.12.1 

func (fake *RelationStoreString) AddReturns(result1 error)

func (*RelationStoreString) AddReturnsOnCall added in v1.12.1 

func (fake *RelationStoreString) AddReturnsOnCall(i int, result1 error)

func (*RelationStoreString) Delete added in v1.12.1 

func (fake *RelationStoreString) Delete(arg1 context.Context, arg2 string) error

func (*RelationStoreString) DeleteArgsForCall added in v1.12.1 

func (fake *RelationStoreString) DeleteArgsForCall(i int) (context.Context, string)

func (*RelationStoreString) DeleteCallCount added in v1.12.1 

func (fake *RelationStoreString) DeleteCallCount() int

func (*RelationStoreString) DeleteCalls added in v1.12.1 

func (fake *RelationStoreString) DeleteCalls(stub func(context.Context, string) error)

func (*RelationStoreString) DeleteReturns added in v1.12.1 

func (fake *RelationStoreString) DeleteReturns(result1 error)

func (*RelationStoreString) DeleteReturnsOnCall added in v1.12.1 

func (fake *RelationStoreString) DeleteReturnsOnCall(i int, result1 error)

func (*RelationStoreString) IDs added in v1.12.1 

func (fake *RelationStoreString) IDs(arg1 context.Context, arg2 string) ([]string, error)

func (*RelationStoreString) IDsArgsForCall added in v1.12.1 

func (fake *RelationStoreString) IDsArgsForCall(i int) (context.Context, string)

func (*RelationStoreString) IDsCallCount added in v1.12.1 

func (fake *RelationStoreString) IDsCallCount() int

func (*RelationStoreString) IDsCalls added in v1.12.1 

func (fake *RelationStoreString) IDsCalls(stub func(context.Context, string) ([]string, error))

func (*RelationStoreString) IDsReturns added in v1.12.1 

func (fake *RelationStoreString) IDsReturns(result1 []string, result2 error)

func (*RelationStoreString) IDsReturnsOnCall added in v1.12.1 

func (fake *RelationStoreString) IDsReturnsOnCall(i int, result1 []string, result2 error)

func (*RelationStoreString) Invert added in v1.12.1 

func (fake *RelationStoreString) Invert() kv.RelationStore[string, string]

func (*RelationStoreString) InvertCallCount added in v1.12.1 

func (fake *RelationStoreString) InvertCallCount() int

func (*RelationStoreString) InvertCalls added in v1.12.1 

func (fake *RelationStoreString) InvertCalls(stub func() kv.RelationStore[string, string])

func (*RelationStoreString) InvertReturns added in v1.12.1 

func (fake *RelationStoreString) InvertReturns(result1 kv.RelationStore[string, string])

func (*RelationStoreString) InvertReturnsOnCall added in v1.12.1 

func (fake *RelationStoreString) InvertReturnsOnCall(i int, result1 kv.RelationStore[string, string])

func (*RelationStoreString) Invocations added in v1.12.1 

func (fake *RelationStoreString) Invocations() map[string][][]interface{}

func (*RelationStoreString) MapIDRelations added in v1.12.1 

func (fake *RelationStoreString) MapIDRelations(arg1 context.Context, arg2 func(ctx context.Context, key string, relatedIDs []string) error) error

func (*RelationStoreString) MapIDRelationsArgsForCall added in v1.12.1 

func (fake *RelationStoreString) MapIDRelationsArgsForCall(i int) (context.Context, func(ctx context.Context, key string, relatedIDs []string) error)

func (*RelationStoreString) MapIDRelationsCallCount added in v1.12.1 

func (fake *RelationStoreString) MapIDRelationsCallCount() int

func (*RelationStoreString) MapIDRelationsCalls added in v1.12.1 

func (fake *RelationStoreString) MapIDRelationsCalls(stub func(context.Context, func(ctx context.Context, key string, relatedIDs []string) error) error)

func (*RelationStoreString) MapIDRelationsReturns added in v1.12.1 

func (fake *RelationStoreString) MapIDRelationsReturns(result1 error)

func (*RelationStoreString) MapIDRelationsReturnsOnCall added in v1.12.1 

func (fake *RelationStoreString) MapIDRelationsReturnsOnCall(i int, result1 error)

func (*RelationStoreString) MapRelationIDs added in v1.12.1 

func (fake *RelationStoreString) MapRelationIDs(arg1 context.Context, arg2 func(ctx context.Context, key string, ids []string) error) error

func (*RelationStoreString) MapRelationIDsArgsForCall added in v1.12.1 

func (fake *RelationStoreString) MapRelationIDsArgsForCall(i int) (context.Context, func(ctx context.Context, key string, ids []string) error)

func (*RelationStoreString) MapRelationIDsCallCount added in v1.12.1 

func (fake *RelationStoreString) MapRelationIDsCallCount() int

func (*RelationStoreString) MapRelationIDsCalls added in v1.12.1 

func (fake *RelationStoreString) MapRelationIDsCalls(stub func(context.Context, func(ctx context.Context, key string, ids []string) error) error)

func (*RelationStoreString) MapRelationIDsReturns added in v1.12.1 

func (fake *RelationStoreString) MapRelationIDsReturns(result1 error)

func (*RelationStoreString) MapRelationIDsReturnsOnCall added in v1.12.1 

func (fake *RelationStoreString) MapRelationIDsReturnsOnCall(i int, result1 error)

func (*RelationStoreString) RelatedIDs added in v1.12.1 

func (fake *RelationStoreString) RelatedIDs(arg1 context.Context, arg2 string) ([]string, error)

func (*RelationStoreString) RelatedIDsArgsForCall added in v1.12.1 

func (fake *RelationStoreString) RelatedIDsArgsForCall(i int) (context.Context, string)

func (*RelationStoreString) RelatedIDsCallCount added in v1.12.1 

func (fake *RelationStoreString) RelatedIDsCallCount() int

func (*RelationStoreString) RelatedIDsCalls added in v1.12.1 

func (fake *RelationStoreString) RelatedIDsCalls(stub func(context.Context, string) ([]string, error))

func (*RelationStoreString) RelatedIDsReturns added in v1.12.1 

func (fake *RelationStoreString) RelatedIDsReturns(result1 []string, result2 error)

func (*RelationStoreString) RelatedIDsReturnsOnCall added in v1.12.1 

func (fake *RelationStoreString) RelatedIDsReturnsOnCall(i int, result1 []string, result2 error)

func (*RelationStoreString) Remove added in v1.12.1 

func (fake *RelationStoreString) Remove(arg1 context.Context, arg2 string, arg3 []string) error

func (*RelationStoreString) RemoveArgsForCall added in v1.12.1 

func (fake *RelationStoreString) RemoveArgsForCall(i int) (context.Context, string, []string)

func (*RelationStoreString) RemoveCallCount added in v1.12.1 

func (fake *RelationStoreString) RemoveCallCount() int

func (*RelationStoreString) RemoveCalls added in v1.12.1 

func (fake *RelationStoreString) RemoveCalls(stub func(context.Context, string, []string) error)

func (*RelationStoreString) RemoveReturns added in v1.12.1 

func (fake *RelationStoreString) RemoveReturns(result1 error)

func (*RelationStoreString) RemoveReturnsOnCall added in v1.12.1 

func (fake *RelationStoreString) RemoveReturnsOnCall(i int, result1 error)

func (*RelationStoreString) Replace added in v1.12.1 

func (fake *RelationStoreString) Replace(arg1 context.Context, arg2 string, arg3 []string) error

func (*RelationStoreString) ReplaceArgsForCall added in v1.12.1 

func (fake *RelationStoreString) ReplaceArgsForCall(i int) (context.Context, string, []string)

func (*RelationStoreString) ReplaceCallCount added in v1.12.1 

func (fake *RelationStoreString) ReplaceCallCount() int

func (*RelationStoreString) ReplaceCalls added in v1.12.1 

func (fake *RelationStoreString) ReplaceCalls(stub func(context.Context, string, []string) error)

func (*RelationStoreString) ReplaceReturns added in v1.12.1 

func (fake *RelationStoreString) ReplaceReturns(result1 error)

func (*RelationStoreString) ReplaceReturnsOnCall added in v1.12.1 

func (fake *RelationStoreString) ReplaceReturnsOnCall(i int, result1 error)

func (*RelationStoreString) StreamIDs added in v1.12.1 

func (fake *RelationStoreString) StreamIDs(arg1 context.Context, arg2 chan<- string) error

func (*RelationStoreString) StreamIDsArgsForCall added in v1.12.1 

func (fake *RelationStoreString) StreamIDsArgsForCall(i int) (context.Context, chan<- string)

func (*RelationStoreString) StreamIDsCallCount added in v1.12.1 

func (fake *RelationStoreString) StreamIDsCallCount() int

func (*RelationStoreString) StreamIDsCalls added in v1.12.1 

func (fake *RelationStoreString) StreamIDsCalls(stub func(context.Context, chan<- string) error)

func (*RelationStoreString) StreamIDsReturns added in v1.12.1 

func (fake *RelationStoreString) StreamIDsReturns(result1 error)

func (*RelationStoreString) StreamIDsReturnsOnCall added in v1.12.1 

func (fake *RelationStoreString) StreamIDsReturnsOnCall(i int, result1 error)

func (*RelationStoreString) StreamRelatedIDs added in v1.12.1 

func (fake *RelationStoreString) StreamRelatedIDs(arg1 context.Context, arg2 chan<- string) error

func (*RelationStoreString) StreamRelatedIDsArgsForCall added in v1.12.1 

func (fake *RelationStoreString) StreamRelatedIDsArgsForCall(i int) (context.Context, chan<- string)

func (*RelationStoreString) StreamRelatedIDsCallCount added in v1.12.1 

func (fake *RelationStoreString) StreamRelatedIDsCallCount() int

func (*RelationStoreString) StreamRelatedIDsCalls added in v1.12.1 

func (fake *RelationStoreString) StreamRelatedIDsCalls(stub func(context.Context, chan<- string) error)

func (*RelationStoreString) StreamRelatedIDsReturns added in v1.12.1 

func (fake *RelationStoreString) StreamRelatedIDsReturns(result1 error)

func (*RelationStoreString) StreamRelatedIDsReturnsOnCall added in v1.12.1 

func (fake *RelationStoreString) StreamRelatedIDsReturnsOnCall(i int, result1 error)

type RelationStoreTxString added in v1.12.1 

type RelationStoreTxString struct {
	AddStub func(context.Context, kv.Tx, string, []string) error

	DeleteStub func(context.Context, kv.Tx, string) error

	IDsStub func(context.Context, kv.Tx, string) ([]string, error)

	InvertStub func() kv.RelationStoreTx[string, string]

	MapIDRelationsStub func(context.Context, kv.Tx, func(ctx context.Context, key string, relatedIDs []string) error) error

	MapRelationIDsStub func(context.Context, kv.Tx, func(ctx context.Context, key string, ids []string) error) error

	RelatedIDsStub func(context.Context, kv.Tx, string) ([]string, error)

	RemoveStub func(context.Context, kv.Tx, string, []string) error

	ReplaceStub func(context.Context, kv.Tx, string, []string) error

	StreamIDsStub func(context.Context, kv.Tx, chan<- string) error

	StreamRelatedIDsStub func(context.Context, kv.Tx, chan<- string) error
	// contains filtered or unexported fields
}

func (*RelationStoreTxString) Add added in v1.12.1 

func (fake *RelationStoreTxString) Add(arg1 context.Context, arg2 kv.Tx, arg3 string, arg4 []string) error

func (*RelationStoreTxString) AddArgsForCall added in v1.12.1 

func (fake *RelationStoreTxString) AddArgsForCall(i int) (context.Context, kv.Tx, string, []string)

func (*RelationStoreTxString) AddCallCount added in v1.12.1 

func (fake *RelationStoreTxString) AddCallCount() int

func (*RelationStoreTxString) AddCalls added in v1.12.1 

func (fake *RelationStoreTxString) AddCalls(stub func(context.Context, kv.Tx, string, []string) error)

func (*RelationStoreTxString) AddReturns added in v1.12.1 

func (fake *RelationStoreTxString) AddReturns(result1 error)

func (*RelationStoreTxString) AddReturnsOnCall added in v1.12.1 

func (fake *RelationStoreTxString) AddReturnsOnCall(i int, result1 error)

func (*RelationStoreTxString) Delete added in v1.12.1 

func (fake *RelationStoreTxString) Delete(arg1 context.Context, arg2 kv.Tx, arg3 string) error

func (*RelationStoreTxString) DeleteArgsForCall added in v1.12.1 

func (fake *RelationStoreTxString) DeleteArgsForCall(i int) (context.Context, kv.Tx, string)

func (*RelationStoreTxString) DeleteCallCount added in v1.12.1 

func (fake *RelationStoreTxString) DeleteCallCount() int

func (*RelationStoreTxString) DeleteCalls added in v1.12.1 

func (fake *RelationStoreTxString) DeleteCalls(stub func(context.Context, kv.Tx, string) error)

func (*RelationStoreTxString) DeleteReturns added in v1.12.1 

func (fake *RelationStoreTxString) DeleteReturns(result1 error)

func (*RelationStoreTxString) DeleteReturnsOnCall added in v1.12.1 

func (fake *RelationStoreTxString) DeleteReturnsOnCall(i int, result1 error)

func (*RelationStoreTxString) IDs added in v1.12.1 

func (fake *RelationStoreTxString) IDs(arg1 context.Context, arg2 kv.Tx, arg3 string) ([]string, error)

func (*RelationStoreTxString) IDsArgsForCall added in v1.12.1 

func (fake *RelationStoreTxString) IDsArgsForCall(i int) (context.Context, kv.Tx, string)

func (*RelationStoreTxString) IDsCallCount added in v1.12.1 

func (fake *RelationStoreTxString) IDsCallCount() int

func (*RelationStoreTxString) IDsCalls added in v1.12.1 

func (fake *RelationStoreTxString) IDsCalls(stub func(context.Context, kv.Tx, string) ([]string, error))

func (*RelationStoreTxString) IDsReturns added in v1.12.1 

func (fake *RelationStoreTxString) IDsReturns(result1 []string, result2 error)

func (*RelationStoreTxString) IDsReturnsOnCall added in v1.12.1 

func (fake *RelationStoreTxString) IDsReturnsOnCall(i int, result1 []string, result2 error)

func (*RelationStoreTxString) Invert added in v1.12.1 

func (fake *RelationStoreTxString) Invert() kv.RelationStoreTx[string, string]

func (*RelationStoreTxString) InvertCallCount added in v1.12.1 

func (fake *RelationStoreTxString) InvertCallCount() int

func (*RelationStoreTxString) InvertCalls added in v1.12.1 

func (fake *RelationStoreTxString) InvertCalls(stub func() kv.RelationStoreTx[string, string])

func (*RelationStoreTxString) InvertReturns added in v1.12.1 

func (fake *RelationStoreTxString) InvertReturns(result1 kv.RelationStoreTx[string, string])

func (*RelationStoreTxString) InvertReturnsOnCall added in v1.12.1 

func (fake *RelationStoreTxString) InvertReturnsOnCall(i int, result1 kv.RelationStoreTx[string, string])

func (*RelationStoreTxString) Invocations added in v1.12.1 

func (fake *RelationStoreTxString) Invocations() map[string][][]interface{}

func (*RelationStoreTxString) MapIDRelations added in v1.12.1 

func (fake *RelationStoreTxString) MapIDRelations(arg1 context.Context, arg2 kv.Tx, arg3 func(ctx context.Context, key string, relatedIDs []string) error) error

func (*RelationStoreTxString) MapIDRelationsArgsForCall added in v1.12.1 

func (fake *RelationStoreTxString) MapIDRelationsArgsForCall(i int) (context.Context, kv.Tx, func(ctx context.Context, key string, relatedIDs []string) error)

func (*RelationStoreTxString) MapIDRelationsCallCount added in v1.12.1 

func (fake *RelationStoreTxString) MapIDRelationsCallCount() int

func (*RelationStoreTxString) MapIDRelationsCalls added in v1.12.1 

func (fake *RelationStoreTxString) MapIDRelationsCalls(stub func(context.Context, kv.Tx, func(ctx context.Context, key string, relatedIDs []string) error) error)

func (*RelationStoreTxString) MapIDRelationsReturns added in v1.12.1 

func (fake *RelationStoreTxString) MapIDRelationsReturns(result1 error)

func (*RelationStoreTxString) MapIDRelationsReturnsOnCall added in v1.12.1 

func (fake *RelationStoreTxString) MapIDRelationsReturnsOnCall(i int, result1 error)

func (*RelationStoreTxString) MapRelationIDs added in v1.12.1 

func (fake *RelationStoreTxString) MapRelationIDs(arg1 context.Context, arg2 kv.Tx, arg3 func(ctx context.Context, key string, ids []string) error) error

func (*RelationStoreTxString) MapRelationIDsArgsForCall added in v1.12.1 

func (fake *RelationStoreTxString) MapRelationIDsArgsForCall(i int) (context.Context, kv.Tx, func(ctx context.Context, key string, ids []string) error)

func (*RelationStoreTxString) MapRelationIDsCallCount added in v1.12.1 

func (fake *RelationStoreTxString) MapRelationIDsCallCount() int

func (*RelationStoreTxString) MapRelationIDsCalls added in v1.12.1 

func (fake *RelationStoreTxString) MapRelationIDsCalls(stub func(context.Context, kv.Tx, func(ctx context.Context, key string, ids []string) error) error)

func (*RelationStoreTxString) MapRelationIDsReturns added in v1.12.1 

func (fake *RelationStoreTxString) MapRelationIDsReturns(result1 error)

func (*RelationStoreTxString) MapRelationIDsReturnsOnCall added in v1.12.1 

func (fake *RelationStoreTxString) MapRelationIDsReturnsOnCall(i int, result1 error)

func (*RelationStoreTxString) RelatedIDs added in v1.12.1 

func (fake *RelationStoreTxString) RelatedIDs(arg1 context.Context, arg2 kv.Tx, arg3 string) ([]string, error)

func (*RelationStoreTxString) RelatedIDsArgsForCall added in v1.12.1 

func (fake *RelationStoreTxString) RelatedIDsArgsForCall(i int) (context.Context, kv.Tx, string)

func (*RelationStoreTxString) RelatedIDsCallCount added in v1.12.1 

func (fake *RelationStoreTxString) RelatedIDsCallCount() int

func (*RelationStoreTxString) RelatedIDsCalls added in v1.12.1 

func (fake *RelationStoreTxString) RelatedIDsCalls(stub func(context.Context, kv.Tx, string) ([]string, error))

func (*RelationStoreTxString) RelatedIDsReturns added in v1.12.1 

func (fake *RelationStoreTxString) RelatedIDsReturns(result1 []string, result2 error)

func (*RelationStoreTxString) RelatedIDsReturnsOnCall added in v1.12.1 

func (fake *RelationStoreTxString) RelatedIDsReturnsOnCall(i int, result1 []string, result2 error)

func (*RelationStoreTxString) Remove added in v1.12.1 

func (fake *RelationStoreTxString) Remove(arg1 context.Context, arg2 kv.Tx, arg3 string, arg4 []string) error

func (*RelationStoreTxString) RemoveArgsForCall added in v1.12.1 

func (fake *RelationStoreTxString) RemoveArgsForCall(i int) (context.Context, kv.Tx, string, []string)

func (*RelationStoreTxString) RemoveCallCount added in v1.12.1 

func (fake *RelationStoreTxString) RemoveCallCount() int

func (*RelationStoreTxString) RemoveCalls added in v1.12.1 

func (fake *RelationStoreTxString) RemoveCalls(stub func(context.Context, kv.Tx, string, []string) error)

func (*RelationStoreTxString) RemoveReturns added in v1.12.1 

func (fake *RelationStoreTxString) RemoveReturns(result1 error)

func (*RelationStoreTxString) RemoveReturnsOnCall added in v1.12.1 

func (fake *RelationStoreTxString) RemoveReturnsOnCall(i int, result1 error)

func (*RelationStoreTxString) Replace added in v1.12.1 

func (fake *RelationStoreTxString) Replace(arg1 context.Context, arg2 kv.Tx, arg3 string, arg4 []string) error

func (*RelationStoreTxString) ReplaceArgsForCall added in v1.12.1 

func (fake *RelationStoreTxString) ReplaceArgsForCall(i int) (context.Context, kv.Tx, string, []string)

func (*RelationStoreTxString) ReplaceCallCount added in v1.12.1 

func (fake *RelationStoreTxString) ReplaceCallCount() int

func (*RelationStoreTxString) ReplaceCalls added in v1.12.1 

func (fake *RelationStoreTxString) ReplaceCalls(stub func(context.Context, kv.Tx, string, []string) error)

func (*RelationStoreTxString) ReplaceReturns added in v1.12.1 

func (fake *RelationStoreTxString) ReplaceReturns(result1 error)

func (*RelationStoreTxString) ReplaceReturnsOnCall added in v1.12.1 

func (fake *RelationStoreTxString) ReplaceReturnsOnCall(i int, result1 error)

func (*RelationStoreTxString) StreamIDs added in v1.12.1 

func (fake *RelationStoreTxString) StreamIDs(arg1 context.Context, arg2 kv.Tx, arg3 chan<- string) error

func (*RelationStoreTxString) StreamIDsArgsForCall added in v1.12.1 

func (fake *RelationStoreTxString) StreamIDsArgsForCall(i int) (context.Context, kv.Tx, chan<- string)

func (*RelationStoreTxString) StreamIDsCallCount added in v1.12.1 

func (fake *RelationStoreTxString) StreamIDsCallCount() int

func (*RelationStoreTxString) StreamIDsCalls added in v1.12.1 

func (fake *RelationStoreTxString) StreamIDsCalls(stub func(context.Context, kv.Tx, chan<- string) error)

func (*RelationStoreTxString) StreamIDsReturns added in v1.12.1 

func (fake *RelationStoreTxString) StreamIDsReturns(result1 error)

func (*RelationStoreTxString) StreamIDsReturnsOnCall added in v1.12.1 

func (fake *RelationStoreTxString) StreamIDsReturnsOnCall(i int, result1 error)

func (*RelationStoreTxString) StreamRelatedIDs added in v1.12.1 

func (fake *RelationStoreTxString) StreamRelatedIDs(arg1 context.Context, arg2 kv.Tx, arg3 chan<- string) error

func (*RelationStoreTxString) StreamRelatedIDsArgsForCall added in v1.12.1 

func (fake *RelationStoreTxString) StreamRelatedIDsArgsForCall(i int) (context.Context, kv.Tx, chan<- string)

func (*RelationStoreTxString) StreamRelatedIDsCallCount added in v1.12.1 

func (fake *RelationStoreTxString) StreamRelatedIDsCallCount() int

func (*RelationStoreTxString) StreamRelatedIDsCalls added in v1.12.1 

func (fake *RelationStoreTxString) StreamRelatedIDsCalls(stub func(context.Context, kv.Tx, chan<- string) error)

func (*RelationStoreTxString) StreamRelatedIDsReturns added in v1.12.1 

func (fake *RelationStoreTxString) StreamRelatedIDsReturns(result1 error)

func (*RelationStoreTxString) StreamRelatedIDsReturnsOnCall added in v1.12.1 

func (fake *RelationStoreTxString) StreamRelatedIDsReturnsOnCall(i int, result1 error)

type RunnableTx added in v1.14.0 

type RunnableTx struct {
	RunStub func(context.Context, kv.Tx) error
	// contains filtered or unexported fields
}

func (*RunnableTx) Invocations added in v1.14.0 

func (fake *RunnableTx) Invocations() map[string][][]interface{}

func (*RunnableTx) Run added in v1.14.0 

func (fake *RunnableTx) Run(arg1 context.Context, arg2 kv.Tx) error

func (*RunnableTx) RunArgsForCall added in v1.14.0 

func (fake *RunnableTx) RunArgsForCall(i int) (context.Context, kv.Tx)

func (*RunnableTx) RunCallCount added in v1.14.0 

func (fake *RunnableTx) RunCallCount() int

func (*RunnableTx) RunCalls added in v1.14.0 

func (fake *RunnableTx) RunCalls(stub func(context.Context, kv.Tx) error)

func (*RunnableTx) RunReturns added in v1.14.0 

func (fake *RunnableTx) RunReturns(result1 error)

func (*RunnableTx) RunReturnsOnCall added in v1.14.0 

func (fake *RunnableTx) RunReturnsOnCall(i int, result1 error)

type Tx 

type Tx struct {
	BucketStub func(context.Context, kv.BucketName) (kv.Bucket, error)

	CreateBucketStub func(context.Context, kv.BucketName) (kv.Bucket, error)

	CreateBucketIfNotExistsStub func(context.Context, kv.BucketName) (kv.Bucket, error)

	DeleteBucketStub func(context.Context, kv.BucketName) error

	ListBucketNamesStub func(context.Context) (kv.BucketNames, error)
	// contains filtered or unexported fields
}

func (*Tx) Bucket 

func (fake *Tx) Bucket(arg1 context.Context, arg2 kv.BucketName) (kv.Bucket, error)

func (*Tx) BucketArgsForCall 

func (fake *Tx) BucketArgsForCall(i int) (context.Context, kv.BucketName)

func (*Tx) BucketCallCount 

func (fake *Tx) BucketCallCount() int

func (*Tx) BucketCalls 

func (fake *Tx) BucketCalls(stub func(context.Context, kv.BucketName) (kv.Bucket, error))

func (*Tx) BucketReturns 

func (fake *Tx) BucketReturns(result1 kv.Bucket, result2 error)

func (*Tx) BucketReturnsOnCall 

func (fake *Tx) BucketReturnsOnCall(i int, result1 kv.Bucket, result2 error)

func (*Tx) CreateBucket 

func (fake *Tx) CreateBucket(arg1 context.Context, arg2 kv.BucketName) (kv.Bucket, error)

func (*Tx) CreateBucketArgsForCall 

func (fake *Tx) CreateBucketArgsForCall(i int) (context.Context, kv.BucketName)

func (*Tx) CreateBucketCallCount 

func (fake *Tx) CreateBucketCallCount() int

func (*Tx) CreateBucketCalls 

func (fake *Tx) CreateBucketCalls(stub func(context.Context, kv.BucketName) (kv.Bucket, error))

func (*Tx) CreateBucketIfNotExists 

func (fake *Tx) CreateBucketIfNotExists(arg1 context.Context, arg2 kv.BucketName) (kv.Bucket, error)

func (*Tx) CreateBucketIfNotExistsArgsForCall 

func (fake *Tx) CreateBucketIfNotExistsArgsForCall(i int) (context.Context, kv.BucketName)

func (*Tx) CreateBucketIfNotExistsCallCount 

func (fake *Tx) CreateBucketIfNotExistsCallCount() int

func (*Tx) CreateBucketIfNotExistsCalls 

func (fake *Tx) CreateBucketIfNotExistsCalls(stub func(context.Context, kv.BucketName) (kv.Bucket, error))

func (*Tx) CreateBucketIfNotExistsReturns 

func (fake *Tx) CreateBucketIfNotExistsReturns(result1 kv.Bucket, result2 error)

func (*Tx) CreateBucketIfNotExistsReturnsOnCall 

func (fake *Tx) CreateBucketIfNotExistsReturnsOnCall(i int, result1 kv.Bucket, result2 error)

func (*Tx) CreateBucketReturns 

func (fake *Tx) CreateBucketReturns(result1 kv.Bucket, result2 error)

func (*Tx) CreateBucketReturnsOnCall 

func (fake *Tx) CreateBucketReturnsOnCall(i int, result1 kv.Bucket, result2 error)

func (*Tx) DeleteBucket 

func (fake *Tx) DeleteBucket(arg1 context.Context, arg2 kv.BucketName) error

func (*Tx) DeleteBucketArgsForCall 

func (fake *Tx) DeleteBucketArgsForCall(i int) (context.Context, kv.BucketName)

func (*Tx) DeleteBucketCallCount 

func (fake *Tx) DeleteBucketCallCount() int

func (*Tx) DeleteBucketCalls 

func (fake *Tx) DeleteBucketCalls(stub func(context.Context, kv.BucketName) error)

func (*Tx) DeleteBucketReturns 

func (fake *Tx) DeleteBucketReturns(result1 error)

func (*Tx) DeleteBucketReturnsOnCall 

func (fake *Tx) DeleteBucketReturnsOnCall(i int, result1 error)

func (*Tx) Invocations 

func (fake *Tx) Invocations() map[string][][]interface{}

func (*Tx) ListBucketNames 

func (fake *Tx) ListBucketNames(arg1 context.Context) (kv.BucketNames, error)

func (*Tx) ListBucketNamesArgsForCall 

func (fake *Tx) ListBucketNamesArgsForCall(i int) context.Context

func (*Tx) ListBucketNamesCallCount 

func (fake *Tx) ListBucketNamesCallCount() int

func (*Tx) ListBucketNamesCalls 

func (fake *Tx) ListBucketNamesCalls(stub func(context.Context) (kv.BucketNames, error))

func (*Tx) ListBucketNamesReturns 

func (fake *Tx) ListBucketNamesReturns(result1 kv.BucketNames, result2 error)

func (*Tx) ListBucketNamesReturnsOnCall 

func (fake *Tx) ListBucketNamesReturnsOnCall(i int, result1 kv.BucketNames, result2 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.