Code
Hub
Workspaces
Following
Trending
Connect
MCP
copy
Create free account
hub
/
github.com/dddengyunjie/fabric
/ functions
Functions
19,835 in github.com/dddengyunjie/fabric
⨍
Functions
19,835
◇
Types & classes
3,362
↓ 27 callers
Function
newPushPullTestInstance
(name string, peers map[string]*pullTestInstance)
gossip/gossip/algo/pull_test.go:60
↓ 27 callers
Function
newTestEnv
(t testing.TB, conf *Conf)
common/ledger/blkstorage/fsblkstorage/pkg_test.go:49
↓ 27 callers
Method
sampleVal
(val, ledgerid string)
core/ledger/kvledger/tests/sample_data_helper.go:246
↓ 27 callers
Function
testPath
()
common/ledger/blkstorage/fsblkstorage/pkg_test.go:36
↓ 26 callers
Method
AddCallCount
()
common/metrics/metricsfakes/gauge.go:96
↓ 26 callers
Method
Format
(w io.Writer, entry zapcore.Entry, fields []zapcore.Field)
common/flogging/fabenc/encoder.go:28
↓ 26 callers
Method
GetTxSimulationResults
GetTxSimulationResults returns the proto bytes of public rwset (public data + hashes of private data) and the private rwset for the transaction
core/ledger/kvledger/txmgmt/rwsetutil/rwset_builder.go:132
↓ 26 callers
Function
InitMSP
InitMSP init MSP
peer/channel/create_test.go:127
↓ 26 callers
Method
MockInvoke
Invoke this chaincode, also starts and ends a transaction.
core/chaincode/shim/mockstub.go:136
↓ 26 callers
Method
ProcessProposal
(ctx context.Context, in *SignedProposal, opts ...grpc.CallOption)
protos/peer/peer.pb.go:127
↓ 26 callers
Method
Release
()
core/comm/throttle.go:18
↓ 26 callers
Method
WithOptions
(opts ...zap.Option)
common/flogging/zap.go:100
↓ 26 callers
Function
assertBlockReception
assertBlockReception asserts that the given orderers have expected heights for the given channel--> height mapping
integration/e2e/etcdraft_reconfig_test.go:1247
↓ 26 callers
Function
createRWset
(t *testing.T, ccnames ...string)
core/committer/txvalidator/validator_test.go:133
↓ 26 callers
Function
newConfigUpdateEnv
(chainID string, oldValues, newValues map[string]*common.ConfigValue)
orderer/consensus/etcdraft/chain_test.go:3984
↓ 26 callers
Method
recordInvocation
(key string, args []interface{})
core/chaincode/mock/tx_simulator.go:2052
↓ 25 callers
Method
Bytes
Bytes converts this key to its byte representation, if this operation is allowed.
bccsp/bccsp.go:29
↓ 25 callers
Method
Clone
Clone makes a copy of this TransportCredentials.
core/comm/creds.go:84
↓ 25 callers
Method
ConnCount
()
core/deliverservice/mocks/orderer.go:74
↓ 25 callers
Method
DecodeVarint
DecodeVarint wraps the actual method and updates the position
common/ledger/util/protobuf_util.go:37
↓ 25 callers
Method
HandleInvokeChaincode
Handles requests that modify ledger state
core/chaincode/handler.go:1093
↓ 25 callers
Method
IsTagLegal
IsTagLegal checks the GossipMessage tags and inner type and returns an error if the tag doesn't match the type.
protos/gossip/extensions.go:244
↓ 25 callers
Method
JoinChan
JoinChan makes the Gossip instance join a channel
gossip/gossip/gossip.go:69
↓ 25 callers
Method
MSPID
MSPID returns the MSP ID associated with this org
common/channelconfig/api.go:26
↓ 25 callers
Function
New
New creates a new instance of the LSCC Typically there is only one of these per peer
core/scc/lscc/lscc.go:146
↓ 25 callers
Function
NewTreeVertex
NewTreeVertex creates a new vertex with a given unique id and a given arbitrary data
common/graph/tree.go:26
↓ 25 callers
Method
NextBlock
NextBlock constructs next block in sequence that includes a number of transactions - one per simulationResults
common/ledger/testutil/test_helper.go:52
↓ 25 callers
Method
ObserveArgsForCall
(i int)
common/metrics/metricsfakes/histogram.go:97
↓ 25 callers
Method
PutState
PutState writes the specified `value` and `key` into the ledger.
core/chaincode/shim/mockstub.go:207
↓ 25 callers
Method
SetNextExpectedSeek
(seq uint64)
core/deliverservice/mocks/orderer.go:86
↓ 25 callers
Method
UpdateLedgerHeight
UpdateLedgerHeight updates the ledger height the peer publishes to other peers in the channel
gossip/gossip/gossip.go:49
↓ 25 callers
Function
configureAdapter
(adapter *gossipAdapterMock, members ...discovery.NetworkMember)
gossip/gossip/channel/channel_test.go:275
↓ 25 callers
Function
getSignedByMSPMemberPolicy
(mspID string)
core/handlers/validation/builtin/v13/validation_logic_test.go:289
↓ 25 callers
Function
getSignedByMSPMemberPolicy
(mspID string)
core/handlers/validation/builtin/v12/validation_logic_test.go:288
↓ 25 callers
Function
newClusterNode
(t *testing.T)
orderer/common/cluster/deliver_test.go:261
↓ 25 callers
Function
newCollectionStore
()
gossip/privdata/pull_test.go:68
↓ 25 callers
Function
processDone
(t *testing.T, done chan error, expecterr bool)
core/chaincode/shim/shim_test.go:552
↓ 24 callers
Method
AddArgsForCall
(i int)
orderer/consensus/kafka/mock/metrics_gauge.go:102
↓ 24 callers
Method
AddToReadSet
AddToReadSet adds a key and corresponding version to the read-set
core/ledger/kvledger/txmgmt/rwsetutil/rwset_builder.go:77
↓ 24 callers
Method
Capabilities
Capabilities defines the capabilities for the application portion of this channel
core/committer/txvalidator/validator.go:55
↓ 24 callers
Method
Discover
Discover receives a signed request, and returns a response.
protos/discovery/protocol.pb.go:1403
↓ 24 callers
Method
GetDataMsg
()
protos/gossip/message.pb.go:551
↓ 24 callers
Method
GetOrCreate
GetOrCreate gets an existing ledger (if it exists) or creates it if it does not
common/ledger/blockledger/ledger.go:18
↓ 24 callers
Method
GetStateReturnsOnCall
(i int, result1 []byte, result2 error)
token/ledger/mock/ledger_reader.go:86
↓ 24 callers
Method
IsDataMsg
IsDataMsg returns whether this GossipMessage is a data message
protos/gossip/extensions.go:130
↓ 24 callers
Method
KeyDeriv
KeyDeriv derives a key from k using opts. The opts argument should be appropriate for the primitive used.
bccsp/sw/internals.go:37
↓ 24 callers
Method
Notify
(msg *pb.ChaincodeMessage)
core/chaincode/handler.go:529
↓ 24 callers
Method
Open
Open opens the db
core/ledger/kvledger/txmgmt/statedb/statedb.go:71
↓ 24 callers
Method
ReadDoc
ReadDoc method provides function to retrieve a document and its revision from the database by id
core/ledger/util/couchdb/couchdb.go:746
↓ 24 callers
Method
SendBlock
(seq uint64)
core/deliverservice/mocks/orderer.go:90
↓ 24 callers
Method
SetStateContext
SetStateContext sets the consensus-type migration state and context of the underlying chain.
orderer/consensus/migration/migration.go:23
↓ 24 callers
Method
WithReturns
(result1 metrics.Gauge)
common/metrics/metricsfakes/gauge.go:65
↓ 24 callers
Method
WriteBatch
WriteBatch writes a batch
common/ledger/util/leveldbhelper/leveldb_helper.go:147
↓ 24 callers
Method
WriteBlockArgsForCall
(i int)
orderer/consensus/mocks/mock_consenter_support.go:1186
↓ 24 callers
Method
WriteBlockCallCount
()
orderer/consensus/mocks/mock_consenter_support.go:1174
↓ 24 callers
Function
createDiscoveryInstance
(port int, id string, bootstrapPeers []string)
gossip/discovery/discovery_test.go:343
↓ 24 callers
Method
elect
elect deterministically elects a node as leader
orderer/consensus/etcdraft/chain_test.go:3920
↓ 24 callers
Function
extractSimpleMsgPlainField
(source []byte)
common/tools/protolator/statically_opaque_test.go:29
↓ 24 callers
Method
retryOptions
()
orderer/consensus/kafka/consenter.go:98
↓ 24 callers
Method
stop
()
gossip/gossip/algo/pull_test.go:128
↓ 23 callers
Method
AssertExpectations
AssertExpectations overrider the mock method for convenience
core/aclmgmt/mocks/mocks.go:43
↓ 23 callers
Method
Build
()
core/container/controller.go:26
↓ 23 callers
Method
Exists
Exists tells whether the ledger with given id exists
core/ledger/ledger_interface.go:41
↓ 23 callers
Method
GetDBHandle
GetDBHandle returns a handle to a VersionedDB
core/ledger/kvledger/txmgmt/statedb/statedb.go:24
↓ 23 callers
Method
Iterator
Iterator returns an Iterator, as specified by an ab.SeekInfo message, and its starting block number
common/ledger/blockledger/ledger.go:40
↓ 23 callers
Method
Len
()
discovery/client/selection.go:142
↓ 23 callers
Method
Stop
Stop stops the chaincode give
core/common/ccprovider/ccprovider.go:531
↓ 23 callers
Function
aliveMessage
(id int)
discovery/client/client_test.go:878
↓ 23 callers
Function
constructVersionedKV
(ns string, key string, value []byte, version *version.Height)
core/ledger/kvledger/txmgmt/validator/statebasedval/combined_iterator_test.go:119
↓ 23 callers
Function
createTestKey
(i int)
core/ledger/kvledger/txmgmt/txmgr/lockbasedtxmgr/txmgr_test.go:651
↓ 23 callers
Function
newMockEnvelope
(content string)
orderer/consensus/kafka/consenter_test.go:176
↓ 23 callers
Method
validateAndCommitRWSet
(txRWSet *rwset.TxReadWriteSet)
core/ledger/kvledger/txmgmt/txmgr/lockbasedtxmgr/pkg_test.go:125
↓ 23 callers
Method
verifyPvtState
(ns, coll, key string, expectedVal string)
core/ledger/kvledger/tests/verifier.go:55
↓ 22 callers
Method
EligibleForChannel
EligibleForChannel returns whether the given member should get blocks for this channel
gossip/gossip/channel/channel.go:82
↓ 22 callers
Method
Execute
Execute executes a standard chaincode invocation for a chaincode and an input
core/common/ccprovider/ccprovider.go:526
↓ 22 callers
Method
GetSignedProposal
GetSignedProposal returns the SignedProposal object, which contains all data elements part of a transaction proposal.
core/chaincode/shim/interfaces.go:332
↓ 22 callers
Method
Init
Init initializes the Filter with the next EndorserServer
core/handlers/auth/auth.go:18
↓ 22 callers
Method
Level
(ctx context.Context, fullMethod string)
common/grpclogging/server.go:23
↓ 22 callers
Method
Open
Open opens an already created ledger
core/ledger/ledger_interface.go:39
↓ 22 callers
Method
ProcessProposal
(context.Context, *SignedProposal)
protos/peer/peer.pb.go:149
↓ 22 callers
Method
Warnf
(template string, args ...interface{})
core/operations/system.go:36
↓ 22 callers
Function
putCCInfo
(theLedger ledger.PeerLedger, ccname string, policy []byte, t *testing.T)
core/committer/txvalidator/validator_test.go:322
↓ 21 callers
Method
AddDescendant
AddDescendant creates a new vertex who's parent is the invoker vertex, with a given id and data. Returns the new vertex
common/graph/tree.go:41
↓ 21 callers
Function
BasePort
()
integration/e2e/e2e_suite_test.go:47
↓ 21 callers
Method
DiscoveredPeer
the function creates a new DiscoveredPeer from the peer and chaincodes passed as arguments
integration/nwo/network.go:1083
↓ 21 callers
Method
GetContent
()
protos/gossip/message.pb.go:523
↓ 21 callers
Method
GetIterator
GetIterator returns an iterator over key-value store. The iterator should be released after the use. The resultset contains all the keys that are pres
common/ledger/util/leveldbhelper/leveldb_helper.go:142
↓ 21 callers
Method
GetPolicy
GetPolicy returns a policy and true if it was the policy requested, or false if it is the default policy
common/policies/policy.go:129
↓ 21 callers
Method
GetStaticCollectionConfig
()
protos/common/collection.pb.go:115
↓ 21 callers
Method
IsSetTo
IsSetTo returns true if the specified transaction equals flag; false otherwise.
core/ledger/util/txvalidationflags.go:58
↓ 21 callers
Method
MigrationStatus
Status provides access to the consensus-type migration status of the underlying chain.
orderer/consensus/consensus.go:71
↓ 21 callers
Method
NewConnection
NewConnection creates a new connection. Returns the connection, the endpoint selected, nil on success. Returns nil, "", error on failure
core/comm/producer.go:32
↓ 21 callers
Method
NewGauge
NewGauge creates a new instance of a Gauge.
orderer/common/cluster/metrics.go:105
↓ 21 callers
Method
NewStream
NewStream creates a new stream. It is not thread safe, and Send() or Recv() block only until the timeout expires.
orderer/common/cluster/comm.go:641
↓ 21 callers
Method
OfChannel
OfChannel sets the next queries added to be in the given channel's context
discovery/client/client.go:139
↓ 21 callers
Method
Setup
(requiredPeerCount int, maxPeerCount int, accessFilter privdata.Filter, orgs []string, memberOnlyRead bool)
gossip/privdata/distributor_test.go:67
↓ 21 callers
Method
Size
size returns the amount of messages in the store
gossip/gossip/msgstore/msgs.go:88
↓ 21 callers
Method
StoreKey
StoreKey stores the key k in this KeyStore. If this KeyStore is read only then the method will fail.
bccsp/keystore.go:33
↓ 21 callers
Method
Validate
Validate implements the function of the StateBasedValidator interface
core/common/validation/statebased/validator_keylevel.go:198
↓ 21 callers
Method
WriteBlock
WriteBlock commits a block to the ledger.
orderer/consensus/consensus.go:100
← previous
next →
301–400 of 19,835, ranked by callers