recentstorage

package
v0.7.6 Latest Latest
Warning

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

 Go to latest Published: Jan 29, 2019 License: Apache-2.0 Imports: 6 Imported by: 0

Documentation

Index

Constants

This section is empty.

Variables

This section is empty.

Functions

This section is empty.

Types

type Provider 

type Provider interface {
	GetStorage(ctx context.Context, jetID core.RecordID) RecentStorage
	CloneStorage(ctx context.Context, fromJetID, toJetID core.RecordID)
	RemoveStorage(ctx context.Context, id core.RecordID)
}

Provider provides a recent storage for jet

type ProviderMock 

type ProviderMock struct {
	CloneStorageFunc       func(p context.Context, p1 core.RecordID, p2 core.RecordID)
	CloneStorageCounter    uint64
	CloneStoragePreCounter uint64
	CloneStorageMock       mProviderMockCloneStorage

	GetStorageFunc       func(p context.Context, p1 core.RecordID) (r RecentStorage)
	GetStorageCounter    uint64
	GetStoragePreCounter uint64
	GetStorageMock       mProviderMockGetStorage

	RemoveStorageFunc       func(p context.Context, p1 core.RecordID)
	RemoveStorageCounter    uint64
	RemoveStoragePreCounter uint64
	RemoveStorageMock       mProviderMockRemoveStorage
	// contains filtered or unexported fields
}

ProviderMock implements github.com/insolar/insolar/ledger/recentstorage.Provider

func NewProviderMock 

func NewProviderMock(t minimock.Tester) *ProviderMock

NewProviderMock returns a mock for github.com/insolar/insolar/ledger/recentstorage.Provider

func (*ProviderMock) AllMocksCalled 

func (m *ProviderMock) AllMocksCalled() bool

AllMocksCalled returns true if all mocked methods were called before the execution of AllMocksCalled, it can be used with assert/require, i.e. assert.True(mock.AllMocksCalled())

func (*ProviderMock) CheckMocksCalled 

func (m *ProviderMock) CheckMocksCalled()

CheckMocksCalled checks that all mocked methods of the interface have been called at least once Deprecated: please use MinimockFinish method or use Finish method of minimock.Controller

func (*ProviderMock) CloneStorage 

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

CloneStorage implements github.com/insolar/insolar/ledger/recentstorage.Provider interface

func (*ProviderMock) CloneStorageFinished 

func (m *ProviderMock) CloneStorageFinished() bool

CloneStorageFinished returns true if mock invocations count is ok

func (*ProviderMock) CloneStorageMinimockCounter 

func (m *ProviderMock) CloneStorageMinimockCounter() uint64

CloneStorageMinimockCounter returns a count of ProviderMock.CloneStorageFunc invocations

func (*ProviderMock) CloneStorageMinimockPreCounter 

func (m *ProviderMock) CloneStorageMinimockPreCounter() uint64

CloneStorageMinimockPreCounter returns the value of ProviderMock.CloneStorage invocations

func (*ProviderMock) Finish 

func (m *ProviderMock) Finish()

Finish checks that all mocked methods of the interface have been called at least once Deprecated: please use MinimockFinish or use Finish method of minimock.Controller

func (*ProviderMock) GetStorage 

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

GetStorage implements github.com/insolar/insolar/ledger/recentstorage.Provider interface

func (*ProviderMock) GetStorageFinished 

func (m *ProviderMock) GetStorageFinished() bool

GetStorageFinished returns true if mock invocations count is ok

func (*ProviderMock) GetStorageMinimockCounter 

func (m *ProviderMock) GetStorageMinimockCounter() uint64

GetStorageMinimockCounter returns a count of ProviderMock.GetStorageFunc invocations

func (*ProviderMock) GetStorageMinimockPreCounter 

func (m *ProviderMock) GetStorageMinimockPreCounter() uint64

GetStorageMinimockPreCounter returns the value of ProviderMock.GetStorage invocations

func (*ProviderMock) MinimockFinish 

func (m *ProviderMock) MinimockFinish()

MinimockFinish checks that all mocked methods of the interface have been called at least once

