Why Go
- Case Studies
  
  Common problems companies solve with Go
- Use Cases
  
  Stories about how and why companies use Go
- Security Policy
  
  How Go can help keep you secure by default
Learn
Docs
- Effective Go
  
  Tips for writing clear, performant, and idiomatic Go code
- Go User Manual
  
  A complete introduction to building software with Go
- Standard library
  
  Reference documentation for Go's standard library
- Release Notes
  
  Learn what's new in each Go release
Packages
Community
- Recorded Talks
  
  Videos from prior events
- Meetups
  
  Meet other local Go developers
- Conferences
  
  Learn and network with Go developers from around the world
- Go blog
  
  The Go project's official blog.
- Go project
  
  Get help and stay informed from Go
- Get connected

recentstorage

package

Go to main page

Versions in this module

v0

v0.8.7

Apr 23, 2019

v0.8.6

Mar 22, 2019

v0.8.5

Mar 12, 2019

v0.8.4

Feb 26, 2019

v0.8.3

Feb 22, 2019

v0.8.2

Feb 21, 2019

v0.8.1

Feb 21, 2019

v0.8.0

Feb 20, 2019

Changes in this version

+ type PendingObjectContext struct

+ Active bool

+ Requests []core.RecordID

+ type PendingStorage interface

+ AddPendingRequest func(ctx context.Context, obj, req core.RecordID)

+ GetRequests func() map[core.RecordID]PendingObjectContext

+ GetRequestsForObject func(obj core.RecordID) []core.RecordID

+ RemovePendingRequest func(ctx context.Context, obj, req core.RecordID)

+ SetContextToObject func(ctx context.Context, obj core.RecordID, objContext PendingObjectContext)

+ type PendingStorageConcrete struct

+ func NewPendingStorage(jetID core.RecordID) *PendingStorageConcrete

+ func (r *PendingStorageConcrete) AddPendingRequest(ctx context.Context, obj, req core.RecordID)

+ func (r *PendingStorageConcrete) GetRequests() map[core.RecordID]PendingObjectContext

+ func (r *PendingStorageConcrete) GetRequestsForObject(obj core.RecordID) []core.RecordID

+ func (r *PendingStorageConcrete) RemovePendingRequest(ctx context.Context, obj, req core.RecordID)

+ func (r *PendingStorageConcrete) SetContextToObject(ctx context.Context, obj core.RecordID, objContext PendingObjectContext)

+ type PendingStorageMock struct

+ AddPendingRequestCounter uint64

+ AddPendingRequestFunc func(p context.Context, p1 core.RecordID, p2 core.RecordID)

+ AddPendingRequestMock mPendingStorageMockAddPendingRequest

+ AddPendingRequestPreCounter uint64

+ GetRequestsCounter uint64

+ GetRequestsForObjectCounter uint64

+ GetRequestsForObjectFunc func(p core.RecordID) (r []core.RecordID)

+ GetRequestsForObjectMock mPendingStorageMockGetRequestsForObject

+ GetRequestsForObjectPreCounter uint64

+ GetRequestsFunc func() (r map[core.RecordID]PendingObjectContext)

+ GetRequestsMock mPendingStorageMockGetRequests

+ GetRequestsPreCounter uint64

+ RemovePendingRequestCounter uint64

+ RemovePendingRequestFunc func(p context.Context, p1 core.RecordID, p2 core.RecordID)

+ RemovePendingRequestMock mPendingStorageMockRemovePendingRequest

+ RemovePendingRequestPreCounter uint64

+ SetContextToObjectCounter uint64

+ SetContextToObjectFunc func(p context.Context, p1 core.RecordID, p2 PendingObjectContext)

+ SetContextToObjectMock mPendingStorageMockSetContextToObject

+ SetContextToObjectPreCounter uint64

+ func NewPendingStorageMock(t minimock.Tester) *PendingStorageMock

+ func (m *PendingStorageMock) AddPendingRequest(p context.Context, p1 core.RecordID, p2 core.RecordID)

+ func (m *PendingStorageMock) AddPendingRequestFinished() bool

