storage

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

+ var ErrBadPulse = errors.New("pulse should be bigger than latest")

+ var ErrPrevPulse = errors.New("previous pulse not found")

type Cleaner

+ func NewCleaner() Cleaner

+ CleanJetIndexes func(ctx context.Context, jetID core.RecordID, ...) (RmStat, error)

+ CleanJetRecordsUntilPulse func(ctx context.Context, jetID core.RecordID, pn core.PulseNumber) (map[string]RmStat, error)

type CleanerMock

+ CleanJetIndexesCounter uint64

+ CleanJetIndexesFunc func(p context.Context, p1 core.RecordID, p2 recentstorage.RecentIndexStorage, ...) (r RmStat, r1 error)

+ CleanJetIndexesMock mCleanerMockCleanJetIndexes

+ CleanJetIndexesPreCounter uint64

+ CleanJetRecordsUntilPulseCounter uint64

+ CleanJetRecordsUntilPulseFunc func(p context.Context, p1 core.RecordID, p2 core.PulseNumber) (r map[string]RmStat, r1 error)

+ CleanJetRecordsUntilPulseMock mCleanerMockCleanJetRecordsUntilPulse

+ CleanJetRecordsUntilPulsePreCounter uint64

+ func (m *CleanerMock) CleanJetIndexes(p context.Context, p1 core.RecordID, p2 recentstorage.RecentIndexStorage, ...) (r RmStat, r1 error)

+ func (m *CleanerMock) CleanJetIndexesFinished() bool

+ func (m *CleanerMock) CleanJetIndexesMinimockCounter() uint64

+ func (m *CleanerMock) CleanJetIndexesMinimockPreCounter() uint64

+ func (m *CleanerMock) CleanJetRecordsUntilPulse(p context.Context, p1 core.RecordID, p2 core.PulseNumber) (r map[string]RmStat, r1 error)

+ func (m *CleanerMock) CleanJetRecordsUntilPulseFinished() bool

+ func (m *CleanerMock) CleanJetRecordsUntilPulseMinimockCounter() uint64

+ func (m *CleanerMock) CleanJetRecordsUntilPulseMinimockPreCounter() uint64

+ type CleanerMockCleanJetIndexesExpectation struct

+ func (e *CleanerMockCleanJetIndexesExpectation) Return(r RmStat, r1 error)

+ type CleanerMockCleanJetIndexesInput struct

+ type CleanerMockCleanJetIndexesResult struct

+ type CleanerMockCleanJetRecordsUntilPulseExpectation struct

+ func (e *CleanerMockCleanJetRecordsUntilPulseExpectation) Return(r map[string]RmStat, r1 error)

+ type CleanerMockCleanJetRecordsUntilPulseInput struct

+ type CleanerMockCleanJetRecordsUntilPulseResult struct

type DB

+ func (db *DB) GetPlatformCryptographyScheme() core.PlatformCryptographyScheme

type DBContext

+ GetPlatformCryptographyScheme func() core.PlatformCryptographyScheme

+ IterateLocalData func(ctx context.Context, pulse core.PulseNumber, prefix []byte, ...) error

+ IterateRecordsOnPulse func(ctx context.Context, jetID core.RecordID, pulse core.PulseNumber, ...) error

type DBContextMock

+ GetPlatformCryptographySchemeCounter uint64

+ GetPlatformCryptographySchemeFunc func() (r core.PlatformCryptographyScheme)

+ GetPlatformCryptographySchemeMock mDBContextMockGetPlatformCryptographyScheme

+ GetPlatformCryptographySchemePreCounter uint64

+ IterateLocalDataCounter uint64

+ IterateLocalDataFunc func(p context.Context, p1 core.PulseNumber, p2 []byte, ...) (r error)

+ IterateLocalDataMock mDBContextMockIterateLocalData

+ IterateLocalDataPreCounter uint64

+ IterateRecordsOnPulseCounter uint64

+ IterateRecordsOnPulseFunc func(p context.Context, p1 core.RecordID, p2 core.PulseNumber, ...) (r error)

+ IterateRecordsOnPulseMock mDBContextMockIterateRecordsOnPulse

+ IterateRecordsOnPulsePreCounter uint64

+ func (m *DBContextMock) GetPlatformCryptographyScheme() (r core.PlatformCryptographyScheme)

+ func (m *DBContextMock) GetPlatformCryptographySchemeFinished() bool

+ func (m *DBContextMock) GetPlatformCryptographySchemeMinimockCounter() uint64

+ func (m *DBContextMock) GetPlatformCryptographySchemeMinimockPreCounter() uint64

+ func (m *DBContextMock) IterateLocalData(p context.Context, p1 core.PulseNumber, p2 []byte, ...) (r error)

+ func (m *DBContextMock) IterateLocalDataFinished() bool

+ func (m *DBContextMock) IterateLocalDataMinimockCounter() uint64

+ func (m *DBContextMock) IterateLocalDataMinimockPreCounter() uint64

+ func (m *DBContextMock) IterateRecordsOnPulse(p context.Context, p1 core.RecordID, p2 core.PulseNumber, ...) (r error)

+ func (m *DBContextMock) IterateRecordsOnPulseFinished() bool

+ func (m *DBContextMock) IterateRecordsOnPulseMinimockCounter() uint64

+ func (m *DBContextMock) IterateRecordsOnPulseMinimockPreCounter() uint64

+ type DBContextMockGetPlatformCryptographySchemeExpectation struct

+ func (e *DBContextMockGetPlatformCryptographySchemeExpectation) Return(r core.PlatformCryptographyScheme)

+ type DBContextMockGetPlatformCryptographySchemeResult struct

+ type DBContextMockIterateLocalDataExpectation struct

+ func (e *DBContextMockIterateLocalDataExpectation) Return(r error)

+ type DBContextMockIterateLocalDataInput struct

+ type DBContextMockIterateLocalDataResult struct

+ type DBContextMockIterateRecordsOnPulseExpectation struct

+ func (e *DBContextMockIterateRecordsOnPulseExpectation) Return(r error)

+ type DBContextMockIterateRecordsOnPulseInput struct

+ type DBContextMockIterateRecordsOnPulseResult struct

+ type DBContextMockgetExpectation struct

+ func (e *DBContextMockgetExpectation) Return(r []byte, r1 error)

+ type DBContextMockgetInput struct

+ type DBContextMockgetResult struct

+ type DBContextMockiterateExpectation struct

+ func (e *DBContextMockiterateExpectation) Return(r error)

+ type DBContextMockiterateInput struct

+ type DBContextMockiterateResult struct

+ type DBContextMocksetExpectation struct

+ func (e *DBContextMocksetExpectation) Return(r error)

+ type DBContextMocksetInput struct

+ type DBContextMocksetResult struct

+ type DBContextMockwaitingFlightExpectation struct

+ type DropStorage interface

+ AddDropSize func(ctx context.Context, dropSize *jet.DropSize) error

+ CreateDrop func(ctx context.Context, jetID core.RecordID, pulse core.PulseNumber, ...) (*jet.JetDrop, [][]byte, uint64, error)

+ GetDrop func(ctx context.Context, jetID core.RecordID, pulse core.PulseNumber) (*jet.JetDrop, error)

+ GetDropSizeHistory func(ctx context.Context, jetID core.RecordID) (jet.DropSizeHistory, error)

+ GetJetSizesHistoryDepth func() int

+ SetDrop func(ctx context.Context, jetID core.RecordID, drop *jet.JetDrop) error

+ SetDropSizeHistory func(ctx context.Context, jetID core.RecordID, dropSizeHistory jet.DropSizeHistory) error

+ func NewDropStorage(jetSizesHistoryDepth int) DropStorage

+ type DropStorageMock struct

+ AddDropSizeCounter uint64

+ AddDropSizeFunc func(p context.Context, p1 *jet.DropSize) (r error)

+ AddDropSizeMock mDropStorageMockAddDropSize

+ AddDropSizePreCounter uint64

+ CreateDropCounter uint64

+ CreateDropFunc func(p context.Context, p1 core.RecordID, p2 core.PulseNumber, p3 []byte) (r *jet.JetDrop, r1 [][]byte, r2 uint64, r3 error)

+ CreateDropMock mDropStorageMockCreateDrop

+ CreateDropPreCounter uint64

+ GetDropCounter uint64

+ GetDropFunc func(p context.Context, p1 core.RecordID, p2 core.PulseNumber) (r *jet.JetDrop, r1 error)

+ GetDropMock mDropStorageMockGetDrop

+ GetDropPreCounter uint64

+ GetDropSizeHistoryCounter uint64

+ GetDropSizeHistoryFunc func(p context.Context, p1 core.RecordID) (r jet.DropSizeHistory, r1 error)

+ GetDropSizeHistoryMock mDropStorageMockGetDropSizeHistory

+ GetDropSizeHistoryPreCounter uint64

+ GetJetSizesHistoryDepthCounter uint64

+ GetJetSizesHistoryDepthFunc func() (r int)

+ GetJetSizesHistoryDepthMock mDropStorageMockGetJetSizesHistoryDepth

+ GetJetSizesHistoryDepthPreCounter uint64

+ SetDropCounter uint64

+ SetDropFunc func(p context.Context, p1 core.RecordID, p2 *jet.JetDrop) (r error)

+ SetDropMock mDropStorageMockSetDrop

+ SetDropPreCounter uint64

+ SetDropSizeHistoryCounter uint64

+ SetDropSizeHistoryFunc func(p context.Context, p1 core.RecordID, p2 jet.DropSizeHistory) (r error)

+ SetDropSizeHistoryMock mDropStorageMockSetDropSizeHistory

+ SetDropSizeHistoryPreCounter uint64

+ func NewDropStorageMock(t minimock.Tester) *DropStorageMock

+ func (m *DropStorageMock) AddDropSize(p context.Context, p1 *jet.DropSize) (r error)

+ func (m *DropStorageMock) AddDropSizeFinished() bool

+ func (m *DropStorageMock) AddDropSizeMinimockCounter() uint64

+ func (m *DropStorageMock) AddDropSizeMinimockPreCounter() uint64

+ func (m *DropStorageMock) AllMocksCalled() bool

+ func (m *DropStorageMock) CheckMocksCalled()

+ func (m *DropStorageMock) CreateDrop(p context.Context, p1 core.RecordID, p2 core.PulseNumber, p3 []byte) (r *jet.JetDrop, r1 [][]byte, r2 uint64, r3 error)

+ func (m *DropStorageMock) CreateDropFinished() bool

+ func (m *DropStorageMock) CreateDropMinimockCounter() uint64

+ func (m *DropStorageMock) CreateDropMinimockPreCounter() uint64

+ func (m *DropStorageMock) Finish()

+ func (m *DropStorageMock) GetDrop(p context.Context, p1 core.RecordID, p2 core.PulseNumber) (r *jet.JetDrop, r1 error)

+ func (m *DropStorageMock) GetDropFinished() bool

+ func (m *DropStorageMock) GetDropMinimockCounter() uint64

+ func (m *DropStorageMock) GetDropMinimockPreCounter() uint64

+ func (m *DropStorageMock) GetDropSizeHistory(p context.Context, p1 core.RecordID) (r jet.DropSizeHistory, r1 error)

+ func (m *DropStorageMock) GetDropSizeHistoryFinished() bool

+ func (m *DropStorageMock) GetDropSizeHistoryMinimockCounter() uint64

+ func (m *DropStorageMock) GetDropSizeHistoryMinimockPreCounter() uint64

+ func (m *DropStorageMock) GetJetSizesHistoryDepth() (r int)

+ func (m *DropStorageMock) GetJetSizesHistoryDepthFinished() bool

+ func (m *DropStorageMock) GetJetSizesHistoryDepthMinimockCounter() uint64

+ func (m *DropStorageMock) GetJetSizesHistoryDepthMinimockPreCounter() uint64

+ func (m *DropStorageMock) MinimockFinish()

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

+ func (m *DropStorageMock) SetDrop(p context.Context, p1 core.RecordID, p2 *jet.JetDrop) (r error)

+ func (m *DropStorageMock) SetDropFinished() bool

+ func (m *DropStorageMock) SetDropMinimockCounter() uint64

+ func (m *DropStorageMock) SetDropMinimockPreCounter() uint64