func (*ProviderMock) MinimockWait 

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

MinimockWait waits for all mocked methods to be called at least once this method is called by minimock.Controller

func (*ProviderMock) RemoveStorage 

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

RemoveStorage implements github.com/insolar/insolar/ledger/recentstorage.Provider interface

func (*ProviderMock) RemoveStorageFinished 

func (m *ProviderMock) RemoveStorageFinished() bool

RemoveStorageFinished returns true if mock invocations count is ok

func (*ProviderMock) RemoveStorageMinimockCounter 

func (m *ProviderMock) RemoveStorageMinimockCounter() uint64

RemoveStorageMinimockCounter returns a count of ProviderMock.RemoveStorageFunc invocations

func (*ProviderMock) RemoveStorageMinimockPreCounter 

func (m *ProviderMock) RemoveStorageMinimockPreCounter() uint64

RemoveStorageMinimockPreCounter returns the value of ProviderMock.RemoveStorage invocations

func (*ProviderMock) ValidateCallCounters 

func (m *ProviderMock) ValidateCallCounters()

ValidateCallCounters checks that all mocked methods of the interface have been called at least once Deprecated: please use MinimockFinish method or use Finish method of minimock.Controller

func (*ProviderMock) Wait 

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

Wait waits for all mocked methods to be called at least once Deprecated: please use MinimockWait or use Wait method of minimock.Controller

type ProviderMockCloneStorageExpectation 

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

type ProviderMockCloneStorageInput 

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

type ProviderMockGetStorageExpectation 

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

func (*ProviderMockGetStorageExpectation) Return 

func (e *ProviderMockGetStorageExpectation) Return(r RecentStorage)

type ProviderMockGetStorageInput 

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

type ProviderMockGetStorageResult 

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

type ProviderMockRemoveStorageExpectation 

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

type ProviderMockRemoveStorageInput 

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

type RecentStorage 

type RecentStorage interface {
	AddObject(ctx context.Context, id core.RecordID)
	AddObjectWithTLL(ctx context.Context, id core.RecordID, ttl int)

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

	GetObjects() map[core.RecordID]int
	GetRequests() map[core.RecordID]map[core.RecordID]struct{}
	GetRequestsForObject(obj core.RecordID) []core.RecordID

	IsRecordIDCached(obj core.RecordID) bool

	DecreaseTTL(ctx context.Context)
}

RecentStorage is a base interface for the storage of recent objects and indexes

type RecentStorageMock 

type RecentStorageMock struct {
	AddObjectFunc       func(p context.Context, p1 core.RecordID)
	AddObjectCounter    uint64
	AddObjectPreCounter uint64
	AddObjectMock       mRecentStorageMockAddObject

	AddObjectWithTLLFunc       func(p context.Context, p1 core.RecordID, p2 int)
	AddObjectWithTLLCounter    uint64
	AddObjectWithTLLPreCounter uint64
	AddObjectWithTLLMock       mRecentStorageMockAddObjectWithTLL

	AddPendingRequestFunc       func(p context.Context, p1 core.RecordID, p2 core.RecordID)
	AddPendingRequestCounter    uint64
	AddPendingRequestPreCounter uint64
	AddPendingRequestMock       mRecentStorageMockAddPendingRequest

	DecreaseTTLFunc       func(p context.Context)
	DecreaseTTLCounter    uint64
	DecreaseTTLPreCounter uint64
	DecreaseTTLMock       mRecentStorageMockDecreaseTTL

	GetObjectsFunc       func() (r map[core.RecordID]int)
	GetObjectsCounter    uint64
	GetObjectsPreCounter uint64
	GetObjectsMock       mRecentStorageMockGetObjects

	GetRequestsFunc func() (r map[core.RecordID]map[core.RecordID]struct {
	})
	GetRequestsCounter    uint64
	GetRequestsPreCounter uint64
	GetRequestsMock       mRecentStorageMockGetRequests

	GetRequestsForObjectFunc       func(p core.RecordID) (r []core.RecordID)
	GetRequestsForObjectCounter    uint64
	GetRequestsForObjectPreCounter uint64
	GetRequestsForObjectMock       mRecentStorageMockGetRequestsForObject

	IsRecordIDCachedFunc       func(p core.RecordID) (r bool)
	IsRecordIDCachedCounter    uint64
	IsRecordIDCachedPreCounter uint64
	IsRecordIDCachedMock       mRecentStorageMockIsRecordIDCached

	RemovePendingRequestFunc       func(p context.Context, p1 core.RecordID, p2 core.RecordID)
	RemovePendingRequestCounter    uint64
	RemovePendingRequestPreCounter uint64
	RemovePendingRequestMock       mRecentStorageMockRemovePendingRequest
	// contains filtered or unexported fields
}

