Versions in this module Expand all Collapse all v2 v2.3.2 Nov 21, 2021 Changes in this version + const CouchDB + const GoLevelDB + type BlockAndPvtData struct + Block *common.Block + MissingPvtData TxMissingPvtData + PvtData TxPvtDataMap + type BlockPvtdata struct + MissingPvtData TxMissingPvtData + PvtData TxPvtDataMap + type ChaincodeDefinition struct + CollectionConfigs *peer.CollectionConfigPackage + Hash []byte + Name string + Version string + func (cdef *ChaincodeDefinition) String() string + type ChaincodeLifecycleDetails struct + CollectionsRemoved []string + CollectionsUpdated []string + HashChanged bool + Updated bool + type ChaincodeLifecycleEventListener interface + ChaincodeDeployDone func(succeeded bool) + HandleChaincodeDeploy func(chaincodeDefinition *ChaincodeDefinition, dbArtifactsTar []byte) error + type ChaincodeLifecycleEventProvider interface + RegisterListener func(channelID string, listener ChaincodeLifecycleEventListener, ...) error + type ChaincodeLifecycleInfo struct + Deleted bool + Details *ChaincodeLifecycleDetails + Name string + type CollConfigNotDefinedError struct + Ns string + func (e *CollConfigNotDefinedError) Error() string + type CollectionConfigInfo struct + CollectionConfig *peer.CollectionConfigPackage + CommittingBlockNum uint64 + type CollectionPvtdataInfo struct + Collection string + CollectionConfig *peer.StaticCollectionConfig + Endorsers []*peer.Endorsement + ExpectedHash []byte + Namespace string + type CommitOptions struct + FetchPvtDataFromLedger bool + type Config struct + HistoryDBConfig *HistoryDBConfig + PrivateDataConfig *PrivateDataConfig + RootFSPath string + SnapshotsConfig *SnapshotsConfig + StateDBConfig *StateDBConfig + type ConfigHistoryRetriever interface + MostRecentCollectionConfigBelow func(blockNum uint64, chaincodeName string) (*CollectionConfigInfo, error) + type CouchDBConfig struct + Address string + CreateGlobalChangesDB bool + InternalQueryLimit int + MaxBatchUpdateSize int + MaxRetries int + MaxRetriesOnStartup int + Password string + RedoLogPath string + RequestTimeout time.Duration + UserCacheSizeMBs int + Username string + WarmIndexesAfterNBlocks int + type CustomTxProcessor interface + GenerateSimulationResults func(txEnvelop *common.Envelope, simulator TxSimulator, initializingLedger bool) error + type DeployedChaincodeInfo struct + ExplicitCollectionConfigPkg *peer.CollectionConfigPackage + Hash []byte + IsLegacy bool + Name string + Version string + type DeployedChaincodeInfoProvider interface + AllChaincodesInfo func(channelName string, qe SimpleQueryExecutor) (map[string]*DeployedChaincodeInfo, error) + AllCollectionsConfigPkg func(channelName, chaincodeName string, qe SimpleQueryExecutor) (*peer.CollectionConfigPackage, error) + ChaincodeInfo func(channelName, chaincodeName string, qe SimpleQueryExecutor) (*DeployedChaincodeInfo, error) + CollectionInfo func(channelName, chaincodeName, collectionName string, qe SimpleQueryExecutor) (*peer.StaticCollectionConfig, error) + GenerateImplicitCollectionForOrg func(mspid string) *peer.StaticCollectionConfig + ImplicitCollections func(channelName, chaincodeName string, qe SimpleQueryExecutor) ([]*peer.StaticCollectionConfig, error) + Namespaces func() []string + UpdatedChaincodes func(stateUpdates map[string][]*kvrwset.KVWrite) ([]*ChaincodeLifecycleInfo, error) + type HashProvider interface + GetHash func(opts bccsp.HashOpts) (hash.Hash, error) + type HealthCheckRegistry interface + RegisterChecker func(string, healthz.HealthChecker) error + type HistoryDBConfig struct + Enabled bool + type HistoryQueryExecutor interface + GetHistoryForKey func(namespace string, key string) (commonledger.ResultsIterator, error) + type Initializer struct + ChaincodeLifecycleEventProvider ChaincodeLifecycleEventProvider + Config *Config + CustomTxProcessors map[common.HeaderType]CustomTxProcessor + DeployedChaincodeInfoProvider DeployedChaincodeInfoProvider + HashProvider HashProvider + HealthCheckRegistry HealthCheckRegistry + MembershipInfoProvider MembershipInfoProvider + MetricsProvider metrics.Provider + StateListeners []StateListener + type InvalidCollNameError struct + Coll string + Ns string + func (e *InvalidCollNameError) Error() string + type InvalidTxError struct + Msg string + func (e *InvalidTxError) Error() string + type KVStateUpdates struct + CollHashUpdates map[string][]*kvrwset.KVWriteHash + PublicUpdates []*kvrwset.KVWrite + type MembershipInfoProvider interface + AmMemberOf func(channelName string, collectionPolicyConfig *peer.CollectionPolicyConfig) (bool, error) + MyImplicitCollectionName func() string + type MissingBlockPvtdataInfo map[uint64][]*MissingCollectionPvtDataInfo + type MissingCollectionPvtDataInfo struct + Collection string + Namespace string + type MissingPvtData struct + Collection string + IsEligible bool + Namespace string + type MissingPvtDataInfo map[uint64]MissingBlockPvtdataInfo + func (missingPvtDataInfo MissingPvtDataInfo) Add(blkNum, txNum uint64, ns, coll string) + type MissingPvtDataTracker interface + GetMissingPvtDataInfoForMostRecentBlocks func(maxBlocks int) (MissingPvtDataInfo, error) + type PeerLedger interface + CancelSnapshotRequest func(height uint64) error + CommitLegacy func(blockAndPvtdata *BlockAndPvtData, commitOpts *CommitOptions) error + CommitPvtDataOfOldBlocks func(reconciledPvtdata []*ReconciledPvtdata, unreconciled MissingPvtDataInfo) ([]*PvtdataHashMismatch, error) + DoesPvtDataInfoExist func(blockNum uint64) (bool, error) + GetBlockByHash func(blockHash []byte) (*common.Block, error) + GetBlockByTxID func(txID string) (*common.Block, error) + GetConfigHistoryRetriever func() (ConfigHistoryRetriever, error) + GetMissingPvtDataTracker func() (MissingPvtDataTracker, error) + GetPvtDataAndBlockByNum func(blockNum uint64, filter PvtNsCollFilter) (*BlockAndPvtData, error) + GetPvtDataByNum func(blockNum uint64, filter PvtNsCollFilter) ([]*TxPvtData, error) + GetTransactionByID func(txID string) (*peer.ProcessedTransaction, error) + GetTxValidationCodeByTxID func(txID string) (peer.TxValidationCode, error) + NewHistoryQueryExecutor func() (HistoryQueryExecutor, error) + NewQueryExecutor func() (QueryExecutor, error) + NewTxSimulator func(txid string) (TxSimulator, error) + PendingSnapshotRequests func() ([]uint64, error) + SubmitSnapshotRequest func(height uint64) error + TxIDExists func(txID string) (bool, error) + type PeerLedgerProvider interface + Close func() + CreateFromGenesisBlock func(genesisBlock *common.Block) (PeerLedger, error) + CreateFromSnapshot func(snapshotDir string) (PeerLedger, string, error) + Exists func(ledgerID string) (bool, error) + List func() ([]string, error) + Open func(ledgerID string) (PeerLedger, error) + type PrivateDataConfig struct + BatchesInterval int + DeprioritizedDataReconcilerInterval time.Duration + MaxBatchSize int + PurgeInterval int + type PvtCollFilter map[string]bool + type PvtNsCollFilter map[string]PvtCollFilter + func NewPvtNsCollFilter() PvtNsCollFilter + func (filter PvtNsCollFilter) Add(ns string, coll string) + func (filter PvtNsCollFilter) Has(ns string, coll string) bool + type PvtdataHashMismatch struct + BlockNum uint64 + Collection string + Namespace string + TxNum uint64 + type QueryExecutor interface + Done func() + ExecuteQuery func(namespace, query string) (commonledger.ResultsIterator, error) + ExecuteQueryOnPrivateData func(namespace, collection, query string) (commonledger.ResultsIterator, error) + ExecuteQueryWithPagination func(namespace, query, bookmark string, pageSize int32) (QueryResultsIterator, error) + GetPrivateData func(namespace, collection, key string) ([]byte, error) + GetPrivateDataMetadata func(namespace, collection, key string) (map[string][]byte, error) + GetPrivateDataMetadataByHash func(namespace, collection string, keyhash []byte) (map[string][]byte, error) + GetPrivateDataMultipleKeys func(namespace, collection string, keys []string) ([][]byte, error) + GetPrivateDataRangeScanIterator func(namespace, collection, startKey, endKey string) (commonledger.ResultsIterator, error) + GetStateMetadata func(namespace, key string) (map[string][]byte, error) + GetStateMultipleKeys func(namespace string, keys []string) ([][]byte, error) + GetStateRangeScanIteratorWithPagination func(namespace string, startKey, endKey string, pageSize int32) (QueryResultsIterator, error) + type QueryResultsIterator interface + GetBookmarkAndClose func() string + type ReconciledPvtdata struct + BlockNum uint64 + WriteSets TxPvtDataMap + type RetrievedPvtdata interface + GetBlockPvtdata func() *BlockPvtdata + Purge func() + type SimpleQueryExecutor interface + GetPrivateDataHash func(namespace, collection, key string) ([]byte, error) + GetState func(namespace string, key string) ([]byte, error) + GetStateRangeScanIterator func(namespace string, startKey string, endKey string) (commonledger.ResultsIterator, error) + type SnapshotsConfig struct + RootDir string + type StateDBConfig struct + CouchDB *CouchDBConfig + StateDatabase string + type StateListener interface + HandleStateUpdates func(trigger *StateUpdateTrigger) error + Initialize func(ledgerID string, qe SimpleQueryExecutor) error + InterestedInNamespaces func() []string + Name func() string + StateCommitDone func(channelID string) + type StateUpdateTrigger struct + CommittedStateQueryExecutor SimpleQueryExecutor + CommittingBlockNum uint64 + LedgerID string + PostCommitQueryExecutor SimpleQueryExecutor + StateUpdates StateUpdates + type StateUpdates map[string]*KVStateUpdates + type TxMissingPvtData map[uint64][]*MissingPvtData + func (txMissingPvtData TxMissingPvtData) Add(txNum uint64, ns, coll string, isEligible bool) + type TxPvtData struct + SeqInBlock uint64 + WriteSet *rwset.TxPvtReadWriteSet + func (pvtdata *TxPvtData) Has(ns string, coll string) bool + type TxPvtDataMap map[uint64]*TxPvtData + type TxPvtdataInfo struct + CollectionPvtdataInfo []*CollectionPvtdataInfo + Invalid bool + SeqInBlock uint64 + TxID string + type TxSimulationResults struct + PubSimulationResults *rwset.TxReadWriteSet + PvtSimulationResults *rwset.TxPvtReadWriteSet + func (txSim *TxSimulationResults) ContainsPvtWrites() bool + func (txSim *TxSimulationResults) GetPubSimulationBytes() ([]byte, error) + func (txSim *TxSimulationResults) GetPvtSimulationBytes() ([]byte, error) + type TxSimulator interface + DeletePrivateData func(namespace, collection, key string) error + DeletePrivateDataMetadata func(namespace, collection, key string) error + DeleteState func(namespace string, key string) error + DeleteStateMetadata func(namespace, key string) error + ExecuteUpdate func(query string) error + GetTxSimulationResults func() (*TxSimulationResults, error) + SetPrivateData func(namespace, collection, key string, value []byte) error + SetPrivateDataMetadata func(namespace, collection, key string, metadata map[string][]byte) error + SetPrivateDataMultipleKeys func(namespace, collection string, kvs map[string][]byte) error + SetState func(namespace string, key string, value []byte) error + SetStateMetadata func(namespace, key string, metadata map[string][]byte) error + SetStateMultipleKeys func(namespace string, kvs map[string][]byte) error Other modules containing this package github.com/waszqt/fabric
Go to main page