+ func (m *DropStorageMock) SetDropSizeHistory(p context.Context, p1 core.RecordID, p2 jet.DropSizeHistory) (r error)

+ func (m *DropStorageMock) SetDropSizeHistoryFinished() bool

+ func (m *DropStorageMock) SetDropSizeHistoryMinimockCounter() uint64

+ func (m *DropStorageMock) SetDropSizeHistoryMinimockPreCounter() uint64

+ func (m *DropStorageMock) ValidateCallCounters()

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

+ type DropStorageMockAddDropSizeExpectation struct

+ func (e *DropStorageMockAddDropSizeExpectation) Return(r error)

+ type DropStorageMockAddDropSizeInput struct

+ type DropStorageMockAddDropSizeResult struct

+ type DropStorageMockCreateDropExpectation struct

+ func (e *DropStorageMockCreateDropExpectation) Return(r *jet.JetDrop, r1 [][]byte, r2 uint64, r3 error)

+ type DropStorageMockCreateDropInput struct

+ type DropStorageMockCreateDropResult struct

+ type DropStorageMockGetDropExpectation struct

+ func (e *DropStorageMockGetDropExpectation) Return(r *jet.JetDrop, r1 error)

+ type DropStorageMockGetDropInput struct

+ type DropStorageMockGetDropResult struct

+ type DropStorageMockGetDropSizeHistoryExpectation struct

+ func (e *DropStorageMockGetDropSizeHistoryExpectation) Return(r jet.DropSizeHistory, r1 error)

+ type DropStorageMockGetDropSizeHistoryInput struct

+ type DropStorageMockGetDropSizeHistoryResult struct

+ type DropStorageMockGetJetSizesHistoryDepthExpectation struct

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

+ type DropStorageMockGetJetSizesHistoryDepthResult struct

+ type DropStorageMockSetDropExpectation struct

+ func (e *DropStorageMockSetDropExpectation) Return(r error)

+ type DropStorageMockSetDropInput struct

+ type DropStorageMockSetDropResult struct

+ type DropStorageMockSetDropSizeHistoryExpectation struct

+ func (e *DropStorageMockSetDropSizeHistoryExpectation) Return(r error)

+ type DropStorageMockSetDropSizeHistoryInput struct

+ type DropStorageMockSetDropSizeHistoryResult struct

+ type GenesisState interface

+ GenesisRef func() *core.RecordRef

+ func NewGenesisInitializer() GenesisState

type JetStorage

+ func NewJetStorage() JetStorage

+ DeleteJetTree func(ctx context.Context, pulse core.PulseNumber)

+ FindJet func(ctx context.Context, pulse core.PulseNumber, id core.RecordID) (*core.RecordID, bool)

type JetStorageMock

+ DeleteJetTreeCounter uint64

+ DeleteJetTreeFunc func(p context.Context, p1 core.PulseNumber)

+ DeleteJetTreeMock mJetStorageMockDeleteJetTree

+ DeleteJetTreePreCounter uint64

+ FindJetCounter uint64

+ FindJetFunc func(p context.Context, p1 core.PulseNumber, p2 core.RecordID) (r *core.RecordID, r1 bool)

+ FindJetMock mJetStorageMockFindJet

+ FindJetPreCounter uint64

+ func (m *JetStorageMock) DeleteJetTree(p context.Context, p1 core.PulseNumber)

+ func (m *JetStorageMock) DeleteJetTreeFinished() bool

+ func (m *JetStorageMock) DeleteJetTreeMinimockCounter() uint64

+ func (m *JetStorageMock) DeleteJetTreeMinimockPreCounter() uint64

+ func (m *JetStorageMock) FindJet(p context.Context, p1 core.PulseNumber, p2 core.RecordID) (r *core.RecordID, r1 bool)

+ func (m *JetStorageMock) FindJetFinished() bool

+ func (m *JetStorageMock) FindJetMinimockCounter() uint64

+ func (m *JetStorageMock) FindJetMinimockPreCounter() uint64

+ type JetStorageMockDeleteJetTreeExpectation struct

+ type JetStorageMockDeleteJetTreeInput struct

+ type JetStorageMockFindJetExpectation struct

+ func (e *JetStorageMockFindJetExpectation) Return(r *core.RecordID, r1 bool)

+ type JetStorageMockFindJetInput struct

+ type JetStorageMockFindJetResult struct

type Node

+ func (Node) GetState() core.NodeState

+ func (Node) IsWorking() bool

+ func (Node) Leaving() bool

+ func (Node) LeavingETA() core.PulseNumber

+ func (n Node) Address() string

+ func (n Node) ConsensusAddress() string

+ type NodeStorage interface

+ GetActiveNodes func(pulse core.PulseNumber) ([]core.Node, error)

+ GetActiveNodesByRole func(pulse core.PulseNumber, role core.StaticRole) ([]core.Node, error)

+ RemoveActiveNodesUntil func(pulse core.PulseNumber)

+ SetActiveNodes func(pulse core.PulseNumber, nodes []core.Node) error

+ func NewNodeStorage() NodeStorage

+ type NodeStorageMock struct

+ GetActiveNodesByRoleCounter uint64

+ GetActiveNodesByRoleFunc func(p core.PulseNumber, p1 core.StaticRole) (r []core.Node, r1 error)

+ GetActiveNodesByRoleMock mNodeStorageMockGetActiveNodesByRole

+ GetActiveNodesByRolePreCounter uint64

+ GetActiveNodesCounter uint64

+ GetActiveNodesFunc func(p core.PulseNumber) (r []core.Node, r1 error)

+ GetActiveNodesMock mNodeStorageMockGetActiveNodes

+ GetActiveNodesPreCounter uint64

+ RemoveActiveNodesUntilCounter uint64

+ RemoveActiveNodesUntilFunc func(p core.PulseNumber)

+ RemoveActiveNodesUntilMock mNodeStorageMockRemoveActiveNodesUntil

+ RemoveActiveNodesUntilPreCounter uint64

+ SetActiveNodesCounter uint64

+ SetActiveNodesFunc func(p core.PulseNumber, p1 []core.Node) (r error)

+ SetActiveNodesMock mNodeStorageMockSetActiveNodes

+ SetActiveNodesPreCounter uint64

+ func NewNodeStorageMock(t minimock.Tester) *NodeStorageMock

+ func (m *NodeStorageMock) AllMocksCalled() bool

+ func (m *NodeStorageMock) CheckMocksCalled()

+ func (m *NodeStorageMock) Finish()

+ func (m *NodeStorageMock) GetActiveNodes(p core.PulseNumber) (r []core.Node, r1 error)

+ func (m *NodeStorageMock) GetActiveNodesByRole(p core.PulseNumber, p1 core.StaticRole) (r []core.Node, r1 error)

+ func (m *NodeStorageMock) GetActiveNodesByRoleFinished() bool

+ func (m *NodeStorageMock) GetActiveNodesByRoleMinimockCounter() uint64

+ func (m *NodeStorageMock) GetActiveNodesByRoleMinimockPreCounter() uint64

+ func (m *NodeStorageMock) GetActiveNodesFinished() bool

+ func (m *NodeStorageMock) GetActiveNodesMinimockCounter() uint64

+ func (m *NodeStorageMock) GetActiveNodesMinimockPreCounter() uint64

+ func (m *NodeStorageMock) MinimockFinish()

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

+ func (m *NodeStorageMock) RemoveActiveNodesUntil(p core.PulseNumber)

+ func (m *NodeStorageMock) RemoveActiveNodesUntilFinished() bool

+ func (m *NodeStorageMock) RemoveActiveNodesUntilMinimockCounter() uint64

+ func (m *NodeStorageMock) RemoveActiveNodesUntilMinimockPreCounter() uint64

+ func (m *NodeStorageMock) SetActiveNodes(p core.PulseNumber, p1 []core.Node) (r error)

+ func (m *NodeStorageMock) SetActiveNodesFinished() bool

+ func (m *NodeStorageMock) SetActiveNodesMinimockCounter() uint64

+ func (m *NodeStorageMock) SetActiveNodesMinimockPreCounter() uint64

+ func (m *NodeStorageMock) ValidateCallCounters()

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

+ type NodeStorageMockGetActiveNodesByRoleExpectation struct

+ func (e *NodeStorageMockGetActiveNodesByRoleExpectation) Return(r []core.Node, r1 error)

+ type NodeStorageMockGetActiveNodesByRoleInput struct

+ type NodeStorageMockGetActiveNodesByRoleResult struct

+ type NodeStorageMockGetActiveNodesExpectation struct

+ func (e *NodeStorageMockGetActiveNodesExpectation) Return(r []core.Node, r1 error)

+ type NodeStorageMockGetActiveNodesInput struct

+ type NodeStorageMockGetActiveNodesResult struct

+ type NodeStorageMockRemoveActiveNodesUntilExpectation struct

+ type NodeStorageMockRemoveActiveNodesUntilInput struct

+ type NodeStorageMockSetActiveNodesExpectation struct

+ func (e *NodeStorageMockSetActiveNodesExpectation) Return(r error)

+ type NodeStorageMockSetActiveNodesInput struct

+ type NodeStorageMockSetActiveNodesResult struct

type ObjectStorage

+ func NewObjectStorage() ObjectStorage

type PulseTracker

+ func NewPulseTracker() PulseTracker

+ func NewPulseTrackerMemory() PulseTracker

+ DeletePulse func(ctx context.Context, num core.PulseNumber) error

+ GetNthPrevPulse func(ctx context.Context, n uint, from core.PulseNumber) (*Pulse, error)

type PulseTrackerMock

+ DeletePulseCounter uint64

+ DeletePulseFunc func(p context.Context, p1 core.PulseNumber) (r error)

+ DeletePulseMock mPulseTrackerMockDeletePulse

+ DeletePulsePreCounter uint64

+ GetNthPrevPulseCounter uint64

+ GetNthPrevPulseFunc func(p context.Context, p1 uint, p2 core.PulseNumber) (r *Pulse, r1 error)

+ GetNthPrevPulseMock mPulseTrackerMockGetNthPrevPulse

+ GetNthPrevPulsePreCounter uint64

+ func (m *PulseTrackerMock) DeletePulse(p context.Context, p1 core.PulseNumber) (r error)

+ func (m *PulseTrackerMock) DeletePulseFinished() bool

+ func (m *PulseTrackerMock) DeletePulseMinimockCounter() uint64

+ func (m *PulseTrackerMock) DeletePulseMinimockPreCounter() uint64

+ func (m *PulseTrackerMock) GetNthPrevPulse(p context.Context, p1 uint, p2 core.PulseNumber) (r *Pulse, r1 error)

+ func (m *PulseTrackerMock) GetNthPrevPulseFinished() bool

+ func (m *PulseTrackerMock) GetNthPrevPulseMinimockCounter() uint64

+ func (m *PulseTrackerMock) GetNthPrevPulseMinimockPreCounter() uint64

+ type PulseTrackerMockDeletePulseExpectation struct

+ func (e *PulseTrackerMockDeletePulseExpectation) Return(r error)

+ type PulseTrackerMockDeletePulseInput struct

+ type PulseTrackerMockDeletePulseResult struct

+ type PulseTrackerMockGetNthPrevPulseExpectation struct

+ func (e *PulseTrackerMockGetNthPrevPulseExpectation) Return(r *Pulse, r1 error)

+ type PulseTrackerMockGetNthPrevPulseInput struct

+ type PulseTrackerMockGetNthPrevPulseResult struct

type ReplicaStorage

+ func NewReplicaStorage() ReplicaStorage

+ type RmStat struct

+ Errors int64

+ Removed int64

+ Scanned int64

v0.7.6

Jan 29, 2019

v0.7.5

Jan 29, 2019

Changes in this version

+ var ErrClosed = errors.New("db is closed")

+ func NullifyJetInKey(key []byte)

+ type ActiveNodesStorage interface

+ GetActiveNodes func(pulse core.PulseNumber) ([]core.Node, error)

+ GetActiveNodesByRole func(pulse core.PulseNumber, role core.StaticRole) ([]core.Node, error)

+ RemoveActiveNodesUntil func(pulse core.PulseNumber)

+ SetActiveNodes func(pulse core.PulseNumber, nodes []core.Node) error

