mocks

package

Go to main page

Versions in this module

v0

v0.1.6

Mar 4, 2021

Changes in this version

type Ledger

+ func (m *Ledger) NewQueryExecutorNoLock() (ledger2.QueryExecutor, error)

type MockBlockHandler

+ func (m *MockBlockHandler) HandleBlock(block *cb.Block) error

+ func (m *MockBlockHandler) NumBlocks() int

type MockBlockPublisher

+ HandleBlock gossipapi.PublishedBlockHandler

+ Height uint64

+ func (m *MockBlockPublisher) AddBlockHandler(handler gossipapi.PublishedBlockHandler)

v0.1.5

Dec 1, 2020

Changes in this version

type CollectionBuilder

+ func (c *CollectionBuilder) BuildConfig() *peer.CollectionConfig

type StateDB

+ UpdateCacheStub func(blockNum uint64, updates []byte) error

+ func (fake *StateDB) UpdateCache(blockNum uint64, updates []byte) error

+ func (fake *StateDB) UpdateCacheArgsForCall(i int) (uint64, []byte)

+ func (fake *StateDB) UpdateCacheCallCount() int

+ func (fake *StateDB) UpdateCacheReturns(result1 error)

+ func (fake *StateDB) UpdateCacheReturnsOnCall(i int, result1 error)

v0.1.4

Aug 27, 2020

Changes in this version

+ func NewAppDataReqMsg(channelID string, reqID uint64, dataType string, reqPayload []byte) *protoext.SignedGossipMessage

+ func NewAppDataResMsg(channelID string, reqID uint64, response []byte) *protoext.SignedGossipMessage

+ type ACLProvider struct

+ CheckACLStub func(resName string, channelID string, idinfo interface{}) error

+ func (fake *ACLProvider) CheckACL(resName string, channelID string, idinfo interface{}) error

+ func (fake *ACLProvider) CheckACLArgsForCall(i int) (string, string, interface{})

+ func (fake *ACLProvider) CheckACLCallCount() int

+ func (fake *ACLProvider) CheckACLReturns(result1 error)

+ func (fake *ACLProvider) CheckACLReturnsOnCall(i int, result1 error)

+ func (fake *ACLProvider) Invocations() map[string][][]interface{}

+ type ChaincodeInfoProvider struct

+ func NewChaincodeInfoProvider() *ChaincodeInfoProvider

+ func (p *ChaincodeInfoProvider) ChaincodeInfo(channelName, chaincodeName string, qe ledger.SimpleQueryExecutor) (*ledger.DeployedChaincodeInfo, error)

+ func (p *ChaincodeInfoProvider) WithData(ccName string, ccInfo *ledger.DeployedChaincodeInfo) *ChaincodeInfoProvider

+ func (p *ChaincodeInfoProvider) WithError(err error) *ChaincodeInfoProvider

+ type ChaincodeUpdateHandler struct

+ HandleStateUpdatesStub func(trigger *ledger.StateUpdateTrigger) error

+ func (fake *ChaincodeUpdateHandler) HandleStateUpdates(trigger *ledger.StateUpdateTrigger) error

+ func (fake *ChaincodeUpdateHandler) HandleStateUpdatesArgsForCall(i int) *ledger.StateUpdateTrigger

+ func (fake *ChaincodeUpdateHandler) HandleStateUpdatesCallCount() int

+ func (fake *ChaincodeUpdateHandler) HandleStateUpdatesReturns(result1 error)

+ func (fake *ChaincodeUpdateHandler) HandleStateUpdatesReturnsOnCall(i int, result1 error)

+ func (fake *ChaincodeUpdateHandler) Invocations() map[string][][]interface{}

+ type CollHashedRWSetBuilder struct

+ func NewCollHashedRWSetBuilder(coll string) *CollHashedRWSetBuilder

+ func (b *CollHashedRWSetBuilder) Build() *rwsetutil.CollHashedRwSet

+ func (b *CollHashedRWSetBuilder) Delete(keyHash []byte) *CollHashedRWSetBuilder

+ func (b *CollHashedRWSetBuilder) HashedRead(keyHash []byte, version *kvrwset.Version) *CollHashedRWSetBuilder

+ func (b *CollHashedRWSetBuilder) HashedWrite(keyHash, valueHash []byte) *CollHashedRWSetBuilder

type MockBlockHandler

+ func (m *MockBlockHandler) HandleCollHashRead(txMetadata api.TxMetadata, namespace, collection string, ...) error

+ func (m *MockBlockHandler) HandleCollHashWrite(txMetadata api.TxMetadata, namespace, collection string, ...) error

+ func (m *MockBlockHandler) NumCollHashReads() int

+ func (m *MockBlockHandler) NumCollHashWrites() int

type MockBlockPublisher

+ HandleCollHashRead gossipapi.CollHashReadHandler

+ HandleCollHashWrite gossipapi.CollHashWriteHandler

+ func (m *MockBlockPublisher) AddCollHashReadHandler(handler gossipapi.CollHashReadHandler)

+ func (m *MockBlockPublisher) AddCollHashWriteHandler(handler gossipapi.CollHashWriteHandler)

type NamespaceRWSetBuilder

+ func (b *NamespaceRWSetBuilder) Collection(coll string) *CollHashedRWSetBuilder

type QueryExecutor

+ func (m *QueryExecutor) ExecuteQueryWithPagination(namespace, query, bookmark string, pageSize int32) (ledger.QueryResultsIterator, error)

+ func (m *QueryExecutor) GetStateRangeScanIteratorWithPagination(namespace string, startKey, endKey string, pageSize int32) (ledger.QueryResultsIterator, error)

type ReadWriteSetBuilder

+ func (b *ReadWriteSetBuilder) BuildBytes() []byte

+ type StateDB struct

+ BytesKeySupportedStub func() bool

+ ExecuteQueryStub func(namespace, query string) (statedbtxmgmt.ResultsIterator, error)

+ ExecuteQueryWithPaginationStub func(namespace, query, bookmark string, pageSize int32) (statedbtxmgmt.QueryResultsIterator, error)

+ GetStateMultipleKeysStub func(namespace string, keys []string) ([][]byte, error)

+ GetStateRangeScanIteratorStub func(namespace string, startKey string, endKey string) (statedbtxmgmt.ResultsIterator, error)

+ GetStateRangeScanIteratorWithPaginationStub func(namespace string, startKey string, endKey string, pageSize int32) (statedbtxmgmt.QueryResultsIterator, error)

+ GetStateStub func(namespace string, key string) ([]byte, error)

+ func (fake *StateDB) BytesKeySupported() bool

+ func (fake *StateDB) BytesKeySupportedCallCount() int

+ func (fake *StateDB) BytesKeySupportedReturns(result1 bool)

+ func (fake *StateDB) BytesKeySupportedReturnsOnCall(i int, result1 bool)

+ func (fake *StateDB) ExecuteQuery(namespace string, query string) (statedbtxmgmt.ResultsIterator, error)

+ func (fake *StateDB) ExecuteQueryArgsForCall(i int) (string, string)

+ func (fake *StateDB) ExecuteQueryCallCount() int

+ func (fake *StateDB) ExecuteQueryReturns(result1 statedbtxmgmt.ResultsIterator, result2 error)

+ func (fake *StateDB) ExecuteQueryReturnsOnCall(i int, result1 statedbtxmgmt.ResultsIterator, result2 error)

+ func (fake *StateDB) ExecuteQueryWithPagination(namespace string, query string, bookmark string, pageSize int32) (statedbtxmgmt.QueryResultsIterator, error)

+ func (fake *StateDB) ExecuteQueryWithPaginationArgsForCall(i int) (string, string, string, int32)

+ func (fake *StateDB) ExecuteQueryWithPaginationCallCount() int

+ func (fake *StateDB) ExecuteQueryWithPaginationReturns(result1 statedbtxmgmt.QueryResultsIterator, result2 error)

+ func (fake *StateDB) ExecuteQueryWithPaginationReturnsOnCall(i int, result1 statedbtxmgmt.QueryResultsIterator, result2 error)

