object

package
v0.9.12 Latest Latest
Warning

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

 Go to latest Published: Sep 30, 2019 License: Apache-2.0 Imports: 19 Imported by: 0

Documentation

Overview

Package object contains code and types for storage records manipulation.

Index

Constants

View Source 
const TypeIDSize = 4

TypeIDSize is a size of TypeID type.

Variables

View Source 
var (
	// ErrNotFound is returned when value not found.
	ErrNotFound = errors.New("object not found")
	// ErrOverride is returned when trying to update existing record with the same id.
	ErrOverride = errors.New("record override is forbidden")

	// ErrIndexNotFound is returned when an index not found.
	ErrIndexNotFound = errors.New("index not found")
)

Functions

func CalculateIDForBlob 

func CalculateIDForBlob(scheme insolar.PlatformCryptographyScheme, pulseNumber insolar.PulseNumber, blob []byte) *insolar.ID

CalculateIDForBlob calculate id for blob with using current pulse number

func CloneLifeline 

func CloneLifeline(idx record.Lifeline) record.Lifeline

CloneLifeline returns copy of argument idx value.

func DecodeLifeline 

func DecodeLifeline(buff []byte) (record.Lifeline, error)

DecodeLifeline converts byte array into lifeline index struct.

func EncodeLifeline 

func EncodeLifeline(index record.Lifeline) []byte

EncodeLifeline converts lifeline index into binary format.

func MustDecodeLifeline 

func MustDecodeLifeline(buff []byte) (index record.Lifeline)

MustDecodeLifeline converts byte array into lifeline index struct.

Types

type AtomicRecordModifier 

type AtomicRecordModifier interface {
	// SetAtomic atomically stores records to storage. Guarantees to either store all records or none.
	SetAtomic(ctx context.Context, records ...record.Material) error
}

AtomicRecordModifier allows to modify multiple record atomically.

type AtomicRecordModifierMock 

type AtomicRecordModifierMock struct {
	SetAtomicMock mAtomicRecordModifierMockSetAtomic
	// contains filtered or unexported fields
}

AtomicRecordModifierMock implements AtomicRecordModifier

func NewAtomicRecordModifierMock 

func NewAtomicRecordModifierMock(t minimock.Tester) *AtomicRecordModifierMock

NewAtomicRecordModifierMock returns a mock for AtomicRecordModifier

func (*AtomicRecordModifierMock) MinimockFinish 

func (m *AtomicRecordModifierMock) MinimockFinish()

MinimockFinish checks that all mocked methods have been called the expected number of times

func (*AtomicRecordModifierMock) MinimockSetAtomicDone 

func (m *AtomicRecordModifierMock) MinimockSetAtomicDone() bool

MinimockSetAtomicDone returns true if the count of the SetAtomic invocations corresponds the number of defined expectations

func (*AtomicRecordModifierMock) MinimockSetAtomicInspect 

func (m *AtomicRecordModifierMock) MinimockSetAtomicInspect()

MinimockSetAtomicInspect logs each unmet expectation

func (*AtomicRecordModifierMock) MinimockWait 

func (m *AtomicRecordModifierMock) MinimockWait(timeout mm_time.Duration)

MinimockWait waits for all mocked methods to be called the expected number of times

func (*AtomicRecordModifierMock) SetAtomic 

func (mmSetAtomic *AtomicRecordModifierMock) SetAtomic(ctx context.Context, records ...record.Material) (err error)

SetAtomic implements AtomicRecordModifier

func (*AtomicRecordModifierMock) SetAtomicAfterCounter 

func (mmSetAtomic *AtomicRecordModifierMock) SetAtomicAfterCounter() uint64

SetAtomicAfterCounter returns a count of finished AtomicRecordModifierMock.SetAtomic invocations

func (*AtomicRecordModifierMock) SetAtomicBeforeCounter 

func (mmSetAtomic *AtomicRecordModifierMock) SetAtomicBeforeCounter() uint64

SetAtomicBeforeCounter returns a count of AtomicRecordModifierMock.SetAtomic invocations

type AtomicRecordModifierMockSetAtomicExpectation 

type AtomicRecordModifierMockSetAtomicExpectation struct {
	Counter uint64
	// contains filtered or unexported fields
}

AtomicRecordModifierMockSetAtomicExpectation specifies expectation struct of the AtomicRecordModifier.SetAtomic

func (*AtomicRecordModifierMockSetAtomicExpectation) Then 

func (e *AtomicRecordModifierMockSetAtomicExpectation) Then(err error) *AtomicRecordModifierMock

Then sets up AtomicRecordModifier.SetAtomic return parameters for the expectation previously defined by the When method

type AtomicRecordModifierMockSetAtomicParams 

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

AtomicRecordModifierMockSetAtomicParams contains parameters of the AtomicRecordModifier.SetAtomic

type AtomicRecordModifierMockSetAtomicResults 

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

AtomicRecordModifierMockSetAtomicResults contains results of the AtomicRecordModifier.SetAtomic

type AtomicRecordStorage 

type AtomicRecordStorage interface {
	RecordAccessor
	AtomicRecordModifier
}

AtomicRecordStorage is an union of RecordAccessor and AtomicRecordModifier

type AtomicRecordStorageMock 

type AtomicRecordStorageMock struct {
	ForIDMock mAtomicRecordStorageMockForID

	SetAtomicMock mAtomicRecordStorageMockSetAtomic
	// contains filtered or unexported fields
}

AtomicRecordStorageMock implements AtomicRecordStorage

func NewAtomicRecordStorageMock 

func NewAtomicRecordStorageMock(t minimock.Tester) *AtomicRecordStorageMock

NewAtomicRecordStorageMock returns a mock for AtomicRecordStorage

func (*AtomicRecordStorageMock) ForID 

func (mmForID *AtomicRecordStorageMock) ForID(ctx context.Context, id insolar.ID) (m1 record.Material, err error)

ForID implements AtomicRecordStorage

func (*AtomicRecordStorageMock) ForIDAfterCounter 

func (mmForID *AtomicRecordStorageMock) ForIDAfterCounter() uint64

ForIDAfterCounter returns a count of finished AtomicRecordStorageMock.ForID invocations

func (*AtomicRecordStorageMock) ForIDBeforeCounter 

func (mmForID *AtomicRecordStorageMock) ForIDBeforeCounter() uint64

ForIDBeforeCounter returns a count of AtomicRecordStorageMock.ForID invocations

func (*AtomicRecordStorageMock) MinimockFinish 

func (m *AtomicRecordStorageMock) MinimockFinish()

MinimockFinish checks that all mocked methods have been called the expected number of times

func (*AtomicRecordStorageMock) MinimockForIDDone 

func (m *AtomicRecordStorageMock) MinimockForIDDone() bool

MinimockForIDDone returns true if the count of the ForID invocations corresponds the number of defined expectations

func (*AtomicRecordStorageMock) MinimockForIDInspect 

func (m *AtomicRecordStorageMock) MinimockForIDInspect()

MinimockForIDInspect logs each unmet expectation

func (*AtomicRecordStorageMock) MinimockSetAtomicDone 

func (m *AtomicRecordStorageMock) MinimockSetAtomicDone() bool

MinimockSetAtomicDone returns true if the count of the SetAtomic invocations corresponds the number of defined expectations

func (*AtomicRecordStorageMock) MinimockSetAtomicInspect 

func (m *AtomicRecordStorageMock) MinimockSetAtomicInspect()

MinimockSetAtomicInspect logs each unmet expectation

func (*AtomicRecordStorageMock) MinimockWait 

func (m *AtomicRecordStorageMock) MinimockWait(timeout mm_time.Duration)

MinimockWait waits for all mocked methods to be called the expected number of times

func (*AtomicRecordStorageMock) SetAtomic 

func (mmSetAtomic *AtomicRecordStorageMock) SetAtomic(ctx context.Context, records ...record.Material) (err error)

SetAtomic implements AtomicRecordStorage

func (*AtomicRecordStorageMock) SetAtomicAfterCounter 

func (mmSetAtomic *AtomicRecordStorageMock) SetAtomicAfterCounter() uint64

SetAtomicAfterCounter returns a count of finished AtomicRecordStorageMock.SetAtomic invocations

func (*AtomicRecordStorageMock) SetAtomicBeforeCounter 

func (mmSetAtomic *AtomicRecordStorageMock) SetAtomicBeforeCounter() uint64

SetAtomicBeforeCounter returns a count of AtomicRecordStorageMock.SetAtomic invocations

type AtomicRecordStorageMockForIDExpectation 

type AtomicRecordStorageMockForIDExpectation struct {
	Counter uint64
	// contains filtered or unexported fields
}

AtomicRecordStorageMockForIDExpectation specifies expectation struct of the AtomicRecordStorage.ForID

func (*AtomicRecordStorageMockForIDExpectation) Then 

func (e *AtomicRecordStorageMockForIDExpectation) Then(m1 record.Material, err error) *AtomicRecordStorageMock

Then sets up AtomicRecordStorage.ForID return parameters for the expectation previously defined by the When method

type AtomicRecordStorageMockForIDParams 

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

AtomicRecordStorageMockForIDParams contains parameters of the AtomicRecordStorage.ForID

type AtomicRecordStorageMockForIDResults 

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

AtomicRecordStorageMockForIDResults contains results of the AtomicRecordStorage.ForID

type AtomicRecordStorageMockSetAtomicExpectation 

type AtomicRecordStorageMockSetAtomicExpectation struct {
	Counter uint64
	// contains filtered or unexported fields
}

