Documentation
¶
Index ¶
- type QECombiner
- func (c *QECombiner) GetPrivateDataHash(namespace, collection, key string) ([]byte, error)
- func (c *QECombiner) GetState(namespace string, key string) ([]byte, error)
- func (c *QECombiner) GetStateRangeScanIterator(namespace string, startKey string, endKey string) (commonledger.ResultsIterator, error)
- type QueryExecuter
- type UpdateBatchBackedQueryExecuter
- func (qe *UpdateBatchBackedQueryExecuter) GetPrivateDataHash(ns, coll, key string) (*statedb.VersionedValue, error)
- func (qe *UpdateBatchBackedQueryExecuter) GetState(ns, key string) (*statedb.VersionedValue, error)
- func (qe *UpdateBatchBackedQueryExecuter) GetStateRangeScanIterator(namespace, startKey, endKey string) (statedb.ResultsIterator, error)
Constants ¶
This section is empty.
Variables ¶
This section is empty.
Functions ¶
This section is empty.
Types ¶
type QECombiner ¶
type QECombiner struct {
QueryExecuters []QueryExecuter // actual executers in decending order of priority
}
QECombiner combines the query results from one or more underlying 'queryExecuters' In case, the same key is returned by multiple 'queryExecuters', the first 'queryExecuter' in the input is considered having the latest state of the key
func (*QECombiner) GetPrivateDataHash ¶
func (c *QECombiner) GetPrivateDataHash(namespace, collection, key string) ([]byte, error)
func (*QECombiner) GetState ¶
func (c *QECombiner) GetState(namespace string, key string) ([]byte, error)
GetState implements function in the interface ledger.SimpleQueryExecutor
func (*QECombiner) GetStateRangeScanIterator ¶
func (c *QECombiner) GetStateRangeScanIterator(namespace string, startKey string, endKey string) (commonledger.ResultsIterator, error)
GetStateRangeScanIterator implements function in the interface ledger.SimpleQueryExecutor
type QueryExecuter ¶
type QueryExecuter interface {
GetState(namespace, key string) (*statedb.VersionedValue, error)
GetStateRangeScanIterator(namespace, startKey, endKey string) (statedb.ResultsIterator, error)
GetPrivateDataHash(namespace, collection, key string) (*statedb.VersionedValue, error)
}
QueryExecuter encapsulates query functions
type UpdateBatchBackedQueryExecuter ¶
type UpdateBatchBackedQueryExecuter struct {
UpdateBatch *statedb.UpdateBatch
HashUpdatesBatch *privacyenabledstate.HashedUpdateBatch
}
UpdateBatchBackedQueryExecuter wraps an update batch for providing functions in the interface 'queryExecuter'
func (*UpdateBatchBackedQueryExecuter) GetPrivateDataHash ¶
func (qe *UpdateBatchBackedQueryExecuter) GetPrivateDataHash(ns, coll, key string) (*statedb.VersionedValue, error)
func (*UpdateBatchBackedQueryExecuter) GetState ¶
func (qe *UpdateBatchBackedQueryExecuter) GetState(ns, key string) (*statedb.VersionedValue, error)
GetState implements function in interface 'queryExecuter'
func (*UpdateBatchBackedQueryExecuter) GetStateRangeScanIterator ¶
func (qe *UpdateBatchBackedQueryExecuter) GetStateRangeScanIterator(namespace, startKey, endKey string) (statedb.ResultsIterator, error)
GetStateRangeScanIterator implements function in interface 'queryExecuter'
Source Files
Directories