Functions — github.com/apache/incubator-pegasus

CodeHub MCPcopy Create free account

hub / github.com/apache/incubator-pegasus / functions

Functions8,667 in github.com/apache/incubator-pegasus

⨍ Functions 8,667◇ Types & classes 2,204

↓ 4 callersMethodlist_snapshot_by_regexp

src/perf_counter/perf_counters.cpp:286

↓ 4 callersMethodload_metadata

src/block_service/local/local_service.cpp:273

↓ 4 callersFunctionmaintain_drops

src/meta/meta_data.cpp:104

↓ 4 callersMethodmarkSessionDisconnect

java-client/src/main/java/org/apache/pegasus/rpc/async/ReplicaSession.java:256

↓ 4 callersMethodmatch

src/server/compaction_filter_rule.cpp:56

↓ 4 callersMethodmax_duration_time

src/server/range_read_limiter.h:89

↓ 4 callersMethodmin_confirmed_decree

src/replica/duplication/replica_duplicator_manager.cpp:92

↓ 4 callersMethodmock

src/utils/clock.cpp:33

↓ 4 callersMethodmulti_del

Remove multiple entire <hash_key, sort_key>-values in pegasus. :param hash_key: (bytes) which hash key used for this API. :p

python-client/pypegasus/pgclient.py:961

↓ 4 callersMethodnative_handle

src/aio/disk_engine.h:66

↓ 4 callersFunctionnewClientWithError

go-client/pegasus/client.go:62

↓ 4 callersFunctionnew_cacheline_aligned_int64_array

src/utils/long_adder.cpp:63

↓ 4 callersMethodnew_mutation

src/replica/replica.cpp:442

↓ 4 callersMethodnew_transaction_entries

src/meta/meta_state_service_simple.cpp:303

↓ 4 callersMethodonChallenge

(negotiation_response response)

java-client/src/main/java/org/apache/pegasus/security/Negotiation.java:141

↓ 4 callersMethodonRecvMechanisms

(negotiation_response response)

java-client/src/main/java/org/apache/pegasus/security/Negotiation.java:119

↓ 4 callersMethodon_call

src/runtime/rpc/rpc_engine.cpp:294

↓ 4 callersMethodowner_delete_commit

src/runtime/task/task_tracker.h:219

↓ 4 callersFunctionparse_kv_map

src/replica/storage/simple_kv/test/case.cpp:71

↓ 4 callersMethodpause

src/runtime/pipeline.h:147

↓ 4 callersFunctionpegasus_hash_key_hash

Calculate hash value from hash key.

src/base/pegasus_key_schema.h:168

↓ 4 callersMethodpersist_progress

src/meta/duplication/duplication_info.cpp:151

↓ 4 callersMethodpick_up_partition

src/meta/cluster_balance_policy.cpp:459

↓ 4 callersMethodprevious_log_max_decree

src/replica/log_file.cpp:360

↓ 4 callersMethodprimary_address

src/replica/replica_stub.h:205

↓ 4 callersFunctionprint_trouble

(prog, message, use_colors)

scripts/run-clang-format.py:267

↓ 4 callersFunctionprint_usage

src/utils/long_adder_bench/long_adder_bench.cpp:115

↓ 4 callersMethodquery

python-client/pypegasus/pgclient.py:282

↓ 4 callersMethodquery_duplication_handler

src/replica/replica_http_service.cpp:39

↓ 4 callersMethodrandom_member

src/runtime/rpc/group_address.h:61

↓ 4 callersFunctionreadPegasusArgs

readPegasusArgs assumes the args to be [hashkey, sortkey, value]. It returns the bytes encoded from the args if no failure.

pegic/executor/context.go:82

↓ 4 callersMethodread_next_log_block

src/replica/log_file.cpp:213

↓ 4 callersMethodread_u64

src/utils/endians.h:119

↓ 4 callersMethodrecord

src/test/function_test/throttle_test/test_throttle.cpp:117

↓ 4 callersMethodregister_id