AtomicRecordStorageMockSetAtomicExpectation specifies expectation struct of the AtomicRecordStorage.SetAtomic

func (*AtomicRecordStorageMockSetAtomicExpectation) Then 

func (e *AtomicRecordStorageMockSetAtomicExpectation) Then(err error) *AtomicRecordStorageMock

Then sets up AtomicRecordStorage.SetAtomic return parameters for the expectation previously defined by the When method

type AtomicRecordStorageMockSetAtomicParams 

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

AtomicRecordStorageMockSetAtomicParams contains parameters of the AtomicRecordStorage.SetAtomic

type AtomicRecordStorageMockSetAtomicResults 

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

AtomicRecordStorageMockSetAtomicResults contains results of the AtomicRecordStorage.SetAtomic

type IndexAccessor 

type IndexAccessor interface {
	ForID(ctx context.Context, pn insolar.PulseNumber, objID insolar.ID) (record.Index, error)
	// ForPulse returns a collection of buckets for a provided pulse number.
	ForPulse(ctx context.Context, pn insolar.PulseNumber) ([]record.Index, error)
}

IndexAccessor provides an interface for fetching buckets from an index.

type IndexAccessorMock 

type IndexAccessorMock struct {
	ForIDMock mIndexAccessorMockForID

	ForPulseMock mIndexAccessorMockForPulse
	// contains filtered or unexported fields
}

IndexAccessorMock implements IndexAccessor

func NewIndexAccessorMock 

func NewIndexAccessorMock(t minimock.Tester) *IndexAccessorMock

NewIndexAccessorMock returns a mock for IndexAccessor

func (*IndexAccessorMock) ForID 

func (mmForID *IndexAccessorMock) ForID(ctx context.Context, pn insolar.PulseNumber, objID insolar.ID) (i1 record.Index, err error)

ForID implements IndexAccessor

func (*IndexAccessorMock) ForIDAfterCounter 

func (mmForID *IndexAccessorMock) ForIDAfterCounter() uint64

ForIDAfterCounter returns a count of finished IndexAccessorMock.ForID invocations

func (*IndexAccessorMock) ForIDBeforeCounter 

func (mmForID *IndexAccessorMock) ForIDBeforeCounter() uint64

ForIDBeforeCounter returns a count of IndexAccessorMock.ForID invocations

func (*IndexAccessorMock) ForPulse 

func (mmForPulse *IndexAccessorMock) ForPulse(ctx context.Context, pn insolar.PulseNumber) (ia1 []record.Index, err error)

ForPulse implements IndexAccessor

func (*IndexAccessorMock) ForPulseAfterCounter 

func (mmForPulse *IndexAccessorMock) ForPulseAfterCounter() uint64

ForPulseAfterCounter returns a count of finished IndexAccessorMock.ForPulse invocations

func (*IndexAccessorMock) ForPulseBeforeCounter 

func (mmForPulse *IndexAccessorMock) ForPulseBeforeCounter() uint64

ForPulseBeforeCounter returns a count of IndexAccessorMock.ForPulse invocations

func (*IndexAccessorMock) MinimockFinish 

func (m *IndexAccessorMock) MinimockFinish()

MinimockFinish checks that all mocked methods have been called the expected number of times

func (*IndexAccessorMock) MinimockForIDDone 

func (m *IndexAccessorMock) MinimockForIDDone() bool

MinimockForIDDone returns true if the count of the ForID invocations corresponds the number of defined expectations

func (*IndexAccessorMock) MinimockForIDInspect 

func (m *IndexAccessorMock) MinimockForIDInspect()

MinimockForIDInspect logs each unmet expectation

func (*IndexAccessorMock) MinimockForPulseDone 

func (m *IndexAccessorMock) MinimockForPulseDone() bool

MinimockForPulseDone returns true if the count of the ForPulse invocations corresponds the number of defined expectations

func (*IndexAccessorMock) MinimockForPulseInspect 

func (m *IndexAccessorMock) MinimockForPulseInspect()

MinimockForPulseInspect logs each unmet expectation

func (*IndexAccessorMock) MinimockWait 

func (m *IndexAccessorMock) MinimockWait(timeout mm_time.Duration)

MinimockWait waits for all mocked methods to be called the expected number of times

type IndexAccessorMockForIDExpectation 

type IndexAccessorMockForIDExpectation struct {
	Counter uint64
	// contains filtered or unexported fields
}

IndexAccessorMockForIDExpectation specifies expectation struct of the IndexAccessor.ForID

func (*IndexAccessorMockForIDExpectation) Then 

func (e *IndexAccessorMockForIDExpectation) Then(i1 record.Index, err error) *IndexAccessorMock

Then sets up IndexAccessor.ForID return parameters for the expectation previously defined by the When method

type IndexAccessorMockForIDParams 

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

IndexAccessorMockForIDParams contains parameters of the IndexAccessor.ForID

type IndexAccessorMockForIDResults 

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

IndexAccessorMockForIDResults contains results of the IndexAccessor.ForID

type IndexAccessorMockForPulseExpectation 

type IndexAccessorMockForPulseExpectation struct {
	Counter uint64
	// contains filtered or unexported fields
}

IndexAccessorMockForPulseExpectation specifies expectation struct of the IndexAccessor.ForPulse

func (*IndexAccessorMockForPulseExpectation) Then 

func (e *IndexAccessorMockForPulseExpectation) Then(ia1 []record.Index, err error) *IndexAccessorMock

Then sets up IndexAccessor.ForPulse return parameters for the expectation previously defined by the When method

type IndexAccessorMockForPulseParams 

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

IndexAccessorMockForPulseParams contains parameters of the IndexAccessor.ForPulse

type IndexAccessorMockForPulseResults 

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

IndexAccessorMockForPulseResults contains results of the IndexAccessor.ForPulse

type IndexCleaner 

type IndexCleaner interface {
	// DeleteForPN method removes indexes from a storage for a provided
	DeleteForPN(ctx context.Context, pn insolar.PulseNumber)
}

IndexCleaner provides an interface for removing backets from a storage.

type IndexCleanerMock 

type IndexCleanerMock struct {
	DeleteForPNMock mIndexCleanerMockDeleteForPN
	// contains filtered or unexported fields
}

IndexCleanerMock implements IndexCleaner

func NewIndexCleanerMock 

func NewIndexCleanerMock(t minimock.Tester) *IndexCleanerMock

NewIndexCleanerMock returns a mock for IndexCleaner

func (*IndexCleanerMock) DeleteForPN 

func (mmDeleteForPN *IndexCleanerMock) DeleteForPN(ctx context.Context, pn insolar.PulseNumber)

DeleteForPN implements IndexCleaner

func (*IndexCleanerMock) DeleteForPNAfterCounter 

func (mmDeleteForPN *IndexCleanerMock) DeleteForPNAfterCounter() uint64

DeleteForPNAfterCounter returns a count of finished IndexCleanerMock.DeleteForPN invocations

func (*IndexCleanerMock) DeleteForPNBeforeCounter 

func (mmDeleteForPN *IndexCleanerMock) DeleteForPNBeforeCounter() uint64

DeleteForPNBeforeCounter returns a count of IndexCleanerMock.DeleteForPN invocations

func (*IndexCleanerMock) MinimockDeleteForPNDone 

func (m *IndexCleanerMock) MinimockDeleteForPNDone() bool

MinimockDeleteForPNDone returns true if the count of the DeleteForPN invocations corresponds the number of defined expectations

func (*IndexCleanerMock) MinimockDeleteForPNInspect 

func (m *IndexCleanerMock) MinimockDeleteForPNInspect()

MinimockDeleteForPNInspect logs each unmet expectation

func (*IndexCleanerMock) MinimockFinish 

func (m *IndexCleanerMock) MinimockFinish()

MinimockFinish checks that all mocked methods have been called the expected number of times

func (*IndexCleanerMock) MinimockWait 

func (m *IndexCleanerMock) MinimockWait(timeout mm_time.Duration)

MinimockWait waits for all mocked methods to be called the expected number of times

type IndexCleanerMockDeleteForPNExpectation 

type IndexCleanerMockDeleteForPNExpectation struct {
	Counter uint64
	// contains filtered or unexported fields
}

IndexCleanerMockDeleteForPNExpectation specifies expectation struct of the IndexCleaner.DeleteForPN

type IndexCleanerMockDeleteForPNParams 

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

IndexCleanerMockDeleteForPNParams contains parameters of the IndexCleaner.DeleteForPN

type IndexDB 

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

IndexDB is a db-based storage, that stores a collection of IndexBuckets

func NewIndexDB 

func NewIndexDB(db store.DB, recordStore *RecordDB) *IndexDB

NewIndexDB creates a new instance of IndexDB

func (*IndexDB) ForID 

func (i *IndexDB) ForID(ctx context.Context, pn insolar.PulseNumber, objID insolar.ID) (record.Index, error)

ForID returns a lifeline from a bucket with provided PN and ObjID

func (*IndexDB) ForPulse 

func (i *IndexDB) ForPulse(ctx context.Context, pn insolar.PulseNumber) ([]record.Index, error)

func (*IndexDB) Records 

func (i *IndexDB) Records(ctx context.Context, readFrom insolar.PulseNumber, readUntil insolar.PulseNumber, objID insolar.ID) ([]record.CompositeFilamentRecord, error)

func (*IndexDB) SetIndex 

func (i *IndexDB) SetIndex(ctx context.Context, pn insolar.PulseNumber, bucket record.Index) error

SetIndex adds a bucket with provided pulseNumber and ID

func (*IndexDB) TruncateHead 