+ type ActiveNodesStorageMock struct

+ GetActiveNodesByRoleCounter uint64

+ GetActiveNodesByRoleFunc func(p core.PulseNumber, p1 core.StaticRole) (r []core.Node, r1 error)

+ GetActiveNodesByRoleMock mActiveNodesStorageMockGetActiveNodesByRole

+ GetActiveNodesByRolePreCounter uint64

+ GetActiveNodesCounter uint64

+ GetActiveNodesFunc func(p core.PulseNumber) (r []core.Node, r1 error)

+ GetActiveNodesMock mActiveNodesStorageMockGetActiveNodes

+ GetActiveNodesPreCounter uint64

+ RemoveActiveNodesUntilCounter uint64

+ RemoveActiveNodesUntilFunc func(p core.PulseNumber)

+ RemoveActiveNodesUntilMock mActiveNodesStorageMockRemoveActiveNodesUntil

+ RemoveActiveNodesUntilPreCounter uint64

+ SetActiveNodesCounter uint64

+ SetActiveNodesFunc func(p core.PulseNumber, p1 []core.Node) (r error)

+ SetActiveNodesMock mActiveNodesStorageMockSetActiveNodes

+ SetActiveNodesPreCounter uint64

+ func NewActiveNodesStorageMock(t minimock.Tester) *ActiveNodesStorageMock

+ func (m *ActiveNodesStorageMock) AllMocksCalled() bool

+ func (m *ActiveNodesStorageMock) CheckMocksCalled()

+ func (m *ActiveNodesStorageMock) Finish()

+ func (m *ActiveNodesStorageMock) GetActiveNodes(p core.PulseNumber) (r []core.Node, r1 error)

+ func (m *ActiveNodesStorageMock) GetActiveNodesByRole(p core.PulseNumber, p1 core.StaticRole) (r []core.Node, r1 error)

+ func (m *ActiveNodesStorageMock) GetActiveNodesByRoleFinished() bool

+ func (m *ActiveNodesStorageMock) GetActiveNodesByRoleMinimockCounter() uint64

+ func (m *ActiveNodesStorageMock) GetActiveNodesByRoleMinimockPreCounter() uint64

+ func (m *ActiveNodesStorageMock) GetActiveNodesFinished() bool

+ func (m *ActiveNodesStorageMock) GetActiveNodesMinimockCounter() uint64

+ func (m *ActiveNodesStorageMock) GetActiveNodesMinimockPreCounter() uint64

+ func (m *ActiveNodesStorageMock) MinimockFinish()

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

+ func (m *ActiveNodesStorageMock) RemoveActiveNodesUntil(p core.PulseNumber)

+ func (m *ActiveNodesStorageMock) RemoveActiveNodesUntilFinished() bool

+ func (m *ActiveNodesStorageMock) RemoveActiveNodesUntilMinimockCounter() uint64

+ func (m *ActiveNodesStorageMock) RemoveActiveNodesUntilMinimockPreCounter() uint64

+ func (m *ActiveNodesStorageMock) SetActiveNodes(p core.PulseNumber, p1 []core.Node) (r error)

+ func (m *ActiveNodesStorageMock) SetActiveNodesFinished() bool

+ func (m *ActiveNodesStorageMock) SetActiveNodesMinimockCounter() uint64

+ func (m *ActiveNodesStorageMock) SetActiveNodesMinimockPreCounter() uint64

+ func (m *ActiveNodesStorageMock) ValidateCallCounters()

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

+ type ActiveNodesStorageMockGetActiveNodesByRoleExpectation struct

+ func (e *ActiveNodesStorageMockGetActiveNodesByRoleExpectation) Return(r []core.Node, r1 error)

+ type ActiveNodesStorageMockGetActiveNodesByRoleInput struct

+ type ActiveNodesStorageMockGetActiveNodesByRoleResult struct

+ type ActiveNodesStorageMockGetActiveNodesExpectation struct

+ func (e *ActiveNodesStorageMockGetActiveNodesExpectation) Return(r []core.Node, r1 error)

+ type ActiveNodesStorageMockGetActiveNodesInput struct

+ type ActiveNodesStorageMockGetActiveNodesResult struct

+ type ActiveNodesStorageMockRemoveActiveNodesUntilExpectation struct

+ type ActiveNodesStorageMockRemoveActiveNodesUntilInput struct

+ type ActiveNodesStorageMockSetActiveNodesExpectation struct

+ func (e *ActiveNodesStorageMockSetActiveNodesExpectation) Return(r error)

+ type ActiveNodesStorageMockSetActiveNodesInput struct

+ type ActiveNodesStorageMockSetActiveNodesResult struct

+ type Cleaner interface

+ RemoveAllForJetUntilPulse func(ctx context.Context, jetID core.RecordID, pn core.PulseNumber, ...) (map[string]int, error)

+ RemoveJetBlobsUntil func(ctx context.Context, jetID core.RecordID, pn core.PulseNumber) (int, error)

+ RemoveJetDropsUntil func(ctx context.Context, jetID core.RecordID, pn core.PulseNumber) (int, error)

+ RemoveJetIndexesUntil func(ctx context.Context, jetID core.RecordID, pn core.PulseNumber, ...) (int, error)

+ RemoveJetRecordsUntil func(ctx context.Context, jetID core.RecordID, pn core.PulseNumber, ...) (int, error)

+ type CleanerMock struct

+ RemoveAllForJetUntilPulseCounter uint64

+ RemoveAllForJetUntilPulseFunc func(p context.Context, p1 core.RecordID, p2 core.PulseNumber, ...) (r map[string]int, r1 error)

+ RemoveAllForJetUntilPulseMock mCleanerMockRemoveAllForJetUntilPulse

+ RemoveAllForJetUntilPulsePreCounter uint64

+ RemoveJetBlobsUntilCounter uint64

+ RemoveJetBlobsUntilFunc func(p context.Context, p1 core.RecordID, p2 core.PulseNumber) (r int, r1 error)

+ RemoveJetBlobsUntilMock mCleanerMockRemoveJetBlobsUntil

+ RemoveJetBlobsUntilPreCounter uint64

+ RemoveJetDropsUntilCounter uint64

+ RemoveJetDropsUntilFunc func(p context.Context, p1 core.RecordID, p2 core.PulseNumber) (r int, r1 error)

+ RemoveJetDropsUntilMock mCleanerMockRemoveJetDropsUntil

+ RemoveJetDropsUntilPreCounter uint64

+ RemoveJetIndexesUntilCounter uint64

+ RemoveJetIndexesUntilFunc func(p context.Context, p1 core.RecordID, p2 core.PulseNumber, ...) (r int, r1 error)

+ RemoveJetIndexesUntilMock mCleanerMockRemoveJetIndexesUntil

+ RemoveJetIndexesUntilPreCounter uint64

+ RemoveJetRecordsUntilCounter uint64

+ RemoveJetRecordsUntilFunc func(p context.Context, p1 core.RecordID, p2 core.PulseNumber, ...) (r int, r1 error)

+ RemoveJetRecordsUntilMock mCleanerMockRemoveJetRecordsUntil

+ RemoveJetRecordsUntilPreCounter uint64

+ func NewCleanerMock(t minimock.Tester) *CleanerMock

+ func (m *CleanerMock) AllMocksCalled() bool

+ func (m *CleanerMock) CheckMocksCalled()

+ func (m *CleanerMock) Finish()

+ func (m *CleanerMock) MinimockFinish()

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

+ func (m *CleanerMock) RemoveAllForJetUntilPulse(p context.Context, p1 core.RecordID, p2 core.PulseNumber, ...) (r map[string]int, r1 error)

+ func (m *CleanerMock) RemoveAllForJetUntilPulseFinished() bool

+ func (m *CleanerMock) RemoveAllForJetUntilPulseMinimockCounter() uint64

+ func (m *CleanerMock) RemoveAllForJetUntilPulseMinimockPreCounter() uint64

+ func (m *CleanerMock) RemoveJetBlobsUntil(p context.Context, p1 core.RecordID, p2 core.PulseNumber) (r int, r1 error)

+ func (m *CleanerMock) RemoveJetBlobsUntilFinished() bool

+ func (m *CleanerMock) RemoveJetBlobsUntilMinimockCounter() uint64

+ func (m *CleanerMock) RemoveJetBlobsUntilMinimockPreCounter() uint64

+ func (m *CleanerMock) RemoveJetDropsUntil(p context.Context, p1 core.RecordID, p2 core.PulseNumber) (r int, r1 error)

+ func (m *CleanerMock) RemoveJetDropsUntilFinished() bool

+ func (m *CleanerMock) RemoveJetDropsUntilMinimockCounter() uint64

+ func (m *CleanerMock) RemoveJetDropsUntilMinimockPreCounter() uint64

+ func (m *CleanerMock) RemoveJetIndexesUntil(p context.Context, p1 core.RecordID, p2 core.PulseNumber, ...) (r int, r1 error)

+ func (m *CleanerMock) RemoveJetIndexesUntilFinished() bool

+ func (m *CleanerMock) RemoveJetIndexesUntilMinimockCounter() uint64

+ func (m *CleanerMock) RemoveJetIndexesUntilMinimockPreCounter() uint64

+ func (m *CleanerMock) RemoveJetRecordsUntil(p context.Context, p1 core.RecordID, p2 core.PulseNumber, ...) (r int, r1 error)

+ func (m *CleanerMock) RemoveJetRecordsUntilFinished() bool

+ func (m *CleanerMock) RemoveJetRecordsUntilMinimockCounter() uint64

+ func (m *CleanerMock) RemoveJetRecordsUntilMinimockPreCounter() uint64

+ func (m *CleanerMock) ValidateCallCounters()

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

+ type CleanerMockRemoveAllForJetUntilPulseExpectation struct

+ func (e *CleanerMockRemoveAllForJetUntilPulseExpectation) Return(r map[string]int, r1 error)

+ type CleanerMockRemoveAllForJetUntilPulseInput struct

+ type CleanerMockRemoveAllForJetUntilPulseResult struct

+ type CleanerMockRemoveJetBlobsUntilExpectation struct

+ func (e *CleanerMockRemoveJetBlobsUntilExpectation) Return(r int, r1 error)

+ type CleanerMockRemoveJetBlobsUntilInput struct

+ type CleanerMockRemoveJetBlobsUntilResult struct

+ type CleanerMockRemoveJetDropsUntilExpectation struct

+ func (e *CleanerMockRemoveJetDropsUntilExpectation) Return(r int, r1 error)

+ type CleanerMockRemoveJetDropsUntilInput struct

+ type CleanerMockRemoveJetDropsUntilResult struct

+ type CleanerMockRemoveJetIndexesUntilExpectation struct

+ func (e *CleanerMockRemoveJetIndexesUntilExpectation) Return(r int, r1 error)

+ type CleanerMockRemoveJetIndexesUntilInput struct

+ type CleanerMockRemoveJetIndexesUntilResult struct

+ type CleanerMockRemoveJetRecordsUntilExpectation struct

+ func (e *CleanerMockRemoveJetRecordsUntilExpectation) Return(r int, r1 error)

+ type CleanerMockRemoveJetRecordsUntilInput struct

+ type CleanerMockRemoveJetRecordsUntilResult struct

type DB

+ func (db *DB) AddDropSize(ctx context.Context, dropSize *jet.DropSize) error

+ func (db *DB) AddJets(ctx context.Context, jetIDs ...core.RecordID) error

+ func (db *DB) CloneJetTree(ctx context.Context, from, to core.PulseNumber) (*jet.Tree, error)

+ func (db *DB) GetActiveNodesByRole(pulse core.PulseNumber, role core.StaticRole) ([]core.Node, error)

+ func (db *DB) GetAllNonEmptySyncClientJets(ctx context.Context) (map[core.RecordID][]core.PulseNumber, error)

+ func (db *DB) GetAllSyncClientJets(ctx context.Context) (map[core.RecordID][]core.PulseNumber, error)

+ func (db *DB) GetDropSizeHistory(ctx context.Context, jetID core.RecordID) (jet.DropSizeHistory, error)

+ func (db *DB) GetJetSizesHistoryDepth() int

+ func (db *DB) GetJetTree(ctx context.Context, pulse core.PulseNumber) (*jet.Tree, error)

