recentstorage

package
v0.7.3-alpha Latest Latest
Warning

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

Go to latest
Published: Jan 24, 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

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

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

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

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
}

Jump to

Keyboard shortcuts

? : This menu
/ : Search site
f or F : Jump to
y or Y : Canonical URL