+ func (fake *StateDB) GetState(namespace string, key string) ([]byte, error)

+ func (fake *StateDB) GetStateArgsForCall(i int) (string, string)

+ func (fake *StateDB) GetStateCallCount() int

+ func (fake *StateDB) GetStateMultipleKeys(namespace string, keys []string) ([][]byte, error)

+ func (fake *StateDB) GetStateMultipleKeysArgsForCall(i int) (string, []string)

+ func (fake *StateDB) GetStateMultipleKeysCallCount() int

+ func (fake *StateDB) GetStateMultipleKeysReturns(result1 [][]byte, result2 error)

+ func (fake *StateDB) GetStateMultipleKeysReturnsOnCall(i int, result1 [][]byte, result2 error)

+ func (fake *StateDB) GetStateRangeScanIterator(namespace string, startKey string, endKey string) (statedbtxmgmt.ResultsIterator, error)

+ func (fake *StateDB) GetStateRangeScanIteratorArgsForCall(i int) (string, string, string)

+ func (fake *StateDB) GetStateRangeScanIteratorCallCount() int

+ func (fake *StateDB) GetStateRangeScanIteratorReturns(result1 statedbtxmgmt.ResultsIterator, result2 error)

+ func (fake *StateDB) GetStateRangeScanIteratorReturnsOnCall(i int, result1 statedbtxmgmt.ResultsIterator, result2 error)

+ func (fake *StateDB) GetStateRangeScanIteratorWithPagination(namespace string, startKey string, endKey string, pageSize int32) (statedbtxmgmt.QueryResultsIterator, error)

+ func (fake *StateDB) GetStateRangeScanIteratorWithPaginationArgsForCall(i int) (string, string, string, int32)

+ func (fake *StateDB) GetStateRangeScanIteratorWithPaginationCallCount() int

+ func (fake *StateDB) GetStateRangeScanIteratorWithPaginationReturns(result1 statedbtxmgmt.QueryResultsIterator, result2 error)

+ func (fake *StateDB) GetStateRangeScanIteratorWithPaginationReturnsOnCall(i int, result1 statedbtxmgmt.QueryResultsIterator, result2 error)

+ func (fake *StateDB) GetStateReturns(result1 []byte, result2 error)

+ func (fake *StateDB) GetStateReturnsOnCall(i int, result1 []byte, result2 error)

+ func (fake *StateDB) Invocations() map[string][][]interface{}

type TxSimulator

+ ExecuteQueryWithPaginationStub func(namespace, query, bookmark string, pageSize int32) (ledger.QueryResultsIterator, error)

+ GetStateRangeScanIteratorWithPaginationStub func(namespace string, startKey, endKey string, pageSize int32) (ledger.QueryResultsIterator, error)

+ func (fake *TxSimulator) ExecuteQueryWithPagination(namespace string, query string, bookmark string, pageSize int32) (ledger.QueryResultsIterator, error)

+ func (fake *TxSimulator) ExecuteQueryWithPaginationArgsForCall(i int) (string, string, string, int32)

+ func (fake *TxSimulator) ExecuteQueryWithPaginationCallCount() int

+ func (fake *TxSimulator) ExecuteQueryWithPaginationReturns(result1 ledger.QueryResultsIterator, result2 error)

+ func (fake *TxSimulator) ExecuteQueryWithPaginationReturnsOnCall(i int, result1 ledger.QueryResultsIterator, result2 error)

+ func (fake *TxSimulator) GetStateRangeScanIteratorWithPagination(namespace string, startKey string, endKey string, pageSize int32) (ledger.QueryResultsIterator, error)

+ func (fake *TxSimulator) GetStateRangeScanIteratorWithPaginationArgsForCall(i int) (string, string, string, int32)

+ func (fake *TxSimulator) GetStateRangeScanIteratorWithPaginationCallCount() int

+ func (fake *TxSimulator) GetStateRangeScanIteratorWithPaginationReturns(result1 ledger.QueryResultsIterator, result2 error)

+ func (fake *TxSimulator) GetStateRangeScanIteratorWithPaginationReturnsOnCall(i int, result1 ledger.QueryResultsIterator, result2 error)

v0.1.3

May 6, 2020

v0.1.2

Feb 25, 2020

Changes in this version

type TxSimulator

+ DeletePrivateDataMetadataStub func(namespace, collection, key string) error

+ DeletePrivateDataStub func(namespace, collection, key string) error

+ DeleteStateMetadataStub func(namespace, key string) error

+ DeleteStateStub func(namespace string, key string) error

+ DoneStub func()

+ ExecuteQueryOnPrivateDataStub func(namespace, collection, query string) (commonledger.ResultsIterator, error)

+ ExecuteQueryStub func(namespace, query string) (commonledger.ResultsIterator, error)

+ ExecuteQueryWithMetadataStub func(namespace, query string, metadata map[string]interface{}) (ledger.QueryResultsIterator, error)

+ ExecuteUpdateStub func(query string) error

+ GetPrivateDataHashStub func(namespace, collection, key string) ([]byte, error)

+ GetPrivateDataMetadataByHashStub func(namespace, collection string, keyhash []byte) (map[string][]byte, error)

+ GetPrivateDataMetadataStub func(namespace, collection, key string) (map[string][]byte, error)

+ GetPrivateDataMultipleKeysStub func(namespace, collection string, keys []string) ([][]byte, error)

+ GetPrivateDataRangeScanIteratorStub func(namespace, collection, startKey, endKey string) (commonledger.ResultsIterator, error)

+ GetPrivateDataStub func(namespace, collection, key string) ([]byte, error)

+ GetStateMetadataStub func(namespace, key string) (map[string][]byte, error)

+ GetStateMultipleKeysStub func(namespace string, keys []string) ([][]byte, error)

+ GetStateRangeScanIteratorStub func(namespace string, startKey string, endKey string) (commonledger.ResultsIterator, error)

+ GetStateRangeScanIteratorWithMetadataStub func(namespace string, startKey, endKey string, metadata map[string]interface{}) (ledger.QueryResultsIterator, error)

+ GetStateStub func(namespace string, key string) ([]byte, error)

+ GetTxSimulationResultsStub func() (*ledger.TxSimulationResults, error)

+ SetPrivateDataMetadataStub func(namespace, collection, key string, metadata map[string][]byte) error

+ SetPrivateDataMultipleKeysStub func(namespace, collection string, kvs map[string][]byte) error

+ SetPrivateDataStub func(namespace, collection, key string, value []byte) error

+ SetStateMetadataStub func(namespace, key string, metadata map[string][]byte) error

+ SetStateMultipleKeysStub func(namespace string, kvs map[string][]byte) error

+ SetStateStub func(namespace string, key string, value []byte) error

+ func (fake *TxSimulator) DeletePrivateDataArgsForCall(i int) (string, string, string)

+ func (fake *TxSimulator) DeletePrivateDataCallCount() int

+ func (fake *TxSimulator) DeletePrivateDataMetadataArgsForCall(i int) (string, string, string)

+ func (fake *TxSimulator) DeletePrivateDataMetadataCallCount() int

+ func (fake *TxSimulator) DeletePrivateDataMetadataReturns(result1 error)

+ func (fake *TxSimulator) DeletePrivateDataMetadataReturnsOnCall(i int, result1 error)

+ func (fake *TxSimulator) DeletePrivateDataReturns(result1 error)

+ func (fake *TxSimulator) DeletePrivateDataReturnsOnCall(i int, result1 error)

+ func (fake *TxSimulator) DeleteStateArgsForCall(i int) (string, string)

+ func (fake *TxSimulator) DeleteStateCallCount() int

+ func (fake *TxSimulator) DeleteStateMetadataArgsForCall(i int) (string, string)

+ func (fake *TxSimulator) DeleteStateMetadataCallCount() int

+ func (fake *TxSimulator) DeleteStateMetadataReturns(result1 error)

+ func (fake *TxSimulator) DeleteStateMetadataReturnsOnCall(i int, result1 error)