+ func (m *PendingStorageMock) AddPendingRequestMinimockCounter() uint64

+ func (m *PendingStorageMock) AddPendingRequestMinimockPreCounter() uint64

+ func (m *PendingStorageMock) AllMocksCalled() bool

+ func (m *PendingStorageMock) CheckMocksCalled()

+ func (m *PendingStorageMock) Finish()

+ func (m *PendingStorageMock) GetRequests() (r map[core.RecordID]PendingObjectContext)

+ func (m *PendingStorageMock) GetRequestsFinished() bool

+ func (m *PendingStorageMock) GetRequestsForObject(p core.RecordID) (r []core.RecordID)

+ func (m *PendingStorageMock) GetRequestsForObjectFinished() bool

+ func (m *PendingStorageMock) GetRequestsForObjectMinimockCounter() uint64

+ func (m *PendingStorageMock) GetRequestsForObjectMinimockPreCounter() uint64

+ func (m *PendingStorageMock) GetRequestsMinimockCounter() uint64

+ func (m *PendingStorageMock) GetRequestsMinimockPreCounter() uint64

+ func (m *PendingStorageMock) MinimockFinish()

+ func (m *PendingStorageMock) MinimockWait(timeout time.Duration)

+ func (m *PendingStorageMock) RemovePendingRequest(p context.Context, p1 core.RecordID, p2 core.RecordID)

+ func (m *PendingStorageMock) RemovePendingRequestFinished() bool

+ func (m *PendingStorageMock) RemovePendingRequestMinimockCounter() uint64

+ func (m *PendingStorageMock) RemovePendingRequestMinimockPreCounter() uint64

+ func (m *PendingStorageMock) SetContextToObject(p context.Context, p1 core.RecordID, p2 PendingObjectContext)

+ func (m *PendingStorageMock) SetContextToObjectFinished() bool

+ func (m *PendingStorageMock) SetContextToObjectMinimockCounter() uint64

+ func (m *PendingStorageMock) SetContextToObjectMinimockPreCounter() uint64

+ func (m *PendingStorageMock) ValidateCallCounters()

+ func (m *PendingStorageMock) Wait(timeout time.Duration)

+ type PendingStorageMockAddPendingRequestExpectation struct

+ type PendingStorageMockAddPendingRequestInput struct

+ type PendingStorageMockGetRequestsExpectation struct

+ func (e *PendingStorageMockGetRequestsExpectation) Return(r map[core.RecordID]PendingObjectContext)

+ type PendingStorageMockGetRequestsForObjectExpectation struct

+ func (e *PendingStorageMockGetRequestsForObjectExpectation) Return(r []core.RecordID)

+ type PendingStorageMockGetRequestsForObjectInput struct

+ type PendingStorageMockGetRequestsForObjectResult struct

+ type PendingStorageMockGetRequestsResult struct

+ type PendingStorageMockRemovePendingRequestExpectation struct

+ type PendingStorageMockRemovePendingRequestInput struct

+ type PendingStorageMockSetContextToObjectExpectation struct

+ type PendingStorageMockSetContextToObjectInput struct

type Provider

+ CloneIndexStorage func(ctx context.Context, fromJetID, toJetID core.RecordID)

+ ClonePendingStorage func(ctx context.Context, fromJetID, toJetID core.RecordID)

+ Count func() int

+ DecreaseIndexesTTL func(ctx context.Context) map[core.RecordID][]core.RecordID

+ GetIndexStorage func(ctx context.Context, jetID core.RecordID) RecentIndexStorage

+ GetPendingStorage func(ctx context.Context, jetID core.RecordID) PendingStorage

+ RemovePendingStorage func(ctx context.Context, id core.RecordID)

type ProviderMock

+ CloneIndexStorageCounter uint64

+ CloneIndexStorageFunc func(p context.Context, p1 core.RecordID, p2 core.RecordID)

+ CloneIndexStorageMock mProviderMockCloneIndexStorage

+ CloneIndexStoragePreCounter uint64

+ ClonePendingStorageCounter uint64