+ func (db *DB) GetJets(ctx context.Context) (jet.IDSet, error)

+ func (db *DB) GetLatestPulse(ctx context.Context) (*Pulse, error)

+ func (db *DB) GetPreviousPulse(ctx context.Context, num core.PulseNumber) (*Pulse, error)

+ func (db *DB) GetSyncClientJetPulses(ctx context.Context, jetID core.RecordID) ([]core.PulseNumber, error)

+ func (db *DB) IterateIndexIDs(ctx context.Context, jetID core.RecordID, handler func(id core.RecordID) error) error

+ func (db *DB) IterateRecordsOnPulse(ctx context.Context, jetID core.RecordID, pulse core.PulseNumber, ...) error

+ func (db *DB) RemoveActiveNodesUntil(pulse core.PulseNumber)

+ func (db *DB) RemoveAllForJetUntilPulse(ctx context.Context, jetID core.RecordID, pn core.PulseNumber, ...) (map[string]int, error)

+ func (db *DB) RemoveJetBlobsUntil(ctx context.Context, jetID core.RecordID, pn core.PulseNumber) (int, error)

+ func (db *DB) RemoveJetDropsUntil(ctx context.Context, jetID core.RecordID, pn core.PulseNumber) (int, error)

+ func (db *DB) RemoveJetIndexesUntil(ctx context.Context, jetID core.RecordID, pn core.PulseNumber, ...) (int, error)

+ func (db *DB) RemoveJetRecordsUntil(ctx context.Context, jetID core.RecordID, pn core.PulseNumber, ...) (int, error)

+ func (db *DB) RemoveObjectIndex(ctx context.Context, jetID core.RecordID, ref *core.RecordID) error

+ func (db *DB) SetDropSizeHistory(ctx context.Context, jetID core.RecordID, dropSizeHistory jet.DropSizeHistory) error

+ func (db *DB) SetSyncClientJetPulses(ctx context.Context, jetID core.RecordID, pns []core.PulseNumber) error

+ func (db *DB) SplitJetTree(ctx context.Context, pulse core.PulseNumber, jetID core.RecordID) (*core.RecordID, *core.RecordID, error)

+ func (db *DB) UpdateJetTree(ctx context.Context, pulse core.PulseNumber, setActual bool, ...) error

+ type DBContext interface

+ BeginTransaction func(update bool) (*TransactionManager, error)

+ Close func() error

+ GenesisRef func() *core.RecordRef

+ GetBadgerDB func() *badger.DB

+ GetJetSizesHistoryDepth func() int

+ GetLocalData func(ctx context.Context, pulse core.PulseNumber, key []byte) ([]byte, error)

+ SetLocalData func(ctx context.Context, pulse core.PulseNumber, key []byte, data []byte) error

+ SetTxRetiries func(n int)

+ StoreKeyValues func(ctx context.Context, kvs []core.KV) error

+ Update func(ctx context.Context, fn func(*TransactionManager) error) error

+ View func(ctx context.Context, fn func(*TransactionManager) error) error

+ type DBContextMock struct

+ BeginTransactionCounter uint64

+ BeginTransactionFunc func(p bool) (r *TransactionManager, r1 error)

+ BeginTransactionMock mDBContextMockBeginTransaction

+ BeginTransactionPreCounter uint64

+ CloseCounter uint64

+ CloseFunc func() (r error)

+ CloseMock mDBContextMockClose

+ ClosePreCounter uint64

+ GenesisRefCounter uint64

+ GenesisRefFunc func() (r *core.RecordRef)

+ GenesisRefMock mDBContextMockGenesisRef

+ GenesisRefPreCounter uint64

+ GetBadgerDBCounter uint64

+ GetBadgerDBFunc func() (r *badger.DB)

+ GetBadgerDBMock mDBContextMockGetBadgerDB

+ GetBadgerDBPreCounter uint64

+ GetJetSizesHistoryDepthCounter uint64

+ GetJetSizesHistoryDepthFunc func() (r int)

+ GetJetSizesHistoryDepthMock mDBContextMockGetJetSizesHistoryDepth

+ GetJetSizesHistoryDepthPreCounter uint64

+ GetLocalDataCounter uint64

+ GetLocalDataFunc func(p context.Context, p1 core.PulseNumber, p2 []byte) (r []byte, r1 error)

+ GetLocalDataMock mDBContextMockGetLocalData

+ GetLocalDataPreCounter uint64

+ SetLocalDataCounter uint64

+ SetLocalDataFunc func(p context.Context, p1 core.PulseNumber, p2 []byte, p3 []byte) (r error)

+ SetLocalDataMock mDBContextMockSetLocalData

+ SetLocalDataPreCounter uint64

+ SetTxRetiriesCounter uint64

+ SetTxRetiriesFunc func(p int)

+ SetTxRetiriesMock mDBContextMockSetTxRetiries

+ SetTxRetiriesPreCounter uint64

+ StoreKeyValuesCounter uint64

+ StoreKeyValuesFunc func(p context.Context, p1 []core.KV) (r error)

+ StoreKeyValuesMock mDBContextMockStoreKeyValues

+ StoreKeyValuesPreCounter uint64

+ UpdateCounter uint64

+ UpdateFunc func(p context.Context, p1 func(p *TransactionManager) (r error)) (r error)

+ UpdateMock mDBContextMockUpdate

+ UpdatePreCounter uint64

+ ViewCounter uint64

+ ViewFunc func(p context.Context, p1 func(p *TransactionManager) (r error)) (r error)

+ ViewMock mDBContextMockView

+ ViewPreCounter uint64

+ func NewDBContextMock(t minimock.Tester) *DBContextMock

+ func (m *DBContextMock) AllMocksCalled() bool

+ func (m *DBContextMock) BeginTransaction(p bool) (r *TransactionManager, r1 error)

+ func (m *DBContextMock) BeginTransactionFinished() bool

+ func (m *DBContextMock) BeginTransactionMinimockCounter() uint64

+ func (m *DBContextMock) BeginTransactionMinimockPreCounter() uint64

+ func (m *DBContextMock) CheckMocksCalled()

+ func (m *DBContextMock) Close() (r error)

+ func (m *DBContextMock) CloseFinished() bool

+ func (m *DBContextMock) CloseMinimockCounter() uint64

+ func (m *DBContextMock) CloseMinimockPreCounter() uint64

+ func (m *DBContextMock) Finish()

+ func (m *DBContextMock) GenesisRef() (r *core.RecordRef)

+ func (m *DBContextMock) GenesisRefFinished() bool

+ func (m *DBContextMock) GenesisRefMinimockCounter() uint64

+ func (m *DBContextMock) GenesisRefMinimockPreCounter() uint64

+ func (m *DBContextMock) GetBadgerDB() (r *badger.DB)

+ func (m *DBContextMock) GetBadgerDBFinished() bool

+ func (m *DBContextMock) GetBadgerDBMinimockCounter() uint64

+ func (m *DBContextMock) GetBadgerDBMinimockPreCounter() uint64

+ func (m *DBContextMock) GetJetSizesHistoryDepth() (r int)

+ func (m *DBContextMock) GetJetSizesHistoryDepthFinished() bool

+ func (m *DBContextMock) GetJetSizesHistoryDepthMinimockCounter() uint64

+ func (m *DBContextMock) GetJetSizesHistoryDepthMinimockPreCounter() uint64

+ func (m *DBContextMock) GetLocalData(p context.Context, p1 core.PulseNumber, p2 []byte) (r []byte, r1 error)

+ func (m *DBContextMock) GetLocalDataFinished() bool

+ func (m *DBContextMock) GetLocalDataMinimockCounter() uint64

+ func (m *DBContextMock) GetLocalDataMinimockPreCounter() uint64

+ func (m *DBContextMock) MinimockFinish()

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

+ func (m *DBContextMock) SetLocalData(p context.Context, p1 core.PulseNumber, p2 []byte, p3 []byte) (r error)

+ func (m *DBContextMock) SetLocalDataFinished() bool

+ func (m *DBContextMock) SetLocalDataMinimockCounter() uint64

+ func (m *DBContextMock) SetLocalDataMinimockPreCounter() uint64

+ func (m *DBContextMock) SetTxRetiries(p int)

+ func (m *DBContextMock) SetTxRetiriesFinished() bool

+ func (m *DBContextMock) SetTxRetiriesMinimockCounter() uint64

+ func (m *DBContextMock) SetTxRetiriesMinimockPreCounter() uint64

+ func (m *DBContextMock) StoreKeyValues(p context.Context, p1 []core.KV) (r error)

+ func (m *DBContextMock) StoreKeyValuesFinished() bool

+ func (m *DBContextMock) StoreKeyValuesMinimockCounter() uint64

+ func (m *DBContextMock) StoreKeyValuesMinimockPreCounter() uint64

+ func (m *DBContextMock) Update(p context.Context, p1 func(p *TransactionManager) (r error)) (r error)

+ func (m *DBContextMock) UpdateFinished() bool

+ func (m *DBContextMock) UpdateMinimockCounter() uint64

+ func (m *DBContextMock) UpdateMinimockPreCounter() uint64

+ func (m *DBContextMock) ValidateCallCounters()

+ func (m *DBContextMock) View(p context.Context, p1 func(p *TransactionManager) (r error)) (r error)

+ func (m *DBContextMock) ViewFinished() bool

+ func (m *DBContextMock) ViewMinimockCounter() uint64

+ func (m *DBContextMock) ViewMinimockPreCounter() uint64

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

+ type DBContextMockBeginTransactionExpectation struct

+ func (e *DBContextMockBeginTransactionExpectation) Return(r *TransactionManager, r1 error)

+ type DBContextMockBeginTransactionInput struct

+ type DBContextMockBeginTransactionResult struct

+ type DBContextMockCloseExpectation struct

+ func (e *DBContextMockCloseExpectation) Return(r error)

+ type DBContextMockCloseResult struct

+ type DBContextMockGenesisRefExpectation struct

+ func (e *DBContextMockGenesisRefExpectation) Return(r *core.RecordRef)

+ type DBContextMockGenesisRefResult struct

+ type DBContextMockGetBadgerDBExpectation struct

+ func (e *DBContextMockGetBadgerDBExpectation) Return(r *badger.DB)

+ type DBContextMockGetBadgerDBResult struct

+ type DBContextMockGetJetSizesHistoryDepthExpectation struct

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

+ type DBContextMockGetJetSizesHistoryDepthResult struct

+ type DBContextMockGetLocalDataExpectation struct

+ func (e *DBContextMockGetLocalDataExpectation) Return(r []byte, r1 error)

+ type DBContextMockGetLocalDataInput struct

+ type DBContextMockGetLocalDataResult struct

+ type DBContextMockSetLocalDataExpectation struct

+ func (e *DBContextMockSetLocalDataExpectation) Return(r error)

+ type DBContextMockSetLocalDataInput struct

+ type DBContextMockSetLocalDataResult struct

+ type DBContextMockSetTxRetiriesExpectation struct

+ type DBContextMockSetTxRetiriesInput struct

+ type DBContextMockStoreKeyValuesExpectation struct

+ func (e *DBContextMockStoreKeyValuesExpectation) Return(r error)

+ type DBContextMockStoreKeyValuesInput struct

+ type DBContextMockStoreKeyValuesResult struct

+ type DBContextMockUpdateExpectation struct

+ func (e *DBContextMockUpdateExpectation) Return(r error)

+ type DBContextMockUpdateInput struct

+ type DBContextMockUpdateResult struct

+ type DBContextMockViewExpectation struct

+ func (e *DBContextMockViewExpectation) Return(r error)

+ type DBContextMockViewInput struct

+ type DBContextMockViewResult struct

+ type JetStorage interface

+ AddDropSize func(ctx context.Context, dropSize *jet.DropSize) error

+ AddJets func(ctx context.Context, jetIDs ...core.RecordID) error

+ CloneJetTree func(ctx context.Context, from, to core.PulseNumber) (*jet.Tree, error)

+ CreateDrop func(ctx context.Context, jetID core.RecordID, pulse core.PulseNumber, ...) (*jet.JetDrop, [][]byte, uint64, error)

+ GetDrop func(ctx context.Context, jetID core.RecordID, pulse core.PulseNumber) (*jet.JetDrop, error)