func (i *IndexDB) TruncateHead(ctx context.Context, from insolar.PulseNumber) error

TruncateHead remove all records after lastPulse

func (*IndexDB) UpdateLastKnownPulse 

func (i *IndexDB) UpdateLastKnownPulse(ctx context.Context, topSyncPulse insolar.PulseNumber) error

UpdateLastKnownPulse must be called after updating TopSyncPulse

type IndexLocker 

type IndexLocker interface {
	Lock(id insolar.ID)
	Unlock(id insolar.ID)
}

IndexLocker provides Lock/Unlock methods per record ID.

func NewIndexLocker 

func NewIndexLocker() IndexLocker

NewIndexLocker creates new initialized IndexLocker.

type IndexLockerMock 

type IndexLockerMock struct {
	LockMock mIndexLockerMockLock

	UnlockMock mIndexLockerMockUnlock
	// contains filtered or unexported fields
}

IndexLockerMock implements IndexLocker

func NewIndexLockerMock 

func NewIndexLockerMock(t minimock.Tester) *IndexLockerMock

NewIndexLockerMock returns a mock for IndexLocker

func (*IndexLockerMock) Lock 

func (mmLock *IndexLockerMock) Lock(id insolar.ID)

Lock implements IndexLocker

func (*IndexLockerMock) LockAfterCounter 

func (mmLock *IndexLockerMock) LockAfterCounter() uint64

LockAfterCounter returns a count of finished IndexLockerMock.Lock invocations

func (*IndexLockerMock) LockBeforeCounter 

func (mmLock *IndexLockerMock) LockBeforeCounter() uint64

LockBeforeCounter returns a count of IndexLockerMock.Lock invocations

func (*IndexLockerMock) MinimockFinish 

func (m *IndexLockerMock) MinimockFinish()

MinimockFinish checks that all mocked methods have been called the expected number of times

func (*IndexLockerMock) MinimockLockDone 

func (m *IndexLockerMock) MinimockLockDone() bool

MinimockLockDone returns true if the count of the Lock invocations corresponds the number of defined expectations

func (*IndexLockerMock) MinimockLockInspect 

func (m *IndexLockerMock) MinimockLockInspect()

MinimockLockInspect logs each unmet expectation

func (*IndexLockerMock) MinimockUnlockDone 

func (m *IndexLockerMock) MinimockUnlockDone() bool

MinimockUnlockDone returns true if the count of the Unlock invocations corresponds the number of defined expectations

func (*IndexLockerMock) MinimockUnlockInspect 

func (m *IndexLockerMock) MinimockUnlockInspect()

MinimockUnlockInspect logs each unmet expectation

func (*IndexLockerMock) MinimockWait 

func (m *IndexLockerMock) MinimockWait(timeout mm_time.Duration)

MinimockWait waits for all mocked methods to be called the expected number of times

func (*IndexLockerMock) Unlock 

func (mmUnlock *IndexLockerMock) Unlock(id insolar.ID)

Unlock implements IndexLocker

func (*IndexLockerMock) UnlockAfterCounter 

func (mmUnlock *IndexLockerMock) UnlockAfterCounter() uint64

UnlockAfterCounter returns a count of finished IndexLockerMock.Unlock invocations

func (*IndexLockerMock) UnlockBeforeCounter 

func (mmUnlock *IndexLockerMock) UnlockBeforeCounter() uint64

UnlockBeforeCounter returns a count of IndexLockerMock.Unlock invocations

type IndexLockerMockLockExpectation 

type IndexLockerMockLockExpectation struct {
	Counter uint64
	// contains filtered or unexported fields
}

IndexLockerMockLockExpectation specifies expectation struct of the IndexLocker.Lock

type IndexLockerMockLockParams 

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

IndexLockerMockLockParams contains parameters of the IndexLocker.Lock

type IndexLockerMockUnlockExpectation 

type IndexLockerMockUnlockExpectation struct {
	Counter uint64
	// contains filtered or unexported fields
}

IndexLockerMockUnlockExpectation specifies expectation struct of the IndexLocker.Unlock

type IndexLockerMockUnlockParams 

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

IndexLockerMockUnlockParams contains parameters of the IndexLocker.Unlock

type IndexModifier 

type IndexModifier interface {
	// SetIndex adds a bucket with provided pulseNumber and ID
	SetIndex(ctx context.Context, pn insolar.PulseNumber, index record.Index) error
	// UpdateLastKnownPulse updates last know pulse to given one for all objects from this pulse
	UpdateLastKnownPulse(ctx context.Context, pn insolar.PulseNumber) error
}

IndexModifier provides methods for modifying buckets of index. Lifeline contains buckets with pn->objID->Bucket hierarchy. With using of IndexModifier there is a possibility to set buckets from outside of an index.

type IndexModifierMock 

type IndexModifierMock struct {
	SetIndexMock mIndexModifierMockSetIndex

	UpdateLastKnownPulseMock mIndexModifierMockUpdateLastKnownPulse
	// contains filtered or unexported fields
}

IndexModifierMock implements IndexModifier

func NewIndexModifierMock 

func NewIndexModifierMock(t minimock.Tester) *IndexModifierMock

NewIndexModifierMock returns a mock for IndexModifier

func (*IndexModifierMock) MinimockFinish 

func (m *IndexModifierMock) MinimockFinish()

MinimockFinish checks that all mocked methods have been called the expected number of times

func (*IndexModifierMock) MinimockSetIndexDone 

func (m *IndexModifierMock) MinimockSetIndexDone() bool

MinimockSetIndexDone returns true if the count of the SetIndex invocations corresponds the number of defined expectations

func (*IndexModifierMock) MinimockSetIndexInspect 

func (m *IndexModifierMock) MinimockSetIndexInspect()

MinimockSetIndexInspect logs each unmet expectation

func (*IndexModifierMock) MinimockUpdateLastKnownPulseDone 

func (m *IndexModifierMock) MinimockUpdateLastKnownPulseDone() bool

MinimockUpdateLastKnownPulseDone returns true if the count of the UpdateLastKnownPulse invocations corresponds the number of defined expectations

func (*IndexModifierMock) MinimockUpdateLastKnownPulseInspect 

func (m *IndexModifierMock) MinimockUpdateLastKnownPulseInspect()

MinimockUpdateLastKnownPulseInspect logs each unmet expectation

func (*IndexModifierMock) MinimockWait 

func (m *IndexModifierMock) MinimockWait(timeout mm_time.Duration)

MinimockWait waits for all mocked methods to be called the expected number of times

func (*IndexModifierMock) SetIndex 

func (mmSetIndex *IndexModifierMock) SetIndex(ctx context.Context, pn insolar.PulseNumber, index record.Index) (err error)

SetIndex implements IndexModifier

func (*IndexModifierMock) SetIndexAfterCounter 

func (mmSetIndex *IndexModifierMock) SetIndexAfterCounter() uint64

SetIndexAfterCounter returns a count of finished IndexModifierMock.SetIndex invocations

func (*IndexModifierMock) SetIndexBeforeCounter 

func (mmSetIndex *IndexModifierMock) SetIndexBeforeCounter() uint64

SetIndexBeforeCounter returns a count of IndexModifierMock.SetIndex invocations

func (*IndexModifierMock) UpdateLastKnownPulse 

func (mmUpdateLastKnownPulse *IndexModifierMock) UpdateLastKnownPulse(ctx context.Context, pn insolar.PulseNumber) (err error)

UpdateLastKnownPulse implements IndexModifier

func (*IndexModifierMock) UpdateLastKnownPulseAfterCounter 

func (mmUpdateLastKnownPulse *IndexModifierMock) UpdateLastKnownPulseAfterCounter() uint64

UpdateLastKnownPulseAfterCounter returns a count of finished IndexModifierMock.UpdateLastKnownPulse invocations

func (*IndexModifierMock) UpdateLastKnownPulseBeforeCounter 

func (mmUpdateLastKnownPulse *IndexModifierMock) UpdateLastKnownPulseBeforeCounter() uint64

UpdateLastKnownPulseBeforeCounter returns a count of IndexModifierMock.UpdateLastKnownPulse invocations

type IndexModifierMockSetIndexExpectation 

type IndexModifierMockSetIndexExpectation struct {
	Counter uint64
	// contains filtered or unexported fields
}

IndexModifierMockSetIndexExpectation specifies expectation struct of the IndexModifier.SetIndex

func (*IndexModifierMockSetIndexExpectation) Then 

func (e *IndexModifierMockSetIndexExpectation) Then(err error) *IndexModifierMock

Then sets up IndexModifier.SetIndex return parameters for the expectation previously defined by the When method

type IndexModifierMockSetIndexParams 

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

IndexModifierMockSetIndexParams contains parameters of the IndexModifier.SetIndex

type IndexModifierMockSetIndexResults 

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

IndexModifierMockSetIndexResults contains results of the IndexModifier.SetIndex

type IndexModifierMockUpdateLastKnownPulseExpectation 

type IndexModifierMockUpdateLastKnownPulseExpectation struct {
	Counter uint64
	// contains filtered or unexported fields
}

IndexModifierMockUpdateLastKnownPulseExpectation specifies expectation struct of the IndexModifier.UpdateLastKnownPulse

func (*IndexModifierMockUpdateLastKnownPulseExpectation) Then 

func (e *IndexModifierMockUpdateLastKnownPulseExpectation) Then(err error) *IndexModifierMock

Then sets up IndexModifier.UpdateLastKnownPulse return parameters for the expectation previously defined by the When method

type IndexModifierMockUpdateLastKnownPulseParams 

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

