MCPcopy Create free account

hub / github.com/DeAI-Artist/Linkis / functions

Functions9,565 in github.com/DeAI-Artist/Linkis

↓ 22 callersMethodOpen
(dst, nonce, ciphertext, additionalData []byte)
crypto/xchacha20poly1305/xchachapoly.go:82
↓ 22 callersMethodPushBack
Panics if list grows beyond its max length.
libs/clist/clist.go:316
↓ 22 callersFunctionQueryForEvent
(eventType string)
types/events.go:168
↓ 22 callersMethodsend
(...args: ContractMethodArgs<A, S>)
contracts/typechain-types/common.ts:128
↓ 21 callersMethodFireEvent
(event string, data EventData)
libs/events/events.go:35
↓ 21 callersMethodLoadValidators
LoadValidators loads the validator set at a given height
state/store.go:62
↓ 21 callersFunctionMakeValSetChangeTx
(pubkey pc.PublicKey, power int64)
abci/example/kvstore/persistent_kvstore.go:197
↓ 21 callersFunctionNewPool
NewPool creates an evidence pool. If using an existing evidence store, it will add all pending evidence to the concurrent list.
evidence/pool.go:54
↓ 21 callersMethodSet
(key []byte, value []byte)
crypto/merkle/types.go:16
↓ 21 callersMethodSize
()
crypto/merkle/types.go:10
↓ 21 callersFunctionencodeVarintTypes
(dAtA []byte, offset int, v uint64)
proto/tendermint/privval/types.pb.go:1261
↓ 21 callersFunctionrandVoteSet
NOTE: privValidators are in order
types/vote_set_test.go:478
↓ 20 callersMethodBase
()
blockchain/v2/reactor.go:28
↓ 20 callersMethodEmpty
Is Address Book Empty? Answer should not depend on being in your own address book, or private peers
p2p/pex/addrbook.go:58
↓ 20 callersFunctionMakeCommit
(blockID BlockID, height int64, round int32, voteSet *VoteSet, validators []PrivValidator, now time.Time)
types/test_util.go:12
↓ 20 callersMethodMarshal
()
proto/tendermint/p2p/conn.pb.go:439
↓ 20 callersMethodMarshalToSizedBuffer
(dAtA []byte)
proto/tendermint/consensus/types.pb.go:1108
↓ 20 callersFunctionRandValidatorSet
---------------------------------------- RandValidatorSet returns a randomized validator set (size: +numValidators+), where each validator has a votin
types/validator_set.go:1027
↓ 20 callersMethodSize
()
proto/tendermint/consensus/types.pb.go:662
↓ 20 callersMethodSubscribe
Subscribe creates a subscription for the given client. An error will be returned to the caller if the context is canceled or if subscription already
libs/pubsub/pubsub.go:149
↓ 20 callersFunctionVoteSignBytes
VoteSignBytes returns the proto-encoding of the canonicalized Vote, for signing. Panics is the marshaling fails. The encoded Protobuf message is vari
types/vote.go:93
↓ 20 callersFunctionmustWrapMsg
TODO: Add ChainIDRequest
privval/msgs.go:13
↓ 19 callersMethodAccept
Accept returns a newly connected Peer.
p2p/transport.go:66
↓ 19 callersFunctionDefaultConsensusParams
DefaultConsensusParams returns a default ConsensusParams.
types/params.go:25
↓ 19 callersMethodGetPart
(index int)
types/part_set.go:296
↓ 19 callersMethodIsErr
IsErr returns true if Code is something other than OK.
abci/types/result.go:40
↓ 19 callersMethodMarshal
()
rpc/grpc/types.pb.go:347
↓ 19 callersMethodMarshalToSizedBuffer
(dAtA []byte)
proto/tendermint/privval/types.pb.go:1076
↓ 19 callersMethodNetAddress
Listening address.
p2p/transport.go:63
↓ 19 callersFunctionNewNetAddress
NewNetAddress returns a new NetAddress using the provided TCP address. When testing, other net.Addr (except TCP) will result in using 0.0.0.0:0. When
p2p/netaddress.go:43
↓ 19 callersFunctionNewSyncWriter
NewSyncWriter returns a new writer that is safe for concurrent use by multiple goroutines. Writes to the returned writer are passed on to w. If anothe
libs/log/logger.go:28
↓ 19 callersMethodRemove
Remove removes the given raw transaction from the cache.
mempool/cache.go:24
↓ 19 callersMethodSubscribe
Subscribe subscribes given subscriber to query. Returns a channel with cap=1 onto which events are published. An error is returned if it fails to subs
rpc/client/interface.go:126
↓ 19 callersMethodTrustedLightBlock
TrustedLightBlock returns a trusted light block at the given height (0 - the latest). It returns an error if: - there are some issues with the truste
light/client.go:404
↓ 19 callersMethodValid
For IPv4 these are either a 0 or all bits set address. For IPv6 a zero address or one that matches the RFC3849 documentation address format.
p2p/netaddress.go:264
↓ 19 callersMethodWalFile
WalFile returns the full path to the write-ahead log file
config/config.go:1029
↓ 19 callersFunctionwriteStr
(w io.Writer, s string)
libs/json/encoder.go:251
↓ 18 callersMethodAddr
()
p2p/peer_test.go:160
↓ 18 callersMethodFlush
Flush removes all transactions from the mempool and caches.
mempool/mempool.go:81
↓ 18 callersMethodHasAddress
Check if the address is in the book
p2p/pex/addrbook.go:52
↓ 18 callersMethodLoad
Load loads the current state of the blockchain
state/store.go:60
↓ 18 callersMethodLoadBlock
(height int64)
blockchain/v2/reactor.go:26
↓ 18 callersFunctionNewEventBus
NewEventBus returns a new event bus.
types/event_bus.go:39
↓ 18 callersMethodReadMsg
(msg proto.Message)
libs/protoio/io.go:49
↓ 18 callersFunctionmakeBlock
(state sm.State, height int64)
state/helpers_test.go:136
↓ 18 callersFunctionmakeBlockID
(hash []byte, partSetSize uint32, partSetHash []byte)
types/block_test.go:185
↓ 18 callersFunctionmustWrapPacket
---------------------------------------- Packet mustWrapPacket takes a packet kind (oneof) and wraps it in a tmp2p.Packet message.
p2p/conn/connection.go:889
↓ 18 callersFunctionsMakeRequestsEv
(current, expected string, maxPendingRequests int)
blockchain/v1/reactor_fsm_test.go:114
↓ 18 callersFunctionsovTypes
(x uint64)
proto/tendermint/statesync/types.pb.go:856
↓ 18 callersFunctionsovTypes
(x uint64)
proto/tendermint/p2p/types.pb.go:646
↓ 17 callersMethodAddPeer
AddPeer is called by the switch after the peer is added and successfully started. Use it to start goroutines communicating with the peer.
p2p/base_reactor.go:35
↓ 17 callersMethodAllocate
Allocate allocates a chunk to the caller, making it responsible for fetching it. Returns errDone once no chunks are left or the queue is closed.
statesync/chunks.go:105
↓ 17 callersMethodBitArray
()
types/vote_set.go:686
↓ 17 callersMethodCommitSig
CommitSig converts the Vote to a CommitSig.
types/vote.go:62
↓ 17 callersMethodMarshalToSizedBuffer
(dAtA []byte)
proto/tendermint/types/types.pb.go:1188
↓ 17 callersFunctionNewDelimitedReader
NewDelimitedReader reads varint-delimited Protobuf messages from a reader. Unlike the gogoproto NewDelimitedReader, this does not buffer the reader, w
libs/protoio/reader.go:47
↓ 17 callersFunctionNewDelimitedWriter
NewDelimitedWriter writes a varint-delimited Protobuf message to a writer. It is equivalent to the gogoproto NewDelimitedWriter, except WriteMsg() als
libs/protoio/writer.go:44
↓ 17 callersFunctionNewProposal
NewProposal returns a new Proposal. If there is no POLRound, polRound should be -1.
types/proposal.go:37
↓ 17 callersMethodPrecommit
Precommit returns the amount of time to wait for straggler votes after receiving any +2/3 precommits
config/config.go:1016
↓ 17 callersFunctionResetConfig
(name string)
consensus/common_test.go:64
↓ 17 callersMethodSetProposalAndBlock
SetProposalAndBlock inputs the proposal and all block parts.
consensus/state.go:494
↓ 17 callersMethodSize
Size returns a number of currently existing header & validator set pairs.
light/store/store.go:47
↓ 17 callersMethodStatus
peer's info
p2p/peer.go:37
↓ 17 callersMethodStringShort
StringShort returns a string
consensus/types/round_state.go:212
↓ 17 callersMethodTotal
()
types/part_set.go:259
↓ 17 callersMethodUnmarshal
(dAtA []byte)
abci/types/types.pb.go:12859
↓ 17 callersMethodUpdateWithChangeSet
UpdateWithChangeSet attempts to update the validator set with 'changes'. It performs the following steps: - validates the changes making sure there ar
types/validator_set.go:656
↓ 17 callersMethodWrap
Wrap will take the underlying message and wrap it in its wrapper type.
p2p/types.go:34
↓ 17 callersFunctiondeleteTempFile
(fname string)
p2p/pex/addrbook_test.go:732
↓ 17 callersFunctionwaitForAndValidateBlock
( t *testing.T, n int, activeVals map[string]struct{}, blocksSubs []types.Subscription, css []*State, tx
consensus/reactor_test.go:579
↓ 16 callersMethodDecode
Decode reads the next custom-encoded value from its reader and returns it.
consensus/wal.go:365
↓ 16 callersMethodError
Error returns an error if the client was stopped abruptly.
abci/client/socket_client.go:101
↓ 16 callersFunctionFail
indexes Fail calls
libs/fail/fail.go:28
↓ 16 callersMethodGetValue
()
abci/types/types.pb.go:1344
↓ 16 callersFunctionIDAddressString
IDAddressString returns id@hostPort. It strips the leading protocol from protocolHostPort if it exists.
p2p/netaddress.go:33
↓ 16 callersFunctionLoadFilePV
LoadFilePV loads a FilePV from the filePaths. The FilePV handles double signing prevention by persisting data to the stateFilePath. If either file p
privval/file.go:178
↓ 16 callersMethodNewBatch
NewBatch creates a new batch client for this HTTP client.
rpc/client/http/http.go:169
↓ 16 callersMethodReceiveEnvelope
ReceiveEnvelope is called by the switch when an envelope is received from any connected peer on any of the channels registered by the reactor. Only o
p2p/base_reactor.go:63
↓ 16 callersMethodSaveLightBlock
SaveSignedHeaderAndValidatorSet saves a SignedHeader (h: sh.Height) and a ValidatorSet (h: sh.Height). height must be > 0.
light/store/store.go:11
↓ 16 callersMethodSetLogger
SetLogger sets the Logger on the reactor and the underlying Evidence.
evidence/reactor.go:46
↓ 16 callersMethodSum
(b []byte)
crypto/tmhash/hash.go:37
↓ 16 callersMethodUint64
()
libs/rand/random.go:189
↓ 16 callersMethodUnmarshal
(dAtA []byte)
abci/types/types.pb.go:9917
↓ 16 callersFunctionassertMempool
for testing
consensus/mempool_test.go:23
↓ 16 callersFunctionencodeVarintTypes
(dAtA []byte, offset int, v uint64)
proto/tendermint/statesync/types.pb.go:707
↓ 16 callersFunctionencodeVarintTypes
(dAtA []byte, offset int, v uint64)
proto/tendermint/p2p/types.pb.go:543
↓ 16 callersFunctionsovParams
(x uint64)
proto/tendermint/types/params.pb.go:1042
↓ 16 callersFunctiontestNodeInfo
---------------------------------------------------------------- rand node info
p2p/test_util.go:258
↓ 15 callersMethodBroadcastTxCommit
Writing to abci app
rpc/client/interface.go:59
↓ 15 callersMethodChoose
(r *rand.Rand)
test/e2e/generator/random.go:55
↓ 15 callersMethodCompare
(other queue.Item)
blockchain/v2/types.go:11
↓ 15 callersMethodCopy
Copy each validator into a new ValidatorSet.
types/validator_set.go:249
↓ 15 callersMethodError
()
abci/client/grpc_client.go:146
↓ 15 callersMethodGetValue
()
abci/types/types.pb.go:284
↓ 15 callersMethodHeight
()
evidence/services.go:12
↓ 15 callersMethodInfo
(msg string, keyvals ...interface{})
libs/log/logger.go:12
↓ 15 callersFunctionMakeSwitch
( cfg *config.P2PConfig, i int, network, version string, initSwitch func(int, *Switch) *Switch, opts ...S
p2p/test_util.go:178
↓ 15 callersFunctionMakeTxKV
MakeTxKV returns a text transaction, allong with expected key, value pair
rpc/client/event_test.go:23
↓ 15 callersMethodMempool
Mempool connection
proxy/multi_app_conn.go:25
↓ 15 callersFunctionNewPartSetFromHeader
Returns an empty PartSet ready to be populated.
types/part_set.go:197
← previousnext →201–300 of 9,565, ranked by callers