storageManager

Documentation

Index

• type StorageManagerStub
  • func (sms *StorageManagerStub) Close() error
  • func (sms *StorageManagerStub) EnterPruningBufferingMode()
  • func (sms *StorageManagerStub) ExitPruningBufferingMode()
  • func (sms *StorageManagerStub) Get(key []byte) ([]byte, error)
  • func (sms *StorageManagerStub) GetBaseTrieStorageManager() common.StorageManager
  • func (sms *StorageManagerStub) GetFromCurrentEpoch(key []byte) ([]byte, error)
  • func (sms *StorageManagerStub) GetIdentifier() string
  • func (sms *StorageManagerStub) GetLatestStorageEpoch() (uint32, error)
  • func (sms *StorageManagerStub) GetStateStatsHandler() common.StateStatisticsHandler
  • func (sms *StorageManagerStub) IsClosed() bool
  • func (sms *StorageManagerStub) IsInterfaceNil() bool
  • func (sms *StorageManagerStub) IsPruningBlocked() bool
  • func (sms *StorageManagerStub) IsPruningEnabled() bool
  • func (sms *StorageManagerStub) IsSnapshotSupported() bool
  • func (sms *StorageManagerStub) Put(key []byte, val []byte) error
  • func (sms *StorageManagerStub) PutInEpoch(key []byte, val []byte, epoch uint32) error
  • func (sms *StorageManagerStub) PutInEpochWithoutCache(key []byte, val []byte, epoch uint32) error
  • func (sms *StorageManagerStub) Remove(hash []byte) error
  • func (sms *StorageManagerStub) RemoveFromAllActiveEpochs(hash []byte) error
  • func (sms *StorageManagerStub) RemoveFromCurrentEpoch(hash []byte) error
  • func (sms *StorageManagerStub) SetEpochForPutOperation(epoch uint32)
  • func (sms *StorageManagerStub) ShouldTakeSnapshot() bool
  • func (sms *StorageManagerStub) TakeSnapshot(address string, rootHash []byte, mainTrieRootHash []byte, ...)

Types

type StorageManagerStub

type StorageManagerStub struct {
	PutCalled                       func([]byte, []byte) error
	PutInEpochCalled                func([]byte, []byte, uint32) error
	PutInEpochWithoutCacheCalled    func([]byte, []byte, uint32) error
	GetCalled                       func([]byte) ([]byte, error)
	GetFromCurrentEpochCalled       func([]byte) ([]byte, error)
	TakeSnapshotCalled              func(string, []byte, []byte, *common.TrieIteratorChannels, chan []byte, common.SnapshotStatisticsHandler, uint32)
	GetDbThatContainsHashCalled     func([]byte) common.BaseStorer
	IsPruningEnabledCalled          func() bool
	IsPruningBlockedCalled          func() bool
	EnterPruningBufferingModeCalled func()
	ExitPruningBufferingModeCalled  func()
	RemoveFromCurrentEpochCalled    func([]byte) error
	RemoveCalled                    func([]byte) error
	IsInterfaceNilCalled            func() bool
	SetEpochForPutOperationCalled   func(uint32)
	ShouldTakeSnapshotCalled        func() bool
	GetLatestStorageEpochCalled     func() (uint32, error)
	IsClosedCalled                  func() bool
	GetBaseTrieStorageManagerCalled func() common.StorageManager
	GetIdentifierCalled             func() string
	CloseCalled                     func() error
	RemoveFromAllActiveEpochsCalled func(hash []byte) error
	IsSnapshotSupportedCalled       func() bool
	GetStateStatsHandlerCalled      func() common.StateStatisticsHandler
}

StorageManagerStub -

func (*StorageManagerStub) Close

func (sms *StorageManagerStub) Close() error

Close -

func (*StorageManagerStub) EnterPruningBufferingMode

func (sms *StorageManagerStub) EnterPruningBufferingMode()

EnterPruningBufferingMode -

func (*StorageManagerStub) ExitPruningBufferingMode

func (sms *StorageManagerStub) ExitPruningBufferingMode()

ExitPruningBufferingMode -

func (*StorageManagerStub) Get

func (sms *StorageManagerStub) Get(key []byte) ([]byte, error)

Get -

func (*StorageManagerStub) GetBaseTrieStorageManager

func (sms *StorageManagerStub) GetBaseTrieStorageManager() common.StorageManager

GetBaseTrieStorageManager -

func (*StorageManagerStub) GetFromCurrentEpoch

func (sms *StorageManagerStub) GetFromCurrentEpoch(key []byte) ([]byte, error)

GetFromCurrentEpoch -

func (*StorageManagerStub) GetIdentifier

func (sms *StorageManagerStub) GetIdentifier() string

GetIdentifier -

func (*StorageManagerStub) GetLatestStorageEpoch

func (sms *StorageManagerStub) GetLatestStorageEpoch() (uint32, error)

GetLatestStorageEpoch -

func (*StorageManagerStub) GetStateStatsHandler

func (sms *StorageManagerStub) GetStateStatsHandler() common.StateStatisticsHandler

GetStateStatsHandler -

func (*StorageManagerStub) IsClosed

func (sms *StorageManagerStub) IsClosed() bool

IsClosed -

func (*StorageManagerStub) IsInterfaceNil

func (sms *StorageManagerStub) IsInterfaceNil() bool

IsInterfaceNil -

func (*StorageManagerStub) IsPruningBlocked

func (sms *StorageManagerStub) IsPruningBlocked() bool

IsPruningBlocked -

func (*StorageManagerStub) IsPruningEnabled

func (sms *StorageManagerStub) IsPruningEnabled() bool

IsPruningEnabled -

func (*StorageManagerStub) IsSnapshotSupported

func (sms *StorageManagerStub) IsSnapshotSupported() bool

IsSnapshotSupported -

func (*StorageManagerStub) Put

func (sms *StorageManagerStub) Put(key []byte, val []byte) error

Put -

func (*StorageManagerStub) PutInEpoch

func (sms *StorageManagerStub) PutInEpoch(key []byte, val []byte, epoch uint32) error

PutInEpoch -

func (*StorageManagerStub) PutInEpochWithoutCache

func (sms *StorageManagerStub) PutInEpochWithoutCache(key []byte, val []byte, epoch uint32) error

PutInEpochWithoutCache -

func (*StorageManagerStub) Remove

func (sms *StorageManagerStub) Remove(hash []byte) error

Remove -

func (*StorageManagerStub) RemoveFromAllActiveEpochs

func (sms *StorageManagerStub) RemoveFromAllActiveEpochs(hash []byte) error

RemoveFromAllActiveEpochs -

func (*StorageManagerStub) RemoveFromCurrentEpoch

func (sms *StorageManagerStub) RemoveFromCurrentEpoch(hash []byte) error

RemoveFromCurrentEpoch -

func (*StorageManagerStub) SetEpochForPutOperation

func (sms *StorageManagerStub) SetEpochForPutOperation(epoch uint32)

SetEpochForPutOperation -

func (*StorageManagerStub) ShouldTakeSnapshot

func (sms *StorageManagerStub) ShouldTakeSnapshot() bool

ShouldTakeSnapshot -

func (*StorageManagerStub) TakeSnapshot

func (sms *StorageManagerStub) TakeSnapshot(
	address string,
	rootHash []byte,
	mainTrieRootHash []byte,
	iteratorChannels *common.TrieIteratorChannels,
	missingNodesChan chan []byte,
	stats common.SnapshotStatisticsHandler,
	epoch uint32,
)

TakeSnapshot -