+ ClonePendingStorageFunc func(p context.Context, p1 core.RecordID, p2 core.RecordID)

+ ClonePendingStorageMock mProviderMockClonePendingStorage

+ ClonePendingStoragePreCounter uint64

+ CountCounter uint64

+ CountFunc func() (r int)

+ CountMock mProviderMockCount

+ CountPreCounter uint64

+ DecreaseIndexesTTLCounter uint64

+ DecreaseIndexesTTLFunc func(p context.Context) (r map[core.RecordID][]core.RecordID)

+ DecreaseIndexesTTLMock mProviderMockDecreaseIndexesTTL

+ DecreaseIndexesTTLPreCounter uint64

+ GetIndexStorageCounter uint64

+ GetIndexStorageFunc func(p context.Context, p1 core.RecordID) (r RecentIndexStorage)

+ GetIndexStorageMock mProviderMockGetIndexStorage

+ GetIndexStoragePreCounter uint64

+ GetPendingStorageCounter uint64

+ GetPendingStorageFunc func(p context.Context, p1 core.RecordID) (r PendingStorage)

+ GetPendingStorageMock mProviderMockGetPendingStorage

+ GetPendingStoragePreCounter uint64

+ RemovePendingStorageCounter uint64

+ RemovePendingStorageFunc func(p context.Context, p1 core.RecordID)

+ RemovePendingStorageMock mProviderMockRemovePendingStorage

+ RemovePendingStoragePreCounter uint64

+ func (m *ProviderMock) CloneIndexStorage(p context.Context, p1 core.RecordID, p2 core.RecordID)

+ func (m *ProviderMock) CloneIndexStorageFinished() bool

+ func (m *ProviderMock) CloneIndexStorageMinimockCounter() uint64

+ func (m *ProviderMock) CloneIndexStorageMinimockPreCounter() uint64

+ func (m *ProviderMock) ClonePendingStorage(p context.Context, p1 core.RecordID, p2 core.RecordID)

+ func (m *ProviderMock) ClonePendingStorageFinished() bool

+ func (m *ProviderMock) ClonePendingStorageMinimockCounter() uint64

+ func (m *ProviderMock) ClonePendingStorageMinimockPreCounter() uint64

+ func (m *ProviderMock) Count() (r int)

+ func (m *ProviderMock) CountFinished() bool

+ func (m *ProviderMock) CountMinimockCounter() uint64

+ func (m *ProviderMock) CountMinimockPreCounter() uint64

+ func (m *ProviderMock) DecreaseIndexesTTL(p context.Context) (r map[core.RecordID][]core.RecordID)

+ func (m *ProviderMock) DecreaseIndexesTTLFinished() bool

+ func (m *ProviderMock) DecreaseIndexesTTLMinimockCounter() uint64

+ func (m *ProviderMock) DecreaseIndexesTTLMinimockPreCounter() uint64

+ func (m *ProviderMock) GetIndexStorage(p context.Context, p1 core.RecordID) (r RecentIndexStorage)

+ func (m *ProviderMock) GetIndexStorageFinished() bool

+ func (m *ProviderMock) GetIndexStorageMinimockCounter() uint64

+ func (m *ProviderMock) GetIndexStorageMinimockPreCounter() uint64

+ func (m *ProviderMock) GetPendingStorage(p context.Context, p1 core.RecordID) (r PendingStorage)

+ func (m *ProviderMock) GetPendingStorageFinished() bool

+ func (m *ProviderMock) GetPendingStorageMinimockCounter() uint64

+ func (m *ProviderMock) GetPendingStorageMinimockPreCounter() uint64

+ func (m *ProviderMock) RemovePendingStorage(p context.Context, p1 core.RecordID)

+ func (m *ProviderMock) RemovePendingStorageFinished() bool

+ func (m *ProviderMock) RemovePendingStorageMinimockCounter() uint64

+ func (m *ProviderMock) RemovePendingStorageMinimockPreCounter() uint64

+ type ProviderMockCloneIndexStorageExpectation struct

+ type ProviderMockCloneIndexStorageInput struct

