Versions in this module Expand all Collapse all v1 v1.4.6 Feb 25, 2020 Changes in this version + type CommonStorageDB struct + func (s *CommonStorageDB) ApplyPrivacyAwareUpdates(updates *UpdateBatch, height *version.Height) error + func (s *CommonStorageDB) ApplyUpdates(batch *statedb.UpdateBatch, height *version.Height) error + func (s *CommonStorageDB) ChaincodeDeployDone(succeeded bool) + func (s *CommonStorageDB) ClearCachedVersions() + func (s *CommonStorageDB) GetCachedKeyHashVersion(namespace, collection string, keyHash []byte) (*version.Height, bool) + func (s *CommonStorageDB) GetChaincodeEventListener() cceventmgmt.ChaincodeLifecycleEventListener + func (s *CommonStorageDB) GetKeyHashVersion(namespace, collection string, keyHash []byte) (*version.Height, error) + func (s *CommonStorageDB) GetPrivateData(namespace, collection, key string) (*statedb.VersionedValue, error) + func (s *CommonStorageDB) GetPrivateDataMetadataByHash(namespace, collection string, keyHash []byte) ([]byte, error) + func (s *CommonStorageDB) GetPrivateDataMultipleKeys(namespace, collection string, keys []string) ([]*statedb.VersionedValue, error) + func (s *CommonStorageDB) GetPrivateDataRangeScanIterator(namespace, collection, startKey, endKey string) (statedb.ResultsIterator, error) + func (s *CommonStorageDB) GetStateMetadata(namespace, key string) ([]byte, error) + func (s *CommonStorageDB) GetValueHash(namespace, collection string, keyHash []byte) (*statedb.VersionedValue, error) + func (s *CommonStorageDB) HandleChaincodeDeploy(chaincodeDefinition *cceventmgmt.ChaincodeDefinition, dbArtifactsTar []byte) error + func (s *CommonStorageDB) IsBulkOptimizable() bool + func (s *CommonStorageDB) LoadCommittedVersionsOfPubAndHashedKeys(pubKeys []*statedb.CompositeKey, hashedKeys []*HashedCompositeKey) error + func (s CommonStorageDB) ExecuteQueryOnPrivateData(namespace, collection, query string) (statedb.ResultsIterator, error) + type CommonStorageDBProvider struct + HealthCheckRegistry ledger.HealthCheckRegistry + func (p *CommonStorageDBProvider) Close() + func (p *CommonStorageDBProvider) GetDBHandle(id string) (DB, error) + func (p *CommonStorageDBProvider) RegisterHealthChecker() error + type CouchDBCommonStorageTestEnv struct + func (env *CouchDBCommonStorageTestEnv) Cleanup() + func (env *CouchDBCommonStorageTestEnv) GetDBHandle(id string) DB + func (env *CouchDBCommonStorageTestEnv) GetName() string + func (env *CouchDBCommonStorageTestEnv) Init(t testing.TB) + type DB interface + ApplyPrivacyAwareUpdates func(updates *UpdateBatch, height *version.Height) error + ClearCachedVersions func() + ExecuteQueryOnPrivateData func(namespace, collection, query string) (statedb.ResultsIterator, error) + GetCachedKeyHashVersion func(namespace, collection string, keyHash []byte) (*version.Height, bool) + GetChaincodeEventListener func() cceventmgmt.ChaincodeLifecycleEventListener + GetKeyHashVersion func(namespace, collection string, keyHash []byte) (*version.Height, error) + GetPrivateData func(namespace, collection, key string) (*statedb.VersionedValue, error) + GetPrivateDataMetadataByHash func(namespace, collection string, keyHash []byte) ([]byte, error) + GetPrivateDataMultipleKeys func(namespace, collection string, keys []string) ([]*statedb.VersionedValue, error) + GetPrivateDataRangeScanIterator func(namespace, collection, startKey, endKey string) (statedb.ResultsIterator, error) + GetStateMetadata func(namespace, key string) ([]byte, error) + GetValueHash func(namespace, collection string, keyHash []byte) (*statedb.VersionedValue, error) + IsBulkOptimizable func() bool + LoadCommittedVersionsOfPubAndHashedKeys func(pubKeys []*statedb.CompositeKey, hashedKeys []*HashedCompositeKey) error + func NewCommonStorageDB(vdb statedb.VersionedDB, ledgerid string, metadataHint *metadataHint) (DB, error) + type DBProvider interface + Close func() + GetDBHandle func(id string) (DB, error) + func NewCommonStorageDBProvider(bookkeeperProvider bookkeeping.Provider, metricsProvider metrics.Provider, ...) (DBProvider, error) + type HashedCompositeKey struct + CollectionName string + KeyHash string + Namespace string + func (hck *HashedCompositeKey) String() string + type HashedUpdateBatch struct + func NewHashedUpdateBatch() *HashedUpdateBatch + func (h HashedUpdateBatch) Contains(ns, coll string, keyHash []byte) bool + func (h HashedUpdateBatch) Delete(ns, coll string, key []byte, version *version.Height) + func (h HashedUpdateBatch) Put(ns, coll string, key []byte, value []byte, version *version.Height) + func (h HashedUpdateBatch) PutValHashAndMetadata(ns, coll string, key []byte, value []byte, metadata []byte, ...) + func (h HashedUpdateBatch) ToCompositeKeyMap() map[HashedCompositeKey]*statedb.VersionedValue + type KVWriteProto struct + Collection string + IsDelete bool + Key []byte + Namespace string + Value []byte + VersionBytes []byte + func (*KVWriteProto) Descriptor() ([]byte, []int) + func (*KVWriteProto) ProtoMessage() + func (m *KVWriteProto) GetCollection() string + func (m *KVWriteProto) GetIsDelete() bool + func (m *KVWriteProto) GetKey() []byte + func (m *KVWriteProto) GetNamespace() string + func (m *KVWriteProto) GetValue() []byte + func (m *KVWriteProto) GetVersionBytes() []byte + func (m *KVWriteProto) Reset() + func (m *KVWriteProto) String() string + type KVWritesBatchProto struct + Kvwrites []*KVWriteProto + func (*KVWritesBatchProto) Descriptor() ([]byte, []int) + func (*KVWritesBatchProto) ProtoMessage() + func (m *KVWritesBatchProto) GetKvwrites() []*KVWriteProto + func (m *KVWritesBatchProto) Reset() + func (m *KVWritesBatchProto) String() string + type LevelDBCommonStorageTestEnv struct + func (env *LevelDBCommonStorageTestEnv) Cleanup() + func (env *LevelDBCommonStorageTestEnv) GetDBHandle(id string) DB + func (env *LevelDBCommonStorageTestEnv) GetName() string + func (env *LevelDBCommonStorageTestEnv) Init(t testing.TB) + type PubUpdateBatch struct + func NewPubUpdateBatch() *PubUpdateBatch + type PvtKVWrite struct + IsDelete bool + Key string + Value []byte + Version *version.Height + type PvtUpdateBatch struct + func NewPvtUpdateBatch() *PvtUpdateBatch + func (p PvtUpdateBatch) ToCompositeKeyMap() PvtdataCompositeKeyMap + type PvtdataCompositeKey struct + CollectionName string + Key string + Namespace string + type PvtdataCompositeKeyMap map[PvtdataCompositeKey]*statedb.VersionedValue + type TestEnv interface + Cleanup func() + GetDBHandle func(id string) DB + GetName func() string + Init func(t testing.TB) + type UpdateBatch struct + HashUpdates *HashedUpdateBatch + PubUpdates *PubUpdateBatch + PvtUpdates *PvtUpdateBatch + func NewUpdateBatch() *UpdateBatch + type UpdateMap map[string]nsBatch + func (b UpdateMap) Contains(ns, coll, key string) bool + func (b UpdateMap) Delete(ns, coll, key string, version *version.Height) + func (b UpdateMap) Get(ns, coll, key string) *statedb.VersionedValue + func (b UpdateMap) IsEmpty() bool + func (b UpdateMap) Put(ns, coll, key string, value []byte, version *version.Height) + func (b UpdateMap) PutValAndMetadata(ns, coll, key string, value []byte, metadata []byte, version *version.Height) + type UpdatesBytesBuilder struct + func (bb *UpdatesBytesBuilder) DeterministicBytesForPubAndHashUpdates(u *UpdateBatch) ([]byte, error) Incompatible versions in this module v2.0.1+incompatible Feb 26, 2020
Go to main page