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

↓ 1 callersMethoddecrement

src/perf_counter/perf_counter_atomic.h:169

↓ 1 callersMethoddecrement_by

src/utils/metrics.h:813

↓ 1 callersFunctiondefaultAggregator

The default column aggregate type, sum(value...)

admin-cli/tabular/template.go:228

↓ 1 callersMethoddel

(byte[] sortKey)

java-client/src/main/java/org/apache/pegasus/client/Mutations.java:64

↓ 1 callersMethoddel

(byte[] hashKey, byte[] sortKey, int timeout)

java-client/src/main/java/org/apache/pegasus/client/PegasusTable.java:1669

↓ 1 callersMethoddelRange

( byte[] hashKey, byte[] startSortKey, byte[] stopSortKey, DelRangeOptions options, int timeout)

java-client/src/main/java/org/apache/pegasus/client/PegasusTable.java:1754

↓ 1 callersMethoddelay

src/utils/exp_delay.h:69

↓ 1 callersMethoddemand_switch_file

src/replica/mutation_log.h:302

↓ 1 callersMethodderegister_command

src/utils/command_manager.cpp:72

↓ 1 callersMethodderegister_commands

src/utils/logging_provider.h:76

↓ 1 callersMethoddescription

src/utils/metrics.h:593

↓ 1 callersMethoddetectHostAndInit

(String tag, int reportIntervalSec)

java-client/src/main/java/org/apache/pegasus/metrics/MetricsManager.java:62

↓ 1 callersFunctiondiagnose_recommend

src/shell/commands/recovery.cpp:169

↓ 1 callersMethoddial

If the dialing ended successfully, it will start loopForRequest and loopForResponse which handle the data communications. If the last attempt failed,

go-client/session/session.go:186

↓ 1 callersMethoddiff_string

src/replica/storage/simple_kv/test/common.cpp:233

↓ 1 callersMethoddisable_backup_policy

src/client/replication_ddl_client.cpp:1082

↓ 1 callersMethoddispatch_event

src/zookeeper/zookeeper_session.cpp:203

↓ 1 callersMethoddispatch_zookeeper_session_expire

src/zookeeper/distributed_lock_service_zookeeper.cpp:261

↓ 1 callersMethoddoConnect

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

↓ 1 callersFunctiondo_check

src/test/kill_test/data_verifier.cpp:287

↓ 1 callersMethoddo_manual_compact

src/server/pegasus_server_impl.cpp:3319

↓ 1 callersMethoddo_possible_commit_on_primary

src/replica/replica_2pc.cpp:424

↓ 1 callersMethoddownload

TODO: handle the localfile path

src/block_service/fds/fds_service.cpp:665

↓ 1 callersFunctiondownload_block_file_sync

src/block_service/block_service_manager.cpp:123

↓ 1 callersMethoddrain

src/replica/log_file_stream.h:170

↓ 1 callersFunctiondsn_address_from_string

src/runtime/test/rpc.cpp:67

↓ 1 callersFunctiondsn_app_registration_pegasus

src/server/main.cpp:69

↓ 1 callersFunctiondsn_app_registration_simple_kv

src/replica/storage/simple_kv/simple_kv.main.cpp:46

↓ 1 callersFunctiondsn_app_registration_simple_kv

src/replica/storage/simple_kv/test/simple_kv.main.cpp:54

↓ 1 callersFunctiondsn_config_dump

src/utils/config_api.cpp:37

↓ 1 callersFunctiondsn_config_get_value_int64

src/utils/config_api.cpp:63

↓ 1 callersFunctiondsn_config_load

src/utils/config_api.cpp:32

↓ 1 callersFunctiondsn_core_init

src/runtime/core_main.cpp:35

↓ 1 callersFunctiondsn_coredump

src/runtime/service_api_c.cpp:129

↓ 1 callersFunctiondsn_global_init

src/runtime/service_api_c.cpp:328

↓ 1 callersFunctiondsn_init

src/redis_protocol/proxy_ut/redis_proxy_test.cpp:641

↓ 1 callersFunctiondsn_log

src/utils/logging.cpp:125

↓ 1 callersMethoddsn_log

src/utils/simple_logger.cpp:295

↓ 1 callersFunctiondsn_log_get_start_level

src/utils/logging.cpp:97

↓ 1 callersFunctiondsn_log_set_start_level

src/utils/logging.cpp:99

↓ 1 callersFunctiondsn_logv

src/utils/logging.cpp:101

↓ 1 callersFunctiondsn_task_queue_virtual_length_ptr

src/runtime/service_api_c.cpp:121

↓ 1 callersMethoddsptr

src/perf_counter/perf_counter.h:105

↓ 1 callersMethoddump_write_request

dump the write request some info to string, it may need overload

src/replica/replication_app_base.h:258

↓ 1 callersMethodduplicate

src/replica/test/mock_utils.h:466

↓ 1 callersFunctionduplication_entry_to_string

src/common/duplication_common.cpp:156

↓ 1 callersMethodduplication_sync

ThreadPool(WRITE): THREAD_POOL_META_STATE

src/meta/duplication/meta_duplication_service.cpp:270

↓ 1 callersMethodempty_put

src/server/pegasus_write_service.cpp:172

↓ 1 callersMethodenableBackupRequest

java-client/src/main/java/org/apache/pegasus/client/TableOptions.java:45

↓ 1 callersMethodenableCompression

java-client/src/main/java/org/apache/pegasus/client/TableOptions.java:49

↓ 1 callersMethodenableWriteLimit