IndexModifierMockUpdateLastKnownPulseParams contains parameters of the IndexModifier.UpdateLastKnownPulse

type IndexModifierMockUpdateLastKnownPulseResults 

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

IndexModifierMockUpdateLastKnownPulseResults contains results of the IndexModifier.UpdateLastKnownPulse

type IndexStorage 

type IndexStorage interface {
	IndexAccessor
	IndexModifier
}

type IndexStorageMemory 

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

func NewIndexStorageMemory 

func NewIndexStorageMemory() *IndexStorageMemory

func (*IndexStorageMemory) DeleteForPN 

func (i *IndexStorageMemory) DeleteForPN(ctx context.Context, pn insolar.PulseNumber)

DeleteForPN deletes all buckets for a provided pulse number

func (*IndexStorageMemory) ForID 

func (i *IndexStorageMemory) ForID(ctx context.Context, pn insolar.PulseNumber, objID insolar.ID) (record.Index, error)

func (*IndexStorageMemory) ForPulse 

func (i *IndexStorageMemory) ForPulse(ctx context.Context, pn insolar.PulseNumber) ([]record.Index, error)

ForPulse returns a collection of buckets for a provided pulse number.

func (*IndexStorageMemory) Set 

func (i *IndexStorageMemory) Set(ctx context.Context, pn insolar.PulseNumber, bucket record.Index)

type IndexStorageMock 

type IndexStorageMock struct {
	ForIDMock mIndexStorageMockForID

	ForPulseMock mIndexStorageMockForPulse

	SetIndexMock mIndexStorageMockSetIndex

	UpdateLastKnownPulseMock mIndexStorageMockUpdateLastKnownPulse
	// contains filtered or unexported fields
}

IndexStorageMock implements IndexStorage

func NewIndexStorageMock 

func NewIndexStorageMock(t minimock.Tester) *IndexStorageMock

NewIndexStorageMock returns a mock for IndexStorage

func (*IndexStorageMock) ForID 

func (mmForID *IndexStorageMock) ForID(ctx context.Context, pn insolar.PulseNumber, objID insolar.ID) (i1 record.Index, err error)

ForID implements IndexStorage

func (*IndexStorageMock) ForIDAfterCounter 

func (mmForID *IndexStorageMock) ForIDAfterCounter() uint64

ForIDAfterCounter returns a count of finished IndexStorageMock.ForID invocations

func (*IndexStorageMock) ForIDBeforeCounter 

func (mmForID *IndexStorageMock) ForIDBeforeCounter() uint64

ForIDBeforeCounter returns a count of IndexStorageMock.ForID invocations

func (*IndexStorageMock) ForPulse 

func (mmForPulse *IndexStorageMock) ForPulse(ctx context.Context, pn insolar.PulseNumber) (ia1 []record.Index, err error)

ForPulse implements IndexStorage

func (*IndexStorageMock) ForPulseAfterCounter 

func (mmForPulse *IndexStorageMock) ForPulseAfterCounter() uint64

ForPulseAfterCounter returns a count of finished IndexStorageMock.ForPulse invocations

func (*IndexStorageMock) ForPulseBeforeCounter 

func (mmForPulse *IndexStorageMock) ForPulseBeforeCounter() uint64

ForPulseBeforeCounter returns a count of IndexStorageMock.ForPulse invocations

func (*IndexStorageMock) MinimockFinish 

func (m *IndexStorageMock) MinimockFinish()

MinimockFinish checks that all mocked methods have been called the expected number of times

func (*IndexStorageMock) MinimockForIDDone 

func (m *IndexStorageMock) MinimockForIDDone() bool

MinimockForIDDone returns true if the count of the ForID invocations corresponds the number of defined expectations

func (*IndexStorageMock) MinimockForIDInspect 

func (m *IndexStorageMock) MinimockForIDInspect()

MinimockForIDInspect logs each unmet expectation

func (*IndexStorageMock) MinimockForPulseDone 

func (m *IndexStorageMock) MinimockForPulseDone() bool

MinimockForPulseDone returns true if the count of the ForPulse invocations corresponds the number of defined expectations

func (*IndexStorageMock) MinimockForPulseInspect 

func (m *IndexStorageMock) MinimockForPulseInspect()

MinimockForPulseInspect logs each unmet expectation

func (*IndexStorageMock) MinimockSetIndexDone 

func (m *IndexStorageMock) MinimockSetIndexDone() bool

MinimockSetIndexDone returns true if the count of the SetIndex invocations corresponds the number of defined expectations

func (*IndexStorageMock) MinimockSetIndexInspect 

func (m *IndexStorageMock) MinimockSetIndexInspect()

MinimockSetIndexInspect logs each unmet expectation

func (*IndexStorageMock) MinimockUpdateLastKnownPulseDone 

func (m *IndexStorageMock) MinimockUpdateLastKnownPulseDone() bool

MinimockUpdateLastKnownPulseDone returns true if the count of the UpdateLastKnownPulse invocations corresponds the number of defined expectations

func (*IndexStorageMock) MinimockUpdateLastKnownPulseInspect 

func (m *IndexStorageMock) MinimockUpdateLastKnownPulseInspect()

MinimockUpdateLastKnownPulseInspect logs each unmet expectation

func (*IndexStorageMock) MinimockWait 

func (m *IndexStorageMock) MinimockWait(timeout mm_time.Duration)

MinimockWait waits for all mocked methods to be called the expected number of times

func (*IndexStorageMock) SetIndex 

func (mmSetIndex *IndexStorageMock) SetIndex(ctx context.Context, pn insolar.PulseNumber, index record.Index) (err error)

SetIndex implements IndexStorage

func (*IndexStorageMock) SetIndexAfterCounter 

func (mmSetIndex *IndexStorageMock) SetIndexAfterCounter() uint64

SetIndexAfterCounter returns a count of finished IndexStorageMock.SetIndex invocations

func (*IndexStorageMock) SetIndexBeforeCounter 

func (mmSetIndex *IndexStorageMock) SetIndexBeforeCounter() uint64

SetIndexBeforeCounter returns a count of IndexStorageMock.SetIndex invocations

func (*IndexStorageMock) UpdateLastKnownPulse 

func (mmUpdateLastKnownPulse *IndexStorageMock) UpdateLastKnownPulse(ctx context.Context, pn insolar.PulseNumber) (err error)

UpdateLastKnownPulse implements IndexStorage

func (*IndexStorageMock) UpdateLastKnownPulseAfterCounter 

func (mmUpdateLastKnownPulse *IndexStorageMock) UpdateLastKnownPulseAfterCounter() uint64

UpdateLastKnownPulseAfterCounter returns a count of finished IndexStorageMock.UpdateLastKnownPulse invocations

func (*IndexStorageMock) UpdateLastKnownPulseBeforeCounter 

func (mmUpdateLastKnownPulse *IndexStorageMock) UpdateLastKnownPulseBeforeCounter() uint64

UpdateLastKnownPulseBeforeCounter returns a count of IndexStorageMock.UpdateLastKnownPulse invocations

type IndexStorageMockForIDExpectation 

type IndexStorageMockForIDExpectation struct {
	Counter uint64
	// contains filtered or unexported fields
}

IndexStorageMockForIDExpectation specifies expectation struct of the IndexStorage.ForID

func (*IndexStorageMockForIDExpectation) Then 

func (e *IndexStorageMockForIDExpectation) Then(i1 record.Index, err error) *IndexStorageMock

Then sets up IndexStorage.ForID return parameters for the expectation previously defined by the When method

type IndexStorageMockForIDParams 

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

IndexStorageMockForIDParams contains parameters of the IndexStorage.ForID

type IndexStorageMockForIDResults 

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

IndexStorageMockForIDResults contains results of the IndexStorage.ForID

type IndexStorageMockForPulseExpectation 

type IndexStorageMockForPulseExpectation struct {
	Counter uint64
	// contains filtered or unexported fields
}

IndexStorageMockForPulseExpectation specifies expectation struct of the IndexStorage.ForPulse

func (*IndexStorageMockForPulseExpectation) Then 

func (e *IndexStorageMockForPulseExpectation) Then(ia1 []record.Index, err error) *IndexStorageMock

Then sets up IndexStorage.ForPulse return parameters for the expectation previously defined by the When method

type IndexStorageMockForPulseParams 

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

IndexStorageMockForPulseParams contains parameters of the IndexStorage.ForPulse

type IndexStorageMockForPulseResults 

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

IndexStorageMockForPulseResults contains results of the IndexStorage.ForPulse

type IndexStorageMockSetIndexExpectation 

type IndexStorageMockSetIndexExpectation struct {
	Counter uint64
	// contains filtered or unexported fields
}

IndexStorageMockSetIndexExpectation specifies expectation struct of the IndexStorage.SetIndex

func (*IndexStorageMockSetIndexExpectation) Then 

func (e *IndexStorageMockSetIndexExpectation) Then(err error) *IndexStorageMock

Then sets up IndexStorage.SetIndex return parameters for the expectation previously defined by the When method

type IndexStorageMockSetIndexParams 

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

IndexStorageMockSetIndexParams contains parameters of the IndexStorage.SetIndex

type IndexStorageMockSetIndexResults 

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

IndexStorageMockSetIndexResults contains results of the IndexStorage.SetIndex

type IndexStorageMockUpdateLastKnownPulseExpectation 

type IndexStorageMockUpdateLastKnownPulseExpectation struct {
	Counter uint64
	// contains filtered or unexported fields
}

IndexStorageMockUpdateLastKnownPulseExpectation specifies expectation struct of the IndexStorage.UpdateLastKnownPulse