RecentStorageMock implements github.com/insolar/insolar/ledger/recentstorage.RecentStorage

func NewRecentStorageMock 

func NewRecentStorageMock(t minimock.Tester) *RecentStorageMock

NewRecentStorageMock returns a mock for github.com/insolar/insolar/ledger/recentstorage.RecentStorage

func (*RecentStorageMock) AddObject 

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

AddObject implements github.com/insolar/insolar/ledger/recentstorage.RecentStorage interface

func (*RecentStorageMock) AddObjectFinished 

func (m *RecentStorageMock) AddObjectFinished() bool

AddObjectFinished returns true if mock invocations count is ok

func (*RecentStorageMock) AddObjectMinimockCounter 

func (m *RecentStorageMock) AddObjectMinimockCounter() uint64

AddObjectMinimockCounter returns a count of RecentStorageMock.AddObjectFunc invocations

func (*RecentStorageMock) AddObjectMinimockPreCounter 

func (m *RecentStorageMock) AddObjectMinimockPreCounter() uint64

AddObjectMinimockPreCounter returns the value of RecentStorageMock.AddObject invocations

func (*RecentStorageMock) AddObjectWithTLL 

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

AddObjectWithTLL implements github.com/insolar/insolar/ledger/recentstorage.RecentStorage interface

func (*RecentStorageMock) AddObjectWithTLLFinished 

func (m *RecentStorageMock) AddObjectWithTLLFinished() bool

AddObjectWithTLLFinished returns true if mock invocations count is ok

func (*RecentStorageMock) AddObjectWithTLLMinimockCounter 

func (m *RecentStorageMock) AddObjectWithTLLMinimockCounter() uint64

AddObjectWithTLLMinimockCounter returns a count of RecentStorageMock.AddObjectWithTLLFunc invocations

func (*RecentStorageMock) AddObjectWithTLLMinimockPreCounter 

func (m *RecentStorageMock) AddObjectWithTLLMinimockPreCounter() uint64

AddObjectWithTLLMinimockPreCounter returns the value of RecentStorageMock.AddObjectWithTLL invocations

func (*RecentStorageMock) AddPendingRequest 

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

AddPendingRequest implements github.com/insolar/insolar/ledger/recentstorage.RecentStorage interface

func (*RecentStorageMock) AddPendingRequestFinished 

func (m *RecentStorageMock) AddPendingRequestFinished() bool

AddPendingRequestFinished returns true if mock invocations count is ok

func (*RecentStorageMock) AddPendingRequestMinimockCounter 

func (m *RecentStorageMock) AddPendingRequestMinimockCounter() uint64

AddPendingRequestMinimockCounter returns a count of RecentStorageMock.AddPendingRequestFunc invocations

func (*RecentStorageMock) AddPendingRequestMinimockPreCounter 

func (m *RecentStorageMock) AddPendingRequestMinimockPreCounter() uint64

AddPendingRequestMinimockPreCounter returns the value of RecentStorageMock.AddPendingRequest invocations

func (*RecentStorageMock) AllMocksCalled 

func (m *RecentStorageMock) AllMocksCalled() bool

AllMocksCalled returns true if all mocked methods were called before the execution of AllMocksCalled, it can be used with assert/require, i.e. assert.True(mock.AllMocksCalled())

func (*RecentStorageMock) CheckMocksCalled 

func (m *RecentStorageMock) CheckMocksCalled()