+ GetDropSizeHistory func(ctx context.Context, jetID core.RecordID) (jet.DropSizeHistory, error)

+ GetJetTree func(ctx context.Context, pulse core.PulseNumber) (*jet.Tree, error)

+ GetJets func(ctx context.Context) (jet.IDSet, error)

+ SetDrop func(ctx context.Context, jetID core.RecordID, drop *jet.JetDrop) error

+ SetDropSizeHistory func(ctx context.Context, jetID core.RecordID, dropSizeHistory jet.DropSizeHistory) error

+ SplitJetTree func(ctx context.Context, pulse core.PulseNumber, jetID core.RecordID) (*core.RecordID, *core.RecordID, error)

+ UpdateJetTree func(ctx context.Context, pulse core.PulseNumber, setActual bool, ...) error

+ type JetStorageMock struct

+ AddDropSizeCounter uint64

+ AddDropSizeFunc func(p context.Context, p1 *jet.DropSize) (r error)

+ AddDropSizeMock mJetStorageMockAddDropSize

+ AddDropSizePreCounter uint64

+ AddJetsCounter uint64

+ AddJetsFunc func(p context.Context, p1 ...core.RecordID) (r error)

+ AddJetsMock mJetStorageMockAddJets

+ AddJetsPreCounter uint64

+ CloneJetTreeCounter uint64

+ CloneJetTreeFunc func(p context.Context, p1 core.PulseNumber, p2 core.PulseNumber) (r *jet.Tree, r1 error)

+ CloneJetTreeMock mJetStorageMockCloneJetTree

+ CloneJetTreePreCounter uint64

+ CreateDropCounter uint64

+ CreateDropFunc func(p context.Context, p1 core.RecordID, p2 core.PulseNumber, p3 []byte) (r *jet.JetDrop, r1 [][]byte, r2 uint64, r3 error)

+ CreateDropMock mJetStorageMockCreateDrop

+ CreateDropPreCounter uint64

+ GetDropCounter uint64

+ GetDropFunc func(p context.Context, p1 core.RecordID, p2 core.PulseNumber) (r *jet.JetDrop, r1 error)

+ GetDropMock mJetStorageMockGetDrop

+ GetDropPreCounter uint64

+ GetDropSizeHistoryCounter uint64

+ GetDropSizeHistoryFunc func(p context.Context, p1 core.RecordID) (r jet.DropSizeHistory, r1 error)

+ GetDropSizeHistoryMock mJetStorageMockGetDropSizeHistory

+ GetDropSizeHistoryPreCounter uint64

+ GetJetTreeCounter uint64

+ GetJetTreeFunc func(p context.Context, p1 core.PulseNumber) (r *jet.Tree, r1 error)

+ GetJetTreeMock mJetStorageMockGetJetTree

+ GetJetTreePreCounter uint64

+ GetJetsCounter uint64

+ GetJetsFunc func(p context.Context) (r jet.IDSet, r1 error)

+ GetJetsMock mJetStorageMockGetJets

+ GetJetsPreCounter uint64

+ SetDropCounter uint64

+ SetDropFunc func(p context.Context, p1 core.RecordID, p2 *jet.JetDrop) (r error)

+ SetDropMock mJetStorageMockSetDrop

+ SetDropPreCounter uint64

+ SetDropSizeHistoryCounter uint64

+ SetDropSizeHistoryFunc func(p context.Context, p1 core.RecordID, p2 jet.DropSizeHistory) (r error)

+ SetDropSizeHistoryMock mJetStorageMockSetDropSizeHistory

+ SetDropSizeHistoryPreCounter uint64

+ SplitJetTreeCounter uint64

+ SplitJetTreeFunc func(p context.Context, p1 core.PulseNumber, p2 core.RecordID) (r *core.RecordID, r1 *core.RecordID, r2 error)

+ SplitJetTreeMock mJetStorageMockSplitJetTree

+ SplitJetTreePreCounter uint64

+ UpdateJetTreeCounter uint64

+ UpdateJetTreeFunc func(p context.Context, p1 core.PulseNumber, p2 bool, p3 ...core.RecordID) (r error)

+ UpdateJetTreeMock mJetStorageMockUpdateJetTree

+ UpdateJetTreePreCounter uint64

+ func NewJetStorageMock(t minimock.Tester) *JetStorageMock

+ func (m *JetStorageMock) AddDropSize(p context.Context, p1 *jet.DropSize) (r error)

+ func (m *JetStorageMock) AddDropSizeFinished() bool

+ func (m *JetStorageMock) AddDropSizeMinimockCounter() uint64

+ func (m *JetStorageMock) AddDropSizeMinimockPreCounter() uint64

+ func (m *JetStorageMock) AddJets(p context.Context, p1 ...core.RecordID) (r error)

+ func (m *JetStorageMock) AddJetsFinished() bool

+ func (m *JetStorageMock) AddJetsMinimockCounter() uint64

+ func (m *JetStorageMock) AddJetsMinimockPreCounter() uint64

+ func (m *JetStorageMock) AllMocksCalled() bool

+ func (m *JetStorageMock) CheckMocksCalled()

+ func (m *JetStorageMock) CloneJetTree(p context.Context, p1 core.PulseNumber, p2 core.PulseNumber) (r *jet.Tree, r1 error)

+ func (m *JetStorageMock) CloneJetTreeFinished() bool

+ func (m *JetStorageMock) CloneJetTreeMinimockCounter() uint64

+ func (m *JetStorageMock) CloneJetTreeMinimockPreCounter() uint64

+ func (m *JetStorageMock) CreateDrop(p context.Context, p1 core.RecordID, p2 core.PulseNumber, p3 []byte) (r *jet.JetDrop, r1 [][]byte, r2 uint64, r3 error)

+ func (m *JetStorageMock) CreateDropFinished() bool

+ func (m *JetStorageMock) CreateDropMinimockCounter() uint64

+ func (m *JetStorageMock) CreateDropMinimockPreCounter() uint64

+ func (m *JetStorageMock) Finish()

+ func (m *JetStorageMock) GetDrop(p context.Context, p1 core.RecordID, p2 core.PulseNumber) (r *jet.JetDrop, r1 error)

+ func (m *JetStorageMock) GetDropFinished() bool

+ func (m *JetStorageMock) GetDropMinimockCounter() uint64

+ func (m *JetStorageMock) GetDropMinimockPreCounter() uint64

+ func (m *JetStorageMock) GetDropSizeHistory(p context.Context, p1 core.RecordID) (r jet.DropSizeHistory, r1 error)

+ func (m *JetStorageMock) GetDropSizeHistoryFinished() bool

+ func (m *JetStorageMock) GetDropSizeHistoryMinimockCounter() uint64

+ func (m *JetStorageMock) GetDropSizeHistoryMinimockPreCounter() uint64

+ func (m *JetStorageMock) GetJetTree(p context.Context, p1 core.PulseNumber) (r *jet.Tree, r1 error)

+ func (m *JetStorageMock) GetJetTreeFinished() bool

+ func (m *JetStorageMock) GetJetTreeMinimockCounter() uint64

+ func (m *JetStorageMock) GetJetTreeMinimockPreCounter() uint64

+ func (m *JetStorageMock) GetJets(p context.Context) (r jet.IDSet, r1 error)

+ func (m *JetStorageMock) GetJetsFinished() bool

+ func (m *JetStorageMock) GetJetsMinimockCounter() uint64

+ func (m *JetStorageMock) GetJetsMinimockPreCounter() uint64

+ func (m *JetStorageMock) MinimockFinish()

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

+ func (m *JetStorageMock) SetDrop(p context.Context, p1 core.RecordID, p2 *jet.JetDrop) (r error)

+ func (m *JetStorageMock) SetDropFinished() bool

+ func (m *JetStorageMock) SetDropMinimockCounter() uint64

+ func (m *JetStorageMock) SetDropMinimockPreCounter() uint64

+ func (m *JetStorageMock) SetDropSizeHistory(p context.Context, p1 core.RecordID, p2 jet.DropSizeHistory) (r error)

+ func (m *JetStorageMock) SetDropSizeHistoryFinished() bool

+ func (m *JetStorageMock) SetDropSizeHistoryMinimockCounter() uint64

+ func (m *JetStorageMock) SetDropSizeHistoryMinimockPreCounter() uint64

+ func (m *JetStorageMock) SplitJetTree(p context.Context, p1 core.PulseNumber, p2 core.RecordID) (r *core.RecordID, r1 *core.RecordID, r2 error)

+ func (m *JetStorageMock) SplitJetTreeFinished() bool

+ func (m *JetStorageMock) SplitJetTreeMinimockCounter() uint64

+ func (m *JetStorageMock) SplitJetTreeMinimockPreCounter() uint64

+ func (m *JetStorageMock) UpdateJetTree(p context.Context, p1 core.PulseNumber, p2 bool, p3 ...core.RecordID) (r error)

+ func (m *JetStorageMock) UpdateJetTreeFinished() bool

+ func (m *JetStorageMock) UpdateJetTreeMinimockCounter() uint64

+ func (m *JetStorageMock) UpdateJetTreeMinimockPreCounter() uint64

+ func (m *JetStorageMock) ValidateCallCounters()

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

+ type JetStorageMockAddDropSizeExpectation struct

+ func (e *JetStorageMockAddDropSizeExpectation) Return(r error)

+ type JetStorageMockAddDropSizeInput struct

+ type JetStorageMockAddDropSizeResult struct

+ type JetStorageMockAddJetsExpectation struct

+ func (e *JetStorageMockAddJetsExpectation) Return(r error)

+ type JetStorageMockAddJetsInput struct

+ type JetStorageMockAddJetsResult struct

+ type JetStorageMockCloneJetTreeExpectation struct

+ func (e *JetStorageMockCloneJetTreeExpectation) Return(r *jet.Tree, r1 error)

+ type JetStorageMockCloneJetTreeInput struct

+ type JetStorageMockCloneJetTreeResult struct

+ type JetStorageMockCreateDropExpectation struct

+ func (e *JetStorageMockCreateDropExpectation) Return(r *jet.JetDrop, r1 [][]byte, r2 uint64, r3 error)

+ type JetStorageMockCreateDropInput struct

+ type JetStorageMockCreateDropResult struct

+ type JetStorageMockGetDropExpectation struct

+ func (e *JetStorageMockGetDropExpectation) Return(r *jet.JetDrop, r1 error)

+ type JetStorageMockGetDropInput struct

+ type JetStorageMockGetDropResult struct

+ type JetStorageMockGetDropSizeHistoryExpectation struct

+ func (e *JetStorageMockGetDropSizeHistoryExpectation) Return(r jet.DropSizeHistory, r1 error)

+ type JetStorageMockGetDropSizeHistoryInput struct

+ type JetStorageMockGetDropSizeHistoryResult struct

+ type JetStorageMockGetJetTreeExpectation struct

+ func (e *JetStorageMockGetJetTreeExpectation) Return(r *jet.Tree, r1 error)

+ type JetStorageMockGetJetTreeInput struct

+ type JetStorageMockGetJetTreeResult struct

+ type JetStorageMockGetJetsExpectation struct

+ func (e *JetStorageMockGetJetsExpectation) Return(r jet.IDSet, r1 error)

+ type JetStorageMockGetJetsInput struct

+ type JetStorageMockGetJetsResult struct

+ type JetStorageMockSetDropExpectation struct

+ func (e *JetStorageMockSetDropExpectation) Return(r error)

+ type JetStorageMockSetDropInput struct

+ type JetStorageMockSetDropResult struct

+ type JetStorageMockSetDropSizeHistoryExpectation struct

+ func (e *JetStorageMockSetDropSizeHistoryExpectation) Return(r error)

+ type JetStorageMockSetDropSizeHistoryInput struct

+ type JetStorageMockSetDropSizeHistoryResult struct

+ type JetStorageMockSplitJetTreeExpectation struct

+ func (e *JetStorageMockSplitJetTreeExpectation) Return(r *core.RecordID, r1 *core.RecordID, r2 error)

+ type JetStorageMockSplitJetTreeInput struct

+ type JetStorageMockSplitJetTreeResult struct

+ type JetStorageMockUpdateJetTreeExpectation struct

+ func (e *JetStorageMockUpdateJetTreeExpectation) Return(r error)