+ type ProviderMockClonePendingStorageExpectation struct

+ type ProviderMockClonePendingStorageInput struct

+ type ProviderMockCountExpectation struct

+ func (e *ProviderMockCountExpectation) Return(r int)

+ type ProviderMockCountResult struct

+ type ProviderMockDecreaseIndexesTTLExpectation struct

+ func (e *ProviderMockDecreaseIndexesTTLExpectation) Return(r map[core.RecordID][]core.RecordID)

+ type ProviderMockDecreaseIndexesTTLInput struct

+ type ProviderMockDecreaseIndexesTTLResult struct

+ type ProviderMockGetIndexStorageExpectation struct

+ func (e *ProviderMockGetIndexStorageExpectation) Return(r RecentIndexStorage)

+ type ProviderMockGetIndexStorageInput struct

+ type ProviderMockGetIndexStorageResult struct

+ type ProviderMockGetPendingStorageExpectation struct

+ func (e *ProviderMockGetPendingStorageExpectation) Return(r PendingStorage)

+ type ProviderMockGetPendingStorageInput struct

+ type ProviderMockGetPendingStorageResult struct

+ type ProviderMockRemovePendingStorageExpectation struct

+ type ProviderMockRemovePendingStorageInput struct

+ type RecentIndexStorage interface

+ AddObject func(ctx context.Context, id core.RecordID)

+ AddObjectWithTLL func(ctx context.Context, id core.RecordID, ttl int)

+ DecreaseIndexTTL func(ctx context.Context) []core.RecordID

+ FilterNotExistWithLock func(ctx context.Context, candidates []core.RecordID, ...)

+ GetObjects func() map[core.RecordID]int

+ type RecentIndexStorageConcrete struct

+ DefaultTTL int

+ func NewRecentIndexStorage(jetID core.RecordID, defaultTTL int) *RecentIndexStorageConcrete

+ func (r *RecentIndexStorageConcrete) AddObject(ctx context.Context, id core.RecordID)

+ func (r *RecentIndexStorageConcrete) AddObjectWithTLL(ctx context.Context, id core.RecordID, ttl int)

+ func (r *RecentIndexStorageConcrete) DecreaseIndexTTL(ctx context.Context) []core.RecordID

+ func (r *RecentIndexStorageConcrete) FilterNotExistWithLock(ctx context.Context, candidates []core.RecordID, ...)

+ func (r *RecentIndexStorageConcrete) GetObjects() map[core.RecordID]int

+ type RecentIndexStorageMock struct

+ AddObjectCounter uint64

+ AddObjectFunc func(p context.Context, p1 core.RecordID)

+ AddObjectMock mRecentIndexStorageMockAddObject

+ AddObjectPreCounter uint64

+ AddObjectWithTLLCounter uint64

+ AddObjectWithTLLFunc func(p context.Context, p1 core.RecordID, p2 int)

+ AddObjectWithTLLMock mRecentIndexStorageMockAddObjectWithTLL

+ AddObjectWithTLLPreCounter uint64

+ DecreaseIndexTTLCounter uint64

+ DecreaseIndexTTLFunc func(p context.Context) (r []core.RecordID)

+ DecreaseIndexTTLMock mRecentIndexStorageMockDecreaseIndexTTL

+ DecreaseIndexTTLPreCounter uint64

+ FilterNotExistWithLockCounter uint64

+ FilterNotExistWithLockFunc func(p context.Context, p1 []core.RecordID, p2 func(p []core.RecordID))

+ FilterNotExistWithLockMock mRecentIndexStorageMockFilterNotExistWithLock

+ FilterNotExistWithLockPreCounter uint64

+ GetObjectsCounter uint64

+ GetObjectsFunc func() (r map[core.RecordID]int)

+ GetObjectsMock mRecentIndexStorageMockGetObjects

+ GetObjectsPreCounter uint64

+ func NewRecentIndexStorageMock(t minimock.Tester) *RecentIndexStorageMock

+ func (m *RecentIndexStorageMock) AddObject(p context.Context, p1 core.RecordID)

