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

↓ 3 callersMethodgetPartitionByGpid

(gpid *base.Gpid)

go-client/pegasus/table_connector.go:683

↓ 3 callersMethodgetPartitionCount

java-client/src/main/java/org/apache/pegasus/rpc/Table.java:62

↓ 3 callersMethodgetScanner

( byte[] hashKey, byte[] startSortKey, byte[] stopSortKey, ScanOptions options)

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

↓ 3 callersMethodgetTableTag

(String counterName)

java-client/src/main/java/org/apache/pegasus/metrics/MetricsPool.java:117

↓ 3 callersMethodgetTimeout

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

↓ 3 callersMethodgetUnorderedScanners

Get Scanners for all data in database @param tableName TableHandler name @param maxScannerCount how many scanner expected @param options scan options

java-client/src/main/java/org/apache/pegasus/client/PegasusClientInterface.java:681

↓ 3 callersMethodget_access_controller

src/meta/meta_service.h:152

↓ 3 callersMethodget_app_counter

src/perf_counter/perf_counters.cpp:178

↓ 3 callersMethodget_app_envs

src/client/replication_ddl_client.cpp:1472

↓ 3 callersFunctionget_app_partitions

src/shell/command_helper.h:1009

↓ 3 callersFunctionget_apps_and_nodes

src/shell/command_helper.h:993

↓ 3 callersFunctionget_bool_envs

src/replica/replica_config.cpp:89

↓ 3 callersFunctionget_bucket_id

src/server/hotkey_collector.cpp:131

↓ 3 callersMethodget_bulk_load_downloading_count

src/replica/test/mock_utils.h:370

↓ 3 callersMethodget_chunk_size

src/utils/fixed_size_buffer_pool.h:47

↓ 3 callersMethodget_client

src/block_service/fds/fds_service.h:62

↓ 3 callersMethodget_cluster

src/redis_protocol/proxy_lib/proxy_layer.h:93

↓ 3 callersMethodget_counter

src/perf_counter/perf_counters.cpp:246

↓ 3 callersFunctionget_current_directory

src/utils/filesystem.cpp:630

↓ 3 callersMethodget_duplication_confirms_to_update

src/replica/duplication/replica_duplicator_manager.cpp:32

↓ 3 callersMethodget_global_offset

src/replica/mutation_log.h:366

↓ 3 callersFunctionget_hashkey

src/test/pressure_test/main.cpp:82

↓ 3 callersFunctionget_intersection

src/utils/utils.h:123

↓ 3 callersMethodget_lock_owner

src/zookeeper/lock_struct.cpp:385

↓ 3 callersFunctionget_max_replica_count

src/shell/commands/table_management.cpp:971

↓ 3 callersMethodget_meta_view

src/meta/server_state.h:150

↓ 3 callersFunctionget_min_max_set

src/meta/cluster_balance_policy.cpp:81

↓ 3 callersMethodget_partition_count

src/meta/app_balance_policy.cpp:159

↓ 3 callersMethodget_partition_path

src/meta/duplication/meta_duplication_service.h:115

↓ 3 callersFunctionget_recent_start_time_handler

src/http/builtin_http_calls.cpp:60

↓ 3 callersFunctionget_remote_chkpt_dirname

src/common/backup_common.cpp:101

↓ 3 callersMethodget_response

java-client/src/main/java/org/apache/pegasus/operator/rrdb_incr_operator.java:57

↓ 3 callersMethodget_response

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

↓ 3 callersMethodget_response

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

↓ 3 callersFunctionget_rpc_address

src/meta/test/balancer_validator.cpp:175

↓ 3 callersFunctionget_service_node_name

src/runtime/tool_api.cpp:119

↓ 3 callersMethodget_sort_keys

Get multiple sort keys under hash_key. :param hash_key: (bytes) which hash key used for this API. :param max_kv_count: (int)

python-client/pypegasus/pgclient.py:940

↓ 3 callersFunctionget_sortkey

src/test/pressure_test/main.cpp:92

↓ 3 callersFunctionget_stat_internal

npath need to be a normalized path

src/utils/filesystem.cpp:85

↓ 3 callersMethodget_total_read_qps

src/shell/command_helper.h:719

↓ 3 callersMethodget_total_write_qps

src/shell/command_helper.h:721

↓ 3 callersMethodget_unordered_scanners

Get scanners for the whole pegasus table. :param max_split_count: (int) max count of scanners will be returned. :param scan_

python-client/pypegasus/pgclient.py:1018

↓ 3 callersMethodhandle_log_failure

src/replica/replica_stub.cpp:2482

↓ 3 callersMethodhasRecentUnresponsiveWrite

hasRecentUnresponsiveWrite returns if session is active in sending tcp request but gets no response.

go-client/session/session.go:265

↓ 3 callersMethodincrement_by

src/utils/test/long_adder_test.cpp:198

↓ 3 callersMethodinit

src/runtime/global_config.cpp:232

↓ 3 callersMethodinitMeta

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

↓ 3 callersMethodinit_prepare

src/replica/replica_2pc.cpp:237

↓ 3 callersMethodisEnablePerfCounter

