privdata

type AppCapabilities interface {
	channelconfig.ApplicationCapabilities
}

type CapabilityProvider interface {
	Capabilities() channelconfig.ApplicationCapabilities
}

type CollectionAccessFactory interface {
	AccessPolicy(config *common.CollectionConfig, chainID string) (privdata.CollectionAccessPolicy, error)
}

type CollectionStore interface {
	privdata.CollectionStore
}

type Committer interface {
	committer.Committer
}

type ConfigHistoryRetriever interface {
	ledger.ConfigHistoryRetriever
}

type Coordinator interface {
	StoreBlock(block *common.Block, data util.PvtDataCollections) error

	StorePvtData(txid string, privData *protostransientstore.TxPvtReadWriteSetWithConfigInfo, blckHeight uint64) error

	GetPvtDataAndBlockByNum(seqNum uint64, peerAuth protoutil.SignedData) (*common.Block, util.PvtDataCollections, error)

	LedgerHeight() (uint64, error)

	Close()
}

type CoordinatorConfig struct {
	TransientBlockRetention        uint64
	PullRetryThreshold             time.Duration
	SkipPullingInvalidTransactions bool
}

type DataStore interface {
	GetTxPvtRWSetByTxid(txid string, filter ledger.PvtNsCollFilter) (transientstore.RWSetScanner, error)

	GetPvtDataByNum(blockNum uint64, filter ledger.PvtNsCollFilter) ([]*ledger.TxPvtData, error)

	GetConfigHistoryRetriever() (ledger.ConfigHistoryRetriever, error)

	LedgerHeight() (uint64, error)
}

type Dig2PvtRWSetWithConfig map[privdatacommon.DigKey]*util.PrivateRWSetWithConfig

type Fetcher interface {
	// contains filtered or unexported methods
}

type IdentityDeserializerFactory interface {
	GetIdentityDeserializer(chainID string) msp.IdentityDeserializer
}

type IdentityDeserializerFactoryFunc func(chainID string) msp.IdentityDeserializer

type MissingPvtDataTracker interface {
	ledger.MissingPvtDataTracker
}

type NoOpReconciler struct {
}

type PrivateDataRetriever interface {
	CollectionRWSet(dig []*protosgossip.PvtDataDigest, blockNum uint64) (Dig2PvtRWSetWithConfig, bool, error)
}

type PrivdataConfig struct {
	ReconcileSleepInterval time.Duration

	ReconcileBatchSize int

	ReconciliationEnabled bool
}

type PvtDataDistributor interface {
	Distribute(txID string, privData *transientstore.TxPvtReadWriteSetWithConfigInfo, blkHt uint64) error
}

type PvtDataReconciler interface {
	Start()

	Stop()
}

type RWSetScanner interface {
	transientstore.RWSetScanner
}

type Reconciler struct {
	ReconcileSleepInterval time.Duration
	ReconcileBatchSize     int

	ReconciliationFetcher
	committer.Committer
	// contains filtered or unexported fields
}

type ReconciliationFetcher interface {
	FetchReconciledItems(dig2collectionConfig privdatacommon.Dig2CollectionConfig) (*privdatacommon.FetchedPvtDataContainer, error)
}

type StorageDataRetriever interface {
	CollectionRWSet(dig []*protosgossip.PvtDataDigest, blockNum uint64) (Dig2PvtRWSetWithConfig, bool, error)
}

type Support struct {
	ChainID string
	privdata.CollectionStore
	txvalidator.Validator
	committer.Committer
	TransientStore
	Fetcher
	CapabilityProvider
}

type TransientStore interface {
	Persist(txid string, blockHeight uint64, privateSimulationResultsWithConfig *protostransientstore.TxPvtReadWriteSetWithConfigInfo) error

	GetTxPvtRWSetByTxid(txid string, filter ledger.PvtNsCollFilter) (transientstore.RWSetScanner, error)

	PurgeByTxids(txids []string) error

	PurgeByHeight(maxBlockNumToRetain uint64) error
}