queryutil

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)

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'