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 callersFunctioncheck_nonempty

src/utils/test/utils.cpp:101

↓ 1 callersMethodcheck_order

src/meta/meta_data.cpp:410

↓ 1 callersMethodcheck_partition_hash

src/replica/split/replica_split_manager.h:214

↓ 1 callersFunctioncheck_prototype_and_extract_value_map_from_json_string

src/utils/test/metrics_test.cpp:977

↓ 1 callersFunctioncheck_ranger_database_table_policy_allowed

src/runtime/ranger/ranger_resource_policy.cpp:197

↓ 1 callersMethodcheck_read_result

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

↓ 1 callersFunctioncheck_registry_json_string

src/utils/test/metrics_test.cpp:2308

↓ 1 callersMethodcheck_replica_config

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

↓ 1 callersMethodcheck_satisfied

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

↓ 1 callersMethodcheck_size

src/meta/meta_data.cpp:326

↓ 1 callersMethodcheck_state

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

↓ 1 callersMethodcheck_valid_start_offset

src/replica/mutation_log.cpp:901

↓ 1 callersFunctioncheck_wait_task

src/runtime/task/task.cpp:237

↓ 1 callersMethodcheck_write_result

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

↓ 1 callersFunctioncheckpoint_folder

src/replica/replica_chkpt.cpp:99

↓ 1 callersMethodchild_acked

src/replica/mutation.h:134

↓ 1 callersMethodchild_apply_private_logs

ThreadPool: THREAD_POOL_REPLICATION_LONG

src/replica/split/replica_split_manager.cpp:412

↓ 1 callersMethodchild_catch_up_states

ThreadPool: THREAD_POOL_REPLICATION

src/replica/split/replica_split_manager.cpp:508

↓ 1 callersMethodchild_copy_prepare_list

ThreadPool: THREAD_POOL_REPLICATION

src/replica/split/replica_split_manager.cpp:295

↓ 1 callersMethodchild_init_replica

ThreadPool: THREAD_POOL_REPLICATION

src/replica/split/replica_split_manager.cpp:131

↓ 1 callersMethodchild_learn_states

ThreadPool: THREAD_POOL_REPLICATION_LONG

src/replica/split/replica_split_manager.cpp:344

↓ 1 callersFunctionchkpt_init_from_dir

src/server/pegasus_server_impl.cpp:133

↓ 1 callersFunctionclassify_files

Scan all the files of the project, mark the ones that have copyright info.

scripts/check_license.py:88

↓ 1 callersMethodcleanup_bulk_load_states

src/replica/replica_context.cpp:166

↓ 1 callersMethodclearBulkLoad

(ctx context.Context, req *admin.ClearBulkLoadStateRequest)

go-client/session/admin_rpc_types.go:605

↓ 1 callersMethodclearDatabase

java-client/src/test/java/org/apache/pegasus/client/TestBench.java:31

↓ 1 callersFunctionclear_bulk_load

src/shell/commands/bulk_load.cpp:457

↓ 1 callersMethodclear_bulk_load

src/client/replication_ddl_client.cpp:1643

↓ 1 callersMethodclear_bulk_load_states_if_needed

ThreadPool: THREAD_POOL_REPLICATION

src/replica/bulk_load/replica_bulk_loader.cpp:1068

↓ 1 callersMethodclear_ddd_partitions

src/meta/partition_guardian.h:59

↓ 1 callersFunctionclear_files

src/utils/test/logger.cpp:74

↓ 1 callersMethodclear_on_failure

src/replica/replica_stub.cpp:2380

↓ 1 callersMethodclear_paths

Just for testing. Since paths are registered to a singleton, some paths will be re-registered when create http service in test, and cause crash. We wi

src/http/http_call_registry.h:78

↓ 1 callersMethodclear_prepare_or_commit_tasks

src/replica/mutation.cpp:333

↓ 1 callersMethodclear_proposals

src/meta/server_state.cpp:2416

↓ 1 callersMethodclear_scanner

---------- call RPC_RRDB_RRDB_CLEAR_SCANNER ------------

src/include/rrdb/rrdb.client.h:450

↓ 1 callersMethodclear_tasks_state

src/runtime/task/task_tracker.h:164

↓ 1 callersMethodclear_user_specified_ops

src/server/key_ttl_compaction_filter.h:186

↓ 1 callersFunctionclone_app_mapper

src/meta/test/update_configuration_test.cpp:384

↓ 1 callersMethodclose

python-client/pypegasus/pgclient.py:146

↓ 1 callersMethodclose

python-client/pypegasus/pgclient.py:235

↓ 1 callersMethodclose

java-client/src/main/java/org/apache/pegasus/client/PegasusAbstractClient.java:59

↓ 1 callersMethodcluster_info

src/client/replication_ddl_client.cpp:648

↓ 1 callersMethodcluster_name

src/client/replication_ddl_client.cpp:622

↓ 1 callersMethodcluster_root

src/meta/meta_service.h:218

↓ 1 callersMethodcollapse

src/aio/aio_task.cpp:65

↓ 1 callersMethodcollect_drop_replica

src/meta/meta_data.cpp:376

↓ 1 callersFunctioncolorize

scripts/run-clang-format.py:232

↓ 1 callersMethodcommit_buffer

src/replica/duplication/test/mutation_batch_test.cpp:52

↓ 1 callersMethodcompareExchange