+ type JetStorageMockUpdateJetTreeInput struct

+ type JetStorageMockUpdateJetTreeResult struct

+ type Key []byte

+ func (b Key) PulseNumber() core.PulseNumber

+ func (b Key) String() string

+ type Node struct

+ FID core.RecordRef

+ FRole core.StaticRole

+ func (Node) GetGlobuleID() core.GlobuleID

+ func (Node) PhysicalAddress() string

+ func (Node) PublicKey() crypto.PublicKey

+ func (Node) ShortID() core.ShortNodeID

+ func (Node) Version() string

+ func (n Node) ID() core.RecordRef

+ func (n Node) Role() core.StaticRole

+ type ObjectStorage interface

+ GetBlob func(ctx context.Context, jetID core.RecordID, id *core.RecordID) ([]byte, error)

+ GetObjectIndex func(ctx context.Context, jetID core.RecordID, id *core.RecordID, forupdate bool) (*index.ObjectLifeline, error)

+ GetRecord func(ctx context.Context, jetID core.RecordID, id *core.RecordID) (record.Record, error)

+ IterateIndexIDs func(ctx context.Context, jetID core.RecordID, handler func(id core.RecordID) error) error

+ RemoveObjectIndex func(ctx context.Context, jetID core.RecordID, ref *core.RecordID) error

+ SetBlob func(ctx context.Context, jetID core.RecordID, pulseNumber core.PulseNumber, ...) (*core.RecordID, error)

+ SetMessage func(ctx context.Context, jetID core.RecordID, pulseNumber core.PulseNumber, ...) error

+ SetObjectIndex func(ctx context.Context, jetID core.RecordID, id *core.RecordID, ...) error

+ SetRecord func(ctx context.Context, jetID core.RecordID, pulseNumber core.PulseNumber, ...) (*core.RecordID, error)

+ type ObjectStorageMock struct

+ GetBlobCounter uint64

+ GetBlobFunc func(p context.Context, p1 core.RecordID, p2 *core.RecordID) (r []byte, r1 error)

+ GetBlobMock mObjectStorageMockGetBlob

+ GetBlobPreCounter uint64

+ GetObjectIndexCounter uint64

+ GetObjectIndexFunc func(p context.Context, p1 core.RecordID, p2 *core.RecordID, p3 bool) (r *index.ObjectLifeline, r1 error)

+ GetObjectIndexMock mObjectStorageMockGetObjectIndex

+ GetObjectIndexPreCounter uint64

+ GetRecordCounter uint64

+ GetRecordFunc func(p context.Context, p1 core.RecordID, p2 *core.RecordID) (r record.Record, r1 error)

+ GetRecordMock mObjectStorageMockGetRecord

+ GetRecordPreCounter uint64

+ IterateIndexIDsCounter uint64

+ IterateIndexIDsFunc func(p context.Context, p1 core.RecordID, p2 func(p core.RecordID) (r error)) (r error)

+ IterateIndexIDsMock mObjectStorageMockIterateIndexIDs

+ IterateIndexIDsPreCounter uint64

+ RemoveObjectIndexCounter uint64

+ RemoveObjectIndexFunc func(p context.Context, p1 core.RecordID, p2 *core.RecordID) (r error)

+ RemoveObjectIndexMock mObjectStorageMockRemoveObjectIndex

+ RemoveObjectIndexPreCounter uint64

+ SetBlobCounter uint64

+ SetBlobFunc func(p context.Context, p1 core.RecordID, p2 core.PulseNumber, p3 []byte) (r *core.RecordID, r1 error)

+ SetBlobMock mObjectStorageMockSetBlob

+ SetBlobPreCounter uint64

+ SetMessageCounter uint64

+ SetMessageFunc func(p context.Context, p1 core.RecordID, p2 core.PulseNumber, p3 core.Message) (r error)

+ SetMessageMock mObjectStorageMockSetMessage

+ SetMessagePreCounter uint64

+ SetObjectIndexCounter uint64

+ SetObjectIndexFunc func(p context.Context, p1 core.RecordID, p2 *core.RecordID, ...) (r error)

+ SetObjectIndexMock mObjectStorageMockSetObjectIndex

+ SetObjectIndexPreCounter uint64

+ SetRecordCounter uint64

+ SetRecordFunc func(p context.Context, p1 core.RecordID, p2 core.PulseNumber, p3 record.Record) (r *core.RecordID, r1 error)

+ SetRecordMock mObjectStorageMockSetRecord

+ SetRecordPreCounter uint64

+ func NewObjectStorageMock(t minimock.Tester) *ObjectStorageMock

+ func (m *ObjectStorageMock) AllMocksCalled() bool

+ func (m *ObjectStorageMock) CheckMocksCalled()

+ func (m *ObjectStorageMock) Finish()

+ func (m *ObjectStorageMock) GetBlob(p context.Context, p1 core.RecordID, p2 *core.RecordID) (r []byte, r1 error)

+ func (m *ObjectStorageMock) GetBlobFinished() bool

+ func (m *ObjectStorageMock) GetBlobMinimockCounter() uint64

+ func (m *ObjectStorageMock) GetBlobMinimockPreCounter() uint64

+ func (m *ObjectStorageMock) GetObjectIndex(p context.Context, p1 core.RecordID, p2 *core.RecordID, p3 bool) (r *index.ObjectLifeline, r1 error)

+ func (m *ObjectStorageMock) GetObjectIndexFinished() bool

+ func (m *ObjectStorageMock) GetObjectIndexMinimockCounter() uint64

+ func (m *ObjectStorageMock) GetObjectIndexMinimockPreCounter() uint64

+ func (m *ObjectStorageMock) GetRecord(p context.Context, p1 core.RecordID, p2 *core.RecordID) (r record.Record, r1 error)

+ func (m *ObjectStorageMock) GetRecordFinished() bool

+ func (m *ObjectStorageMock) GetRecordMinimockCounter() uint64

+ func (m *ObjectStorageMock) GetRecordMinimockPreCounter() uint64

+ func (m *ObjectStorageMock) IterateIndexIDs(p context.Context, p1 core.RecordID, p2 func(p core.RecordID) (r error)) (r error)

+ func (m *ObjectStorageMock) IterateIndexIDsFinished() bool

+ func (m *ObjectStorageMock) IterateIndexIDsMinimockCounter() uint64

+ func (m *ObjectStorageMock) IterateIndexIDsMinimockPreCounter() uint64

+ func (m *ObjectStorageMock) MinimockFinish()

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

+ func (m *ObjectStorageMock) RemoveObjectIndex(p context.Context, p1 core.RecordID, p2 *core.RecordID) (r error)

+ func (m *ObjectStorageMock) RemoveObjectIndexFinished() bool

+ func (m *ObjectStorageMock) RemoveObjectIndexMinimockCounter() uint64

+ func (m *ObjectStorageMock) RemoveObjectIndexMinimockPreCounter() uint64

+ func (m *ObjectStorageMock) SetBlob(p context.Context, p1 core.RecordID, p2 core.PulseNumber, p3 []byte) (r *core.RecordID, r1 error)

+ func (m *ObjectStorageMock) SetBlobFinished() bool

+ func (m *ObjectStorageMock) SetBlobMinimockCounter() uint64

+ func (m *ObjectStorageMock) SetBlobMinimockPreCounter() uint64

+ func (m *ObjectStorageMock) SetMessage(p context.Context, p1 core.RecordID, p2 core.PulseNumber, p3 core.Message) (r error)

+ func (m *ObjectStorageMock) SetMessageFinished() bool

+ func (m *ObjectStorageMock) SetMessageMinimockCounter() uint64

+ func (m *ObjectStorageMock) SetMessageMinimockPreCounter() uint64

+ func (m *ObjectStorageMock) SetObjectIndex(p context.Context, p1 core.RecordID, p2 *core.RecordID, ...) (r error)

+ func (m *ObjectStorageMock) SetObjectIndexFinished() bool

+ func (m *ObjectStorageMock) SetObjectIndexMinimockCounter() uint64

+ func (m *ObjectStorageMock) SetObjectIndexMinimockPreCounter() uint64

+ func (m *ObjectStorageMock) SetRecord(p context.Context, p1 core.RecordID, p2 core.PulseNumber, p3 record.Record) (r *core.RecordID, r1 error)

+ func (m *ObjectStorageMock) SetRecordFinished() bool

+ func (m *ObjectStorageMock) SetRecordMinimockCounter() uint64

+ func (m *ObjectStorageMock) SetRecordMinimockPreCounter() uint64

+ func (m *ObjectStorageMock) ValidateCallCounters()

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

+ type ObjectStorageMockGetBlobExpectation struct

+ func (e *ObjectStorageMockGetBlobExpectation) Return(r []byte, r1 error)

+ type ObjectStorageMockGetBlobInput struct

+ type ObjectStorageMockGetBlobResult struct

+ type ObjectStorageMockGetObjectIndexExpectation struct

+ func (e *ObjectStorageMockGetObjectIndexExpectation) Return(r *index.ObjectLifeline, r1 error)

+ type ObjectStorageMockGetObjectIndexInput struct

+ type ObjectStorageMockGetObjectIndexResult struct

+ type ObjectStorageMockGetRecordExpectation struct

+ func (e *ObjectStorageMockGetRecordExpectation) Return(r record.Record, r1 error)

+ type ObjectStorageMockGetRecordInput struct

+ type ObjectStorageMockGetRecordResult struct

+ type ObjectStorageMockIterateIndexIDsExpectation struct

+ func (e *ObjectStorageMockIterateIndexIDsExpectation) Return(r error)

+ type ObjectStorageMockIterateIndexIDsInput struct

+ type ObjectStorageMockIterateIndexIDsResult struct

+ type ObjectStorageMockRemoveObjectIndexExpectation struct

+ func (e *ObjectStorageMockRemoveObjectIndexExpectation) Return(r error)

+ type ObjectStorageMockRemoveObjectIndexInput struct

+ type ObjectStorageMockRemoveObjectIndexResult struct

+ type ObjectStorageMockSetBlobExpectation struct

+ func (e *ObjectStorageMockSetBlobExpectation) Return(r *core.RecordID, r1 error)

+ type ObjectStorageMockSetBlobInput struct

+ type ObjectStorageMockSetBlobResult struct

+ type ObjectStorageMockSetMessageExpectation struct

+ func (e *ObjectStorageMockSetMessageExpectation) Return(r error)

+ type ObjectStorageMockSetMessageInput struct

+ type ObjectStorageMockSetMessageResult struct

+ type ObjectStorageMockSetObjectIndexExpectation struct

+ func (e *ObjectStorageMockSetObjectIndexExpectation) Return(r error)

+ type ObjectStorageMockSetObjectIndexInput struct

+ type ObjectStorageMockSetObjectIndexResult struct

+ type ObjectStorageMockSetRecordExpectation struct

+ func (e *ObjectStorageMockSetRecordExpectation) Return(r *core.RecordID, r1 error)

+ type ObjectStorageMockSetRecordInput struct

+ type ObjectStorageMockSetRecordResult struct

type Pulse

+ SerialNumber int

+ type PulseStorage struct

+ PulseTracker PulseTracker

+ func NewPulseStorage() *PulseStorage

+ func (ps *PulseStorage) Current(ctx context.Context) (*core.Pulse, error)

+ func (ps *PulseStorage) Lock()

+ func (ps *PulseStorage) Set(pulse *core.Pulse)

+ func (ps *PulseStorage) Unlock()

+ type PulseTracker interface

+ AddPulse func(ctx context.Context, pulse core.Pulse) error

+ GetLatestPulse func(ctx context.Context) (*Pulse, error)

+ GetPreviousPulse func(ctx context.Context, num core.PulseNumber) (*Pulse, error)

+ GetPulse func(ctx context.Context, num core.PulseNumber) (*Pulse, error)

+ type PulseTrackerMock struct

+ AddPulseCounter uint64

+ AddPulseFunc func(p context.Context, p1 core.Pulse) (r error)

+ AddPulseMock mPulseTrackerMockAddPulse

+ AddPulsePreCounter uint64

+ GetLatestPulseCounter uint64

+ GetLatestPulseFunc func(p context.Context) (r *Pulse, r1 error)

+ GetLatestPulseMock mPulseTrackerMockGetLatestPulse

