Versions in this module Expand all Collapse all v1 v1.4.9 Jul 22, 2021 Changes in this version + const TransientBlockRetentionDefault + func GetBtlPullMargin() uint64 + func GetTransientBlockRetention() uint64 + func NewPuller(metrics *metrics.PrivdataMetrics, cs privdata.CollectionStore, g gossip, ...) *puller + type AppCapabilities interface + type CapabilityProvider interface + Capabilities func() channelconfig.ApplicationCapabilities + type CollectionAccessFactory interface + AccessPolicy func(config *common.CollectionConfig, chainID string) (privdata.CollectionAccessPolicy, error) + func NewCollectionAccessFactory(factory IdentityDeserializerFactory) CollectionAccessFactory + type Coordinator interface + Close func() + GetPvtDataAndBlockByNum func(seqNum uint64, peerAuth common.SignedData) (*common.Block, util.PvtDataCollections, error) + LedgerHeight func() (uint64, error) + StoreBlock func(block *common.Block, data util.PvtDataCollections) error + StorePvtData func(txid string, privData *transientstore2.TxPvtReadWriteSetWithConfigInfo, ...) error + func NewCoordinator(mspID string, support Support, selfSignedData common.SignedData, ...) Coordinator + type CoordinatorConfig struct + PullRetryThreshold time.Duration + SkipPullingInvalidTransactions bool + TransientBlockRetention uint64 + type DataStore interface + GetConfigHistoryRetriever func() (ledger.ConfigHistoryRetriever, error) + GetPvtDataByNum func(blockNum uint64, filter ledger.PvtNsCollFilter) ([]*ledger.TxPvtData, error) + GetTxPvtRWSetByTxid func(txid string, filter ledger.PvtNsCollFilter) (transientstore.RWSetScanner, error) + LedgerHeight func() (uint64, error) + type Dig2PvtRWSetWithConfig map[privdatacommon.DigKey]*util.PrivateRWSetWithConfig + type Fetcher interface + type IdentityDeserializerFactory interface + GetIdentityDeserializer func(chainID string) msp.IdentityDeserializer + type NoOpReconciler struct + func (*NoOpReconciler) Start() + func (*NoOpReconciler) Stop() + type PrivateDataRetriever interface + CollectionRWSet func(dig []*proto.PvtDataDigest, blockNum uint64) (Dig2PvtRWSetWithConfig, bool, error) + type PvtDataDistributor interface + Distribute func(txID string, privData *transientstore.TxPvtReadWriteSetWithConfigInfo, ...) error + func NewDistributor(chainID string, gossip gossipAdapter, factory CollectionAccessFactory, ...) PvtDataDistributor + type PvtDataReconciler interface + Start func() + Stop func() + type Reconciler struct + func NewReconciler(channel string, metrics *metrics.PrivdataMetrics, c committer.Committer, ...) *Reconciler + func (r *Reconciler) Start() + func (r *Reconciler) Stop() + type ReconcilerConfig struct + BatchSize int + IsEnabled bool + SleepInterval time.Duration + func GetReconcilerConfig() *ReconcilerConfig + type ReconciliationFetcher interface + FetchReconciledItems func(dig2collectionConfig privdatacommon.Dig2CollectionConfig) (*privdatacommon.FetchedPvtDataContainer, error) + type StorageDataRetriever interface + CollectionRWSet func(dig []*gossip2.PvtDataDigest, blockNum uint64) (Dig2PvtRWSetWithConfig, bool, error) + func NewDataRetriever(store DataStore) StorageDataRetriever + type Support struct + ChainID string + type TransientStore interface + GetTxPvtRWSetByTxid func(txid string, filter ledger.PvtNsCollFilter) (transientstore.RWSetScanner, error) + Persist func(txid string, blockHeight uint64, ...) error + PersistWithConfig func(txid string, blockHeight uint64, ...) error + PurgeByHeight func(maxBlockNumToRetain uint64) error + PurgeByTxids func(txids []string) error
Go to main page