func (*IndexStorageMockUpdateLastKnownPulseExpectation) Then 

func (e *IndexStorageMockUpdateLastKnownPulseExpectation) Then(err error) *IndexStorageMock

Then sets up IndexStorage.UpdateLastKnownPulse return parameters for the expectation previously defined by the When method

type IndexStorageMockUpdateLastKnownPulseParams 

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

IndexStorageMockUpdateLastKnownPulseParams contains parameters of the IndexStorage.UpdateLastKnownPulse

type IndexStorageMockUpdateLastKnownPulseResults 

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

IndexStorageMockUpdateLastKnownPulseResults contains results of the IndexStorage.UpdateLastKnownPulse

type MemoryIndexModifier 

type MemoryIndexModifier interface {
	Set(ctx context.Context, pn insolar.PulseNumber, index record.Index)
}

MemoryIndexModifier writes index to in-memory storage.

type MemoryIndexModifierMock 

type MemoryIndexModifierMock struct {
	SetMock mMemoryIndexModifierMockSet
	// contains filtered or unexported fields
}

MemoryIndexModifierMock implements MemoryIndexModifier

func NewMemoryIndexModifierMock 

func NewMemoryIndexModifierMock(t minimock.Tester) *MemoryIndexModifierMock

NewMemoryIndexModifierMock returns a mock for MemoryIndexModifier

func (*MemoryIndexModifierMock) MinimockFinish 

func (m *MemoryIndexModifierMock) MinimockFinish()

MinimockFinish checks that all mocked methods have been called the expected number of times

func (*MemoryIndexModifierMock) MinimockSetDone 

func (m *MemoryIndexModifierMock) MinimockSetDone() bool

MinimockSetDone returns true if the count of the Set invocations corresponds the number of defined expectations

func (*MemoryIndexModifierMock) MinimockSetInspect 

func (m *MemoryIndexModifierMock) MinimockSetInspect()

MinimockSetInspect logs each unmet expectation

func (*MemoryIndexModifierMock) MinimockWait 

func (m *MemoryIndexModifierMock) MinimockWait(timeout mm_time.Duration)

MinimockWait waits for all mocked methods to be called the expected number of times

func (*MemoryIndexModifierMock) Set 

func (mmSet *MemoryIndexModifierMock) Set(ctx context.Context, pn insolar.PulseNumber, index record.Index)

Set implements MemoryIndexModifier

func (*MemoryIndexModifierMock) SetAfterCounter 

func (mmSet *MemoryIndexModifierMock) SetAfterCounter() uint64

SetAfterCounter returns a count of finished MemoryIndexModifierMock.Set invocations

func (*MemoryIndexModifierMock) SetBeforeCounter 

func (mmSet *MemoryIndexModifierMock) SetBeforeCounter() uint64

SetBeforeCounter returns a count of MemoryIndexModifierMock.Set invocations

type MemoryIndexModifierMockSetExpectation 

type MemoryIndexModifierMockSetExpectation struct {
	Counter uint64
	// contains filtered or unexported fields
}

MemoryIndexModifierMockSetExpectation specifies expectation struct of the MemoryIndexModifier.Set

type MemoryIndexModifierMockSetParams 

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

MemoryIndexModifierMockSetParams contains parameters of the MemoryIndexModifier.Set

type MemoryIndexStorage 

type MemoryIndexStorage interface {
	IndexAccessor
	MemoryIndexModifier
}

type MemoryIndexStorageMock 

type MemoryIndexStorageMock struct {
	ForIDMock mMemoryIndexStorageMockForID

	ForPulseMock mMemoryIndexStorageMockForPulse

	SetMock mMemoryIndexStorageMockSet
	// contains filtered or unexported fields
}

MemoryIndexStorageMock implements MemoryIndexStorage

func NewMemoryIndexStorageMock 

func NewMemoryIndexStorageMock(t minimock.Tester) *MemoryIndexStorageMock

NewMemoryIndexStorageMock returns a mock for MemoryIndexStorage

func (*MemoryIndexStorageMock) ForID 

func (mmForID *MemoryIndexStorageMock) ForID(ctx context.Context, pn insolar.PulseNumber, objID insolar.ID) (i1 record.Index, err error)

ForID implements MemoryIndexStorage

func (*MemoryIndexStorageMock) ForIDAfterCounter 

func (mmForID *MemoryIndexStorageMock) ForIDAfterCounter() uint64

ForIDAfterCounter returns a count of finished MemoryIndexStorageMock.ForID invocations

func (*MemoryIndexStorageMock) ForIDBeforeCounter 

func (mmForID *MemoryIndexStorageMock) ForIDBeforeCounter() uint64

ForIDBeforeCounter returns a count of MemoryIndexStorageMock.ForID invocations

func (*MemoryIndexStorageMock) ForPulse 

func (mmForPulse *MemoryIndexStorageMock) ForPulse(ctx context.Context, pn insolar.PulseNumber) (ia1 []record.Index, err error)

ForPulse implements MemoryIndexStorage

func (*MemoryIndexStorageMock) ForPulseAfterCounter 

func (mmForPulse *MemoryIndexStorageMock) ForPulseAfterCounter() uint64

ForPulseAfterCounter returns a count of finished MemoryIndexStorageMock.ForPulse invocations

func (*MemoryIndexStorageMock) ForPulseBeforeCounter 

func (mmForPulse *MemoryIndexStorageMock) ForPulseBeforeCounter() uint64

ForPulseBeforeCounter returns a count of MemoryIndexStorageMock.ForPulse invocations

func (*MemoryIndexStorageMock) MinimockFinish 

func (m *MemoryIndexStorageMock) MinimockFinish()

MinimockFinish checks that all mocked methods have been called the expected number of times

func (*MemoryIndexStorageMock) MinimockForIDDone 

func (m *MemoryIndexStorageMock) MinimockForIDDone() bool

MinimockForIDDone returns true if the count of the ForID invocations corresponds the number of defined expectations

func (*MemoryIndexStorageMock) MinimockForIDInspect 

func (m *MemoryIndexStorageMock) MinimockForIDInspect()

MinimockForIDInspect logs each unmet expectation

func (*MemoryIndexStorageMock) MinimockForPulseDone 

func (m *MemoryIndexStorageMock) MinimockForPulseDone() bool

MinimockForPulseDone returns true if the count of the ForPulse invocations corresponds the number of defined expectations

func (*MemoryIndexStorageMock) MinimockForPulseInspect 

func (m *MemoryIndexStorageMock) MinimockForPulseInspect()

MinimockForPulseInspect logs each unmet expectation

func (*MemoryIndexStorageMock) MinimockSetDone 

func (m *MemoryIndexStorageMock) MinimockSetDone() bool

MinimockSetDone returns true if the count of the Set invocations corresponds the number of defined expectations

func (*MemoryIndexStorageMock) MinimockSetInspect 

func (m *MemoryIndexStorageMock) MinimockSetInspect()

MinimockSetInspect logs each unmet expectation

func (*MemoryIndexStorageMock) MinimockWait 

func (m *MemoryIndexStorageMock) MinimockWait(timeout mm_time.Duration)

MinimockWait waits for all mocked methods to be called the expected number of times

func (*MemoryIndexStorageMock) Set 

func (mmSet *MemoryIndexStorageMock) Set(ctx context.Context, pn insolar.PulseNumber, index record.Index)

Set implements MemoryIndexStorage

func (*MemoryIndexStorageMock) SetAfterCounter 

func (mmSet *MemoryIndexStorageMock) SetAfterCounter() uint64

SetAfterCounter returns a count of finished MemoryIndexStorageMock.Set invocations

func (*MemoryIndexStorageMock) SetBeforeCounter 

func (mmSet *MemoryIndexStorageMock) SetBeforeCounter() uint64

SetBeforeCounter returns a count of MemoryIndexStorageMock.Set invocations

type MemoryIndexStorageMockForIDExpectation 

type MemoryIndexStorageMockForIDExpectation struct {
	Counter uint64
	// contains filtered or unexported fields
}

MemoryIndexStorageMockForIDExpectation specifies expectation struct of the MemoryIndexStorage.ForID

func (*MemoryIndexStorageMockForIDExpectation) Then 

func (e *MemoryIndexStorageMockForIDExpectation) Then(i1 record.Index, err error) *MemoryIndexStorageMock

Then sets up MemoryIndexStorage.ForID return parameters for the expectation previously defined by the When method

type MemoryIndexStorageMockForIDParams 

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

MemoryIndexStorageMockForIDParams contains parameters of the MemoryIndexStorage.ForID

type MemoryIndexStorageMockForIDResults 

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

MemoryIndexStorageMockForIDResults contains results of the MemoryIndexStorage.ForID

type MemoryIndexStorageMockForPulseExpectation 

type MemoryIndexStorageMockForPulseExpectation struct {
	Counter uint64
	// contains filtered or unexported fields
}

MemoryIndexStorageMockForPulseExpectation specifies expectation struct of the MemoryIndexStorage.ForPulse

func (*MemoryIndexStorageMockForPulseExpectation) Then 

func (e *MemoryIndexStorageMockForPulseExpectation) Then(ia1 []record.Index, err error) *MemoryIndexStorageMock

Then sets up MemoryIndexStorage.ForPulse return parameters for the expectation previously defined by the When method

type MemoryIndexStorageMockForPulseParams 

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

MemoryIndexStorageMockForPulseParams contains parameters of the MemoryIndexStorage.ForPulse

type MemoryIndexStorageMockForPulseResults 

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

