Code
Hub
Workspaces
Following
Trending
Connect
MCP
copy
Create free account
hub
/
github.com/tendermint/tendermint
/ functions
Functions
9,600 in github.com/tendermint/tendermint
⨍
Functions
9,600
◇
Types & classes
1,209
↓ 1 callers
Function
deriveSecrets
( dhSecret *[32]byte, locIsLeast bool, )
privval/secret_connection.go:339
↓ 1 callers
Function
deterministicResponseDeliverTx
deterministicResponseDeliverTx strips non-deterministic fields from ResponseDeliverTx and returns another ResponseDeliverTx.
types/results.go:47
↓ 1 callers
Function
deterministicValidator
Testing util functions deterministicValidator returns a deterministic validator, useful for testing. UNSTABLE
types/validator_test.go:108
↓ 1 callers
Function
deterministicValidatorSet
Testing Utils deterministicValidatorSet returns a deterministic validator set (size: +numValidators+), where each validator has a power of 50 EXPOSED
types/validator_set_test.go:1608
↓ 1 callers
Function
deterministicVoteSet
( height int64, round int32, signedMsgType tmproto.SignedMsgType, votingPower int64, )
types/vote_set_test.go:491
↓ 1 callers
Method
dialAttemptsInfo
(addr *p2p.NetAddress)
internal/p2p/pex/pex_reactor.go:539
↓ 1 callers
Method
dialPeer
dialPeer connects to a peer by dialing it.
internal/p2p/router.go:756
↓ 1 callers
Method
dialPeers
dialPeers maintains outbound connections to peers by dialing them.
internal/p2p/router.go:651
↓ 1 callers
Method
dialPeersAsync
(netAddrs []*NetAddress)
internal/p2p/switch.go:529
↓ 1 callers
Method
didRecvResponse
(res *types.Response)
abci/client/socket_client.go:181
↓ 1 callers
Function
diffDocs
(w io.Writer, lhs, rhs *tomledit.Document)
scripts/condiff/condiff.go:93
↓ 1 callers
Function
diffKeys
(w io.Writer, lhs, rhs []string)
scripts/condiff/condiff.go:129
↓ 1 callers
Method
dispatch
dispatch takes a peer and allocates it a channel so long as it's not already busy and the receiving channel is still running. It then dispatches the m
internal/statesync/dispatcher.go:80
↓ 1 callers
Function
doHandshake
( stateStore sm.Store, state sm.State, blockStore sm.BlockStore, genDoc *types.GenesisDoc, eventBus types
node/setup.go:142
↓ 1 callers
Method
drainQueue
drainQueue marks as complete and discards all remaining pending requests from the queue.
abci/client/socket_client.go:508
↓ 1 callers
Function
echoBytesViaHTTP
(cl client.Caller, bytes []byte)
rpc/jsonrpc/jsonrpc_test.go:165
↓ 1 callers
Function
echoBytesViaWS
(cl *client.WSClient, bytes []byte)
rpc/jsonrpc/jsonrpc_test.go:231
↓ 1 callers
Function
echoDataBytesViaHTTP
(cl client.Caller, bytes tmbytes.HexBytes)
rpc/jsonrpc/jsonrpc_test.go:176
↓ 1 callers
Function
echoIntViaHTTP
(cl client.Caller, val int)
rpc/jsonrpc/jsonrpc_test.go:154
↓ 1 callers
Function
echoReactor
(channel *p2p.Channel)
internal/p2p/router_test.go:29
↓ 1 callers
Function
echoViaWS
(cl *client.WSClient, val string)
rpc/jsonrpc/jsonrpc_test.go:209
↓ 1 callers
Function
encode
(w io.Writer, v interface{})
libs/json/encoder.go:45
↓ 1 callers
Function
encodeReflectList
(w io.Writer, rv reflect.Value)
libs/json/encoder.go:118
↓ 1 callers
Function
encodeReflectMap
(w io.Writer, rv reflect.Value)
libs/json/encoder.go:153
↓ 1 callers
Function
encodeReflectStruct
(w io.Writer, rv reflect.Value)
libs/json/encoder.go:184
↓ 1 callers
Method
enqueue
(peerID types.NodeID, block *types.Block, height int64)
internal/blocksync/v2/processor.go:97
↓ 1 callers
Method
enqueue
(req *jsonRPCBufferedRequest)
rpc/jsonrpc/client/http_json_client.go:317
↓ 1 callers
Function
ensureBlockSyncStatus
(t *testing.T, msg tmpubsub.Message, complete bool, height int64)
internal/consensus/reactor_test.go:266
↓ 1 callers
Method
ensureCatchupCommitRound
'round': A round for which we have a +2/3 commit.
internal/consensus/peer_state.go:259
↓ 1 callers
Method
ensureConnection
()
privval/signer_dialer_endpoint.go:72
↓ 1 callers
Function
ensureNoNewRoundStep
(stepCh <-chan tmpubsub.Message)
internal/consensus/common_test.go:505
↓ 1 callers
Function
ensureNoNewTimeout
(stepCh <-chan tmpubsub.Message, timeout int64)
internal/consensus/common_test.go:519
↓ 1 callers
Function
ensureNoNewUnlock
(unlockCh <-chan tmpubsub.Message)
internal/consensus/common_test.go:512
↓ 1 callers
Method
ensurePeersRoutine
Ensures that sufficient peers are connected. (continuous)
internal/p2p/pex/pex_reactor.go:418
↓ 1 callers
Function
ensurePrecommitMatch
(t *testing.T, voteCh <-chan tmpubsub.Message, height int64, round int32, hash []byte)
internal/consensus/common_test.go:671
↓ 1 callers
Function
ensurePrecommitTimeout
(ch <-chan tmpubsub.Message)
internal/consensus/common_test.go:723
↓ 1 callers
Function
ensureProposal
(proposalCh <-chan tmpubsub.Message, height int64, round int32, propID types.BlockID)
internal/consensus/common_test.go:636
↓ 1 callers
Method
enterCommit
Enter: +2/3 precommits for block
internal/consensus/state.go:1548
↓ 1 callers
Method
enterPrevoteWait
Enter: any +2/3 prevotes at next round.
internal/consensus/state.go:1357
↓ 1 callers
Function
envSet
()
internal/libs/fail/fail.go:9
↓ 1 callers
Function
eventKey
(compositeKey, typ, eventValue string, height int64)
internal/state/indexer/block/kv/util.go:42
↓ 1 callers
Method
eventListener
()
rpc/client/http/ws.go:219
↓ 1 callers
Method
eventsRoutine
( sub types.Subscription, subscriber string, q pubsub.Query, outc chan<- coretypes.ResultEvent)
rpc/client/local/local.go:256
↓ 1 callers
Method
evictPeers
evictPeers evicts connected peers as requested by the peer manager.
internal/p2p/router.go:991
↓ 1 callers
Function
exampleProposal
()
privval/msgs_test.go:41
↓ 1 callers
Function
exampleVote
()
privval/msgs_test.go:23
↓ 1 callers
Method
execValidatorTx
format is "val:pubkey!power" pubkey is a base64-encoded 32-byte ed25519 key
abci/example/kvstore/persistent_kvstore.go:212
↓ 1 callers
Method
expireNew
Make space in the new buckets by expiring the really bad entries. If no bad entries are available we remove the oldest.
internal/p2p/pex/addrbook.go:743
↓ 1 callers
Function
extractKey
(tmhome, outputPath string)
tools/tm-signer-harness/main.go:143
↓ 1 callers
Function
extractTestnetStats
(intervals []time.Duration)
test/e2e/runner/benchmark.go:194
↓ 1 callers
Method
fadedMemoryValue
Retrieves the actual history data value that represents the requested time interval
internal/p2p/trust/metric.go:375
↓ 1 callers
Function
feedback
(r *Routine)
internal/blocksync/v2/routine_test.go:91
↓ 1 callers
Function
fetchBlockChainSample
fetchBlockChainSample waits for `benchmarkLength` amount of blocks to pass, fetching all of the headers for these blocks from an archive node and retu
test/e2e/runner/benchmark.go:131
↓ 1 callers
Method
fetchChunks
fetchChunks requests chunks from peers, receiving allocations from the chunk queue. Chunks will be received from the reactor via syncer.AddChunks() to
internal/statesync/syncer.go:479
↓ 1 callers
Method
fetchLightBlock
fetchLightBlock works out whether the node has a light block at a particular height and if so returns it so it can be gossiped to peers
internal/statesync/reactor.go:991
↓ 1 callers
Method
filterPeer
(p Peer)
internal/p2p/switch.go:927
↓ 1 callers
Method
filterPeersID
(ctx context.Context, id types.NodeID)
internal/p2p/router.go:558
↓ 1 callers
Method
filterPeersIP
(ctx context.Context, ip net.IP, port uint16)
internal/p2p/router.go:550
↓ 1 callers
Method
finalizeCommit
Increment height and goto cstypes.RoundStepNewHeight
internal/consensus/state.go:1640
↓ 1 callers
Method
findAttr
findAttr returns a slice of attribute values from event matching the condition tag, and reports whether the event type strictly equals the condition t
libs/pubsub/query/query.go:116
↓ 1 callers
Method
findPreviousProposer
findPreviousProposer reverses the compare proposer priority function to find the validator with the lowest proposer priority which would have been the
types/validator_set.go:680
↓ 1 callers
Method
findProposer
()
types/validator_set.go:335
↓ 1 callers
Method
fromBytes
(b []byte)
types/validator_set_test.go:423
↓ 1 callers
Function
funcArgTypes
return a function's argument types
rpc/jsonrpc/server/rpc_func.go:65
↓ 1 callers
Function
funcReturnTypes
return a function's return types
rpc/jsonrpc/server/rpc_func.go:76
↓ 1 callers
Function
genEphKeys
()
privval/secret_connection.go:291
↓ 1 callers
Function
genStatefulHandler
(maxCount int)
internal/blocksync/v2/routine_test.go:76
↓ 1 callers
Function
genValSetWithPowers
new val set with given powers and random initial priorities
internal/state/state_test.go:386
↓ 1 callers
Method
generate
generate generates manifests in a directory.
test/e2e/generator/main.go:74
↓ 1 callers
Function
generateDuplicateVoteEvidence
generateDuplicateVoteEvidence picks a random validator from the val set and returns duplicate vote evidence against the validator
test/e2e/runner/evidence.go:199
↓ 1 callers
Function
generateLightClientAttackEvidence
creates evidence of a lunatic attack. The height provided is the common height. The forged height happens 2 blocks later.
test/e2e/runner/evidence.go:149
↓ 1 callers
Function
generateLightNode
(r *rand.Rand, startAt int64, providers []string)
test/e2e/generator/generate.go:453
↓ 1 callers
Function
generateTestnet
generateTestnet generates a single testnet with the given options.
test/e2e/generator/generate.go:157
↓ 1 callers
Method
get
(rt reflect.Type)
libs/json/structs.go:29
↓ 1 callers
Function
getAllLegacyKeys
(db dbm.DB, storeName string)
scripts/keymigrate/migrate.go:29
↓ 1 callers
Function
getBeginBlockValidatorInfo
(block *types.Block, store Store, initialHeight int64)
internal/state/execution.go:375
↓ 1 callers
Method
getByIndex
(index int32)
types/vote_set.go:672
↓ 1 callers
Function
getConfig
getConfig returns a config for test cases
internal/consensus/wal_generator.go:156
↓ 1 callers
Function
getDefaultMoniker
getDefaultMoniker returns a default moniker, which is the host name. If runtime fails to get the host name, "anonymous" will be returned.
config/config.go:1376
↓ 1 callers
Method
getExternalIPAddress
()
internal/p2p/upnp/upnp.go:301
↓ 1 callers
Function
getHTTPClientWithTimeout
(t *testing.T, conf *config.Config, timeout time.Duration)
rpc/client/rpc_test.go:43
↓ 1 callers
Function
getIDs
(peers []string)
internal/rpc/core/net.go:149
↓ 1 callers
Function
getLatestHeight
(data []toMigrate)
scripts/scmigrate/migrate_test.go:51
↓ 1 callers
Function
getLegacyPrefixKeys
(val int)
scripts/keymigrate/migrate_test.go:19
↓ 1 callers
Function
getMockEndpoints
( t *testing.T, addr string, socketDialer SocketDialer, )
privval/signer_listener_endpoint_test.go:186
↓ 1 callers
Method
getMsgs
(chID byte)
internal/p2p/switch_test.go:86
↓ 1 callers
Method
getOrMakeQueue
(peerID types.NodeID, channels ChannelIDSet)
internal/p2p/router.go:741
↓ 1 callers
Function
getParam
(r *http.Request, param string)
rpc/jsonrpc/server/http_uri_handler.go:228
↓ 1 callers
Function
getPrivateValidatorKeys
(testnet *e2e.Testnet)
test/e2e/runner/evidence.go:128
↓ 1 callers
Function
getRandomValidatorIndex
getRandomValidatorIndex picks a random validator from a slice of mock PrivVals that's also part of the validator set, returning the PrivVal and its in
test/e2e/runner/evidence.go:228
↓ 1 callers
Method
getReportJSON
(net *e2e.Testnet)
test/e2e/runner/benchmark.go:92
↓ 1 callers
Function
getServiceURL
(rootURL string)
internal/p2p/upnp/upnp.go:204
↓ 1 callers
Method
getTrueIndices
()
libs/bits/bit_array.go:265
↓ 1 callers
Method
getV2AddressesFor
(nodes []int)
internal/p2p/pex/reactor_test.go:602
↓ 1 callers
Method
getValWithMostPriority
()
types/validator_set.go:218
↓ 1 callers
Method
getVote
Returns (vote, true) if vote exists for valIndex and blockKey.
types/vote_set.go:219
↓ 1 callers
Method
gossipDataForCatchup
(rs *cstypes.RoundState, prs *cstypes.PeerRoundState, ps *PeerState)
internal/consensus/reactor.go:481
↓ 1 callers
Method
gossipDataRoutine
(ps *PeerState)
internal/consensus/reactor.go:545
↓ 1 callers
Method
gossipVotesForHeight
(rs *cstypes.RoundState, prs *cstypes.PeerRoundState, ps *PeerState)
internal/consensus/reactor.go:710
↓ 1 callers
Method
gossipVotesRoutine
(ps *PeerState)
internal/consensus/reactor.go:768
← previous
next →
3,601–3,700 of 9,600, ranked by callers