MCPcopy Create free account

hub / github.com/tendermint/tendermint / functions

Functions9,600 in github.com/tendermint/tendermint

↓ 5 callersMethodGetPeerState
GetPeerState returns PeerState for a given NodeID.
internal/consensus/reactor.go:338
↓ 5 callersMethodGetSum
()
proto/tendermint/blocksync/types.pb.go:322
↓ 5 callersMethodHas
Has returns true if the given height has been indexed. An error is returned upon database query failure.
internal/state/indexer/indexer.go:31
↓ 5 callersMethodHealth
(context.Context)
rpc/client/interface.go:126
↓ 5 callersFunctionIndexingEnabled
IndexingEnabled returns the given eventSinks is supporting the indexing services.
internal/state/indexer/indexer_service.go:161
↓ 5 callersMethodInfoSync
(context.Context, types.RequestInfo)
internal/proxy/app_conn.go:44
↓ 5 callersMethodIsOutbound
remote address of the connection
internal/p2p/peer.go:30
↓ 5 callersMethodIsPeerPersistent
(na *NetAddress)
internal/p2p/switch.go:660
↓ 5 callersMethodListSnapshots
Commit the state and return the application Merkle root hash State Sync Connection
abci/types/application.go:27
↓ 5 callersFunctionListen
Listen starts a new net.Listener on the given address. It returns an error if the address is invalid or the call to Listen() fails.
rpc/jsonrpc/server/http_server.go:264
↓ 5 callersMethodLoadBlockMeta
LoadBlockMeta returns the BlockMeta for the given height. If no block is found for the given height, it returns nil.
internal/store/store.go:232
↓ 5 callersMethodLoadSnapshotChunk
Offer a snapshot to the application
abci/types/application.go:29
↓ 5 callersMethodLocal
Local returns true if it is a local address.
types/netaddress.go:208
↓ 5 callersMethodLookupNode
LookupNode looks up a node by name. For now, simply do a linear search.
test/e2e/pkg/testnet.go:412
↓ 5 callersFunctionMarshal
Marshal marshals the value as JSON, using Amino-compatible JSON encoding (strings for 64-bit numbers, and type wrappers for registered types).
libs/json/encoder.go:22
↓ 5 callersMethodMarshal
()
proto/tendermint/crypto/proof.pb.go:352
↓ 5 callersMethodMarshal
()
proto/tendermint/state/types.pb.go:655
↓ 5 callersMethodMarshal
()
proto/tendermint/p2p/types.pb.go:469
↓ 5 callersMethodMarshal
()
proto/tendermint/consensus/wal.pb.go:412
↓ 5 callersMethodMarshalToSizedBuffer
(dAtA []byte)
proto/tendermint/types/canonical.pb.go:517
↓ 5 callersMethodMarshalToSizedBuffer
(dAtA []byte)
proto/tendermint/crypto/proof.pb.go:367
↓ 5 callersMethodMarshalToSizedBuffer
(dAtA []byte)
proto/tendermint/rpc/grpc/types.pb.go:362
↓ 5 callersMethodMarshalToSizedBuffer
(dAtA []byte)
rpc/grpc/types.pb.go:362
↓ 5 callersFunctionMaxCommitBytes
(valCount int)
types/block.go:621
↓ 5 callersFunctionMaxDataBytesNoEvidence
MaxDataBytesNoEvidence returns the maximum size of block's data when evidence count is unknown. MaxEvidencePerBlock will be used for the size of evide
types/block.go:290
↓ 5 callersFunctionNetAddressesToProto
NetAddressesToProto converts a slice of NetAddresses into a Protobuf PexAddress slice.
internal/p2p/pex/pex_reactor.go:844
↓ 5 callersFunctionNew
New returns a Store that wraps any DB If you want to share one DB across many light clients consider using PrefixDB
light/store/db/db.go:30
↓ 5 callersFunctionNewCounterApplication
()
internal/consensus/mempool_test.go:230
↓ 5 callersFunctionNewDefaultLogger
NewDefaultLogger returns a default logger that can be used within Tendermint and that fulfills the Logger interface. The underlying logging provider i
libs/log/default.go:29
↓ 5 callersFunctionNewDispatcher
(requestCh chan<- p2p.Envelope)
internal/statesync/dispatcher.go:37
↓ 5 callersFunctionNewEventSink
()
internal/state/indexer/sink/null/null.go:17
↓ 5 callersFunctionNewLRUTxCache
(cacheSize int)
internal/mempool/cache.go:42
↓ 5 callersFunctionNewMetricWithConfig
NewMetricWithConfig returns a trust metric with a custom configuration. Use Start to begin tracking the quality of peer behavior over time
internal/p2p/trust/metric.go:92
↓ 5 callersFunctionNewMockDuplicateVoteEvidence
-------------------------------------------- MOCKING -------------------------------------- unstable - use only for testing assumes the round to be 0
types/evidence.go:674
↓ 5 callersFunctionNewPeerSet
NewPeerSet creates a new peerSet with a list of initial capacity of 256 items.
internal/p2p/peer_set.go:35
↓ 5 callersFunctionNewTestReactor
(channels []*conn.ChannelDescriptor, logMessages bool)
internal/p2p/switch_test.go:57
↓ 5 callersMethodNext
Next advances s to the next token in the input, or reports an error. At the end of input, Next returns io.EOF.
libs/pubsub/query/syntax/scanner.go:85
↓ 5 callersMethodNodeIDs
NodeIDs returns the network's node IDs.
internal/p2p/p2ptest/network.go:126
↓ 5 callersFunctionNopMetrics
NopMetrics returns no-op Metrics.
internal/consensus/metrics.go:272
↓ 5 callersMethodNumPeers
NumPeers returns the count of outbound/inbound and outbound-dialing peers. unconditional peers are not counted here.
internal/p2p/switch.go:339
↓ 5 callersMethodOfferSnapshot
List available snapshots
abci/types/application.go:28
↓ 5 callersMethodOr
Or returns a bit array resulting from a bitwise OR of the two bit arrays. If the two bit-arrys have different lengths, Or right-pads the smaller of th
libs/bits/bit_array.go:119
↓ 5 callersMethodRanked
Ranked returns a list of snapshots ranked by preference. The current heuristic is very naïve, preferring the snapshot with the greatest height, then g
internal/statesync/snapshots.go:163
↓ 5 callersMethodRead
(p []byte)
types/part_set.go:327
↓ 5 callersMethodReadMessage
ReadMessage reads a message from the endpoint
privval/signer_endpoint.go:83
↓ 5 callersMethodRemotePubKey
RemotePubKey returns authenticated remote pubkey
internal/p2p/conn/secret_connection.go:183
↓ 5 callersMethodRescalePriorities
RescalePriorities rescales the priorities such that the distance between the maximum and minimum is smaller than `diffMax`. Panics if validator set is
types/validator_set.go:143
↓ 5 callersMethodResolve
Resolve resolves a NodeAddress into a set of Endpoints, by expanding out a DNS hostname to IP addresses.
internal/p2p/address.go:100
↓ 5 callersMethodRetry
Retry schedules a chunk to be retried, without refetching it.
internal/statesync/chunks.go:304
↓ 5 callersFunctionRollback
Rollback overwrites the current Tendermint state (height n) with the most recent previous state (height n - 1). Note that this function does not affec
internal/state/rollback.go:13
↓ 5 callersMethodRotateFile
RotateFile causes group to close the current head and assign it some index. Note it does not create a new head.
internal/libs/autofile/group.go:303
↓ 5 callersMethodSaveABCIResponses
SaveABCIResponses saves ABCIResponses for a given height
internal/state/store.go:89
↓ 5 callersMethodSaveBlock
(block *types.Block, blockParts *types.PartSet, seenCommit *types.Commit)
internal/state/services.go:27
↓ 5 callersMethodSaveBlock
SaveBlock persists the given block, blockParts, and seenCommit to the underlying db. blockParts: Must be parts of the block seenCommit: The +2/3 preco
internal/store/store.go:449
↓ 5 callersMethodSeal
(dst, nonce, plaintext, additionalData []byte)
crypto/xchacha20poly1305/xchachapoly.go:58
↓ 5 callersMethodSendRequest
SendRequest ensures there is a connection, sends a request and waits for a response
privval/signer_listener_endpoint.go:107
↓ 5 callersMethodSetCallback
Sets sets the callback. If reqRes is already done, it will call the cb immediately. Note, reqRes.cb should not change if reqRes.done and only one call
abci/client/client.go:115
↓ 5 callersMethodSetIndex
SetIndex sets the cursor's file index to index by opening a file at this position.
internal/libs/autofile/group.go:536
↓ 5 callersMethodSetLogger
(l tmlog.Logger)
abci/server/socket_server.go:49
↓ 5 callersMethodSetPeerRange
SetPeerRange sets the peer's alleged blockchain base and height.
internal/blocksync/v0/pool.go:309
↓ 5 callersMethodSetReadDeadline
(t time.Time)
privval/secret_connection.go:284
↓ 5 callersMethodSetResponseCallback
(abciclient.Callback)
internal/proxy/app_conn.go:30
↓ 5 callersMethodSetTimeoutTicker
SetTimeoutTicker sets the local timer. It may be useful to overwrite for testing.
internal/consensus/state.go:310
↓ 5 callersMethodSignProposal
Implements PrivValidator.
types/priv_validator.go:102
↓ 5 callersFunctionSignerDialerEndpointTimeoutReadWrite
SignerDialerEndpointTimeoutReadWrite sets the read and write timeout for connections from client processes.
privval/signer_dialer_endpoint.go:20
↓ 5 callersMethodSize
()
proto/tendermint/mempool/types.pb.go:275
↓ 5 callersFunctionSkippingVerification
SkippingVerification option configures the light client to skip blocks as long as {trustLevel} of the old validator set signed the new header. The ver
light/client.go:76
↓ 5 callersMethodSocketAddr
()
internal/p2p/mock/peer.go:68
↓ 5 callersFunctionSumTruncated
SumTruncated returns the first 20 bytes of SHA256 of the bz.
crypto/tmhash/hash.go:62
↓ 5 callersMethodText
Text returns the text of the current input token.
libs/pubsub/query/syntax/scanner.go:120
↓ 5 callersMethodTime
string format of the evidence
types/evidence.go:29
↓ 5 callersMethodToProto
ToProto converts BitArray to protobuf. It returns nil if BitArray is nil/empty.
libs/bits/bit_array.go:428
↓ 5 callersFunctionToRequestFlush
()
abci/types/messages.go:35
↓ 5 callersMethodUnmarshal
(dAtA []byte)
proto/tendermint/types/params.pb.go:1144
↓ 5 callersMethodUnmarshal
(dAtA []byte)
proto/tendermint/p2p/pex.pb.go:1324
↓ 5 callersMethodUnmarshal
(dAtA []byte)
proto/tendermint/consensus/wal.pb.go:1085
↓ 5 callersFunctionUnmarshalDelimited
(data []byte, msg proto.Message)
internal/libs/protoio/reader.go:103
↓ 5 callersMethodValidate
Validate checks the self-reported NodeInfo is safe. It returns an error if there are too many Channels, if there are any duplicate Channels, if the Li
types/node_info.go:76
↓ 5 callersMethodValidateAndComplete
ValidateAndComplete checks that all necessary fields are present and fills in defaults for optional fields left empty
types/genesis.go:69
↓ 5 callersMethodValidateConsensusParams
Validate validates the ConsensusParams to ensure all values are within their allowed limits, and returns an error if they are not.
types/params.go:130
↓ 5 callersMethodValidator
(val *Validator)
types/protobuf.go:16
↓ 5 callersFunctionWaitForHeight
Wait for height will poll status at reasonable intervals until the block at the given height is available. If waiter is nil, we use DefaultWaitStrate
rpc/client/helpers.go:37
↓ 5 callersMethodWriteRPCResponse
WriteRPCResponse pushes a response to the writeChan, and blocks until it is accepted. It implements WSRPCConnection. It is Goroutine-safe.
rpc/jsonrpc/server/ws_handler.go:260
↓ 5 callersFunctionWriteRPCResponseHTTP
WriteRPCResponseHTTP marshals res as JSON (with indent) and writes it to w. If the rpc response can be cached, add cache-control to the response heade
rpc/jsonrpc/server/http_server.go:137
↓ 5 callersMethodaddCall
(call Call)
rpc/client/mock/abci.go:173
↓ 5 callersMethodaddPendingEvidence
(ev types.Evidence)
internal/evidence/pool.go:300
↓ 5 callersMethodadd_host
Helper method to reduce host duplication
networks/remote/ansible/inventory/digital_ocean.py:425
↓ 5 callersMethodallBlocksProcessed
()
internal/blocksync/v2/scheduler.go:439
↓ 5 callersFunctionassertCanceled
(t *testing.T, subscription *pubsub.Subscription, err error)
libs/pubsub/pubsub_test.go:569
↓ 5 callersFunctionbenchmarkTxIndex
(txsCount int64, b *testing.B)
internal/state/indexer/tx/kv/kv_test.go:336
↓ 5 callersFunctionblockHashKey
(hash []byte)
internal/store/store.go:638
↓ 5 callersFunctioncall
(t *testing.T, method string, c *WSClient)
rpc/jsonrpc/client/ws_client_test.go:213
↓ 5 callersMethodcloseFile
()
internal/libs/autofile/autofile.go:113
↓ 5 callersMethodconnectAll
(t *testing.T)
internal/p2p/pex/reactor_test.go:687
↓ 5 callersMethodconnectPeers
connects node1 to node2
internal/p2p/pex/reactor_test.go:705
↓ 5 callersMethodcrawlPeers
crawlPeers will crawl the network looking for new peer addresses.
internal/p2p/pex/pex_reactor.go:699
↓ 5 callersFunctioncreatePeerSet
(num int)
internal/statesync/dispatcher_test.go:283
↓ 5 callersFunctioncreateTestMConnection
bytes
internal/p2p/conn/connection_test.go:24
↓ 5 callersFunctiondecodeReflect
(bz []byte, rv reflect.Value)
libs/json/decoder.go:39
↓ 5 callersMethoddequeue
dequeue returns a channel ordered according to some queueing policy.
internal/p2p/queue.go:20
← previousnext →901–1,000 of 9,600, ranked by callers