+ func (fake *TxSimulator) DeleteStateReturns(result1 error)

+ func (fake *TxSimulator) DeleteStateReturnsOnCall(i int, result1 error)

+ func (fake *TxSimulator) Done()

+ func (fake *TxSimulator) DoneCallCount() int

+ func (fake *TxSimulator) ExecuteQuery(namespace string, query string) (commonledger.ResultsIterator, error)

+ func (fake *TxSimulator) ExecuteQueryArgsForCall(i int) (string, string)

+ func (fake *TxSimulator) ExecuteQueryCallCount() int

+ func (fake *TxSimulator) ExecuteQueryOnPrivateData(namespace string, collection string, query string) (commonledger.ResultsIterator, error)

+ func (fake *TxSimulator) ExecuteQueryOnPrivateDataArgsForCall(i int) (string, string, string)

+ func (fake *TxSimulator) ExecuteQueryOnPrivateDataCallCount() int

+ func (fake *TxSimulator) ExecuteQueryOnPrivateDataReturns(result1 commonledger.ResultsIterator, result2 error)

+ func (fake *TxSimulator) ExecuteQueryOnPrivateDataReturnsOnCall(i int, result1 commonledger.ResultsIterator, result2 error)

+ func (fake *TxSimulator) ExecuteQueryReturns(result1 commonledger.ResultsIterator, result2 error)

+ func (fake *TxSimulator) ExecuteQueryReturnsOnCall(i int, result1 commonledger.ResultsIterator, result2 error)

+ func (fake *TxSimulator) ExecuteQueryWithMetadata(namespace string, query string, metadata map[string]interface{}) (ledger.QueryResultsIterator, error)

+ func (fake *TxSimulator) ExecuteQueryWithMetadataArgsForCall(i int) (string, string, map[string]interface{})

+ func (fake *TxSimulator) ExecuteQueryWithMetadataCallCount() int

+ func (fake *TxSimulator) ExecuteQueryWithMetadataReturns(result1 ledger.QueryResultsIterator, result2 error)

+ func (fake *TxSimulator) ExecuteQueryWithMetadataReturnsOnCall(i int, result1 ledger.QueryResultsIterator, result2 error)

+ func (fake *TxSimulator) ExecuteUpdateArgsForCall(i int) string

+ func (fake *TxSimulator) ExecuteUpdateCallCount() int

+ func (fake *TxSimulator) ExecuteUpdateReturns(result1 error)

+ func (fake *TxSimulator) ExecuteUpdateReturnsOnCall(i int, result1 error)

+ func (fake *TxSimulator) GetPrivateData(namespace string, collection string, key string) ([]byte, error)

+ func (fake *TxSimulator) GetPrivateDataArgsForCall(i int) (string, string, string)

+ func (fake *TxSimulator) GetPrivateDataCallCount() int

+ func (fake *TxSimulator) GetPrivateDataHash(namespace string, collection string, key string) ([]byte, error)

+ func (fake *TxSimulator) GetPrivateDataHashArgsForCall(i int) (string, string, string)

+ func (fake *TxSimulator) GetPrivateDataHashCallCount() int

+ func (fake *TxSimulator) GetPrivateDataHashReturns(result1 []byte, result2 error)

+ func (fake *TxSimulator) GetPrivateDataHashReturnsOnCall(i int, result1 []byte, result2 error)

+ func (fake *TxSimulator) GetPrivateDataMetadata(namespace string, collection string, key string) (map[string][]byte, error)

+ func (fake *TxSimulator) GetPrivateDataMetadataArgsForCall(i int) (string, string, string)

+ func (fake *TxSimulator) GetPrivateDataMetadataByHash(namespace string, collection string, keyhash []byte) (map[string][]byte, error)

+ func (fake *TxSimulator) GetPrivateDataMetadataByHashArgsForCall(i int) (string, string, []byte)

+ func (fake *TxSimulator) GetPrivateDataMetadataByHashCallCount() int

+ func (fake *TxSimulator) GetPrivateDataMetadataByHashReturns(result1 map[string][]byte, result2 error)

+ func (fake *TxSimulator) GetPrivateDataMetadataByHashReturnsOnCall(i int, result1 map[string][]byte, result2 error)

+ func (fake *TxSimulator) GetPrivateDataMetadataCallCount() int

+ func (fake *TxSimulator) GetPrivateDataMetadataReturns(result1 map[string][]byte, result2 error)

+ func (fake *TxSimulator) GetPrivateDataMetadataReturnsOnCall(i int, result1 map[string][]byte, result2 error)

+ func (fake *TxSimulator) GetPrivateDataMultipleKeys(namespace string, collection string, keys []string) ([][]byte, error)

+ func (fake *TxSimulator) GetPrivateDataMultipleKeysArgsForCall(i int) (string, string, []string)

+ func (fake *TxSimulator) GetPrivateDataMultipleKeysCallCount() int

+ func (fake *TxSimulator) GetPrivateDataMultipleKeysReturns(result1 [][]byte, result2 error)

+ func (fake *TxSimulator) GetPrivateDataMultipleKeysReturnsOnCall(i int, result1 [][]byte, result2 error)

+ func (fake *TxSimulator) GetPrivateDataRangeScanIterator(namespace string, collection string, startKey string, endKey string) (commonledger.ResultsIterator, error)

+ func (fake *TxSimulator) GetPrivateDataRangeScanIteratorArgsForCall(i int) (string, string, string, string)

+ func (fake *TxSimulator) GetPrivateDataRangeScanIteratorCallCount() int

+ func (fake *TxSimulator) GetPrivateDataRangeScanIteratorReturns(result1 commonledger.ResultsIterator, result2 error)

+ func (fake *TxSimulator) GetPrivateDataRangeScanIteratorReturnsOnCall(i int, result1 commonledger.ResultsIterator, result2 error)

+ func (fake *TxSimulator) GetPrivateDataReturns(result1 []byte, result2 error)

+ func (fake *TxSimulator) GetPrivateDataReturnsOnCall(i int, result1 []byte, result2 error)

+ func (fake *TxSimulator) GetState(namespace string, key string) ([]byte, error)

+ func (fake *TxSimulator) GetStateArgsForCall(i int) (string, string)

+ func (fake *TxSimulator) GetStateCallCount() int

+ func (fake *TxSimulator) GetStateMetadata(namespace string, key string) (map[string][]byte, error)

+ func (fake *TxSimulator) GetStateMetadataArgsForCall(i int) (string, string)

+ func (fake *TxSimulator) GetStateMetadataCallCount() int

+ func (fake *TxSimulator) GetStateMetadataReturns(result1 map[string][]byte, result2 error)

+ func (fake *TxSimulator) GetStateMetadataReturnsOnCall(i int, result1 map[string][]byte, result2 error)

+ func (fake *TxSimulator) GetStateMultipleKeys(namespace string, keys []string) ([][]byte, error)

+ func (fake *TxSimulator) GetStateMultipleKeysArgsForCall(i int) (string, []string)

+ func (fake *TxSimulator) GetStateMultipleKeysCallCount() int

+ func (fake *TxSimulator) GetStateMultipleKeysReturns(result1 [][]byte, result2 error)

+ func (fake *TxSimulator) GetStateMultipleKeysReturnsOnCall(i int, result1 [][]byte, result2 error)

+ func (fake *TxSimulator) GetStateRangeScanIterator(namespace string, startKey string, endKey string) (commonledger.ResultsIterator, error)

+ func (fake *TxSimulator) GetStateRangeScanIteratorArgsForCall(i int) (string, string, string)

+ func (fake *TxSimulator) GetStateRangeScanIteratorCallCount() int

+ func (fake *TxSimulator) GetStateRangeScanIteratorReturns(result1 commonledger.ResultsIterator, result2 error)

+ func (fake *TxSimulator) GetStateRangeScanIteratorReturnsOnCall(i int, result1 commonledger.ResultsIterator, result2 error)

+ func (fake *TxSimulator) GetStateRangeScanIteratorWithMetadata(namespace string, startKey string, endKey string, ...) (ledger.QueryResultsIterator, error)

