endorser

type Channel struct {
	IdentityDeserializer msp.IdentityDeserializer
}

type ChannelFetcher interface {
	Channel(channelID string) *Channel
}

type ChannelState struct {
	transientstore.Store
	QueryCreator
}

type ChannelStateRetriever interface {
	NewQueryCreator(channel string) (QueryCreator, error)
}

type CollectionConfigRetriever interface {
	GetState(namespace string, key string) ([]byte, error)
}

type Context struct {
	PluginName     string
	Channel        string
	TxID           string
	Proposal       *pb.Proposal
	SignedProposal *pb.SignedProposal
	Visibility     []byte
	Response       *pb.Response
	Event          []byte
	ChaincodeID    *pb.ChaincodeID
	SimRes         []byte
}

type Endorser struct {
	ChannelFetcher         ChannelFetcher
	LocalMSP               msp.IdentityDeserializer
	PrivateDataDistributor PrivateDataDistributor
	Support                Support
	PvtRWSetAssembler      PvtRWSetAssembler
	Metrics                *Metrics
}

type MapBasedPluginMapper map[string]endorsement.PluginFactory

type Metrics struct {
	ProposalDuration         metrics.Histogram
	ProposalsReceived        metrics.Counter
	SuccessfulProposals      metrics.Counter
	ProposalValidationFailed metrics.Counter
	ProposalACLCheckFailed   metrics.Counter
	InitFailed               metrics.Counter
	EndorsementsFailed       metrics.Counter
	DuplicateTxsFailure      metrics.Counter
}

type PeerOperations interface {
	GetApplicationConfig(cid string) (channelconfig.Application, bool)
	GetLedger(cid string) ledger.PeerLedger
}

type PluginEndorser struct {
	sync.Mutex
	PluginMapper

	ChannelStateRetriever
	endorsement3.SigningIdentityFetcher
	TransientStoreRetriever
	// contains filtered or unexported fields
}

type PluginMapper interface {
	PluginFactoryByName(name PluginName) endorsement.PluginFactory
}

type PluginName string

type PluginSupport struct {
	ChannelStateRetriever
	endorsement3.SigningIdentityFetcher
	PluginMapper
	TransientStoreRetriever
}

type PrivateDataDistributor interface {
	DistributePrivateData(channel string, txID string, privateData *transientstore.TxPvtReadWriteSetWithConfigInfo, blkHt uint64) error
}

type PvtRWSetAssembler interface {
	AssemblePvtRWSet(channelName string,
		privData *rwset.TxPvtReadWriteSet,
		txsim ledger.SimpleQueryExecutor,
		deployedCCInfoProvider ledger.DeployedChaincodeInfoProvider) (
		*transientstore.TxPvtReadWriteSetWithConfigInfo, error,
	)
}

type QueryCreator interface {
	NewQueryExecutor() (ledger.QueryExecutor, error)
}

type StateContext struct {
	transientstore.Store
	ledger.QueryExecutor
}

type Store interface {
	transientstore.Store
}

type Support interface {
	identity.SignerSerializer

	GetTxSimulator(ledgername string, txid string) (ledger.TxSimulator, error)

	GetHistoryQueryExecutor(ledgername string) (ledger.HistoryQueryExecutor, error)

	GetTransactionByID(chid, txID string) (*pb.ProcessedTransaction, error)

	IsSysCC(name string) bool

	Execute(txParams *ccprovider.TransactionParams, name string, input *pb.ChaincodeInput) (*pb.Response, *pb.ChaincodeEvent, error)

	ExecuteLegacyInit(txParams *ccprovider.TransactionParams, name, version string, spec *pb.ChaincodeInput) (*pb.Response, *pb.ChaincodeEvent, error)

	ChaincodeEndorsementInfo(channelID, chaincodeID string, txsim ledger.QueryExecutor) (*lifecycle.ChaincodeEndorsementInfo, error)

	CheckACL(channelID string, signedProp *pb.SignedProposal) error

	EndorseWithPlugin(pluginName, channnelID string, prpBytes []byte, signedProposal *pb.SignedProposal) (*pb.Endorsement, []byte, error)

	GetLedgerHeight(channelID string) (uint64, error)

	GetDeployedCCInfoProvider() ledger.DeployedChaincodeInfoProvider
}

type SupportImpl struct {
	*PluginEndorser
	identity.SignerSerializer
	Peer             PeerOperations
	ChaincodeSupport *chaincode.ChaincodeSupport
	ACLProvider      aclmgmt.ACLProvider
	BuiltinSCCs      scc.BuiltinSCCs
}

type TransientStoreRetriever interface {
	StoreForChannel(channel string) transientstore.Store
}

type UnpackedProposal struct {
	ChaincodeName   string
	ChannelHeader   *cb.ChannelHeader
	Input           *pb.ChaincodeInput
	Proposal        *pb.Proposal
	SignatureHeader *cb.SignatureHeader
	SignedProposal  *pb.SignedProposal
	ProposalHash    []byte
}