+ func (m *RecentIndexStorageMock) AddObjectFinished() bool

+ func (m *RecentIndexStorageMock) AddObjectMinimockCounter() uint64

+ func (m *RecentIndexStorageMock) AddObjectMinimockPreCounter() uint64

+ func (m *RecentIndexStorageMock) AddObjectWithTLL(p context.Context, p1 core.RecordID, p2 int)

+ func (m *RecentIndexStorageMock) AddObjectWithTLLFinished() bool

+ func (m *RecentIndexStorageMock) AddObjectWithTLLMinimockCounter() uint64

+ func (m *RecentIndexStorageMock) AddObjectWithTLLMinimockPreCounter() uint64

+ func (m *RecentIndexStorageMock) AllMocksCalled() bool

+ func (m *RecentIndexStorageMock) CheckMocksCalled()

+ func (m *RecentIndexStorageMock) DecreaseIndexTTL(p context.Context) (r []core.RecordID)

+ func (m *RecentIndexStorageMock) DecreaseIndexTTLFinished() bool

+ func (m *RecentIndexStorageMock) DecreaseIndexTTLMinimockCounter() uint64

+ func (m *RecentIndexStorageMock) DecreaseIndexTTLMinimockPreCounter() uint64

+ func (m *RecentIndexStorageMock) FilterNotExistWithLock(p context.Context, p1 []core.RecordID, p2 func(p []core.RecordID))

+ func (m *RecentIndexStorageMock) FilterNotExistWithLockFinished() bool

+ func (m *RecentIndexStorageMock) FilterNotExistWithLockMinimockCounter() uint64

+ func (m *RecentIndexStorageMock) FilterNotExistWithLockMinimockPreCounter() uint64

+ func (m *RecentIndexStorageMock) Finish()

+ func (m *RecentIndexStorageMock) GetObjects() (r map[core.RecordID]int)

+ func (m *RecentIndexStorageMock) GetObjectsFinished() bool

+ func (m *RecentIndexStorageMock) GetObjectsMinimockCounter() uint64

+ func (m *RecentIndexStorageMock) GetObjectsMinimockPreCounter() uint64

+ func (m *RecentIndexStorageMock) MinimockFinish()

+ func (m *RecentIndexStorageMock) MinimockWait(timeout time.Duration)

+ func (m *RecentIndexStorageMock) ValidateCallCounters()

+ func (m *RecentIndexStorageMock) Wait(timeout time.Duration)

+ type RecentIndexStorageMockAddObjectExpectation struct

+ type RecentIndexStorageMockAddObjectInput struct

+ type RecentIndexStorageMockAddObjectWithTLLExpectation struct

+ type RecentIndexStorageMockAddObjectWithTLLInput struct

+ type RecentIndexStorageMockDecreaseIndexTTLExpectation struct

+ func (e *RecentIndexStorageMockDecreaseIndexTTLExpectation) Return(r []core.RecordID)

+ type RecentIndexStorageMockDecreaseIndexTTLInput struct

+ type RecentIndexStorageMockDecreaseIndexTTLResult struct

+ type RecentIndexStorageMockFilterNotExistWithLockExpectation struct

+ type RecentIndexStorageMockFilterNotExistWithLockInput struct

+ type RecentIndexStorageMockGetObjectsExpectation struct

+ func (e *RecentIndexStorageMockGetObjectsExpectation) Return(r map[core.RecordID]int)

+ type RecentIndexStorageMockGetObjectsResult struct

+ type RecentStorageProvider struct

+ DefaultTTL int

+ func NewRecentStorageProvider(defaultTTL int) *RecentStorageProvider

+ func (p *RecentStorageProvider) CloneIndexStorage(ctx context.Context, fromJetID, toJetID core.RecordID)

+ func (p *RecentStorageProvider) ClonePendingStorage(ctx context.Context, fromJetID, toJetID core.RecordID)

+ func (p *RecentStorageProvider) Count() int

+ func (p *RecentStorageProvider) DecreaseIndexesTTL(ctx context.Context) map[core.RecordID][]core.RecordID