+ func (fake *TxSimulator) GetStateRangeScanIteratorWithMetadataArgsForCall(i int) (string, string, string, map[string]interface{})

+ func (fake *TxSimulator) GetStateRangeScanIteratorWithMetadataCallCount() int

+ func (fake *TxSimulator) GetStateRangeScanIteratorWithMetadataReturns(result1 ledger.QueryResultsIterator, result2 error)

+ func (fake *TxSimulator) GetStateRangeScanIteratorWithMetadataReturnsOnCall(i int, result1 ledger.QueryResultsIterator, result2 error)

+ func (fake *TxSimulator) GetStateReturns(result1 []byte, result2 error)

+ func (fake *TxSimulator) GetStateReturnsOnCall(i int, result1 []byte, result2 error)

+ func (fake *TxSimulator) GetTxSimulationResultsCallCount() int

+ func (fake *TxSimulator) GetTxSimulationResultsReturns(result1 *ledger.TxSimulationResults, result2 error)

+ func (fake *TxSimulator) GetTxSimulationResultsReturnsOnCall(i int, result1 *ledger.TxSimulationResults, result2 error)

+ func (fake *TxSimulator) Invocations() map[string][][]interface{}

+ func (fake *TxSimulator) SetPrivateDataArgsForCall(i int) (string, string, string, []byte)

+ func (fake *TxSimulator) SetPrivateDataCallCount() int

+ func (fake *TxSimulator) SetPrivateDataMetadataArgsForCall(i int) (string, string, string, map[string][]byte)

+ func (fake *TxSimulator) SetPrivateDataMetadataCallCount() int

+ func (fake *TxSimulator) SetPrivateDataMetadataReturns(result1 error)

+ func (fake *TxSimulator) SetPrivateDataMetadataReturnsOnCall(i int, result1 error)

+ func (fake *TxSimulator) SetPrivateDataMultipleKeysArgsForCall(i int) (string, string, map[string][]byte)

+ func (fake *TxSimulator) SetPrivateDataMultipleKeysCallCount() int

+ func (fake *TxSimulator) SetPrivateDataMultipleKeysReturns(result1 error)

+ func (fake *TxSimulator) SetPrivateDataMultipleKeysReturnsOnCall(i int, result1 error)

+ func (fake *TxSimulator) SetPrivateDataReturns(result1 error)

+ func (fake *TxSimulator) SetPrivateDataReturnsOnCall(i int, result1 error)

+ func (fake *TxSimulator) SetStateArgsForCall(i int) (string, string, []byte)

+ func (fake *TxSimulator) SetStateCallCount() int

+ func (fake *TxSimulator) SetStateMetadataArgsForCall(i int) (string, string, map[string][]byte)

+ func (fake *TxSimulator) SetStateMetadataCallCount() int

+ func (fake *TxSimulator) SetStateMetadataReturns(result1 error)

+ func (fake *TxSimulator) SetStateMetadataReturnsOnCall(i int, result1 error)

+ func (fake *TxSimulator) SetStateMultipleKeysArgsForCall(i int) (string, map[string][]byte)

+ func (fake *TxSimulator) SetStateMultipleKeysCallCount() int

+ func (fake *TxSimulator) SetStateMultipleKeysReturns(result1 error)

+ func (fake *TxSimulator) SetStateMultipleKeysReturnsOnCall(i int, result1 error)

+ func (fake *TxSimulator) SetStateReturns(result1 error)

+ func (fake *TxSimulator) SetStateReturnsOnCall(i int, result1 error)

v0.1.1

Jan 29, 2020

Changes in this version

+ func NewCollDataReqMsgWithDigests(channelID string, reqID uint64, digests ...*gproto.CollDataDigest) *protoext.SignedGossipMessage

+ type CollectionConfigProvider struct

+ ForChannelStub func(channelID string) support.CollectionConfigRetriever

+ func (fake *CollectionConfigProvider) ForChannel(channelID string) support.CollectionConfigRetriever

+ func (fake *CollectionConfigProvider) ForChannelArgsForCall(i int) string

+ func (fake *CollectionConfigProvider) ForChannelCallCount() int

+ func (fake *CollectionConfigProvider) ForChannelReturns(result1 support.CollectionConfigRetriever)

+ func (fake *CollectionConfigProvider) ForChannelReturnsOnCall(i int, result1 support.CollectionConfigRetriever)

+ func (fake *CollectionConfigProvider) Invocations() map[string][][]interface{}

+ type CollectionConfigRetriever struct

+ func NewCollectionConfigRetriever() *CollectionConfigRetriever

+ func (s *CollectionConfigRetriever) Config(ns, coll string) (*pb.StaticCollectionConfig, error)

+ func (s *CollectionConfigRetriever) Policy(ns, coll string) (privdata.CollectionAccessPolicy, error)

+ func (s *CollectionConfigRetriever) WithCollectionConfig(collConfig *pb.StaticCollectionConfig) *CollectionConfigRetriever

+ func (s *CollectionConfigRetriever) WithCollectionPolicy(collPolicy privdata.CollectionAccessPolicy) *CollectionConfigRetriever

+ func (s *CollectionConfigRetriever) WithError(err error) *CollectionConfigRetriever

type DataStore

+ func (m *DataStore) WithQueryResults(key *storeapi.QueryKey, results []*storeapi.QueryResult) *DataStore

+ func (m *DataStore) WithResultsIteratorError(err error) *DataStore

+ type GossipProvider struct

+ GetGossipServiceStub func() gossipapi.GossipService

+ func (fake *GossipProvider) GetGossipService() gossipapi.GossipService

+ func (fake *GossipProvider) GetGossipServiceCallCount() int

+ func (fake *GossipProvider) GetGossipServiceReturns(result1 gossipapi.GossipService)

+ func (fake *GossipProvider) GetGossipServiceReturnsOnCall(i int, result1 gossipapi.GossipService)

+ func (fake *GossipProvider) Invocations() map[string][][]interface{}

+ type IdentifierProvider struct

+ GetIdentifierStub func() (string, error)

+ func (fake *IdentifierProvider) GetIdentifier() (string, error)

+ func (fake *IdentifierProvider) GetIdentifierCallCount() int

+ func (fake *IdentifierProvider) GetIdentifierReturns(result1 string, result2 error)

+ func (fake *IdentifierProvider) GetIdentifierReturnsOnCall(i int, result1 string, result2 error)

+ func (fake *IdentifierProvider) Invocations() map[string][][]interface{}

+ type IdentityDeserializer struct

+ DeserializeIdentityStub func(serializedIdentity []byte) (msp.Identity, error)

+ IsWellFormedStub func(identity *mspfabric_protos.SerializedIdentity) error

+ func (fake *IdentityDeserializer) DeserializeIdentity(serializedIdentity []byte) (msp.Identity, error)

+ func (fake *IdentityDeserializer) DeserializeIdentityArgsForCall(i int) []byte

+ func (fake *IdentityDeserializer) DeserializeIdentityCallCount() int

+ func (fake *IdentityDeserializer) DeserializeIdentityReturns(result1 msp.Identity, result2 error)

+ func (fake *IdentityDeserializer) DeserializeIdentityReturnsOnCall(i int, result1 msp.Identity, result2 error)

+ func (fake *IdentityDeserializer) Invocations() map[string][][]interface{}

+ func (fake *IdentityDeserializer) IsWellFormed(identity *mspfabric_protos.SerializedIdentity) error

+ func (fake *IdentityDeserializer) IsWellFormedArgsForCall(i int) *mspfabric_protos.SerializedIdentity

+ func (fake *IdentityDeserializer) IsWellFormedCallCount() int

+ func (fake *IdentityDeserializer) IsWellFormedReturns(result1 error)

+ func (fake *IdentityDeserializer) IsWellFormedReturnsOnCall(i int, result1 error)

+ type IdentityDeserializerProvider struct

+ GetIdentityDeserializerStub func(channelID string) msp.IdentityDeserializer

+ func (fake *IdentityDeserializerProvider) GetIdentityDeserializer(channelID string) msp.IdentityDeserializer