MemoryIndexStorageMockForPulseResults contains results of the MemoryIndexStorage.ForPulse

type MemoryIndexStorageMockSetExpectation 

type MemoryIndexStorageMockSetExpectation struct {
	Counter uint64
	// contains filtered or unexported fields
}

MemoryIndexStorageMockSetExpectation specifies expectation struct of the MemoryIndexStorage.Set

type MemoryIndexStorageMockSetParams 

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

MemoryIndexStorageMockSetParams contains parameters of the MemoryIndexStorage.Set

type RecordAccessor 

type RecordAccessor interface {
	// ForID returns record for provided id.
	ForID(ctx context.Context, id insolar.ID) (record.Material, error)
}

RecordAccessor provides info about record-values from storage.

type RecordAccessorMock 

type RecordAccessorMock struct {
	ForIDMock mRecordAccessorMockForID
	// contains filtered or unexported fields
}

RecordAccessorMock implements RecordAccessor

func NewRecordAccessorMock 

func NewRecordAccessorMock(t minimock.Tester) *RecordAccessorMock

NewRecordAccessorMock returns a mock for RecordAccessor

func (*RecordAccessorMock) ForID 

func (mmForID *RecordAccessorMock) ForID(ctx context.Context, id insolar.ID) (m1 record.Material, err error)

ForID implements RecordAccessor

func (*RecordAccessorMock) ForIDAfterCounter 

func (mmForID *RecordAccessorMock) ForIDAfterCounter() uint64

ForIDAfterCounter returns a count of finished RecordAccessorMock.ForID invocations

func (*RecordAccessorMock) ForIDBeforeCounter 

func (mmForID *RecordAccessorMock) ForIDBeforeCounter() uint64

ForIDBeforeCounter returns a count of RecordAccessorMock.ForID invocations

func (*RecordAccessorMock) MinimockFinish 

func (m *RecordAccessorMock) MinimockFinish()

MinimockFinish checks that all mocked methods have been called the expected number of times

func (*RecordAccessorMock) MinimockForIDDone 

func (m *RecordAccessorMock) MinimockForIDDone() bool

MinimockForIDDone returns true if the count of the ForID invocations corresponds the number of defined expectations

func (*RecordAccessorMock) MinimockForIDInspect 

func (m *RecordAccessorMock) MinimockForIDInspect()

MinimockForIDInspect logs each unmet expectation

func (*RecordAccessorMock) MinimockWait 

func (m *RecordAccessorMock) MinimockWait(timeout mm_time.Duration)

MinimockWait waits for all mocked methods to be called the expected number of times

type RecordAccessorMockForIDExpectation 

type RecordAccessorMockForIDExpectation struct {
	Counter uint64
	// contains filtered or unexported fields
}

RecordAccessorMockForIDExpectation specifies expectation struct of the RecordAccessor.ForID

func (*RecordAccessorMockForIDExpectation) Then 

func (e *RecordAccessorMockForIDExpectation) Then(m1 record.Material, err error) *RecordAccessorMock

Then sets up RecordAccessor.ForID return parameters for the expectation previously defined by the When method

type RecordAccessorMockForIDParams 

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

RecordAccessorMockForIDParams contains parameters of the RecordAccessor.ForID

type RecordAccessorMockForIDResults 

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

RecordAccessorMockForIDResults contains results of the RecordAccessor.ForID

type RecordCleaner 

type RecordCleaner interface {
	// DeleteForPN method removes records from a storage for a pulse
	DeleteForPN(ctx context.Context, pulse insolar.PulseNumber)
}

RecordCleaner provides an interface for removing records from a storage.

type RecordCleanerMock 

type RecordCleanerMock struct {
	DeleteForPNMock mRecordCleanerMockDeleteForPN
	// contains filtered or unexported fields
}

RecordCleanerMock implements RecordCleaner

func NewRecordCleanerMock 

func NewRecordCleanerMock(t minimock.Tester) *RecordCleanerMock

NewRecordCleanerMock returns a mock for RecordCleaner

func (*RecordCleanerMock) DeleteForPN 

func (mmDeleteForPN *RecordCleanerMock) DeleteForPN(ctx context.Context, pulse insolar.PulseNumber)

DeleteForPN implements RecordCleaner

func (*RecordCleanerMock) DeleteForPNAfterCounter 

func (mmDeleteForPN *RecordCleanerMock) DeleteForPNAfterCounter() uint64

DeleteForPNAfterCounter returns a count of finished RecordCleanerMock.DeleteForPN invocations

func (*RecordCleanerMock) DeleteForPNBeforeCounter 

func (mmDeleteForPN *RecordCleanerMock) DeleteForPNBeforeCounter() uint64

DeleteForPNBeforeCounter returns a count of RecordCleanerMock.DeleteForPN invocations

func (*RecordCleanerMock) MinimockDeleteForPNDone 

func (m *RecordCleanerMock) MinimockDeleteForPNDone() bool

MinimockDeleteForPNDone returns true if the count of the DeleteForPN invocations corresponds the number of defined expectations

func (*RecordCleanerMock) MinimockDeleteForPNInspect 

func (m *RecordCleanerMock) MinimockDeleteForPNInspect()

MinimockDeleteForPNInspect logs each unmet expectation

func (*RecordCleanerMock) MinimockFinish 

func (m *RecordCleanerMock) MinimockFinish()

MinimockFinish checks that all mocked methods have been called the expected number of times

func (*RecordCleanerMock) MinimockWait 

func (m *RecordCleanerMock) MinimockWait(timeout mm_time.Duration)

MinimockWait waits for all mocked methods to be called the expected number of times

type RecordCleanerMockDeleteForPNExpectation 

type RecordCleanerMockDeleteForPNExpectation struct {
	Counter uint64
	// contains filtered or unexported fields
}

RecordCleanerMockDeleteForPNExpectation specifies expectation struct of the RecordCleaner.DeleteForPN

type RecordCleanerMockDeleteForPNParams 

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

RecordCleanerMockDeleteForPNParams contains parameters of the RecordCleaner.DeleteForPN

type RecordCollectionAccessor 

type RecordCollectionAccessor interface {
	// ForPulse returns []MaterialRecord for a provided jetID and a pulse number.
	ForPulse(ctx context.Context, jetID insolar.JetID, pn insolar.PulseNumber) []record.Material
}

RecordCollectionAccessor provides methods for querying records with specific search conditions.

type RecordCollectionAccessorMock 

type RecordCollectionAccessorMock struct {
	ForPulseMock mRecordCollectionAccessorMockForPulse
	// contains filtered or unexported fields
}

RecordCollectionAccessorMock implements RecordCollectionAccessor

func NewRecordCollectionAccessorMock 

func NewRecordCollectionAccessorMock(t minimock.Tester) *RecordCollectionAccessorMock

NewRecordCollectionAccessorMock returns a mock for RecordCollectionAccessor

func (*RecordCollectionAccessorMock) ForPulse 

func (mmForPulse *RecordCollectionAccessorMock) ForPulse(ctx context.Context, jetID insolar.JetID, pn insolar.PulseNumber) (ma1 []record.Material)

ForPulse implements RecordCollectionAccessor

func (*RecordCollectionAccessorMock) ForPulseAfterCounter 

func (mmForPulse *RecordCollectionAccessorMock) ForPulseAfterCounter() uint64

ForPulseAfterCounter returns a count of finished RecordCollectionAccessorMock.ForPulse invocations

func (*RecordCollectionAccessorMock) ForPulseBeforeCounter 

func (mmForPulse *RecordCollectionAccessorMock) ForPulseBeforeCounter() uint64

ForPulseBeforeCounter returns a count of RecordCollectionAccessorMock.ForPulse invocations

func (*RecordCollectionAccessorMock) MinimockFinish 

func (m *RecordCollectionAccessorMock) MinimockFinish()

MinimockFinish checks that all mocked methods have been called the expected number of times

func (*RecordCollectionAccessorMock) MinimockForPulseDone 

func (m *RecordCollectionAccessorMock) MinimockForPulseDone() bool

MinimockForPulseDone returns true if the count of the ForPulse invocations corresponds the number of defined expectations

func (*RecordCollectionAccessorMock) MinimockForPulseInspect 

func (m *RecordCollectionAccessorMock) MinimockForPulseInspect()

MinimockForPulseInspect logs each unmet expectation

func (*RecordCollectionAccessorMock) MinimockWait 

func (m *RecordCollectionAccessorMock) MinimockWait(timeout mm_time.Duration)

MinimockWait waits for all mocked methods to be called the expected number of times

type RecordCollectionAccessorMockForPulseExpectation 

type RecordCollectionAccessorMockForPulseExpectation struct {
	Counter uint64
	// contains filtered or unexported fields
}

RecordCollectionAccessorMockForPulseExpectation specifies expectation struct of the RecordCollectionAccessor.ForPulse

func (*RecordCollectionAccessorMockForPulseExpectation) Then 

func (e *RecordCollectionAccessorMockForPulseExpectation) Then(ma1 []record.Material) *RecordCollectionAccessorMock

Then sets up RecordCollectionAccessor.ForPulse return parameters for the expectation previously defined by the When method

type RecordCollectionAccessorMockForPulseParams 

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

RecordCollectionAccessorMockForPulseParams contains parameters of the RecordCollectionAccessor.ForPulse

type RecordCollectionAccessorMockForPulseResults 

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

RecordCollectionAccessorMockForPulseResults contains results of the RecordCollectionAccessor.ForPulse

type RecordDB 

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

RecordDB is a DB storage implementation. It saves records to disk and does not allow removal.

