buckettree

Documentation

Index

• Constants
• type RangeScanIterator
  • func (itr *RangeScanIterator) Close()
  • func (itr *RangeScanIterator) GetKeyValue() (string, []byte)
  • func (itr *RangeScanIterator) Next() bool
• type StateImpl
  • func NewStateImpl() *StateImpl
  • func (stateImpl *StateImpl) AddChangesForPersistence(writeBatch *gorocksdb.WriteBatch) error
  • func (stateImpl *StateImpl) ClearWorkingSet(changesPersisted bool)
  • func (stateImpl *StateImpl) ComputeCryptoHash() ([]byte, error)
  • func (stateImpl *StateImpl) Get(chaincodeID string, key string) ([]byte, error)
  • func (stateImpl *StateImpl) GetRangeScanIterator(chaincodeID string, startKey string, endKey string) (statemgmt.RangeScanIterator, error)
  • func (stateImpl *StateImpl) GetStateSnapshotIterator(snapshot *gorocksdb.Snapshot) (statemgmt.StateSnapshotIterator, error)
  • func (stateImpl *StateImpl) Initialize(configs map[string]interface{}) error
  • func (stateImpl *StateImpl) PerfHintKeyChanged(chaincodeID string, key string)
  • func (stateImpl *StateImpl) PrepareWorkingSet(stateDelta *statemgmt.StateDelta) error
• type StateSnapshotIterator
  • func (snapshotItr *StateSnapshotIterator) Close()
  • func (snapshotItr *StateSnapshotIterator) GetRawKeyValue() ([]byte, []byte)
  • func (snapshotItr *StateSnapshotIterator) Next() bool

Constants

const ConfigHashFunction = "hashFunction"

ConfigHashFunction - config name 'hashFunction'. This is not exposed in yaml file. This configuration is used for testing with custom hash-function

const ConfigMaxGroupingAtEachLevel = "maxGroupingAtEachLevel"

ConfigMaxGroupingAtEachLevel - config name 'maxGroupingAtEachLevel' as it appears in yaml file

const ConfigNumBuckets = "numBuckets"

ConfigNumBuckets - config name 'numBuckets' as it appears in yaml file

const DefaultMaxGroupingAtEachLevel = 10

DefaultMaxGroupingAtEachLevel - Number of max buckets to group at each level. Grouping is started from left. The last group may have less buckets

const DefaultNumBuckets = 10009

DefaultNumBuckets - total buckets

Types

type RangeScanIterator

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

RangeScanIterator implements the interface 'statemgmt.RangeScanIterator'

func (*RangeScanIterator) Close

func (itr *RangeScanIterator) Close()

Close - see interface 'statemgmt.RangeScanIterator' for details

func (*RangeScanIterator) GetKeyValue

func (itr *RangeScanIterator) GetKeyValue() (string, []byte)

GetKeyValue - see interface 'statemgmt.RangeScanIterator' for details

func (*RangeScanIterator) Next

func (itr *RangeScanIterator) Next() bool

Next - see interface 'statemgmt.RangeScanIterator' for details

type StateImpl

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

StateImpl - implements the interface - 'statemgmt.HashableState'

func NewStateImpl

func NewStateImpl() *StateImpl

NewStateImpl constructs a new StateImpl

func (*StateImpl) AddChangesForPersistence

func (stateImpl *StateImpl) AddChangesForPersistence(writeBatch *gorocksdb.WriteBatch) error

AddChangesForPersistence - method implementation for interface 'statemgmt.HashableState'

func (*StateImpl) ClearWorkingSet

func (stateImpl *StateImpl) ClearWorkingSet(changesPersisted bool)

ClearWorkingSet - method implementation for interface 'statemgmt.HashableState'

func (*StateImpl) ComputeCryptoHash

func (stateImpl *StateImpl) ComputeCryptoHash() ([]byte, error)

ComputeCryptoHash - method implementation for interface 'statemgmt.HashableState'

func (*StateImpl) Get

func (stateImpl *StateImpl) Get(chaincodeID string, key string) ([]byte, error)

Get - method implementation for interface 'statemgmt.HashableState'

func (*StateImpl) GetRangeScanIterator

func (stateImpl *StateImpl) GetRangeScanIterator(chaincodeID string, startKey string, endKey string) (statemgmt.RangeScanIterator, error)

GetRangeScanIterator - method implementation for interface 'statemgmt.HashableState'

func (*StateImpl) GetStateSnapshotIterator

func (stateImpl *StateImpl) GetStateSnapshotIterator(snapshot *gorocksdb.Snapshot) (statemgmt.StateSnapshotIterator, error)

GetStateSnapshotIterator - method implementation for interface 'statemgmt.HashableState'

func (*StateImpl) Initialize

func (stateImpl *StateImpl) Initialize(configs map[string]interface{}) error

Initialize - method implementation for interface 'statemgmt.HashableState'

func (*StateImpl) PerfHintKeyChanged

func (stateImpl *StateImpl) PerfHintKeyChanged(chaincodeID string, key string)

PerfHintKeyChanged - method implementation for interface 'statemgmt.HashableState'

func (*StateImpl) PrepareWorkingSet

func (stateImpl *StateImpl) PrepareWorkingSet(stateDelta *statemgmt.StateDelta) error

PrepareWorkingSet - method implementation for interface 'statemgmt.HashableState'

type StateSnapshotIterator

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

StateSnapshotIterator implements the interface 'statemgmt.StateSnapshotIterator'

func (*StateSnapshotIterator) Close

func (snapshotItr *StateSnapshotIterator) Close()

Close - see interface 'statemgmt.StateSnapshotIterator' for details

func (*StateSnapshotIterator) GetRawKeyValue

func (snapshotItr *StateSnapshotIterator) GetRawKeyValue() ([]byte, []byte)

GetRawKeyValue - see interface 'statemgmt.StateSnapshotIterator' for details

func (*StateSnapshotIterator) Next

func (snapshotItr *StateSnapshotIterator) Next() bool

Next - see interface 'statemgmt.StateSnapshotIterator' for details