+ func (p *RecentStorageProvider) GetIndexStorage(ctx context.Context, jetID core.RecordID) RecentIndexStorage

+ func (p *RecentStorageProvider) GetPendingStorage(ctx context.Context, jetID core.RecordID) PendingStorage

+ func (p *RecentStorageProvider) RemovePendingStorage(ctx context.Context, id core.RecordID)

v0.7.6

Jan 29, 2019

v0.7.5

Jan 29, 2019

Changes in this version

+ type Provider interface

+ CloneStorage func(ctx context.Context, fromJetID, toJetID core.RecordID)

+ GetStorage func(ctx context.Context, jetID core.RecordID) RecentStorage

+ RemoveStorage func(ctx context.Context, id core.RecordID)

+ type ProviderMock struct

+ CloneStorageCounter uint64

+ CloneStorageFunc func(p context.Context, p1 core.RecordID, p2 core.RecordID)

+ CloneStorageMock mProviderMockCloneStorage

+ CloneStoragePreCounter uint64

+ GetStorageCounter uint64

+ GetStorageFunc func(p context.Context, p1 core.RecordID) (r RecentStorage)

+ GetStorageMock mProviderMockGetStorage

+ GetStoragePreCounter uint64

+ RemoveStorageCounter uint64

+ RemoveStorageFunc func(p context.Context, p1 core.RecordID)

+ RemoveStorageMock mProviderMockRemoveStorage

+ RemoveStoragePreCounter uint64

+ func NewProviderMock(t minimock.Tester) *ProviderMock

+ func (m *ProviderMock) AllMocksCalled() bool

+ func (m *ProviderMock) CheckMocksCalled()

+ func (m *ProviderMock) CloneStorage(p context.Context, p1 core.RecordID, p2 core.RecordID)

+ func (m *ProviderMock) CloneStorageFinished() bool

+ func (m *ProviderMock) CloneStorageMinimockCounter() uint64

+ func (m *ProviderMock) CloneStorageMinimockPreCounter() uint64

+ func (m *ProviderMock) Finish()

+ func (m *ProviderMock) GetStorage(p context.Context, p1 core.RecordID) (r RecentStorage)

+ func (m *ProviderMock) GetStorageFinished() bool

+ func (m *ProviderMock) GetStorageMinimockCounter() uint64

+ func (m *ProviderMock) GetStorageMinimockPreCounter() uint64

+ func (m *ProviderMock) MinimockFinish()

+ func (m *ProviderMock) MinimockWait(timeout time.Duration)

+ func (m *ProviderMock) RemoveStorage(p context.Context, p1 core.RecordID)

+ func (m *ProviderMock) RemoveStorageFinished() bool

+ func (m *ProviderMock) RemoveStorageMinimockCounter() uint64

+ func (m *ProviderMock) RemoveStorageMinimockPreCounter() uint64

+ func (m *ProviderMock) ValidateCallCounters()

+ func (m *ProviderMock) Wait(timeout time.Duration)

+ type ProviderMockCloneStorageExpectation struct

+ type ProviderMockCloneStorageInput struct

+ type ProviderMockGetStorageExpectation struct

+ func (e *ProviderMockGetStorageExpectation) Return(r RecentStorage)

+ type ProviderMockGetStorageInput struct

+ type ProviderMockGetStorageResult struct

+ type ProviderMockRemoveStorageExpectation struct

+ type ProviderMockRemoveStorageInput struct

+ type RecentStorage interface

+ AddObject func(ctx context.Context, id core.RecordID)

+ AddObjectWithTLL func(ctx context.Context, id core.RecordID, ttl int)

+ AddPendingRequest func(ctx context.Context, obj, req core.RecordID)

+ DecreaseTTL func(ctx context.Context)

+ GetObjects func() map[core.RecordID]int

+ GetRequests func() map[core.RecordID]map[core.RecordID]struct{}

+ GetRequestsForObject func(obj core.RecordID) []core.RecordID

+ IsRecordIDCached func(obj core.RecordID) bool

+ RemovePendingRequest func(ctx context.Context, obj, req core.RecordID)