+ GetLatestPulsePreCounter uint64

+ GetPreviousPulseCounter uint64

+ GetPreviousPulseFunc func(p context.Context, p1 core.PulseNumber) (r *Pulse, r1 error)

+ GetPreviousPulseMock mPulseTrackerMockGetPreviousPulse

+ GetPreviousPulsePreCounter uint64

+ GetPulseCounter uint64

+ GetPulseFunc func(p context.Context, p1 core.PulseNumber) (r *Pulse, r1 error)

+ GetPulseMock mPulseTrackerMockGetPulse

+ GetPulsePreCounter uint64

+ func NewPulseTrackerMock(t minimock.Tester) *PulseTrackerMock

+ func (m *PulseTrackerMock) AddPulse(p context.Context, p1 core.Pulse) (r error)

+ func (m *PulseTrackerMock) AddPulseFinished() bool

+ func (m *PulseTrackerMock) AddPulseMinimockCounter() uint64

+ func (m *PulseTrackerMock) AddPulseMinimockPreCounter() uint64

+ func (m *PulseTrackerMock) AllMocksCalled() bool

+ func (m *PulseTrackerMock) CheckMocksCalled()

+ func (m *PulseTrackerMock) Finish()

+ func (m *PulseTrackerMock) GetLatestPulse(p context.Context) (r *Pulse, r1 error)

+ func (m *PulseTrackerMock) GetLatestPulseFinished() bool

+ func (m *PulseTrackerMock) GetLatestPulseMinimockCounter() uint64

+ func (m *PulseTrackerMock) GetLatestPulseMinimockPreCounter() uint64

+ func (m *PulseTrackerMock) GetPreviousPulse(p context.Context, p1 core.PulseNumber) (r *Pulse, r1 error)

+ func (m *PulseTrackerMock) GetPreviousPulseFinished() bool

+ func (m *PulseTrackerMock) GetPreviousPulseMinimockCounter() uint64

+ func (m *PulseTrackerMock) GetPreviousPulseMinimockPreCounter() uint64

+ func (m *PulseTrackerMock) GetPulse(p context.Context, p1 core.PulseNumber) (r *Pulse, r1 error)

+ func (m *PulseTrackerMock) GetPulseFinished() bool

+ func (m *PulseTrackerMock) GetPulseMinimockCounter() uint64

+ func (m *PulseTrackerMock) GetPulseMinimockPreCounter() uint64

+ func (m *PulseTrackerMock) MinimockFinish()

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

+ func (m *PulseTrackerMock) ValidateCallCounters()

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

+ type PulseTrackerMockAddPulseExpectation struct

+ func (e *PulseTrackerMockAddPulseExpectation) Return(r error)

+ type PulseTrackerMockAddPulseInput struct

+ type PulseTrackerMockAddPulseResult struct

+ type PulseTrackerMockGetLatestPulseExpectation struct

+ func (e *PulseTrackerMockGetLatestPulseExpectation) Return(r *Pulse, r1 error)

+ type PulseTrackerMockGetLatestPulseInput struct

+ type PulseTrackerMockGetLatestPulseResult struct

+ type PulseTrackerMockGetPreviousPulseExpectation struct

+ func (e *PulseTrackerMockGetPreviousPulseExpectation) Return(r *Pulse, r1 error)

+ type PulseTrackerMockGetPreviousPulseInput struct

+ type PulseTrackerMockGetPreviousPulseResult struct

+ type PulseTrackerMockGetPulseExpectation struct

+ func (e *PulseTrackerMockGetPulseExpectation) Return(r *Pulse, r1 error)

+ type PulseTrackerMockGetPulseInput struct

+ type PulseTrackerMockGetPulseResult struct

type RecentStorage

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

+ func (r *RecentStorage) DecreaseTTL(ctx context.Context)

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

+ func (r *RecentStorage) IsRecordIDCached(obj core.RecordID) bool

+ type RecentStorageProvider struct

+ DefaultTTL int

+ func NewRecentStorageProvider(defaultTTL int) *RecentStorageProvider

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

+ func (p *RecentStorageProvider) GetStorage(ctx context.Context, jetID core.RecordID) recentstorage.RecentStorage

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

type ReplicaIter

+ func (r *ReplicaIter) LastSeenPulse() core.PulseNumber

+ type ReplicaStorage interface

+ GetAllNonEmptySyncClientJets func(ctx context.Context) (map[core.RecordID][]core.PulseNumber, error)

+ GetAllSyncClientJets func(ctx context.Context) (map[core.RecordID][]core.PulseNumber, error)

+ GetHeavySyncedPulse func(ctx context.Context, jetID core.RecordID) (pn core.PulseNumber, err error)

+ GetSyncClientJetPulses func(ctx context.Context, jetID core.RecordID) ([]core.PulseNumber, error)

+ SetHeavySyncedPulse func(ctx context.Context, jetID core.RecordID, pulsenum core.PulseNumber) error

+ SetSyncClientJetPulses func(ctx context.Context, jetID core.RecordID, pns []core.PulseNumber) error

+ type ReplicaStorageMock struct

+ GetAllNonEmptySyncClientJetsCounter uint64

+ GetAllNonEmptySyncClientJetsFunc func(p context.Context) (r map[core.RecordID][]core.PulseNumber, r1 error)

+ GetAllNonEmptySyncClientJetsMock mReplicaStorageMockGetAllNonEmptySyncClientJets

+ GetAllNonEmptySyncClientJetsPreCounter uint64

+ GetAllSyncClientJetsCounter uint64

+ GetAllSyncClientJetsFunc func(p context.Context) (r map[core.RecordID][]core.PulseNumber, r1 error)

+ GetAllSyncClientJetsMock mReplicaStorageMockGetAllSyncClientJets

+ GetAllSyncClientJetsPreCounter uint64

+ GetHeavySyncedPulseCounter uint64

+ GetHeavySyncedPulseFunc func(p context.Context, p1 core.RecordID) (r core.PulseNumber, r1 error)

+ GetHeavySyncedPulseMock mReplicaStorageMockGetHeavySyncedPulse

+ GetHeavySyncedPulsePreCounter uint64

+ GetSyncClientJetPulsesCounter uint64

+ GetSyncClientJetPulsesFunc func(p context.Context, p1 core.RecordID) (r []core.PulseNumber, r1 error)

+ GetSyncClientJetPulsesMock mReplicaStorageMockGetSyncClientJetPulses

+ GetSyncClientJetPulsesPreCounter uint64

+ SetHeavySyncedPulseCounter uint64

+ SetHeavySyncedPulseFunc func(p context.Context, p1 core.RecordID, p2 core.PulseNumber) (r error)

+ SetHeavySyncedPulseMock mReplicaStorageMockSetHeavySyncedPulse

+ SetHeavySyncedPulsePreCounter uint64

+ SetSyncClientJetPulsesCounter uint64

+ SetSyncClientJetPulsesFunc func(p context.Context, p1 core.RecordID, p2 []core.PulseNumber) (r error)

+ SetSyncClientJetPulsesMock mReplicaStorageMockSetSyncClientJetPulses

+ SetSyncClientJetPulsesPreCounter uint64

+ func NewReplicaStorageMock(t minimock.Tester) *ReplicaStorageMock

+ func (m *ReplicaStorageMock) AllMocksCalled() bool

+ func (m *ReplicaStorageMock) CheckMocksCalled()

+ func (m *ReplicaStorageMock) Finish()

+ func (m *ReplicaStorageMock) GetAllNonEmptySyncClientJets(p context.Context) (r map[core.RecordID][]core.PulseNumber, r1 error)

+ func (m *ReplicaStorageMock) GetAllNonEmptySyncClientJetsFinished() bool

+ func (m *ReplicaStorageMock) GetAllNonEmptySyncClientJetsMinimockCounter() uint64

+ func (m *ReplicaStorageMock) GetAllNonEmptySyncClientJetsMinimockPreCounter() uint64

+ func (m *ReplicaStorageMock) GetAllSyncClientJets(p context.Context) (r map[core.RecordID][]core.PulseNumber, r1 error)

+ func (m *ReplicaStorageMock) GetAllSyncClientJetsFinished() bool

+ func (m *ReplicaStorageMock) GetAllSyncClientJetsMinimockCounter() uint64

+ func (m *ReplicaStorageMock) GetAllSyncClientJetsMinimockPreCounter() uint64

+ func (m *ReplicaStorageMock) GetHeavySyncedPulse(p context.Context, p1 core.RecordID) (r core.PulseNumber, r1 error)

+ func (m *ReplicaStorageMock) GetHeavySyncedPulseFinished() bool

+ func (m *ReplicaStorageMock) GetHeavySyncedPulseMinimockCounter() uint64

+ func (m *ReplicaStorageMock) GetHeavySyncedPulseMinimockPreCounter() uint64

+ func (m *ReplicaStorageMock) GetSyncClientJetPulses(p context.Context, p1 core.RecordID) (r []core.PulseNumber, r1 error)

+ func (m *ReplicaStorageMock) GetSyncClientJetPulsesFinished() bool

+ func (m *ReplicaStorageMock) GetSyncClientJetPulsesMinimockCounter() uint64

+ func (m *ReplicaStorageMock) GetSyncClientJetPulsesMinimockPreCounter() uint64

+ func (m *ReplicaStorageMock) MinimockFinish()

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

+ func (m *ReplicaStorageMock) SetHeavySyncedPulse(p context.Context, p1 core.RecordID, p2 core.PulseNumber) (r error)

+ func (m *ReplicaStorageMock) SetHeavySyncedPulseFinished() bool

+ func (m *ReplicaStorageMock) SetHeavySyncedPulseMinimockCounter() uint64

+ func (m *ReplicaStorageMock) SetHeavySyncedPulseMinimockPreCounter() uint64

+ func (m *ReplicaStorageMock) SetSyncClientJetPulses(p context.Context, p1 core.RecordID, p2 []core.PulseNumber) (r error)

+ func (m *ReplicaStorageMock) SetSyncClientJetPulsesFinished() bool

+ func (m *ReplicaStorageMock) SetSyncClientJetPulsesMinimockCounter() uint64

+ func (m *ReplicaStorageMock) SetSyncClientJetPulsesMinimockPreCounter() uint64

+ func (m *ReplicaStorageMock) ValidateCallCounters()

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

+ type ReplicaStorageMockGetAllNonEmptySyncClientJetsExpectation struct

+ func (e *ReplicaStorageMockGetAllNonEmptySyncClientJetsExpectation) Return(r map[core.RecordID][]core.PulseNumber, r1 error)

+ type ReplicaStorageMockGetAllNonEmptySyncClientJetsInput struct

+ type ReplicaStorageMockGetAllNonEmptySyncClientJetsResult struct

+ type ReplicaStorageMockGetAllSyncClientJetsExpectation struct

+ func (e *ReplicaStorageMockGetAllSyncClientJetsExpectation) Return(r map[core.RecordID][]core.PulseNumber, r1 error)

+ type ReplicaStorageMockGetAllSyncClientJetsInput struct

+ type ReplicaStorageMockGetAllSyncClientJetsResult struct

+ type ReplicaStorageMockGetHeavySyncedPulseExpectation struct

+ func (e *ReplicaStorageMockGetHeavySyncedPulseExpectation) Return(r core.PulseNumber, r1 error)

+ type ReplicaStorageMockGetHeavySyncedPulseInput struct

+ type ReplicaStorageMockGetHeavySyncedPulseResult struct

+ type ReplicaStorageMockGetSyncClientJetPulsesExpectation struct

+ func (e *ReplicaStorageMockGetSyncClientJetPulsesExpectation) Return(r []core.PulseNumber, r1 error)

+ type ReplicaStorageMockGetSyncClientJetPulsesInput struct

+ type ReplicaStorageMockGetSyncClientJetPulsesResult struct

+ type ReplicaStorageMockSetHeavySyncedPulseExpectation struct

+ func (e *ReplicaStorageMockSetHeavySyncedPulseExpectation) Return(r error)

+ type ReplicaStorageMockSetHeavySyncedPulseInput struct

+ type ReplicaStorageMockSetHeavySyncedPulseResult struct

+ type ReplicaStorageMockSetSyncClientJetPulsesExpectation struct