src/utils/customizable_id.h:198

↓ 4 callersFunctionreplica_count

src/meta/meta_data.h:500

↓ 4 callersMethodreset

src/redis_protocol/proxy_ut/redis_proxy_test.cpp:200

↓ 4 callersMethodreset_node_bulk_load_states

src/replica/replica_context.cpp:157

↓ 4 callersMethodreset_stream

src/replica/log_file.cpp:348

↓ 4 callersMethodresolve_addresses

src/runtime/rpc/dns_resolver.cpp:49

↓ 4 callersMethodrestart_1_replica

python-client/tests/test_integration.py:83

↓ 4 callersFunctionrpc_client_session_send

src/runtime/test/netprovider.cpp:119

↓ 4 callersMethodrun_command

src/utils/command_manager.cpp:82

↓ 4 callersFunctionsdscat

Append the specified null termianted C string to the sds string 's'. * * After the call, the passed sds string is no longer valid and all the * ref

src/shell/sds/sds.c:401

↓ 4 callersFunctionsdscatprintf

Append to the sds string 's' a string obtained using printf-alike format * specifier. * * After the call, the modified sds string is no longer vali

src/shell/sds/sds.c:564

↓ 4 callersFunctionsend_and_check_host_port_by_serialize

src/runtime/test/host_port_test.cpp:214

↓ 4 callersMethodset_description

src/utils/latency_tracer.h:149

↓ 4 callersMethodset_ingestion_status

src/replica/test/mock_utils.h:197

↓ 4 callersMethodset_last_committed_decree

src/replica/test/mock_utils.h:172

↓ 4 callersMethodset_negotiation_succeed

src/runtime/rpc/network.cpp:495

↓ 4 callersMethodset_nths

Set with specified nth indexes. An nth index is typically an index of the sequence container (e.g. std::vector). This method allows nth indexes to be

src/utils/nth_element.h:66

↓ 4 callersMethodset_update_leader_automatically

src/runtime/rpc/group_address.h:76

↓ 4 callersMethodset_valid_start_offset_on_open

src/replica/mutation_log.cpp:995

↓ 4 callersFunctionsimpleFullScanOpts

(t *testing.T, tb TableConnector, handler func(hashKey, sortKey, value []byte), options *ScannerOptions)

go-client/pegasus/scan_test.go:46

↓ 4 callersMethodstart

java-client/src/main/java/org/apache/pegasus/metrics/MetricsReporter.java:89

↓ 4 callersMethodstop

src/runtime/task/task_engine.cpp:122

↓ 4 callersMethodstop_1_replica

python-client/tests/test_integration.py:75

↓ 4 callersFunctionstring_md5

src/utils/strings.cpp:391

↓ 4 callersMethodsubmit_transaction

src/meta/meta_state_service_simple.cpp:310

↓ 4 callersFunctionsupportedEncodingsToString

pegic/interactive/cmd/encoding.go:103

↓ 4 callersMethodtoString

java-client/src/main/java/org/apache/pegasus/base/gpid.java:208

↓ 4 callersMethodto_json

src/meta/meta_data.h:377

↓ 4 callersFunctionto_string_view

src/base/pegasus_utils.h:109

↓ 4 callersMethodtoggle_response_ping

src/failure_detector/test/failure_detector.cpp:167

↓ 4 callersMethodtryWait

src/utils/hpc_locks/sema.h:200

↓ 4 callersMethodtype

src/perf_counter/perf_counter.h:106

↓ 4 callersMethodtype

src/runtime/rpc/rpc_address.h:128

↓ 4 callersMethodunlock_meta_op_status

src/meta/meta_service.cpp:285

↓ 4 callersMethodunregister_rpc_handler

src/runtime/serverlet.h:235

↓ 4 callersFunctionupdate_app_pegasus_perf_counter

src/shell/command_helper.h:867

↓ 4 callersMethodupdate_fail_mode

src/replica/duplication/replica_duplicator.h:91