+ type RecentStorageMock struct

+ AddObjectCounter uint64

+ AddObjectFunc func(p context.Context, p1 core.RecordID)

+ AddObjectMock mRecentStorageMockAddObject

+ AddObjectPreCounter uint64

+ AddObjectWithTLLCounter uint64

+ AddObjectWithTLLFunc func(p context.Context, p1 core.RecordID, p2 int)

+ AddObjectWithTLLMock mRecentStorageMockAddObjectWithTLL

+ AddObjectWithTLLPreCounter uint64

+ AddPendingRequestCounter uint64

+ AddPendingRequestFunc func(p context.Context, p1 core.RecordID, p2 core.RecordID)

+ AddPendingRequestMock mRecentStorageMockAddPendingRequest

+ AddPendingRequestPreCounter uint64

+ DecreaseTTLCounter uint64

+ DecreaseTTLFunc func(p context.Context)

+ DecreaseTTLMock mRecentStorageMockDecreaseTTL

+ DecreaseTTLPreCounter uint64

+ GetObjectsCounter uint64

+ GetObjectsFunc func() (r map[core.RecordID]int)

+ GetObjectsMock mRecentStorageMockGetObjects

+ GetObjectsPreCounter uint64

+ GetRequestsCounter uint64

+ GetRequestsForObjectCounter uint64

+ GetRequestsForObjectFunc func(p core.RecordID) (r []core.RecordID)

+ GetRequestsForObjectMock mRecentStorageMockGetRequestsForObject

+ GetRequestsForObjectPreCounter uint64

+ GetRequestsFunc func() (r map[core.RecordID]map[core.RecordID]struct{})

+ GetRequestsMock mRecentStorageMockGetRequests

+ GetRequestsPreCounter uint64

+ IsRecordIDCachedCounter uint64

+ IsRecordIDCachedFunc func(p core.RecordID) (r bool)

+ IsRecordIDCachedMock mRecentStorageMockIsRecordIDCached

+ IsRecordIDCachedPreCounter uint64

+ RemovePendingRequestCounter uint64

+ RemovePendingRequestFunc func(p context.Context, p1 core.RecordID, p2 core.RecordID)

+ RemovePendingRequestMock mRecentStorageMockRemovePendingRequest

+ RemovePendingRequestPreCounter uint64

+ func NewRecentStorageMock(t minimock.Tester) *RecentStorageMock

+ func (m *RecentStorageMock) AddObject(p context.Context, p1 core.RecordID)

+ func (m *RecentStorageMock) AddObjectFinished() bool

+ func (m *RecentStorageMock) AddObjectMinimockCounter() uint64

+ func (m *RecentStorageMock) AddObjectMinimockPreCounter() uint64

+ func (m *RecentStorageMock) AddObjectWithTLL(p context.Context, p1 core.RecordID, p2 int)

+ func (m *RecentStorageMock) AddObjectWithTLLFinished() bool

+ func (m *RecentStorageMock) AddObjectWithTLLMinimockCounter() uint64

+ func (m *RecentStorageMock) AddObjectWithTLLMinimockPreCounter() uint64

+ func (m *RecentStorageMock) AddPendingRequest(p context.Context, p1 core.RecordID, p2 core.RecordID)

+ func (m *RecentStorageMock) AddPendingRequestFinished() bool

+ func (m *RecentStorageMock) AddPendingRequestMinimockCounter() uint64

+ func (m *RecentStorageMock) AddPendingRequestMinimockPreCounter() uint64

+ func (m *RecentStorageMock) AllMocksCalled() bool

+ func (m *RecentStorageMock) CheckMocksCalled()

+ func (m *RecentStorageMock) DecreaseTTL(p context.Context)

+ func (m *RecentStorageMock) DecreaseTTLFinished() bool

+ func (m *RecentStorageMock) DecreaseTTLMinimockCounter() uint64

+ func (m *RecentStorageMock) DecreaseTTLMinimockPreCounter() uint64

+ func (m *RecentStorageMock) Finish()