+ func (fake *IdentityDeserializerProvider) GetIdentityDeserializerArgsForCall(i int) string

+ func (fake *IdentityDeserializerProvider) GetIdentityDeserializerCallCount() int

+ func (fake *IdentityDeserializerProvider) GetIdentityDeserializerReturns(result1 msp.IdentityDeserializer)

+ func (fake *IdentityDeserializerProvider) GetIdentityDeserializerReturnsOnCall(i int, result1 msp.IdentityDeserializer)

+ func (fake *IdentityDeserializerProvider) Invocations() map[string][][]interface{}

+ type IdentityProvider struct

+ GetDefaultSigningIdentityStub func() (msp.SigningIdentity, error)

+ func (fake *IdentityProvider) GetDefaultSigningIdentity() (msp.SigningIdentity, error)

+ func (fake *IdentityProvider) GetDefaultSigningIdentityCallCount() int

+ func (fake *IdentityProvider) GetDefaultSigningIdentityReturns(result1 msp.SigningIdentity, result2 error)

+ func (fake *IdentityProvider) GetDefaultSigningIdentityReturnsOnCall(i int, result1 msp.SigningIdentity, result2 error)

+ func (fake *IdentityProvider) Invocations() map[string][][]interface{}

type Ledger

+ func (m *Ledger) CommitLegacy(blockAndPvtdata *ledger2.BlockAndPvtData, commitOpts *ledger2.CommitOptions) error

+ func (m *Ledger) DoesPvtDataInfoExist(blockNum uint64) (bool, error)

+ type LedgerProvider struct

+ GetLedgerStub func(cid string) ledger.PeerLedger

+ func (fake *LedgerProvider) GetLedger(cid string) ledger.PeerLedger

+ func (fake *LedgerProvider) GetLedgerArgsForCall(i int) string

+ func (fake *LedgerProvider) GetLedgerCallCount() int

+ func (fake *LedgerProvider) GetLedgerReturns(result1 ledger.PeerLedger)

+ func (fake *LedgerProvider) GetLedgerReturnsOnCall(i int, result1 ledger.PeerLedger)

+ func (fake *LedgerProvider) Invocations() map[string][][]interface{}

type MockBlockPublisherProvider

+ func (m *MockBlockPublisherProvider) WithBlockPublisher(publisher gossipapi.BlockPublisher) *MockBlockPublisherProvider

type MockGossipAdapter

+ func (m *MockGossipAdapter) Accept(acceptor common.MessageAcceptor, passThrough bool) (<-chan *gossipproto.GossipMessage, <-chan protoext.ReceivedMessage)

+ func (m *MockGossipAdapter) DistributePrivateData(chainID string, txID string, ...) error

+ func (m *MockGossipAdapter) Gossip(msg *gossipproto.GossipMessage)

+ func (m *MockGossipAdapter) IsInMyOrg(member discovery.NetworkMember) bool

+ func (m *MockGossipAdapter) Peers() []discovery.NetworkMember

+ func (m *MockGossipAdapter) SelfChannelInfo(common.ChannelID) *protoext.SignedGossipMessage

+ func (m *MockGossipAdapter) SendByCriteria(*protoext.SignedGossipMessage, gossip.SendCriteria) error

+ type PeerConfig struct

+ MSPConfigPathStub func() string

+ MSPIDStub func() string

+ PeerAddressStub func() string

+ PeerIDStub func() string

+ TLSCertPathStub func() string

+ func (fake *PeerConfig) Invocations() map[string][][]interface{}

+ func (fake *PeerConfig) MSPConfigPath() string

+ func (fake *PeerConfig) MSPConfigPathCallCount() int

+ func (fake *PeerConfig) MSPConfigPathReturns(result1 string)

+ func (fake *PeerConfig) MSPConfigPathReturnsOnCall(i int, result1 string)

+ func (fake *PeerConfig) MSPID() string

+ func (fake *PeerConfig) MSPIDCallCount() int

+ func (fake *PeerConfig) MSPIDReturns(result1 string)

+ func (fake *PeerConfig) MSPIDReturnsOnCall(i int, result1 string)

+ func (fake *PeerConfig) PeerAddress() string

+ func (fake *PeerConfig) PeerAddressCallCount() int

+ func (fake *PeerConfig) PeerAddressReturns(result1 string)

+ func (fake *PeerConfig) PeerAddressReturnsOnCall(i int, result1 string)

+ func (fake *PeerConfig) PeerID() string

+ func (fake *PeerConfig) PeerIDCallCount() int

+ func (fake *PeerConfig) PeerIDReturns(result1 string)

+ func (fake *PeerConfig) PeerIDReturnsOnCall(i int, result1 string)

+ func (fake *PeerConfig) TLSCertPath() string

+ func (fake *PeerConfig) TLSCertPathCallCount() int

+ func (fake *PeerConfig) TLSCertPathReturns(result1 string)

+ func (fake *PeerConfig) TLSCertPathReturnsOnCall(i int, result1 string)

+ type SigningIdentity struct

+ AnonymousStub func() bool

+ ExpiresAtStub func() time.Time

+ GetIdentifierStub func() *msp.IdentityIdentifier

+ GetMSPIdentifierStub func() string

+ GetOrganizationalUnitsStub func() []*msp.OUIdentifier

+ GetPublicVersionStub func() msp.Identity

+ SatisfiesPrincipalStub func(principal *mspfabric_protos.MSPPrincipal) error

+ SerializeStub func() ([]byte, error)

+ SignStub func(msg []byte) ([]byte, error)

+ ValidateStub func() error

+ VerifyStub func(msg []byte, sig []byte) error

+ func (fake *SigningIdentity) Anonymous() bool

+ func (fake *SigningIdentity) AnonymousCallCount() int

+ func (fake *SigningIdentity) AnonymousReturns(result1 bool)

+ func (fake *SigningIdentity) AnonymousReturnsOnCall(i int, result1 bool)

+ func (fake *SigningIdentity) ExpiresAt() time.Time

+ func (fake *SigningIdentity) ExpiresAtCallCount() int

+ func (fake *SigningIdentity) ExpiresAtReturns(result1 time.Time)

+ func (fake *SigningIdentity) ExpiresAtReturnsOnCall(i int, result1 time.Time)

+ func (fake *SigningIdentity) GetIdentifier() *msp.IdentityIdentifier

+ func (fake *SigningIdentity) GetIdentifierCallCount() int

+ func (fake *SigningIdentity) GetIdentifierReturns(result1 *msp.IdentityIdentifier)

+ func (fake *SigningIdentity) GetIdentifierReturnsOnCall(i int, result1 *msp.IdentityIdentifier)

+ func (fake *SigningIdentity) GetMSPIdentifier() string

+ func (fake *SigningIdentity) GetMSPIdentifierCallCount() int

+ func (fake *SigningIdentity) GetMSPIdentifierReturns(result1 string)

+ func (fake *SigningIdentity) GetMSPIdentifierReturnsOnCall(i int, result1 string)

+ func (fake *SigningIdentity) GetOrganizationalUnits() []*msp.OUIdentifier

+ func (fake *SigningIdentity) GetOrganizationalUnitsCallCount() int

+ func (fake *SigningIdentity) GetOrganizationalUnitsReturns(result1 []*msp.OUIdentifier)

+ func (fake *SigningIdentity) GetOrganizationalUnitsReturnsOnCall(i int, result1 []*msp.OUIdentifier)

+ func (fake *SigningIdentity) GetPublicVersion() msp.Identity

+ func (fake *SigningIdentity) GetPublicVersionCallCount() int

+ func (fake *SigningIdentity) GetPublicVersionReturns(result1 msp.Identity)

+ func (fake *SigningIdentity) GetPublicVersionReturnsOnCall(i int, result1 msp.Identity)

+ func (fake *SigningIdentity) Invocations() map[string][][]interface{}

+ func (fake *SigningIdentity) SatisfiesPrincipal(principal *mspfabric_protos.MSPPrincipal) error