CheckMocksCalled checks that all mocked methods of the interface have been called at least once Deprecated: please use MinimockFinish method or use Finish method of minimock.Controller

func (*RecentStorageMock) DecreaseTTL 

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

DecreaseTTL implements github.com/insolar/insolar/ledger/recentstorage.RecentStorage interface

func (*RecentStorageMock) DecreaseTTLFinished 

func (m *RecentStorageMock) DecreaseTTLFinished() bool

DecreaseTTLFinished returns true if mock invocations count is ok

func (*RecentStorageMock) DecreaseTTLMinimockCounter 

func (m *RecentStorageMock) DecreaseTTLMinimockCounter() uint64

DecreaseTTLMinimockCounter returns a count of RecentStorageMock.DecreaseTTLFunc invocations

func (*RecentStorageMock) DecreaseTTLMinimockPreCounter 

func (m *RecentStorageMock) DecreaseTTLMinimockPreCounter() uint64

DecreaseTTLMinimockPreCounter returns the value of RecentStorageMock.DecreaseTTL invocations

func (*RecentStorageMock) Finish 

func (m *RecentStorageMock) Finish()

Finish checks that all mocked methods of the interface have been called at least once Deprecated: please use MinimockFinish or use Finish method of minimock.Controller

func (*RecentStorageMock) GetObjects 

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

GetObjects implements github.com/insolar/insolar/ledger/recentstorage.RecentStorage interface

func (*RecentStorageMock) GetObjectsFinished 

func (m *RecentStorageMock) GetObjectsFinished() bool

GetObjectsFinished returns true if mock invocations count is ok

func (*RecentStorageMock) GetObjectsMinimockCounter 

func (m *RecentStorageMock) GetObjectsMinimockCounter() uint64

GetObjectsMinimockCounter returns a count of RecentStorageMock.GetObjectsFunc invocations

func (*RecentStorageMock) GetObjectsMinimockPreCounter 

func (m *RecentStorageMock) GetObjectsMinimockPreCounter() uint64

GetObjectsMinimockPreCounter returns the value of RecentStorageMock.GetObjects invocations

func (*RecentStorageMock) GetRequests 

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

GetRequests implements github.com/insolar/insolar/ledger/recentstorage.RecentStorage interface

func (*RecentStorageMock) GetRequestsFinished 

func (m *RecentStorageMock) GetRequestsFinished() bool

GetRequestsFinished returns true if mock invocations count is ok

func (*RecentStorageMock) GetRequestsForObject 

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

GetRequestsForObject implements github.com/insolar/insolar/ledger/recentstorage.RecentStorage interface

func (*RecentStorageMock) GetRequestsForObjectFinished 

func (m *RecentStorageMock) GetRequestsForObjectFinished() bool

GetRequestsForObjectFinished returns true if mock invocations count is ok

func (*RecentStorageMock) GetRequestsForObjectMinimockCounter 

func (m *RecentStorageMock) GetRequestsForObjectMinimockCounter() uint64

GetRequestsForObjectMinimockCounter returns a count of RecentStorageMock.GetRequestsForObjectFunc invocations

func (*RecentStorageMock) GetRequestsForObjectMinimockPreCounter 

func (m *RecentStorageMock) GetRequestsForObjectMinimockPreCounter() uint64

GetRequestsForObjectMinimockPreCounter returns the value of RecentStorageMock.GetRequestsForObject invocations

func (*RecentStorageMock) GetRequestsMinimockCounter 

func (m *RecentStorageMock) GetRequestsMinimockCounter() uint64

GetRequestsMinimockCounter returns a count of RecentStorageMock.GetRequestsFunc invocations

func (*RecentStorageMock) GetRequestsMinimockPreCounter 

func (m *RecentStorageMock) GetRequestsMinimockPreCounter() uint64

GetRequestsMinimockPreCounter returns the value of RecentStorageMock.GetRequests invocations

func (*RecentStorageMock) IsRecordIDCached 

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

IsRecordIDCached implements github.com/insolar/insolar/ledger/recentstorage.RecentStorage interface