↓ 4 callersMethodupdate_last_durable_decree

src/replica/test/mock_utils.h:218

↓ 4 callersMethodupload_checkpoint_to_remote

src/replica/backup/cold_backup_context.cpp:402

↓ 4 callersMethodvalid

src/server/range_read_limiter.h:50

↓ 4 callersMethodvalidatePositiveNum

java-client/src/main/java/org/apache/pegasus/client/ClientOptions.java:412

↓ 4 callersMethodversion

src/base/value_schema_v2.h:46

↓ 4 callersMethodwait

src/runtime/task/task_engine.sim.cpp:110

↓ 4 callersMethodwaitUninterruptable

(FutureTask<T> task, long millseconds)

java-client/src/main/java/org/apache/pegasus/tools/Tools.java:73

↓ 4 callersFunctionwrapUpdateAppEnvError

admin-cli/executor/table_env.go:81

↓ 4 callersMethodwrite

(final RequestEntry entry, VolatileFields cache)

java-client/src/main/java/org/apache/pegasus/rpc/async/ReplicaSession.java:344

↓ 4 callersMethodwrite_commit

src/runtime/rpc/rpc_message.cpp:426

↓ 4 callersMethodwrite_next

src/runtime/rpc/rpc_message.cpp:407

↓ 3 callersMethodAddDuplication

(tableName string, remoteCluster string, duplicateCheckpoint bool)

admin-cli/client/meta.go:85

↓ 3 callersMethodClose

go-client/session/replica_session.go:223

↓ 3 callersMethodClose

Close the sessions.

go-client/session/meta_session.go:135

↓ 3 callersMethodConnState

Get connection state.

go-client/session/session.go:63

↓ 3 callersMethodCreateApp

(tableName string, envs map[string]string, partitionCount int)

admin-cli/client/meta.go:79

↓ 3 callersMethodCreateTable

(ctx context.Context, tableName string, partitionCount int, successIfExist_optional ...bool)

go-client/admin/client.go:36

↓ 3 callersMethodExist

Check value existence for the entry for `hashKey` + `sortKey`. `hashKey`: CAN'T be nil or empty.

go-client/pegasus/table_connector.go:153

↓ 3 callersMethodFatalf

(format string, args ...interface{})

go-client/pegalog/logger.go:34

↓ 3 callersMethodFilterType

java-client/src/main/java/org/apache/pegasus/client/FilterType.java:33

↓ 3 callersFunctionGetClusterReplicaInfo

GetClusterReplicaInfo returns replica info in both node and table perspectives. = From node perspective, it returns a list of node states, each contai

admin-cli/client/replica_health.go:119

↓ 3 callersMethodIncr

Atomically increment value by key from the cluster. Returns the new value. `hashKey` / `sortKeys` : CAN'T be nil or empty

go-client/pegasus/table_connector.go:181

↓ 3 callersFunctionInvoke

src/utils/absl/base/internal/invoke.h:210

↓ 3 callersFunctionIsNetworkTimeoutErr

IsNetworkTimeoutErr returns whether the given error is a timeout error.

go-client/rpc/utils.go:28

↓ 3 callersFunctionNewMetaManager

(addrs []string, creator NodeSessionCreator)

go-client/session/meta_session.go:75

↓ 3 callersFunctionNewNodeFromTCPAddr

NewNodeFromTCPAddr creates a node from tcp address. NOTE: - Will not initialize TCP connection unless needed. - Should not be called too frequently be

admin-cli/util/pegasus_node.go:91

↓ 3 callersFunctionNewReplicaManager

(creator NodeSessionCreator)

go-client/session/replica_session.go:216

↓ 3 callersFunctionNewWriteStream

NewWriteStream always receives a *net.TcpConn as `writer`, except in testing it can accept a buffer as the fake writer.

go-client/rpc/stream_out.go:33

↓ 3 callersMethodQueryClusterInfo

admin-cli/client/meta.go:71

← previous next →1,101–1,200 of 8,667, ranked by callers