whether to enable write limit . if true, exceed the threshold set will throw exception, See {@linkplain WriteLimiter WriteLimiter}. Defaults to {@lite

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

↓ 1 callersMethodenable_backup_policy

src/client/replication_ddl_client.cpp:1110

↓ 1 callersFunctionencodeNextBytesByKeys

(hashKey []byte, sortKey []byte)

go-client/pegasus/util.go:50

↓ 1 callersFunctionencodeToZkNodeData

(cluster string, addr string)

admin-cli/executor/toolkits/tablemigrator/switcher.go:127

↓ 1 callersFunctionencode_attrs

src/utils/metrics.cpp:116

↓ 1 callersFunctionencode_error

src/utils/metrics.cpp:249

↓ 1 callersFunctionencode_metrics

src/utils/metrics.cpp:130

↓ 1 callersMethodenqueue

src/runtime/task/simple_task_queue.cpp:117

↓ 1 callersMethodenqueue_internal

This function is used to throttle tasks before they enter the queue `queue_length_throttling_threshold` is configured by task pool `throttling_mode` i

src/runtime/task/task_queue.cpp:79

↓ 1 callersMethodensureNotLeader

(rpc_address addr)

java-client/src/test/java/org/apache/pegasus/rpc/async/MetaSessionTest.java:61

↓ 1 callersMethodenv

src/runtime/service_engine.h:116

↓ 1 callersFunctionepoch_now

python-client/pypegasus/utils/tools.py:36

↓ 1 callersMethodequals

java-client/src/main/java/org/apache/pegasus/base/rpc_address.java:194

↓ 1 callersMethodequals

java-client/src/main/java/org/apache/pegasus/base/task_code.java:143

↓ 1 callersMethodequals

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

↓ 1 callersMethodequals

java-client/src/main/java/org/apache/pegasus/base/error_code.java:249

↓ 1 callersMethoderror

src/runtime/rpc/rpc_message.cpp:97

↓ 1 callersMethoderror_code

src/utils/error_code.cpp:58

↓ 1 callersFunctionerror_retry

src/client/partition_resolver.cpp:50

↓ 1 callersFunctionevent_type_from_string

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

↓ 1 callersFunctionevent_type_support_inject_fault

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

↓ 1 callersFunctionexcludes_from_file

scripts/run-clang-format.py:66

↓ 1 callersMethodexec_internal

src/runtime/task/task.cpp:157

↓ 1 callersMethodexecuteMigrateAction

(client *executor.Client, action *Action)

admin-cli/executor/toolkits/nodesmigrator/migrator.go:282

↓ 1 callersFunctionexecute_command

src/shell/main.cpp:598

↓ 1 callersMethodexist

(byte[] hashKey, byte[] sortKey, int timeout)

java-client/src/main/java/org/apache/pegasus/client/PegasusTable.java:1103

↓ 1 callersMethodexistValidReplica

(origin *MigratorNode, target *MigratorNode)

admin-cli/executor/toolkits/nodesmigrator/migrator.go:215

↓ 1 callersMethodextract_entity_metrics

src/utils/metrics.cpp:200

↓ 1 callersFunctionextract_indices

src/geo/lib/latlng_codec.cpp:34

↓ 1 callersFunctionextract_timestamp_from_timetag

src/base/pegasus_value_schema.h:49

↓ 1 callersMethodextract_user_data

src/base/value_schema_v1.cpp:51

↓ 1 callersMethodextract_user_specified_ops

src/server/key_ttl_compaction_filter.h:178

↓ 1 callersFunctionfd_test_init

src/failure_detector/test/failure_detector.cpp:272

↓ 1 callersMethodfetch_and_reset

src/utils/long_adder.cpp:226

↓ 1 callersMethodfetch_and_reset

src/utils/long_adder_bench/long_adder_bench.cpp:49

↓ 1 callersMethodfetch_current_handler

rpc_response_task is a special kind of task, because we support the semantic of distributed service in sending rpc request, for example: "querying met

src/runtime/task/task.h:504

↓ 1 callersFunctionfile_data_compare

src/meta/test/state_sync_test.cpp:94

↓ 1 callersMethodfile_handle

src/replica/log_file.h:209

↓ 1 callersFunctionfile_metadata_from_json

src/block_service/local/local_service.cpp:62

↓ 1 callersFunctionfile_utils_test_cleanup

src/utils/test/file_utils.cpp:895

↓ 1 callersFunctionfile_utils_test_create

src/utils/test/file_utils.cpp:618

↓ 1 callersFunctionfile_utils_test_file_size

src/utils/test/file_utils.cpp:679

↓ 1 callersFunctionfile_utils_test_get_current_directory

src/utils/test/file_utils.cpp:486

↓ 1 callersFunctionfile_utils_test_get_file_name

src/utils/test/file_utils.cpp:572

↓ 1 callersFunctionfile_utils_test_get_normalized_path

src/utils/test/file_utils.cpp:75

↓ 1 callersFunctionfile_utils_test_get_paths

src/utils/test/file_utils.cpp:781

↓ 1 callersFunctionfile_utils_test_get_process_image_path

src/utils/test/file_utils.cpp:57

↓ 1 callersFunctionfile_utils_test_path_combine

src/utils/test/file_utils.cpp:497

↓ 1 callersFunctionfile_utils_test_path_exists

src/utils/test/file_utils.cpp:695

↓ 1 callersFunctionfile_utils_test_remove

src/utils/test/file_utils.cpp:870

← previous next →2,401–2,500 of 8,667, ranked by callers