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
}

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)

func (*QECombiner) GetStateRangeScanIterator

func (c *QECombiner) GetStateRangeScanIterator(namespace string, startKey string, endKey string) (commonledger.ResultsIterator, error)

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)
}

type UpdateBatchBackedQueryExecuter

type UpdateBatchBackedQueryExecuter struct {
	UpdateBatch      *statedb.UpdateBatch
	HashUpdatesBatch *privacyenabledstate.HashedUpdateBatch
}

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)

func (*UpdateBatchBackedQueryExecuter) GetStateRangeScanIterator

func (qe *UpdateBatchBackedQueryExecuter) GetStateRangeScanIterator(namespace, startKey, endKey string) (statedb.ResultsIterator, error)