( byte[] hashKey, byte[] sortKey, byte[] expectedValue, byte[] desiredValue, int

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

↓ 1 callersFunctioncompile_thrift_file

scripts/compile_thrift.py:111

↓ 1 callersFunctioncompleteLine

This is an helper function for linenoiseEdit() and is called when the * user types the <tab> key in order to complete the string currently in the *

src/shell/linenoise/linenoise.c:350

↓ 1 callersMethodcomplete_check

src/replica/backup/cold_backup_context.cpp:104

↓ 1 callersFunctioncompletionCallback

Linenoise completion callback. */

src/shell/main.cpp:607

↓ 1 callersMethodcompression_str_to_type

src/server/test/pegasus_compression_options_test.cpp:79

↓ 1 callersMethodcompression_type_to_str

src/server/test/pegasus_compression_options_test.cpp:84

↓ 1 callersFunctioncomputeMigrateAction

(migrate *MigrateDisk, minSize int64)

admin-cli/executor/toolkits/diskbalancer/migrator.go:166

↓ 1 callersFunctioncompute_num_cells

src/utils/long_adder.cpp:42

↓ 1 callersFunctionconfirm_unsafe_command

src/shell/command_utils.cpp:55

↓ 1 callersMethodconstruct_apps

src/meta/server_state.cpp:2085

↓ 1 callersMethodconstruct_apps_test

src/meta/test/state_sync_test.cpp:371

↓ 1 callersMethodconsume

src/replica/log_file_stream.h:165

↓ 1 callersMethodcontextReset

java-client/src/main/java/org/apache/pegasus/client/PegasusScanner.java:385

↓ 1 callersMethodcontrol

src/utils/throttling_controller.cpp:147

↓ 1 callersMethodcontrolBulkLoad

(ctx context.Context, req *admin.ControlBulkLoadRequest)

go-client/session/admin_rpc_types.go:580

↓ 1 callersMethodcontrolPartitionSplit

(ctx context.Context, req *admin.ControlSplitRequest)

go-client/session/admin_rpc_types.go:505

↓ 1 callersMethodcontrol_balancer

src/replica/storage/simple_kv/test/checker.cpp:168

↓ 1 callersMethodcontrol_partition_split

src/meta/meta_split_service.cpp:353

↓ 1 callersFunctionconvert2MigratorNodes

(client *executor.Client, from []string, to []string)

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

↓ 1 callersMethodconvertExceptions

( List<Pair<PException, Void>> responses, List<PException> exceptions)

java-client/src/main/java/org/apache/pegasus/client/request/Batch.java:68

↓ 1 callersMethodcopy_and_prepare_send

src/runtime/rpc/rpc_message.cpp:275

↓ 1 callersMethodcopy_checkpoint_to_dir

src/replica/storage/simple_kv/simple_kv.server.impl.h:88

↓ 1 callersMethodcopy_from

src/replica/mutation.cpp:130

↓ 1 callersMethodcopy_once

src/meta/load_balance_policy.cpp:681

↓ 1 callersMethodcopy_remote_directory

src/nfs/nfs_node.cpp:43

↓ 1 callersMethodcopy_to

src/utils/extensible_object.h:103

↓ 1 callersMethodcounterEnabled

java-client/src/main/java/org/apache/pegasus/rpc/async/ClusterManager.java:132

↓ 1 callersFunctioncrc64Hash

pegic/executor/partition_index.go:33

↓ 1 callersMethodcreateClient

Create a client instance. After used, should call client.close() to release resource. @param configPath client config path,could be: <pre> - zook

java-client/src/main/java/org/apache/pegasus/client/PegasusAdminClientFactory.java:37

↓ 1 callersMethodcreateCluster

(ClientOptions clientOptions)

java-client/src/main/java/org/apache/pegasus/rpc/Cluster.java:28

↓ 1 callersFunctioncreate_block_file_sync

src/block_service/block_service_manager.cpp:109

↓ 1 callersFunctioncreate_multi_put_request

src/server/test/message_utils.h:29

↓ 1 callersFunctioncreate_multi_remove_request

src/server/test/message_utils.h:35

↓ 1 callersFunctioncreate_negotiation

src/runtime/security/negotiation.cpp:45

↓ 1 callersMethodcreate_new_log_file

src/replica/mutation_log.cpp:738

↓ 1 callersMethodcreate_parser

src/runtime/rpc/message_parser.cpp:204

↓ 1 callersFunctioncreate_remove_request

src/server/test/message_utils.h:46

↓ 1 callersFunctioncreate_replica_access_controller

src/runtime/security/access_controller.cpp:62

↓ 1 callersFunctioncreate_sasl_wrapper

src/runtime/security/sasl_wrapper.cpp:91

↓ 1 callersMethodcreate_time_milliseconds

src/replica/replica.h:241

↓ 1 callersFunctioncreate_timer_task

src/runtime/task/async_calls.h:71

↓ 1 callersMethodcrend

string_view::crend() Returns a const reverse iterator pointing just before the first character at the beginning of the `string_view`. This pointer ac

src/utils/string_view.h:243

↓ 1 callersFunctioncyan

scripts/run-clang-format.py:236

↓ 1 callersFunctiondb_bench_tool

src/test/bench_test/main.cpp:28

↓ 1 callersMethodddd_diagnose

src/meta/meta_service.cpp:1093

↓ 1 callersMethoddebug_string

src/runtime/rpc/message_parser.cpp:95

↓ 1 callersFunctiondecode_char

src/http/uri_decoder.cpp:43

↓ 1 callersMethoddecrease

src/meta/meta_bulk_load_ingestion_context.cpp:116

↓ 1 callersMethoddecrease_count

src/runtime/task/task_queue.h:72

↓ 1 callersMethoddecrease_left_secondary_ack_count

src/replica/mutation.h:123

← previous next →2,301–2,400 of 8,667, ranked by callers