+ func (fake *SigningIdentity) SatisfiesPrincipalArgsForCall(i int) *mspfabric_protos.MSPPrincipal

+ func (fake *SigningIdentity) SatisfiesPrincipalCallCount() int

+ func (fake *SigningIdentity) SatisfiesPrincipalReturns(result1 error)

+ func (fake *SigningIdentity) SatisfiesPrincipalReturnsOnCall(i int, result1 error)

+ func (fake *SigningIdentity) Serialize() ([]byte, error)

+ func (fake *SigningIdentity) SerializeCallCount() int

+ func (fake *SigningIdentity) SerializeReturns(result1 []byte, result2 error)

+ func (fake *SigningIdentity) SerializeReturnsOnCall(i int, result1 []byte, result2 error)

+ func (fake *SigningIdentity) Sign(msg []byte) ([]byte, error)

+ func (fake *SigningIdentity) SignArgsForCall(i int) []byte

+ func (fake *SigningIdentity) SignCallCount() int

+ func (fake *SigningIdentity) SignReturns(result1 []byte, result2 error)

+ func (fake *SigningIdentity) SignReturnsOnCall(i int, result1 []byte, result2 error)

+ func (fake *SigningIdentity) Validate() error

+ func (fake *SigningIdentity) ValidateCallCount() int

+ func (fake *SigningIdentity) ValidateReturns(result1 error)

+ func (fake *SigningIdentity) ValidateReturnsOnCall(i int, result1 error)

+ func (fake *SigningIdentity) Verify(msg []byte, sig []byte) error

+ func (fake *SigningIdentity) VerifyArgsForCall(i int) ([]byte, []byte)

+ func (fake *SigningIdentity) VerifyCallCount() int

+ func (fake *SigningIdentity) VerifyReturns(result1 error)

+ func (fake *SigningIdentity) VerifyReturnsOnCall(i int, result1 error)

+ type StoreProvider struct

+ StoreForChannelStub func(channelID string) storeapi.Store

+ func (fake *StoreProvider) Invocations() map[string][][]interface{}

+ func (fake *StoreProvider) StoreForChannel(channelID string) storeapi.Store

+ func (fake *StoreProvider) StoreForChannelArgsForCall(i int) string

+ func (fake *StoreProvider) StoreForChannelCallCount() int

+ func (fake *StoreProvider) StoreForChannelReturns(result1 storeapi.Store)

+ func (fake *StoreProvider) StoreForChannelReturnsOnCall(i int, result1 storeapi.Store)

v0.1.0

Nov 6, 2019

Changes in this version

+ func NewCollDataReqMsg(channelID string, reqID uint64, keys ...*store.Key) *protoext.SignedGossipMessage

+ func NewCollDataResMsg(channelID string, reqID uint64, keyVals ...*KeyVal) *protoext.SignedGossipMessage

+ func NewDataMsg(channelID string) *protoext.SignedGossipMessage

+ func NewMember(endpoint string, pkiID []byte, roles ...string) discovery.NetworkMember

+ type BlockBuilder struct

+ func NewBlockBuilder(channelID string, blockNum uint64) *BlockBuilder

+ func (b *BlockBuilder) Build() *cb.Block

+ func (b *BlockBuilder) ConfigUpdate() *ConfigUpdateBuilder

+ func (b *BlockBuilder) Transaction(txID string, validationCode pb.TxValidationCode) *TxBuilder

+ type ChaincodeActionBuilder struct

+ func NewChaincodeActionBuilder(ccID, txID string) *ChaincodeActionBuilder

+ func (b *ChaincodeActionBuilder) Build() []byte

+ func (b *ChaincodeActionBuilder) ChaincodeEvent(eventName string, payload []byte) *ChaincodeActionBuilder

+ func (b *ChaincodeActionBuilder) Collection(coll string) *NamespaceRWSetBuilder

+ func (b *ChaincodeActionBuilder) Delete(key string) *ChaincodeActionBuilder

+ func (b *ChaincodeActionBuilder) Read(key string, version *kvrwset.Version) *ChaincodeActionBuilder

+ func (b *ChaincodeActionBuilder) Response(response *pb.Response) *ChaincodeActionBuilder

+ func (b *ChaincodeActionBuilder) Write(key string, value []byte) *ChaincodeActionBuilder

+ type CollectionBuilder struct

+ func NewPvtReadWriteSetCollectionBuilder(name string) *CollectionBuilder

+ func (c *CollectionBuilder) Build() *rwset.CollectionPvtReadWriteSet

+ func (c *CollectionBuilder) DCASConfig(policy string, requiredPeerCount, maximumPeerCount int32, ttl string) *CollectionBuilder

+ func (c *CollectionBuilder) Delete(key string) *CollectionBuilder

+ func (c *CollectionBuilder) OffLedgerConfig(policy string, requiredPeerCount, maximumPeerCount int32, ttl string) *CollectionBuilder

+ func (c *CollectionBuilder) Read(key string, blockNum uint64, txIdx uint64) *CollectionBuilder

+ func (c *CollectionBuilder) StaticConfig(policy string, requiredPeerCount, maximumPeerCount int32, btl uint64) *CollectionBuilder

+ func (c *CollectionBuilder) TransientConfig(policy string, requiredPeerCount, maximumPeerCount int32, ttl string) *CollectionBuilder

+ func (c *CollectionBuilder) WithMarshalError() *CollectionBuilder

+ func (c *CollectionBuilder) Write(key string, value []byte) *CollectionBuilder

+ type ConfigUpdateBuilder struct

+ func NewConfigUpdateBuilder(channelID string) *ConfigUpdateBuilder

+ func (b *ConfigUpdateBuilder) Build() []byte

+ type DataProvider struct

+ func NewDataProvider() *DataProvider

+ func (p *DataProvider) RetrieverForChannel(channel string) storeapi.Retriever

+ func (p *DataProvider) WithData(key *storeapi.Key, value *storeapi.ExpiringValue) *DataProvider

+ func (p *DataProvider) WithError(err error) *DataProvider

+ func (p *DataProvider) WithQueryResults(key *storeapi.QueryKey, results []*storeapi.QueryResult) *DataProvider

+ type DataStore struct

+ func NewDataStore() *DataStore

+ func (m *DataStore) Close()

+ func (m *DataStore) Data(key *storeapi.Key, value *storeapi.ExpiringValue) *DataStore

+ func (m *DataStore) Error(err error) *DataStore

+ func (m *DataStore) GetData(key *storeapi.Key) (*storeapi.ExpiringValue, error)

+ func (m *DataStore) GetDataMultipleKeys(key *storeapi.MultiKey) (storeapi.ExpiringValues, error)

+ func (m *DataStore) GetTransientData(key *storeapi.Key) (*storeapi.ExpiringValue, error)

+ func (m *DataStore) GetTransientDataMultipleKeys(key *storeapi.MultiKey) (storeapi.ExpiringValues, error)

+ func (m *DataStore) Persist(txid string, ...) error

+ func (m *DataStore) PutData(config *cb.StaticCollectionConfig, key *storeapi.Key, ...) error

+ func (m *DataStore) Query(key *storeapi.QueryKey) (storeapi.ResultsIterator, error)

+ func (m *DataStore) TransientData(key *storeapi.Key, value *storeapi.ExpiringValue) *DataStore

+ type KVIterator struct

+ func NewKVIterator(kvs []*statedb.VersionedKV) *KVIterator

+ func (it *KVIterator) Close()

+ func (it *KVIterator) Next() (commonledger.QueryResult, error)

+ func (it *KVIterator) WithError(err error) *KVIterator

+ type KeyVal struct

+ func NewKeyValue(key *store.Key, value *store.ExpiringValue) *KeyVal

+ type Ledger struct

+ BcInfoError error

+ BlockchainInfo *common.BlockchainInfo

+ Error error

+ QueryExecutor *QueryExecutor

+ TxSimulator *TxSimulator

+ func (m *Ledger) CheckpointBlock(block *common.Block) error

+ func (m *Ledger) Close()