func (*RecentStorageMock) IsRecordIDCachedFinished 

func (m *RecentStorageMock) IsRecordIDCachedFinished() bool

IsRecordIDCachedFinished returns true if mock invocations count is ok

func (*RecentStorageMock) IsRecordIDCachedMinimockCounter 

func (m *RecentStorageMock) IsRecordIDCachedMinimockCounter() uint64

IsRecordIDCachedMinimockCounter returns a count of RecentStorageMock.IsRecordIDCachedFunc invocations

func (*RecentStorageMock) IsRecordIDCachedMinimockPreCounter 

func (m *RecentStorageMock) IsRecordIDCachedMinimockPreCounter() uint64

IsRecordIDCachedMinimockPreCounter returns the value of RecentStorageMock.IsRecordIDCached invocations

func (*RecentStorageMock) MinimockFinish 

func (m *RecentStorageMock) MinimockFinish()

MinimockFinish checks that all mocked methods of the interface have been called at least once

func (*RecentStorageMock) MinimockWait 

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

MinimockWait waits for all mocked methods to be called at least once this method is called by minimock.Controller

func (*RecentStorageMock) RemovePendingRequest 

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

RemovePendingRequest implements github.com/insolar/insolar/ledger/recentstorage.RecentStorage interface

func (*RecentStorageMock) RemovePendingRequestFinished 

func (m *RecentStorageMock) RemovePendingRequestFinished() bool

RemovePendingRequestFinished returns true if mock invocations count is ok

func (*RecentStorageMock) RemovePendingRequestMinimockCounter 

func (m *RecentStorageMock) RemovePendingRequestMinimockCounter() uint64

RemovePendingRequestMinimockCounter returns a count of RecentStorageMock.RemovePendingRequestFunc invocations

func (*RecentStorageMock) RemovePendingRequestMinimockPreCounter 

func (m *RecentStorageMock) RemovePendingRequestMinimockPreCounter() uint64

RemovePendingRequestMinimockPreCounter returns the value of RecentStorageMock.RemovePendingRequest invocations

func (*RecentStorageMock) ValidateCallCounters 

func (m *RecentStorageMock) ValidateCallCounters()

ValidateCallCounters checks that all mocked methods of the interface have been called at least once Deprecated: please use MinimockFinish method or use Finish method of minimock.Controller

func (*RecentStorageMock) Wait 

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

Wait waits for all mocked methods to be called at least once Deprecated: please use MinimockWait or use Wait method of minimock.Controller

type RecentStorageMockAddObjectExpectation 

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

type RecentStorageMockAddObjectInput 

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

type RecentStorageMockAddObjectWithTLLExpectation 

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

type RecentStorageMockAddObjectWithTLLInput 

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

type RecentStorageMockAddPendingRequestExpectation 

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

type RecentStorageMockAddPendingRequestInput 

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

type RecentStorageMockDecreaseTTLExpectation 

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

type RecentStorageMockDecreaseTTLInput 

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

type RecentStorageMockGetObjectsExpectation 

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

func (*RecentStorageMockGetObjectsExpectation) Return 

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

type RecentStorageMockGetObjectsResult 

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

type RecentStorageMockGetRequestsExpectation 

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

func (*RecentStorageMockGetRequestsExpectation) Return 

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

type RecentStorageMockGetRequestsForObjectExpectation 

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

func (*RecentStorageMockGetRequestsForObjectExpectation) Return 

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

type RecentStorageMockGetRequestsForObjectInput 

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

type RecentStorageMockGetRequestsForObjectResult 

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

type RecentStorageMockGetRequestsResult 

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

type RecentStorageMockIsRecordIDCachedExpectation 

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

func (*RecentStorageMockIsRecordIDCachedExpectation) Return 

func (e *RecentStorageMockIsRecordIDCachedExpectation) Return(r bool)

type RecentStorageMockIsRecordIDCachedInput 

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

type RecentStorageMockIsRecordIDCachedResult 

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

type RecentStorageMockRemovePendingRequestExpectation 

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

type RecentStorageMockRemovePendingRequestInput 

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

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.