Versions in this module Expand all Collapse all v2 v2.3.2 Nov 21, 2021 Changes in this version + type BootKVHash struct + KeyHash []byte + ValueHash []byte + XXX_NoUnkeyedLiteral struct{} + XXX_sizecache int32 + XXX_unrecognized []byte + func (*BootKVHash) Descriptor() ([]byte, []int) + func (*BootKVHash) ProtoMessage() + func (m *BootKVHash) GetKeyHash() []byte + func (m *BootKVHash) GetValueHash() []byte + func (m *BootKVHash) Reset() + func (m *BootKVHash) String() string + func (m *BootKVHash) XXX_DiscardUnknown() + func (m *BootKVHash) XXX_Marshal(b []byte, deterministic bool) ([]byte, error) + func (m *BootKVHash) XXX_Merge(src proto.Message) + func (m *BootKVHash) XXX_Size() int + func (m *BootKVHash) XXX_Unmarshal(b []byte) error + type BootKVHashes struct + List []*BootKVHash + XXX_NoUnkeyedLiteral struct{} + XXX_sizecache int32 + XXX_unrecognized []byte + func (*BootKVHashes) Descriptor() ([]byte, []int) + func (*BootKVHashes) ProtoMessage() + func (m *BootKVHashes) GetList() []*BootKVHash + func (m *BootKVHashes) Reset() + func (m *BootKVHashes) String() string + func (m *BootKVHashes) XXX_DiscardUnknown() + func (m *BootKVHashes) XXX_Marshal(b []byte, deterministic bool) ([]byte, error) + func (m *BootKVHashes) XXX_Merge(src proto.Message) + func (m *BootKVHashes) XXX_Size() int + func (m *BootKVHashes) XXX_Unmarshal(b []byte) error + type CollElgInfo struct + NsCollMap map[string]*CollNames + XXX_NoUnkeyedLiteral struct{} + XXX_sizecache int32 + XXX_unrecognized []byte + func (*CollElgInfo) Descriptor() ([]byte, []int) + func (*CollElgInfo) ProtoMessage() + func (m *CollElgInfo) GetNsCollMap() map[string]*CollNames + func (m *CollElgInfo) Reset() + func (m *CollElgInfo) String() string + func (m *CollElgInfo) XXX_DiscardUnknown() + func (m *CollElgInfo) XXX_Marshal(b []byte, deterministic bool) ([]byte, error) + func (m *CollElgInfo) XXX_Merge(src proto.Message) + func (m *CollElgInfo) XXX_Size() int + func (m *CollElgInfo) XXX_Unmarshal(b []byte) error + type CollNames struct + Entries []string + XXX_NoUnkeyedLiteral struct{} + XXX_sizecache int32 + XXX_unrecognized []byte + func (*CollNames) Descriptor() ([]byte, []int) + func (*CollNames) ProtoMessage() + func (m *CollNames) GetEntries() []string + func (m *CollNames) Reset() + func (m *CollNames) String() string + func (m *CollNames) XXX_DiscardUnknown() + func (m *CollNames) XXX_Marshal(b []byte, deterministic bool) ([]byte, error) + func (m *CollNames) XXX_Merge(src proto.Message) + func (m *CollNames) XXX_Size() int + func (m *CollNames) XXX_Unmarshal(b []byte) error + type ExpiryData struct + Map map[string]*NamespaceExpiryData + XXX_NoUnkeyedLiteral struct{} + XXX_sizecache int32 + XXX_unrecognized []byte + func (*ExpiryData) Descriptor() ([]byte, []int) + func (*ExpiryData) ProtoMessage() + func (m *ExpiryData) GetMap() map[string]*NamespaceExpiryData + func (m *ExpiryData) Reset() + func (m *ExpiryData) String() string + func (m *ExpiryData) XXX_DiscardUnknown() + func (m *ExpiryData) XXX_Marshal(b []byte, deterministic bool) ([]byte, error) + func (m *ExpiryData) XXX_Merge(src proto.Message) + func (m *ExpiryData) XXX_Size() int + func (m *ExpiryData) XXX_Unmarshal(b []byte) error + type NamespaceExpiryData struct + BootKVHashes map[string]*TxNums + MissingData map[string]bool + PresentData map[string]*TxNums + XXX_NoUnkeyedLiteral struct{} + XXX_sizecache int32 + XXX_unrecognized []byte + func (*NamespaceExpiryData) Descriptor() ([]byte, []int) + func (*NamespaceExpiryData) ProtoMessage() + func (m *NamespaceExpiryData) GetBootKVHashes() map[string]*TxNums + func (m *NamespaceExpiryData) GetMissingData() map[string]bool + func (m *NamespaceExpiryData) GetPresentData() map[string]*TxNums + func (m *NamespaceExpiryData) Reset() + func (m *NamespaceExpiryData) String() string + func (m *NamespaceExpiryData) XXX_DiscardUnknown() + func (m *NamespaceExpiryData) XXX_Marshal(b []byte, deterministic bool) ([]byte, error) + func (m *NamespaceExpiryData) XXX_Merge(src proto.Message) + func (m *NamespaceExpiryData) XXX_Size() int + func (m *NamespaceExpiryData) XXX_Unmarshal(b []byte) error + type PrivateDataConfig struct + StorePath string + type Provider struct + func NewProvider(conf *PrivateDataConfig) (*Provider, error) + func (p *Provider) Close() + func (p *Provider) Drop(ledgerid string) error + func (p *Provider) OpenStore(ledgerid string) (*Store, error) + func (p *Provider) SnapshotDataImporterFor(ledgerID string, lastBlockInSnapshot uint64, ...) (*SnapshotDataImporter, error) + type SnapshotDataImporter struct + func (i *SnapshotDataImporter) ConsumeSnapshotData(namespace, collection string, keyHash, valueHash []byte, ...) error + func (i *SnapshotDataImporter) Done() error + type Store struct + func (s *Store) Commit(blockNum uint64, pvtData []*ledger.TxPvtData, ...) error + func (s *Store) CommitPvtDataOfOldBlocks(blocksPvtData map[uint64][]*ledger.TxPvtData, ...) error + func (s *Store) FetchBootKVHashes(blkNum, txNum uint64, ns, coll string) (map[string][]byte, error) + func (s *Store) GetLastUpdatedOldBlocksPvtData() (map[uint64][]*ledger.TxPvtData, error) + func (s *Store) GetMissingPvtDataInfoForMostRecentBlocks(maxBlock int) (ledger.MissingPvtDataInfo, error) + func (s *Store) GetPvtDataByBlockNum(blockNum uint64, filter ledger.PvtNsCollFilter) ([]*ledger.TxPvtData, error) + func (s *Store) Init(btlPolicy pvtdatapolicy.BTLPolicy) + func (s *Store) LastCommittedBlockHeight() (uint64, error) + func (s *Store) ProcessCollsEligibilityEnabled(committingBlk uint64, nsCollMap map[string][]string) error + func (s *Store) ResetLastUpdatedOldBlocksList() error + type StoreEnv struct + TestStore *Store + TestStoreProvider *Provider + func NewTestStoreEnv(t *testing.T, ledgerid string, btlPolicy pvtdatapolicy.BTLPolicy, ...) *StoreEnv + func (env *StoreEnv) Cleanup() + func (env *StoreEnv) CloseAndReopen() + type TxNums struct + List []uint64 + XXX_NoUnkeyedLiteral struct{} + XXX_sizecache int32 + XXX_unrecognized []byte + func (*TxNums) Descriptor() ([]byte, []int) + func (*TxNums) ProtoMessage() + func (m *TxNums) GetList() []uint64 + func (m *TxNums) Reset() + func (m *TxNums) String() string + func (m *TxNums) XXX_DiscardUnknown() + func (m *TxNums) XXX_Marshal(b []byte, deterministic bool) ([]byte, error) + func (m *TxNums) XXX_Merge(src proto.Message) + func (m *TxNums) XXX_Size() int + func (m *TxNums) XXX_Unmarshal(b []byte) error Other modules containing this package github.com/waszqt/fabric
Go to main page