+ func (m *Ledger) CommitPvtDataOfOldBlocks(blockPvtData []*ledger2.BlockPvtData) ([]*ledger2.PvtdataHashMismatch, error)

+ func (m *Ledger) CommitWithPvtData(blockAndPvtdata *ledger2.BlockAndPvtData) error

+ func (m *Ledger) GetBlockByHash(blockHash []byte) (*common.Block, error)

+ func (m *Ledger) GetBlockByNumber(blockNumber uint64) (*common.Block, error)

+ func (m *Ledger) GetBlockByTxID(txID string) (*common.Block, error)

+ func (m *Ledger) GetBlockchainInfo() (*common.BlockchainInfo, error)

+ func (m *Ledger) GetBlocksIterator(startBlockNumber uint64) (ledger.ResultsIterator, error)

+ func (m *Ledger) GetConfigHistoryRetriever() (ledger2.ConfigHistoryRetriever, error)

+ func (m *Ledger) GetMissingPvtDataTracker() (ledger2.MissingPvtDataTracker, error)

+ func (m *Ledger) GetPvtDataAndBlockByNum(blockNum uint64, filter ledger2.PvtNsCollFilter) (*ledger2.BlockAndPvtData, error)

+ func (m *Ledger) GetPvtDataByNum(blockNum uint64, filter ledger2.PvtNsCollFilter) ([]*ledger2.TxPvtData, error)

+ func (m *Ledger) GetTransactionByID(txID string) (*peer.ProcessedTransaction, error)

+ func (m *Ledger) GetTxValidationCodeByTxID(txID string) (peer.TxValidationCode, error)

+ func (m *Ledger) NewHistoryQueryExecutor() (ledger2.HistoryQueryExecutor, error)

+ func (m *Ledger) NewQueryExecutor() (ledger2.QueryExecutor, error)

+ func (m *Ledger) NewTxSimulator(txid string) (ledger2.TxSimulator, error)

+ type MessageHandler func(msg *gossipproto.GossipMessage)

+ type MockAccessPolicy struct

+ Filter privdata.Filter

+ MaxPeerCount int

+ OnlyRead bool

+ OnlyWrite bool

+ Orgs []string

+ ReqPeerCount int

+ func (m *MockAccessPolicy) AccessFilter() privdata.Filter

+ func (m *MockAccessPolicy) IsMemberOnlyRead() bool

+ func (m *MockAccessPolicy) IsMemberOnlyWrite() bool

+ func (m *MockAccessPolicy) MaximumPeerCount() int

+ func (m *MockAccessPolicy) MemberOrgs() []string

+ func (m *MockAccessPolicy) RequiredPeerCount() int

+ type MockBlockHandler struct

+ func NewMockBlockHandler() *MockBlockHandler

+ func (m *MockBlockHandler) HandleChaincodeEvent(txMetadata api.TxMetadata, event *pb.ChaincodeEvent) error

+ func (m *MockBlockHandler) HandleChaincodeUpgradeEvent(txMetadata api.TxMetadata, chaincodeName string) error

+ func (m *MockBlockHandler) HandleConfigUpdate(blockNum uint64, configUpdate *cb.ConfigUpdate) error

+ func (m *MockBlockHandler) HandleLSCCWrite(txMetadata api.TxMetadata, chaincodeName string, ...) error

+ func (m *MockBlockHandler) HandleRead(txMetadata api.TxMetadata, namespace string, kvRead *kvrwset.KVRead) error

+ func (m *MockBlockHandler) HandleWrite(txMetadata api.TxMetadata, namespace string, kvWrite *kvrwset.KVWrite) error

+ func (m *MockBlockHandler) NumCCEvents() int

+ func (m *MockBlockHandler) NumCCUpgradeEvents() int

+ func (m *MockBlockHandler) NumConfigUpdates() int

+ func (m *MockBlockHandler) NumLSCCWrites() int

+ func (m *MockBlockHandler) NumReads() int

+ func (m *MockBlockHandler) NumWrites() int

+ func (m *MockBlockHandler) WithError(err error) *MockBlockHandler

+ type MockBlockPublisher struct

+ HandleCCEvent gossipapi.ChaincodeEventHandler

+ HandleConfigUpdate gossipapi.ConfigUpdateHandler

+ HandleLSCCWrite gossipapi.LSCCWriteHandler

+ HandleRead gossipapi.ReadHandler

+ HandleUpgrade gossipapi.ChaincodeUpgradeHandler

+ HandleWrite gossipapi.WriteHandler

+ func NewBlockPublisher() *MockBlockPublisher

+ func (m *MockBlockPublisher) AddCCEventHandler(handler gossipapi.ChaincodeEventHandler)

+ func (m *MockBlockPublisher) AddCCUpgradeHandler(handler gossipapi.ChaincodeUpgradeHandler)

+ func (m *MockBlockPublisher) AddConfigUpdateHandler(handler gossipapi.ConfigUpdateHandler)

+ func (m *MockBlockPublisher) AddLSCCWriteHandler(handler gossipapi.LSCCWriteHandler)

+ func (m *MockBlockPublisher) AddReadHandler(handler gossipapi.ReadHandler)

+ func (m *MockBlockPublisher) AddWriteHandler(handler gossipapi.WriteHandler)

+ func (m *MockBlockPublisher) LedgerHeight() uint64

+ func (m *MockBlockPublisher) Publish(block *common.Block)

+ type MockBlockPublisherProvider struct

+ func NewBlockPublisherProvider() *MockBlockPublisherProvider

+ func (m *MockBlockPublisherProvider) ForChannel(channelID string) gossipapi.BlockPublisher

+ type MockGossipAdapter struct

+ func NewMockGossipAdapter() *MockGossipAdapter

+ func (m *MockGossipAdapter) IdentityInfo() gossipapi.PeerIdentitySet

+ func (m *MockGossipAdapter) Member(mspID string, member discovery.NetworkMember) *MockGossipAdapter

+ func (m *MockGossipAdapter) MemberWithNoPKIID(mspID string, member discovery.NetworkMember) *MockGossipAdapter

+ func (m *MockGossipAdapter) MessageHandler(handler MessageHandler) *MockGossipAdapter

+ func (m *MockGossipAdapter) PeersOfChannel(common.ChainID) []discovery.NetworkMember

+ func (m *MockGossipAdapter) Self(mspID string, self discovery.NetworkMember) *MockGossipAdapter

+ func (m *MockGossipAdapter) SelfMembershipInfo() discovery.NetworkMember

+ func (m *MockGossipAdapter) Send(msg *gossipproto.GossipMessage, peers ...*comm.RemotePeer)

+ type MockReceivedMessage struct

+ Member discovery.NetworkMember

+ Message *protoext.SignedGossipMessage

+ RespondTo func(msg *gproto.GossipMessage)

+ func (m *MockReceivedMessage) Ack(err error)

+ func (m *MockReceivedMessage) GetConnectionInfo() *protoext.ConnectionInfo

+ func (m *MockReceivedMessage) GetGossipMessage() *protoext.SignedGossipMessage

+ func (m *MockReceivedMessage) GetSourceEnvelope() *gproto.Envelope

+ func (m *MockReceivedMessage) Respond(msg *gproto.GossipMessage)

+ type MockSupport struct

+ CollConfigs []*cb.StaticCollectionConfig

+ CollPolicy privdata.CollectionAccessPolicy

+ Err error

+ Publisher *MockBlockPublisher

+ func NewMockSupport() *MockSupport

+ func (s *MockSupport) BlockPublisher(channelID string) gossipapi.BlockPublisher

+ func (s *MockSupport) CollectionConfig(collConfig *cb.StaticCollectionConfig) *MockSupport

+ func (s *MockSupport) CollectionPolicy(collPolicy privdata.CollectionAccessPolicy) *MockSupport

+ func (s *MockSupport) Config(channelID, ns, coll string) (*cb.StaticCollectionConfig, error)

+ func (s *MockSupport) Policy(channelID, ns, coll string) (privdata.CollectionAccessPolicy, error)

+ type NamespaceBuilder struct