func NewRecordDB 

func NewRecordDB(db *store.BadgerDB) *RecordDB

NewRecordDB creates new DB storage instance.

func (*RecordDB) AtPosition 

func (r *RecordDB) AtPosition(pn insolar.PulseNumber, position uint32) (insolar.ID, error)

AtPosition returns record ID for a specific pulse and a position

func (*RecordDB) BatchSet 

func (r *RecordDB) BatchSet(ctx context.Context, recs []record.Material) error

BatchSet saves a batch of records to storage with order-processing.

func (*RecordDB) ForID 

func (r *RecordDB) ForID(ctx context.Context, id insolar.ID) (record.Material, error)

ForID returns record for provided id.

func (*RecordDB) LastKnownPosition 

func (r *RecordDB) LastKnownPosition(pn insolar.PulseNumber) (uint32, error)

LastKnownPosition returns last known position of record in Pulse.

func (*RecordDB) Set 

func (r *RecordDB) Set(ctx context.Context, rec record.Material) error

Set saves new record-value in storage.

func (*RecordDB) TruncateHead 

func (r *RecordDB) TruncateHead(ctx context.Context, from insolar.PulseNumber) error

TruncateHead remove all records after lastPulse

type RecordMemory 

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

RecordMemory is an in-indexStorage struct for record-storage.

func NewRecordMemory 

func NewRecordMemory() *RecordMemory

NewRecordMemory creates a new instance of RecordMemory storage.

func (*RecordMemory) DeleteForPN 

func (m *RecordMemory) DeleteForPN(ctx context.Context, pulse insolar.PulseNumber)

DeleteForPN method removes records from a storage for all pulses until pulse (pulse included)

func (*RecordMemory) ForID 

func (m *RecordMemory) ForID(ctx context.Context, id insolar.ID) (rec record.Material, err error)

ForID returns record for provided id.

func (*RecordMemory) ForPulse 

func (m *RecordMemory) ForPulse(
	ctx context.Context, jetID insolar.JetID, pn insolar.PulseNumber,
) []record.Material

ForPulse returns []MaterialRecord for a provided jetID and a pulse number.

func (*RecordMemory) SetAtomic 

func (m *RecordMemory) SetAtomic(ctx context.Context, recs ...record.Material) error

SetAtomic atomically stores records to storage. Guarantees to either store all records or none.

type RecordModifier 

type RecordModifier interface {
	// Set saves new record-value in storage with order-processing.
	Set(ctx context.Context, rec record.Material) error
	// BatchSet saves a batch of records to storage with order-processing.
	BatchSet(ctx context.Context, recs []record.Material) error
}

RecordModifier provides methods for setting record-values to storage.

type RecordModifierMock 

type RecordModifierMock struct {
	BatchSetMock mRecordModifierMockBatchSet

	SetMock mRecordModifierMockSet
	// contains filtered or unexported fields
}

RecordModifierMock implements RecordModifier

func NewRecordModifierMock 

func NewRecordModifierMock(t minimock.Tester) *RecordModifierMock

NewRecordModifierMock returns a mock for RecordModifier

func (*RecordModifierMock) BatchSet 

func (mmBatchSet *RecordModifierMock) BatchSet(ctx context.Context, recs []record.Material) (err error)

BatchSet implements RecordModifier

func (*RecordModifierMock) BatchSetAfterCounter 

func (mmBatchSet *RecordModifierMock) BatchSetAfterCounter() uint64

BatchSetAfterCounter returns a count of finished RecordModifierMock.BatchSet invocations

func (*RecordModifierMock) BatchSetBeforeCounter 

func (mmBatchSet *RecordModifierMock) BatchSetBeforeCounter() uint64

BatchSetBeforeCounter returns a count of RecordModifierMock.BatchSet invocations

func (*RecordModifierMock) MinimockBatchSetDone 

func (m *RecordModifierMock) MinimockBatchSetDone() bool

MinimockBatchSetDone returns true if the count of the BatchSet invocations corresponds the number of defined expectations

func (*RecordModifierMock) MinimockBatchSetInspect 

func (m *RecordModifierMock) MinimockBatchSetInspect()

MinimockBatchSetInspect logs each unmet expectation

func (*RecordModifierMock) MinimockFinish 

func (m *RecordModifierMock) MinimockFinish()

MinimockFinish checks that all mocked methods have been called the expected number of times

func (*RecordModifierMock) MinimockSetDone 

func (m *RecordModifierMock) MinimockSetDone() bool

MinimockSetDone returns true if the count of the Set invocations corresponds the number of defined expectations

func (*RecordModifierMock) MinimockSetInspect 

func (m *RecordModifierMock) MinimockSetInspect()

MinimockSetInspect logs each unmet expectation

func (*RecordModifierMock) MinimockWait 

func (m *RecordModifierMock) MinimockWait(timeout mm_time.Duration)

MinimockWait waits for all mocked methods to be called the expected number of times

func (*RecordModifierMock) Set 

func (mmSet *RecordModifierMock) Set(ctx context.Context, rec record.Material) (err error)

Set implements RecordModifier

func (*RecordModifierMock) SetAfterCounter 

func (mmSet *RecordModifierMock) SetAfterCounter() uint64

SetAfterCounter returns a count of finished RecordModifierMock.Set invocations

func (*RecordModifierMock) SetBeforeCounter 

func (mmSet *RecordModifierMock) SetBeforeCounter() uint64

SetBeforeCounter returns a count of RecordModifierMock.Set invocations

type RecordModifierMockBatchSetExpectation 

type RecordModifierMockBatchSetExpectation struct {
	Counter uint64
	// contains filtered or unexported fields
}

RecordModifierMockBatchSetExpectation specifies expectation struct of the RecordModifier.BatchSet

func (*RecordModifierMockBatchSetExpectation) Then 

func (e *RecordModifierMockBatchSetExpectation) Then(err error) *RecordModifierMock

Then sets up RecordModifier.BatchSet return parameters for the expectation previously defined by the When method

type RecordModifierMockBatchSetParams 

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

RecordModifierMockBatchSetParams contains parameters of the RecordModifier.BatchSet

type RecordModifierMockBatchSetResults 

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

RecordModifierMockBatchSetResults contains results of the RecordModifier.BatchSet

type RecordModifierMockSetExpectation 

type RecordModifierMockSetExpectation struct {
	Counter uint64
	// contains filtered or unexported fields
}

RecordModifierMockSetExpectation specifies expectation struct of the RecordModifier.Set

func (*RecordModifierMockSetExpectation) Then 

func (e *RecordModifierMockSetExpectation) Then(err error) *RecordModifierMock

Then sets up RecordModifier.Set return parameters for the expectation previously defined by the When method

type RecordModifierMockSetParams 

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

RecordModifierMockSetParams contains parameters of the RecordModifier.Set

type RecordModifierMockSetResults 

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

RecordModifierMockSetResults contains results of the RecordModifier.Set

type RecordPositionAccessor 

type RecordPositionAccessor interface {
	// LastKnownPosition returns last known position of record in Pulse.
	LastKnownPosition(pn insolar.PulseNumber) (uint32, error)
	// AtPosition returns record ID for a specific pulse and a position
	AtPosition(pn insolar.PulseNumber, position uint32) (insolar.ID, error)
}

RecordPositionAccessor provides an interface for fetcing position of records.

type RecordPositionAccessorMock 

type RecordPositionAccessorMock struct {
	AtPositionMock mRecordPositionAccessorMockAtPosition

	LastKnownPositionMock mRecordPositionAccessorMockLastKnownPosition
	// contains filtered or unexported fields
}

RecordPositionAccessorMock implements RecordPositionAccessor

func NewRecordPositionAccessorMock 

func NewRecordPositionAccessorMock(t minimock.Tester) *RecordPositionAccessorMock

NewRecordPositionAccessorMock returns a mock for RecordPositionAccessor

func (*RecordPositionAccessorMock) AtPosition 

func (mmAtPosition *RecordPositionAccessorMock) AtPosition(pn insolar.PulseNumber, position uint32) (i1 insolar.ID, err error)

AtPosition implements RecordPositionAccessor

func (*RecordPositionAccessorMock) AtPositionAfterCounter 

func (mmAtPosition *RecordPositionAccessorMock) AtPositionAfterCounter() uint64

AtPositionAfterCounter returns a count of finished RecordPositionAccessorMock.AtPosition invocations

func (*RecordPositionAccessorMock) AtPositionBeforeCounter 

func (mmAtPosition *RecordPositionAccessorMock) AtPositionBeforeCounter() uint64

AtPositionBeforeCounter returns a count of RecordPositionAccessorMock.AtPosition invocations

func (*RecordPositionAccessorMock) LastKnownPosition 

func (mmLastKnownPosition *RecordPositionAccessorMock) LastKnownPosition(pn insolar.PulseNumber) (u1 uint32, err error)

LastKnownPosition implements RecordPositionAccessor

func (*RecordPositionAccessorMock) LastKnownPositionAfterCounter 

func (mmLastKnownPosition *RecordPositionAccessorMock) LastKnownPositionAfterCounter() uint64

LastKnownPositionAfterCounter returns a count of finished RecordPositionAccessorMock.LastKnownPosition invocations

func (*RecordPositionAccessorMock) LastKnownPositionBeforeCounter 

func (mmLastKnownPosition *RecordPositionAccessorMock) LastKnownPositionBeforeCounter() uint64

LastKnownPositionBeforeCounter returns a count of RecordPositionAccessorMock.LastKnownPosition invocations

func (*RecordPositionAccessorMock) MinimockAtPositionDone 

