privacyenabledstate

Jan 28, 2021

Changes in this version

type KVWriteProto

+ XXX_NoUnkeyedLiteral struct{}

+ XXX_sizecache int32

+ XXX_unrecognized []byte

+ func (dst *KVWriteProto) XXX_Merge(src proto.Message)

+ func (m *KVWriteProto) XXX_DiscardUnknown()

+ func (m *KVWriteProto) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)

+ func (m *KVWriteProto) XXX_Size() int

+ func (m *KVWriteProto) XXX_Unmarshal(b []byte) error

type KVWritesBatchProto

+ XXX_NoUnkeyedLiteral struct{}

+ XXX_sizecache int32

+ XXX_unrecognized []byte

+ func (dst *KVWritesBatchProto) XXX_Merge(src proto.Message)

+ func (m *KVWritesBatchProto) XXX_DiscardUnknown()

+ func (m *KVWritesBatchProto) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)

+ func (m *KVWritesBatchProto) XXX_Size() int

+ func (m *KVWritesBatchProto) XXX_Unmarshal(b []byte) error

Jul 17, 2019

Changes in this version

+ 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 UpdatesBytesBuilder struct

+ func (bb *UpdatesBytesBuilder) DeterministicBytesForPubAndHashUpdates(u *UpdateBatch) ([]byte, error)

Apr 11, 2019

Changes in this version

type CommonStorageDBProvider

+ HealthCheckRegistry ledger.HealthCheckRegistry

+ func (p *CommonStorageDBProvider) RegisterHealthChecker() error

Jan 9, 2019

Changes in this version

+ type PvtKVWrite struct

+ IsDelete bool

+ Key string

+ Value []byte

+ Version *version.Height

+ type PvtdataCompositeKeyMap map[PvtdataCompositeKey]*statedb.VersionedValue

Oct 10, 2018

Changes in this version

type CommonStorageDB

+ func (s *CommonStorageDB) GetPrivateDataMetadataByHash(namespace, collection string, keyHash []byte) ([]byte, error)

+ func (s *CommonStorageDB) GetStateMetadata(namespace, key string) ([]byte, error)

type DB

+ GetPrivateDataMetadataByHash func(namespace, collection string, keyHash []byte) ([]byte, error)

+ GetStateMetadata func(namespace, key string) ([]byte, error)

type HashedUpdateBatch

+ func (h HashedUpdateBatch) PutValHashAndMetadata(ns, coll string, key []byte, value []byte, metadata []byte, ...)

type UpdateMap

+ func (b UpdateMap) PutValAndMetadata(ns, coll, key string, value []byte, metadata []byte, version *version.Height)

Jul 3, 2018

Changes in this version

type CommonStorageDB

+ func (s *CommonStorageDB) ChaincodeDeployDone(succeeded bool)

+ func (s *CommonStorageDB) HandleChaincodeDeploy(chaincodeDefinition *cceventmgmt.ChaincodeDefinition, dbArtifactsTar []byte) error

type HashedCompositeKey

+ func (hck *HashedCompositeKey) String() string

type HashedUpdateBatch

+ func (h HashedUpdateBatch) ToCompositeKeyMap() map[HashedCompositeKey]*statedb.VersionedValue

type PvtUpdateBatch

+ func (p PvtUpdateBatch) ToCompositeKeyMap() map[PvtdataCompositeKey]*statedb.VersionedValue

+ type PvtdataCompositeKey struct

+ CollectionName string

+ Key string

+ Namespace string

type UpdateMap

+ func (b UpdateMap) Contains(ns, coll, key string) bool

Mar 15, 2018

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) 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) GetPrivateDataMultipleKeys(namespace, collection string, keys []string) ([]*statedb.VersionedValue, error)

+ func (s *CommonStorageDB) GetPrivateDataRangeScanIterator(namespace, collection, startKey, endKey string) (statedb.ResultsIterator, error)

+ func (s *CommonStorageDB) GetValueHash(namespace, collection string, keyHash []byte) (*statedb.VersionedValue, 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

+ func (p *CommonStorageDBProvider) Close()

+ func (p *CommonStorageDBProvider) GetDBHandle(id string) (DB, 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)

+ GetPrivateDataMultipleKeys func(namespace, collection string, keys []string) ([]*statedb.VersionedValue, error)

+ GetPrivateDataRangeScanIterator func(namespace, collection, startKey, endKey string) (statedb.ResultsIterator, 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) (DB, error)

+ type DBProvider interface

+ Close func()

+ GetDBHandle func(id string) (DB, error)

+ func NewCommonStorageDBProvider() (DBProvider, error)

+ type HashedCompositeKey struct

+ CollectionName string

+ KeyHash string

+ Namespace 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)

+ 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 PvtUpdateBatch struct

+ func NewPvtUpdateBatch() *PvtUpdateBatch

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