Code
Hub
Workspaces
Following
Trending
Connect
MCP
copy
Create free account
hub
/
github.com/DeAI-Artist/Linkis
/ functions
Functions
9,565 in github.com/DeAI-Artist/Linkis
⨍
Functions
9,565
◇
Types & classes
1,236
↓ 22 callers
Method
Open
(dst, nonce, ciphertext, additionalData []byte)
crypto/xchacha20poly1305/xchachapoly.go:82
↓ 22 callers
Method
PushBack
Panics if list grows beyond its max length.
libs/clist/clist.go:316
↓ 22 callers
Function
QueryForEvent
(eventType string)
types/events.go:168
↓ 22 callers
Method
send
(...args: ContractMethodArgs<A, S>)
contracts/typechain-types/common.ts:128
↓ 21 callers
Method
FireEvent
(event string, data EventData)
libs/events/events.go:35
↓ 21 callers
Method
LoadValidators
LoadValidators loads the validator set at a given height
state/store.go:62
↓ 21 callers
Function
MakeValSetChangeTx
(pubkey pc.PublicKey, power int64)
abci/example/kvstore/persistent_kvstore.go:197
↓ 21 callers
Function
NewPool
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 callers
Method
Set
(key []byte, value []byte)
crypto/merkle/types.go:16
↓ 21 callers
Method
Size
()
crypto/merkle/types.go:10
↓ 21 callers
Function
encodeVarintTypes
(dAtA []byte, offset int, v uint64)
proto/tendermint/privval/types.pb.go:1261
↓ 21 callers
Function
randVoteSet
NOTE: privValidators are in order
types/vote_set_test.go:478
↓ 20 callers
Method
Base
()
blockchain/v2/reactor.go:28
↓ 20 callers
Method
Empty
Is Address Book Empty? Answer should not depend on being in your own address book, or private peers
p2p/pex/addrbook.go:58
↓ 20 callers
Function
MakeCommit
(blockID BlockID, height int64, round int32, voteSet *VoteSet, validators []PrivValidator, now time.Time)
types/test_util.go:12
↓ 20 callers
Method
Marshal
()
proto/tendermint/p2p/conn.pb.go:439
↓ 20 callers
Method
MarshalToSizedBuffer
(dAtA []byte)
proto/tendermint/consensus/types.pb.go:1108
↓ 20 callers
Function
RandValidatorSet
---------------------------------------- RandValidatorSet returns a randomized validator set (size: +numValidators+), where each validator has a votin
types/validator_set.go:1027
↓ 20 callers
Method
Size
()
proto/tendermint/consensus/types.pb.go:662
↓ 20 callers
Method
Subscribe
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 callers
Function
VoteSignBytes
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 callers
Function
mustWrapMsg
TODO: Add ChainIDRequest
privval/msgs.go:13
↓ 19 callers
Method
Accept
Accept returns a newly connected Peer.
p2p/transport.go:66
↓ 19 callers
Function
DefaultConsensusParams
DefaultConsensusParams returns a default ConsensusParams.
types/params.go:25
↓ 19 callers
Method
GetPart
(index int)
types/part_set.go:296
↓ 19 callers
Method
IsErr
IsErr returns true if Code is something other than OK.
abci/types/result.go:40
↓ 19 callers
Method
Marshal
()
rpc/grpc/types.pb.go:347
↓ 19 callers
Method
MarshalToSizedBuffer
(dAtA []byte)
proto/tendermint/privval/types.pb.go:1076
↓ 19 callers
Method
NetAddress
Listening address.
p2p/transport.go:63
↓ 19 callers
Function
NewNetAddress
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 callers
Function
NewSyncWriter
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 callers
Method
Remove
Remove removes the given raw transaction from the cache.
mempool/cache.go:24
↓ 19 callers
Method
Subscribe
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 callers
Method
TrustedLightBlock
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 callers
Method
Valid
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 callers
Method
WalFile
WalFile returns the full path to the write-ahead log file
config/config.go:1029
↓ 19 callers
Function
writeStr
(w io.Writer, s string)
libs/json/encoder.go:251
↓ 18 callers
Method
Addr
()
p2p/peer_test.go:160
↓ 18 callers
Method
Flush
Flush removes all transactions from the mempool and caches.
mempool/mempool.go:81
↓ 18 callers
Method
HasAddress
Check if the address is in the book
p2p/pex/addrbook.go:52
↓ 18 callers
Method
Load
Load loads the current state of the blockchain
state/store.go:60
↓ 18 callers
Method
LoadBlock
(height int64)
blockchain/v2/reactor.go:26
↓ 18 callers
Function
NewEventBus
NewEventBus returns a new event bus.
types/event_bus.go:39
↓ 18 callers
Method
ReadMsg
(msg proto.Message)
libs/protoio/io.go:49
↓ 18 callers
Function
makeBlock
(state sm.State, height int64)
state/helpers_test.go:136
↓ 18 callers
Function
makeBlockID
(hash []byte, partSetSize uint32, partSetHash []byte)
types/block_test.go:185
↓ 18 callers
Function
mustWrapPacket
---------------------------------------- Packet mustWrapPacket takes a packet kind (oneof) and wraps it in a tmp2p.Packet message.
p2p/conn/connection.go:889
↓ 18 callers
Function
sMakeRequestsEv
(current, expected string, maxPendingRequests int)
blockchain/v1/reactor_fsm_test.go:114
↓ 18 callers
Function
sovTypes
(x uint64)
proto/tendermint/statesync/types.pb.go:856
↓ 18 callers
Function
sovTypes
(x uint64)
proto/tendermint/p2p/types.pb.go:646
↓ 17 callers
Method
AddPeer
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 callers
Method
Allocate
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 callers
Method
BitArray
()
types/vote_set.go:686
↓ 17 callers
Method
CommitSig
CommitSig converts the Vote to a CommitSig.
types/vote.go:62
↓ 17 callers
Method
MarshalToSizedBuffer
(dAtA []byte)
proto/tendermint/types/types.pb.go:1188
↓ 17 callers
Function
NewDelimitedReader
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 callers
Function
NewDelimitedWriter
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 callers
Function
NewProposal
NewProposal returns a new Proposal. If there is no POLRound, polRound should be -1.
types/proposal.go:37
↓ 17 callers
Method
Precommit
Precommit returns the amount of time to wait for straggler votes after receiving any +2/3 precommits
config/config.go:1016
↓ 17 callers
Function
ResetConfig
(name string)
consensus/common_test.go:64
↓ 17 callers
Method
SetProposalAndBlock
SetProposalAndBlock inputs the proposal and all block parts.
consensus/state.go:494
↓ 17 callers
Method
Size
Size returns a number of currently existing header & validator set pairs.
light/store/store.go:47
↓ 17 callers
Method
Status
peer's info
p2p/peer.go:37
↓ 17 callers
Method
StringShort
StringShort returns a string
consensus/types/round_state.go:212
↓ 17 callers
Method
Total
()
types/part_set.go:259
↓ 17 callers
Method
Unmarshal
(dAtA []byte)
abci/types/types.pb.go:12859
↓ 17 callers
Method
UpdateWithChangeSet
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 callers
Method
Wrap
Wrap will take the underlying message and wrap it in its wrapper type.
p2p/types.go:34
↓ 17 callers
Function
deleteTempFile
(fname string)
p2p/pex/addrbook_test.go:732
↓ 17 callers
Function
waitForAndValidateBlock
( t *testing.T, n int, activeVals map[string]struct{}, blocksSubs []types.Subscription, css []*State, tx
consensus/reactor_test.go:579
↓ 16 callers
Method
Decode
Decode reads the next custom-encoded value from its reader and returns it.
consensus/wal.go:365
↓ 16 callers
Method
Error
Error returns an error if the client was stopped abruptly.
abci/client/socket_client.go:101
↓ 16 callers
Function
Fail
indexes Fail calls
libs/fail/fail.go:28
↓ 16 callers
Method
GetValue
()
abci/types/types.pb.go:1344
↓ 16 callers
Function
IDAddressString
IDAddressString returns id@hostPort. It strips the leading protocol from protocolHostPort if it exists.
p2p/netaddress.go:33
↓ 16 callers
Function
LoadFilePV
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 callers
Method
NewBatch
NewBatch creates a new batch client for this HTTP client.
rpc/client/http/http.go:169
↓ 16 callers
Method
ReceiveEnvelope
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 callers
Method
SaveLightBlock
SaveSignedHeaderAndValidatorSet saves a SignedHeader (h: sh.Height) and a ValidatorSet (h: sh.Height). height must be > 0.
light/store/store.go:11
↓ 16 callers
Method
SetLogger
SetLogger sets the Logger on the reactor and the underlying Evidence.
evidence/reactor.go:46
↓ 16 callers
Method
Sum
(b []byte)
crypto/tmhash/hash.go:37
↓ 16 callers
Method
Uint64
()
libs/rand/random.go:189
↓ 16 callers
Method
Unmarshal
(dAtA []byte)
abci/types/types.pb.go:9917
↓ 16 callers
Function
assertMempool
for testing
consensus/mempool_test.go:23
↓ 16 callers
Function
encodeVarintTypes
(dAtA []byte, offset int, v uint64)
proto/tendermint/statesync/types.pb.go:707
↓ 16 callers
Function
encodeVarintTypes
(dAtA []byte, offset int, v uint64)
proto/tendermint/p2p/types.pb.go:543
↓ 16 callers
Function
sovParams
(x uint64)
proto/tendermint/types/params.pb.go:1042
↓ 16 callers
Function
testNodeInfo
---------------------------------------------------------------- rand node info
p2p/test_util.go:258
↓ 15 callers
Method
BroadcastTxCommit
Writing to abci app
rpc/client/interface.go:59
↓ 15 callers
Method
Choose
(r *rand.Rand)
test/e2e/generator/random.go:55
↓ 15 callers
Method
Compare
(other queue.Item)
blockchain/v2/types.go:11
↓ 15 callers
Method
Copy
Copy each validator into a new ValidatorSet.
types/validator_set.go:249
↓ 15 callers
Method
Error
()
abci/client/grpc_client.go:146
↓ 15 callers
Method
GetValue
()
abci/types/types.pb.go:284
↓ 15 callers
Method
Height
()
evidence/services.go:12
↓ 15 callers
Method
Info
(msg string, keyvals ...interface{})
libs/log/logger.go:12
↓ 15 callers
Function
MakeSwitch
( cfg *config.P2PConfig, i int, network, version string, initSwitch func(int, *Switch) *Switch, opts ...S
p2p/test_util.go:178
↓ 15 callers
Function
MakeTxKV
MakeTxKV returns a text transaction, allong with expected key, value pair
rpc/client/event_test.go:23
↓ 15 callers
Method
Mempool
Mempool connection
proxy/multi_app_conn.go:25
↓ 15 callers
Function
NewPartSetFromHeader
Returns an empty PartSet ready to be populated.
types/part_set.go:197
← previous
next →
201–300 of 9,565, ranked by callers