+ func (m *RecentStorageMock) GetObjects() (r map[core.RecordID]int)

+ func (m *RecentStorageMock) GetObjectsFinished() bool

+ func (m *RecentStorageMock) GetObjectsMinimockCounter() uint64

+ func (m *RecentStorageMock) GetObjectsMinimockPreCounter() uint64

+ func (m *RecentStorageMock) GetRequests() (r map[core.RecordID]map[core.RecordID]struct{})

+ func (m *RecentStorageMock) GetRequestsFinished() bool

+ func (m *RecentStorageMock) GetRequestsForObject(p core.RecordID) (r []core.RecordID)

+ func (m *RecentStorageMock) GetRequestsForObjectFinished() bool

+ func (m *RecentStorageMock) GetRequestsForObjectMinimockCounter() uint64

+ func (m *RecentStorageMock) GetRequestsForObjectMinimockPreCounter() uint64

+ func (m *RecentStorageMock) GetRequestsMinimockCounter() uint64

+ func (m *RecentStorageMock) GetRequestsMinimockPreCounter() uint64

+ func (m *RecentStorageMock) IsRecordIDCached(p core.RecordID) (r bool)

+ func (m *RecentStorageMock) IsRecordIDCachedFinished() bool

+ func (m *RecentStorageMock) IsRecordIDCachedMinimockCounter() uint64

+ func (m *RecentStorageMock) IsRecordIDCachedMinimockPreCounter() uint64

+ func (m *RecentStorageMock) MinimockFinish()

+ func (m *RecentStorageMock) MinimockWait(timeout time.Duration)

+ func (m *RecentStorageMock) RemovePendingRequest(p context.Context, p1 core.RecordID, p2 core.RecordID)

+ func (m *RecentStorageMock) RemovePendingRequestFinished() bool

+ func (m *RecentStorageMock) RemovePendingRequestMinimockCounter() uint64

+ func (m *RecentStorageMock) RemovePendingRequestMinimockPreCounter() uint64

+ func (m *RecentStorageMock) ValidateCallCounters()

+ func (m *RecentStorageMock) Wait(timeout time.Duration)

+ type RecentStorageMockAddObjectExpectation struct

+ type RecentStorageMockAddObjectInput struct

+ type RecentStorageMockAddObjectWithTLLExpectation struct

+ type RecentStorageMockAddObjectWithTLLInput struct

+ type RecentStorageMockAddPendingRequestExpectation struct

+ type RecentStorageMockAddPendingRequestInput struct

+ type RecentStorageMockDecreaseTTLExpectation struct

+ type RecentStorageMockDecreaseTTLInput struct

+ type RecentStorageMockGetObjectsExpectation struct

+ func (e *RecentStorageMockGetObjectsExpectation) Return(r map[core.RecordID]int)

+ type RecentStorageMockGetObjectsResult struct

+ type RecentStorageMockGetRequestsExpectation struct

+ func (e *RecentStorageMockGetRequestsExpectation) Return(r map[core.RecordID]map[core.RecordID]struct{})

+ type RecentStorageMockGetRequestsForObjectExpectation struct

+ func (e *RecentStorageMockGetRequestsForObjectExpectation) Return(r []core.RecordID)

+ type RecentStorageMockGetRequestsForObjectInput struct

+ type RecentStorageMockGetRequestsForObjectResult struct

+ type RecentStorageMockGetRequestsResult struct

+ type RecentStorageMockIsRecordIDCachedExpectation struct

+ func (e *RecentStorageMockIsRecordIDCachedExpectation) Return(r bool)

+ type RecentStorageMockIsRecordIDCachedInput struct

+ type RecentStorageMockIsRecordIDCachedResult struct

+ type RecentStorageMockRemovePendingRequestExpectation struct

+ type RecentStorageMockRemovePendingRequestInput struct

v0.7.4-alpha

Jan 28, 2019

v0.7.3-alpha

Jan 24, 2019

v0.7.2-alpha

Jan 22, 2019

v0.7.1-alpha

Jan 21, 2019

v0.7.0-alpha

Jan 21, 2019