Whether to enable performance statistics. If true, the client will periodically report metrics to local falcon agent (currently we only support falcon

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

↓ 3 callersMethodisWriteLimitEnabled

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

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

↓ 3 callersMethodis_alone

src/utils/link.h:125

↓ 3 callersMethodis_backup_request

src/runtime/rpc/rpc_message.h:224

↓ 3 callersMethodis_connected

src/replica/replica_stub.h:203

↓ 3 callersFunctionis_data_dir_removable

src/replica/disk_cleaner.h:58

↓ 3 callersFunctionis_duplication_status_invalid

src/common/duplication_common.h:49

↓ 3 callersMethodis_ingestion

src/replica/test/mock_utils.h:195

↓ 3 callersFunctionis_leading_space

src/utils/strings.cpp:146

↓ 3 callersMethodis_ready_for_commit

src/replica/mutation.h:87

↓ 3 callersMethodis_right_header

src/replica/log_file.cpp:397

↓ 3 callersMethodis_splitting

src/replica/split/replica_split_manager.h:66

↓ 3 callersFunctionjson_encode

src/meta/meta_data.h:591

↓ 3 callersFunctionjson_encode_iterable

src/common/json_helper.h:436

↓ 3 callersMethodlast_decree

src/replica/duplication/mutation_batch.cpp:131

↓ 3 callersMethodleader_forward

src/runtime/rpc/group_address.h:133

↓ 3 callersMethodline_no

src/replica/storage/simple_kv/test/case.h:80

↓ 3 callersFunctionlinenoiseEditMoveHome

Move cursor to the start of the line. */

src/shell/linenoise/linenoise.c:681

↓ 3 callersFunctionlinenoiseHistoryAdd

This is the API call to add a new entry in the linenoise history. * It uses a fixed array of char pointers that are shifted (memmoved) * when the hi

src/shell/linenoise/linenoise.c:1100

↓ 3 callersFunctionlinenoiseSetHintsCallback

Register a hits function to be called to show hits to the user at the * right of the prompt. */

src/shell/linenoise/linenoise.c:415

↓ 3 callersMethodlist_all_calls

src/http/http_call_registry.h:59

↓ 3 callersFunctionlist_hostname_from_ip

src/utils/utils.cpp:135

↓ 3 callersFunctionlist_hostname_from_ip_port

src/utils/utils.cpp:162

↓ 3 callersMethodlist_nodes

src/client/replication_ddl_client.cpp:475

↓ 3 callersMethodlist_snapshot_by_literal

the filter should return true if the counter satisfies condition.

src/perf_counter/perf_counters.cpp:333

↓ 3 callersMethodlock

src/meta/distributed_lock_service_simple.cpp:111

↓ 3 callersMethodlock_read

src/utils/synchronize.h:84

↓ 3 callersMethodlock_write

src/utils/synchronize.h:88

↓ 3 callersMethodlock_write

src/runtime/zlocks.cpp:146

↓ 3 callersMethodlog_prefix

src/meta/duplication/duplication_info.h:192

↓ 3 callersFunctionlog_print

src/utils/test/logger.cpp:98

↓ 3 callersMethodm_elapsed

src/utils/timer.h:48

↓ 3 callersFunctionmarshall_base

src/common/serialization_helper/thrift_helper.h:649

↓ 3 callersMethodmax_value

src/utils/customizable_id.h:130

↓ 3 callersMethodmax_value_pos

src/meta/load_balance_policy.cpp:585

↓ 3 callersMethodmetaQueryTimeout

The timeout for query meta server, must be positive. Defaults to {@literal 5000ms}, see {@link #DEFAULT_META_QUERY_TIMEOUT}. @param metaQueryTimeout

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

↓ 3 callersFunctionmigration_check_and_apply

src/meta/test/misc/misc.cpp:368

↓ 3 callersMethodmock_max_gced_decree

src/replica/test/mock_utils.h:159

↓ 3 callersMethodmodify_duplication

ThreadPool(WRITE): THREAD_POOL_META_STATE

src/meta/duplication/meta_duplication_service.cpp:81

↓ 3 callersFunctionmove_to_err_path

src/replica/disk_cleaner.cpp:143

↓ 3 callersMethodmultiGet

sync version of MultiGet, please refer to the async version {@link #asyncMultiGet(byte[], List, int, int, int)} and {@link #asyncMultiGet(byte[], List

java-client/src/main/java/org/apache/pegasus/client/PegasusTableInterface.java:952

↓ 3 callersMethodmultiGetSortKeys

( byte[] hashKey, int maxFetchCount, int maxFetchSize, int timeout)

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

↓ 3 callersMethodmulti_get_sortkeys

src/client_lib/pegasus_client_impl.cpp:495

↓ 3 callersMethodnegotiationSucceed

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

↓ 3 callersMethodnewly_add_primary

src/meta/server_load_balancer.cpp:87

↓ 3 callersFunctionnext_u64

src/test/bench_test/rand.cpp:32

↓ 3 callersMethodnotify

src/meta/test/meta_service_test_app.h:73

↓ 3 callersMethodonMechanismSelected

(negotiation_response response)

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

↓ 3 callersMethodonRpcReply

(ClientRequestRound round, long cachedConfigVersion, String serverAddr)

java-client/src/main/java/org/apache/pegasus/rpc/async/TableHandler.java:295

↓ 3 callersMethodon_meta_server_disconnected

src/replica/replica_stub.cpp:1649

↓ 3 callersMethodon_query_disk_info

ThreadPool: THREAD_POOL_DEFAULT

src/replica/replica_stub.cpp:1109

↓ 3 callersMethodon_query_last_checkpoint

src/replica/replica_stub.cpp:1095

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