func (m *RecordPositionAccessorMock) MinimockAtPositionDone() bool

MinimockAtPositionDone returns true if the count of the AtPosition invocations corresponds the number of defined expectations

func (*RecordPositionAccessorMock) MinimockAtPositionInspect 

func (m *RecordPositionAccessorMock) MinimockAtPositionInspect()

MinimockAtPositionInspect logs each unmet expectation

func (*RecordPositionAccessorMock) MinimockFinish 

func (m *RecordPositionAccessorMock) MinimockFinish()

MinimockFinish checks that all mocked methods have been called the expected number of times

func (*RecordPositionAccessorMock) MinimockLastKnownPositionDone 

func (m *RecordPositionAccessorMock) MinimockLastKnownPositionDone() bool

MinimockLastKnownPositionDone returns true if the count of the LastKnownPosition invocations corresponds the number of defined expectations

func (*RecordPositionAccessorMock) MinimockLastKnownPositionInspect 

func (m *RecordPositionAccessorMock) MinimockLastKnownPositionInspect()

MinimockLastKnownPositionInspect logs each unmet expectation

func (*RecordPositionAccessorMock) MinimockWait 

func (m *RecordPositionAccessorMock) MinimockWait(timeout mm_time.Duration)

MinimockWait waits for all mocked methods to be called the expected number of times

type RecordPositionAccessorMockAtPositionExpectation 

type RecordPositionAccessorMockAtPositionExpectation struct {
	Counter uint64
	// contains filtered or unexported fields
}

RecordPositionAccessorMockAtPositionExpectation specifies expectation struct of the RecordPositionAccessor.AtPosition

func (*RecordPositionAccessorMockAtPositionExpectation) Then 

func (e *RecordPositionAccessorMockAtPositionExpectation) Then(i1 insolar.ID, err error) *RecordPositionAccessorMock

Then sets up RecordPositionAccessor.AtPosition return parameters for the expectation previously defined by the When method

type RecordPositionAccessorMockAtPositionParams 

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

RecordPositionAccessorMockAtPositionParams contains parameters of the RecordPositionAccessor.AtPosition

type RecordPositionAccessorMockAtPositionResults 

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

RecordPositionAccessorMockAtPositionResults contains results of the RecordPositionAccessor.AtPosition

type RecordPositionAccessorMockLastKnownPositionExpectation 

type RecordPositionAccessorMockLastKnownPositionExpectation struct {
	Counter uint64
	// contains filtered or unexported fields
}

RecordPositionAccessorMockLastKnownPositionExpectation specifies expectation struct of the RecordPositionAccessor.LastKnownPosition

func (*RecordPositionAccessorMockLastKnownPositionExpectation) Then 

func (e *RecordPositionAccessorMockLastKnownPositionExpectation) Then(u1 uint32, err error) *RecordPositionAccessorMock

Then sets up RecordPositionAccessor.LastKnownPosition return parameters for the expectation previously defined by the When method

type RecordPositionAccessorMockLastKnownPositionParams 

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

RecordPositionAccessorMockLastKnownPositionParams contains parameters of the RecordPositionAccessor.LastKnownPosition

type RecordPositionAccessorMockLastKnownPositionResults 

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

RecordPositionAccessorMockLastKnownPositionResults contains results of the RecordPositionAccessor.LastKnownPosition

type RecordStorage 

type RecordStorage interface {
	RecordAccessor
	RecordModifier
}

RecordStorage is an union of RecordAccessor and RecordModifier

type RecordStorageMock 

type RecordStorageMock struct {
	BatchSetMock mRecordStorageMockBatchSet

	ForIDMock mRecordStorageMockForID

	SetMock mRecordStorageMockSet
	// contains filtered or unexported fields
}

RecordStorageMock implements RecordStorage

func NewRecordStorageMock 

func NewRecordStorageMock(t minimock.Tester) *RecordStorageMock

NewRecordStorageMock returns a mock for RecordStorage

func (*RecordStorageMock) BatchSet 

func (mmBatchSet *RecordStorageMock) BatchSet(ctx context.Context, recs []record.Material) (err error)

BatchSet implements RecordStorage

func (*RecordStorageMock) BatchSetAfterCounter 

func (mmBatchSet *RecordStorageMock) BatchSetAfterCounter() uint64

BatchSetAfterCounter returns a count of finished RecordStorageMock.BatchSet invocations

func (*RecordStorageMock) BatchSetBeforeCounter 

func (mmBatchSet *RecordStorageMock) BatchSetBeforeCounter() uint64

BatchSetBeforeCounter returns a count of RecordStorageMock.BatchSet invocations

func (*RecordStorageMock) ForID 

func (mmForID *RecordStorageMock) ForID(ctx context.Context, id insolar.ID) (m1 record.Material, err error)

ForID implements RecordStorage

func (*RecordStorageMock) ForIDAfterCounter 

func (mmForID *RecordStorageMock) ForIDAfterCounter() uint64

ForIDAfterCounter returns a count of finished RecordStorageMock.ForID invocations

func (*RecordStorageMock) ForIDBeforeCounter 

func (mmForID *RecordStorageMock) ForIDBeforeCounter() uint64

ForIDBeforeCounter returns a count of RecordStorageMock.ForID invocations

func (*RecordStorageMock) MinimockBatchSetDone 

func (m *RecordStorageMock) MinimockBatchSetDone() bool

MinimockBatchSetDone returns true if the count of the BatchSet invocations corresponds the number of defined expectations

func (*RecordStorageMock) MinimockBatchSetInspect 

func (m *RecordStorageMock) MinimockBatchSetInspect()

MinimockBatchSetInspect logs each unmet expectation

func (*RecordStorageMock) MinimockFinish 

func (m *RecordStorageMock) MinimockFinish()

MinimockFinish checks that all mocked methods have been called the expected number of times

func (*RecordStorageMock) MinimockForIDDone 

func (m *RecordStorageMock) MinimockForIDDone() bool

MinimockForIDDone returns true if the count of the ForID invocations corresponds the number of defined expectations

func (*RecordStorageMock) MinimockForIDInspect 

func (m *RecordStorageMock) MinimockForIDInspect()

MinimockForIDInspect logs each unmet expectation

func (*RecordStorageMock) MinimockSetDone 

func (m *RecordStorageMock) MinimockSetDone() bool

MinimockSetDone returns true if the count of the Set invocations corresponds the number of defined expectations

func (*RecordStorageMock) MinimockSetInspect 

func (m *RecordStorageMock) MinimockSetInspect()

MinimockSetInspect logs each unmet expectation

func (*RecordStorageMock) MinimockWait 

func (m *RecordStorageMock) MinimockWait(timeout mm_time.Duration)

MinimockWait waits for all mocked methods to be called the expected number of times

func (*RecordStorageMock) Set 

func (mmSet *RecordStorageMock) Set(ctx context.Context, rec record.Material) (err error)

Set implements RecordStorage

func (*RecordStorageMock) SetAfterCounter 

func (mmSet *RecordStorageMock) SetAfterCounter() uint64

SetAfterCounter returns a count of finished RecordStorageMock.Set invocations

func (*RecordStorageMock) SetBeforeCounter 

func (mmSet *RecordStorageMock) SetBeforeCounter() uint64

SetBeforeCounter returns a count of RecordStorageMock.Set invocations

type RecordStorageMockBatchSetExpectation 

type RecordStorageMockBatchSetExpectation struct {
	Counter uint64
	// contains filtered or unexported fields
}

RecordStorageMockBatchSetExpectation specifies expectation struct of the RecordStorage.BatchSet

func (*RecordStorageMockBatchSetExpectation) Then 

func (e *RecordStorageMockBatchSetExpectation) Then(err error) *RecordStorageMock

Then sets up RecordStorage.BatchSet return parameters for the expectation previously defined by the When method

type RecordStorageMockBatchSetParams 

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

RecordStorageMockBatchSetParams contains parameters of the RecordStorage.BatchSet

type RecordStorageMockBatchSetResults 

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

RecordStorageMockBatchSetResults contains results of the RecordStorage.BatchSet

type RecordStorageMockForIDExpectation 

type RecordStorageMockForIDExpectation struct {
	Counter uint64
	// contains filtered or unexported fields
}

RecordStorageMockForIDExpectation specifies expectation struct of the RecordStorage.ForID

func (*RecordStorageMockForIDExpectation) Then 

func (e *RecordStorageMockForIDExpectation) Then(m1 record.Material, err error) *RecordStorageMock

Then sets up RecordStorage.ForID return parameters for the expectation previously defined by the When method

type RecordStorageMockForIDParams 

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

RecordStorageMockForIDParams contains parameters of the RecordStorage.ForID

type RecordStorageMockForIDResults 

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

RecordStorageMockForIDResults contains results of the RecordStorage.ForID

type RecordStorageMockSetExpectation 

type RecordStorageMockSetExpectation struct {
	Counter uint64
	// contains filtered or unexported fields
}

RecordStorageMockSetExpectation specifies expectation struct of the RecordStorage.Set

func (*RecordStorageMockSetExpectation) Then 

func (e *RecordStorageMockSetExpectation) Then(err error) *RecordStorageMock

Then sets up RecordStorage.Set return parameters for the expectation previously defined by the When method

type RecordStorageMockSetParams 

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

RecordStorageMockSetParams contains parameters of the RecordStorage.Set

type RecordStorageMockSetResults 

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

RecordStorageMockSetResults contains results of the RecordStorage.Set

type TypeID 

type TypeID uint32

TypeID encodes a record object type.

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.