+ func (e *ReplicaStorageMockSetSyncClientJetPulsesExpectation) Return(r error)

+ type ReplicaStorageMockSetSyncClientJetPulsesInput struct

+ type ReplicaStorageMockSetSyncClientJetPulsesResult struct

type Store

+ GetLatestPulse func(ctx context.Context) (*Pulse, error)

+ RemoveObjectIndex func(ctx context.Context, jetID core.RecordID, ref *core.RecordID) error

type TransactionManager

+ func (m *TransactionManager) GetLatestPulse(ctx context.Context) (*Pulse, error)

+ func (m *TransactionManager) RemoveObjectIndex(ctx context.Context, j core.RecordID, ref *core.RecordID) error

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

v0.6.3

Nov 30, 2018

Changes in this version

+ var ErrReplicatorDone = errors.New("no more items in iterator")

type DB

+ PlatformCryptographyScheme core.PlatformCryptographyScheme

+ func (db *DB) GetActiveNodes(pulse core.PulseNumber) ([]core.Node, error)

+ func (db *DB) GetHeavySyncedPulse(ctx context.Context) (pn core.PulseNumber, err error)

+ func (db *DB) GetLastPulseAsLightMaterial(ctx context.Context) (core.PulseNumber, error)

+ func (db *DB) GetLocalData(ctx context.Context, pulse core.PulseNumber, key []byte) ([]byte, error)

+ func (db *DB) GetReplicatedPulse(ctx context.Context) (core.PulseNumber, error)

+ func (db *DB) Init(ctx context.Context) error

+ func (db *DB) IterateLocalData(ctx context.Context, pulse core.PulseNumber, prefix []byte, ...) error

+ func (db *DB) IterateRecords(ctx context.Context, pulse core.PulseNumber, ...) error

+ func (db *DB) SetActiveNodes(pulse core.PulseNumber, nodes []core.Node) error

+ func (db *DB) SetHeavySyncedPulse(ctx context.Context, pulsenum core.PulseNumber) error

+ func (db *DB) SetLastPulseAsLightMaterial(ctx context.Context, pulsenum core.PulseNumber) error

+ func (db *DB) SetLocalData(ctx context.Context, pulse core.PulseNumber, key []byte, data []byte) error

+ func (db *DB) SetReplicatedPulse(ctx context.Context, pulsenum core.PulseNumber) error

+ func (db *DB) Stop(ctx context.Context) error

+ func (db *DB) StoreKeyValues(ctx context.Context, kvs []core.KV) error

+ type Pulse struct

+ Next *core.PulseNumber

+ Prev *core.PulseNumber

+ Pulse core.Pulse

+ func (p *Pulse) Bytes() []byte

+ type RecentObjectsIndexMeta struct

+ TTL int

+ type RecentStorage struct

+ DefaultTTL int

+ func NewRecentStorage(defaultTTL int) *RecentStorage

+ func (r *RecentStorage) AddObject(id core.RecordID)

+ func (r *RecentStorage) AddPendingRequest(id core.RecordID)

+ func (r *RecentStorage) ClearObjects()

+ func (r *RecentStorage) ClearZeroTTLObjects()

+ func (r *RecentStorage) GetObjects() map[core.RecordID]*RecentObjectsIndexMeta

+ func (r *RecentStorage) GetRequests() []core.RecordID

+ func (r *RecentStorage) RemovePendingRequest(id core.RecordID)

+ type ReplicaIter struct

+ func NewReplicaIter(ctx context.Context, db *DB, start core.PulseNumber, end core.PulseNumber, ...) *ReplicaIter

+ func (r *ReplicaIter) LastPulse() core.PulseNumber

+ func (r *ReplicaIter) NextRecords() ([]core.KV, error)

type Store

+ GetPulse func(ctx context.Context, num core.PulseNumber) (*Pulse, error)

type TransactionManager

+ func (m *TransactionManager) GetPulse(ctx context.Context, num core.PulseNumber) (*Pulse, error)

v0.6.2

Nov 1, 2018

Changes in this version

type DB

+ func (db *DB) GetBlob(ctx context.Context, id *core.RecordID) ([]byte, error)

+ func (db *DB) SetBlob(ctx context.Context, pulseNumber core.PulseNumber, blob []byte) (*core.RecordID, error)

+ func (db *DB) SetMessage(pulseNumber core.PulseNumber, genericMessage core.Message) error

type Store

+ GetBlob func(ctx context.Context, ref *core.RecordID) ([]byte, error)

+ SetBlob func(ctx context.Context, number core.PulseNumber, blob []byte) (*core.RecordID, error)

type TransactionManager

+ func (m *TransactionManager) GetBlob(ctx context.Context, id *core.RecordID) ([]byte, error)

+ func (m *TransactionManager) SetBlob(ctx context.Context, pulseNumber core.PulseNumber, blob []byte) (*core.RecordID, error)

v0.6.1

Oct 23, 2018

Changes in this version

type DB

+ func (db *DB) GetBadgerDB() *badger.DB

v0.6.0

Oct 16, 2018

Changes in this version

type DB

+ func (db *DB) AddPulse(pulse core.Pulse) error

+ func (db *DB) CreateDrop(pulse core.PulseNumber, prevHash []byte) (*jetdrop.JetDrop, [][2][]byte, error)

+ func (db *DB) GenesisRef() *record.Reference

+ func (db *DB) GetLatestPulseNumber() (core.PulseNumber, error)

+ func (db *DB) GetPulse(num core.PulseNumber) (*record.PulseRecord, error)

+ func (db *DB) SetRecordBinary(key, rec []byte) error

+ type IDLocker struct

+ func NewIDLocker() *IDLocker

+ func (l *IDLocker) Lock(id *record.ID)

+ func (l *IDLocker) Unlock(id *record.ID)

type Store

+ GetLatestPulseNumber func() (core.PulseNumber, error)

type TransactionManager

+ func (m *TransactionManager) GetLatestPulseNumber() (core.PulseNumber, error)

v0.5.0

Oct 9, 2018

Changes in this version

+ var ErrNotIterable = errors.New("record is not iterable")

+ type ChainIterator struct

+ func NewChainIterator(db *DB, from *record.ID) *ChainIterator

+ func (i *ChainIterator) HasNext() bool

+ func (i *ChainIterator) Next() (*record.ID, ChainRecord, error)

+ type ChainRecord interface

+ Next func() *record.ID

type DB

+ func (db *DB) GetRequest(id *record.ID) (record.Request, error)

+ func (db *DB) SetRequest(req record.Request) (*record.ID, error)

type TransactionManager

+ func (m *TransactionManager) GetRequest(id *record.ID) (record.Request, error)

+ func (m *TransactionManager) SetRequest(req record.Request) (*record.ID, error)

v0.4.1

Oct 3, 2018

v0.4.0

Oct 3, 2018

v0.3.0

Sep 25, 2018

v0.2.0

Sep 18, 2018

Changes in this version

+ var ErrOverride = errors.New("records override is forbidden")

v0.0.6

Sep 13, 2018

Changes in this version

+ var ErrConflict = badger.ErrConflict

+ var ErrConflictRetriesOver = errors.New("Transaction Conflict retries exceeded")

+ type DB struct

+ func NewDB(conf configuration.Ledger, opts *badger.Options) (*DB, error)

+ func (db *DB) BeginTransaction(update bool) *TransactionManager

+ func (db *DB) Bootstrap() error

+ func (db *DB) Close() error

+ func (db *DB) Get(key []byte) ([]byte, error)

+ func (db *DB) GetClassIndex(ref *record.Reference) (*index.ClassLifeline, error)

+ func (db *DB) GetCurrentPulse() record.PulseNum

+ func (db *DB) GetDrop(pulse record.PulseNum) (*jetdrop.JetDrop, error)

+ func (db *DB) GetEntropy(pulse record.PulseNum) ([]byte, error)

+ func (db *DB) GetObjectIndex(ref *record.Reference) (*index.ObjectLifeline, error)

+ func (db *DB) GetRecord(ref *record.Reference) (record.Record, error)

+ func (db *DB) GetSlotHashes(n record.PulseNum) ([][]byte, error)

+ func (db *DB) ProcessSlotHashes(n record.PulseNum, ifn func(it HashIterator) error) error

+ func (db *DB) RootRef() *record.Reference

+ func (db *DB) Set(key, value []byte) error

+ func (db *DB) SetClassIndex(ref *record.Reference, idx *index.ClassLifeline) error

+ func (db *DB) SetCurrentPulse(pulse record.PulseNum)

+ func (db *DB) SetDrop(pulse record.PulseNum, prevdrop *jetdrop.JetDrop) (*jetdrop.JetDrop, error)

+ func (db *DB) SetEntropy(pulse record.PulseNum, entropy []byte) error

+ func (db *DB) SetObjectIndex(ref *record.Reference, idx *index.ObjectLifeline) error

+ func (db *DB) SetRecord(rec record.Record) (ref *record.Reference, err error)

+ func (db *DB) SetTxRetiries(n int)

+ func (db *DB) Update(fn func(*TransactionManager) error) error

+ func (db *DB) View(fn func(*TransactionManager) error) error

+ type HashIterator interface

+ Hash func() []byte

+ Next func() bool

+ ShallowHash func() []byte

+ type TransactionManager struct

+ func (m *TransactionManager) Commit() error

+ func (m *TransactionManager) Discard()

+ func (m *TransactionManager) Get(key []byte) ([]byte, error)

+ func (m *TransactionManager) GetClassIndex(ref *record.Reference) (*index.ClassLifeline, error)

+ func (m *TransactionManager) GetEntropy(pulse record.PulseNum) ([]byte, error)

+ func (m *TransactionManager) GetObjectIndex(ref *record.Reference) (*index.ObjectLifeline, error)

+ func (m *TransactionManager) GetRecord(ref *record.Reference) (record.Record, error)

+ func (m *TransactionManager) Set(key, value []byte) error

+ func (m *TransactionManager) SetClassIndex(ref *record.Reference, idx *index.ClassLifeline) error

+ func (m *TransactionManager) SetEntropy(pulse record.PulseNum, entropy []byte) error

+ func (m *TransactionManager) SetObjectIndex(ref *record.Reference, idx *index.ObjectLifeline) error

+ func (m *TransactionManager) SetRecord(rec record.Record) (*record.Reference, error)

v0.0.5

Sep 4, 2018

Changes in this version

+ type Store interface

+ GetClassIndex func(*record.Reference) (*index.ClassLifeline, error)

+ GetCurrentPulse func() record.PulseNum

+ GetDrop func(record.PulseNum) (*jetdrop.JetDrop, error)

+ GetEntropy func(record.PulseNum) ([]byte, error)

+ GetObjectIndex func(*record.Reference) (*index.ObjectLifeline, error)

+ GetRecord func(*record.Reference) (record.Record, error)

+ SetClassIndex func(*record.Reference, *index.ClassLifeline) error

+ SetCurrentPulse func(record.PulseNum)

+ SetDrop func(record.PulseNum, *jetdrop.JetDrop) (*jetdrop.JetDrop, error)

+ SetEntropy func(record.PulseNum, []byte) error

+ SetObjectIndex func(*record.Reference, *index.ObjectLifeline) error

+ SetRecord func(record.Record) (*record.Reference, error)

v0.0.4

Aug 28, 2018

v0.0.3

Aug 20, 2018

Changes in this version

+ var ErrNotFound = errors.New("storage object not found")

type LedgerStorer

+ GetCurrentPulse func() record.PulseNum

+ GetDrop func(record.PulseNum) (*jetdrop.JetDrop, error)

+ GetPulseKeys func(record.PulseNum) ([][]byte, error)

+ SetDrop func(record.PulseNum, *jetdrop.JetDrop) error

v0.0.2

Aug 14, 2018

Changes in this version

+ type LedgerStorer interface

+ GetClassIndex func(*record.Reference) (*index.ClassLifeline, error)

+ GetObjectIndex func(*record.Reference) (*index.ObjectLifeline, error)

+ GetRecord func(*record.Reference) (record.Record, error)

+ SetClassIndex func(*record.Reference, *index.ClassLifeline) error

+ SetObjectIndex func(*record.Reference, *index.ObjectLifeline) error

+ SetRecord func(record.Record) (*record.Reference, error)

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