+ func NewNamespaceBuilder(name string) *NamespaceBuilder

+ func (b *NamespaceBuilder) BuildCollectionConfig() *common.CollectionConfigPackage

+ func (b *NamespaceBuilder) BuildCollectionHashedRWSets() []*rwset.CollectionHashedReadWriteSet

+ func (b *NamespaceBuilder) BuildNSReadWriteSets() []byte

+ func (b *NamespaceBuilder) BuildReadWriteSets() []*rwset.CollectionPvtReadWriteSet

+ func (b *NamespaceBuilder) Collection(name string) *CollectionBuilder

+ func (b *NamespaceBuilder) Delete(key string) *NamespaceBuilder

+ func (b *NamespaceBuilder) Read(key string, blockNum uint64, txIdx uint64) *NamespaceBuilder

+ func (b *NamespaceBuilder) WithMarshalError() *NamespaceBuilder

+ func (b *NamespaceBuilder) Write(key string, value []byte) *NamespaceBuilder

+ type NamespaceRWSetBuilder struct

+ func NewNamespaceRWSetBuilder(ns string) *NamespaceRWSetBuilder

+ func (b *NamespaceRWSetBuilder) Build() *rwsetutil.NsRwSet

+ func (b *NamespaceRWSetBuilder) Delete(key string) *NamespaceRWSetBuilder

+ func (b *NamespaceRWSetBuilder) Read(key string, version *kvrwset.Version) *NamespaceRWSetBuilder

+ func (b *NamespaceRWSetBuilder) Write(key string, value []byte) *NamespaceRWSetBuilder

+ type PvtReadWriteSetBuilder struct

+ func NewPvtReadWriteSetBuilder() *PvtReadWriteSetBuilder

+ func (b *PvtReadWriteSetBuilder) Build() *transientstore.TxPvtReadWriteSetWithConfigInfo

+ func (b *PvtReadWriteSetBuilder) BuildCollectionConfigs() map[string]*common.CollectionConfigPackage

+ func (b *PvtReadWriteSetBuilder) BuildReadWriteSet() *rwset.TxPvtReadWriteSet

+ func (b *PvtReadWriteSetBuilder) Namespace(name string) *NamespaceBuilder

+ type QueryExecutor struct

+ func NewQueryExecutor() *QueryExecutor

+ func (m *QueryExecutor) Done()

+ func (m *QueryExecutor) ExecuteQuery(namespace, query string) (commonledger.ResultsIterator, error)

+ func (m *QueryExecutor) ExecuteQueryOnPrivateData(namespace, collection, query string) (commonledger.ResultsIterator, error)

+ func (m *QueryExecutor) ExecuteQueryWithMetadata(namespace, query string, metadata map[string]interface{}) (ledger.QueryResultsIterator, error)

+ func (m *QueryExecutor) GetPrivateData(namespace, collection, key string) ([]byte, error)

+ func (m *QueryExecutor) GetPrivateDataHash(namespace, collection, key string) ([]byte, error)

+ func (m *QueryExecutor) GetPrivateDataMetadata(namespace, collection, key string) (map[string][]byte, error)

+ func (m *QueryExecutor) GetPrivateDataMetadataByHash(namespace, collection string, keyhash []byte) (map[string][]byte, error)

+ func (m *QueryExecutor) GetPrivateDataMultipleKeys(namespace, collection string, keys []string) ([][]byte, error)

+ func (m *QueryExecutor) GetPrivateDataRangeScanIterator(namespace, collection, startKey, endKey string) (commonledger.ResultsIterator, error)

+ func (m *QueryExecutor) GetState(namespace string, key string) ([]byte, error)

+ func (m *QueryExecutor) GetStateMetadata(namespace, key string) (map[string][]byte, error)

+ func (m *QueryExecutor) GetStateMultipleKeys(namespace string, keys []string) ([][]byte, error)

+ func (m *QueryExecutor) GetStateRangeScanIterator(namespace string, startKey string, endKey string) (commonledger.ResultsIterator, error)

+ func (m *QueryExecutor) GetStateRangeScanIteratorWithMetadata(namespace string, startKey, endKey string, metadata map[string]interface{}) (ledger.QueryResultsIterator, error)

+ func (m *QueryExecutor) WithDeletedPrivateState(ns, collection, key string) *QueryExecutor

+ func (m *QueryExecutor) WithDeletedState(ns, key string) *QueryExecutor

+ func (m *QueryExecutor) WithError(err error) *QueryExecutor

+ func (m *QueryExecutor) WithIteratorProvider(p func() *ResultsIterator) *QueryExecutor

+ func (m *QueryExecutor) WithKVIteratorProvider(p func(kvs []*statedb.VersionedKV) *KVIterator) *QueryExecutor

+ func (m *QueryExecutor) WithPrivateQueryResults(ns, coll, query string, results []*queryresult.KV) *QueryExecutor

+ func (m *QueryExecutor) WithPrivateState(ns, collection, key string, value []byte) *QueryExecutor

+ func (m *QueryExecutor) WithQueryError(err error) *QueryExecutor

+ func (m *QueryExecutor) WithQueryResults(ns, query string, results []*queryresult.KV) *QueryExecutor

+ func (m *QueryExecutor) WithState(ns, key string, value []byte) *QueryExecutor

+ type QueryExecutorProvider struct

+ func NewQueryExecutorProvider() *QueryExecutorProvider

+ func (m *QueryExecutorProvider) GetQueryExecutorForLedger(channelID string) (ledger.QueryExecutor, error)

+ func (m *QueryExecutorProvider) WithError(err error) *QueryExecutorProvider

+ func (m *QueryExecutorProvider) WithMockQueryExecutor(qe *QueryExecutor) *QueryExecutorProvider

+ type ReadWriteSetBuilder struct

+ func NewReadWriteSetBuilder() *ReadWriteSetBuilder

+ func (b *ReadWriteSetBuilder) Build() *rwset.TxReadWriteSet

+ func (b *ReadWriteSetBuilder) Namespace(name string) *NamespaceBuilder

+ type ResultsIterator struct

+ func NewResultsIterator() *ResultsIterator

+ func (m *ResultsIterator) Close()

+ func (m *ResultsIterator) Next() (commonledger.QueryResult, error)

+ func (m *ResultsIterator) WithError(err error) *ResultsIterator

+ func (m *ResultsIterator) WithResults(results []*queryresult.KV) *ResultsIterator

+ type TxBuilder struct

+ func NewTxBuilder(channelID, txID string, validationCode pb.TxValidationCode) *TxBuilder

+ func (b *TxBuilder) Build() ([]byte, pb.TxValidationCode)

+ func (b *TxBuilder) ChaincodeAction(ccID string) *ChaincodeActionBuilder

+ type TxSimulator struct

+ Error error

+ SimError error

+ SimulationResults *ledger.TxSimulationResults

+ func (m *TxSimulator) DeletePrivateData(namespace, collection, key string) error

+ func (m *TxSimulator) DeletePrivateDataMetadata(namespace, collection, key string) error

+ func (m *TxSimulator) DeleteState(namespace string, key string) error

+ func (m *TxSimulator) DeleteStateMetadata(namespace, key string) error

+ func (m *TxSimulator) ExecuteUpdate(query string) error

+ func (m *TxSimulator) GetTxSimulationResults() (*ledger.TxSimulationResults, error)

+ func (m *TxSimulator) SetPrivateData(namespace, collection, key string, value []byte) error

+ func (m *TxSimulator) SetPrivateDataMetadata(namespace, collection, key string, metadata map[string][]byte) error

+ func (m *TxSimulator) SetPrivateDataMultipleKeys(namespace, collection string, kvs map[string][]byte) error

+ func (m *TxSimulator) SetState(namespace string, key string, value []byte) error

+ func (m *TxSimulator) SetStateMetadata(namespace, key string, metadata map[string][]byte) error

+ func (m *TxSimulator) SetStateMultipleKeys(namespace string, kvs map[string][]byte) error

?	: This menu
/	: Search site
f or F	: Jump to
y or Y	: Canonical URL