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

↓ 2 callersMethodfindByThriftId

Find the _Fields constant that matches fieldId, or null if its not found.

java-client/src/main/java/org/apache/pegasus/base/blob.java:56

↓ 2 callersMethodfindByThriftId

Find the _Fields constant that matches fieldId, or null if its not found.

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

↓ 2 callersMethodfindByThriftId

Find the _Fields constant that matches fieldId, or null if its not found.

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

↓ 2 callersMethodfindTable

(tableName string)

go-client/pegasus/client.go:115

↓ 2 callersMethodfind_from_dropped

src/meta/meta_data.cpp:338

↓ 2 callersMethodfind_shortest_path

using dijstra to find shortest path

src/meta/load_balance_policy.cpp:501

↓ 2 callersFunctionfind_string_prefix

src/utils/strings.cpp:419

↓ 2 callersFunctionflags_initialize

src/utils/flags.cpp:385

↓ 2 callersMethodflush

src/replica/mutation_log.cpp:105

↓ 2 callersFunctionfreeCompletions

Free a list of completion option populated by linenoiseAddCompletion(). */

src/shell/linenoise/linenoise.c:336

↓ 2 callersFunctionfrom_hex

src/http/uri_decoder.cpp:29

↓ 2 callersMethodfrom_string

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

↓ 2 callersMethodgenJsonsFromHistogram

(String name, Histogram hist, StringBuilder output)

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

↓ 2 callersMethodgenJsonsFromMeter

(String name, Meter meter, StringBuilder output)

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

↓ 2 callersFunctiongenerateKeyRule

(ruleType string, pattern string, match string)

admin-cli/executor/compaction.go:166

↓ 2 callersFunctiongenerate_apps

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

↓ 2 callersFunctiongenerate_hotkey

src/test/function_test/utils/utils.h:54

↓ 2 callersFunctiongenerate_multi_columns_tp

src/utils/test/output_utils_test.cpp:111

↓ 2 callersMethodgenerate_replica

src/replica/test/mock_utils.h:309

↓ 2 callersMethodgenerate_replicas_base_dir_nodes_for_app

src/replica/test/mock_utils.h:328

↓ 2 callersFunctiongenerate_single_column_tp

src/utils/test/output_utils_test.cpp:102

↓ 2 callersFunctiongenerate_str_vector_by_random

src/test/function_test/utils/utils.h:62

↓ 2 callersMethodget

Get value stored in <hash_key, sort_key>. :param hash_key: (bytes) which hash key used for this API. :param sort_key: (bytes

python-client/pypegasus/pgclient.py:738

↓ 2 callersMethodgetAndRemoveEntry

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

↓ 2 callersFunctiongetCursorPosition

Use the ESC [6n escape sequence to query the horizontal cursor position * and return it. On error -1 is returned, on success the position of the * c

src/shell/linenoise/linenoise.c:262

↓ 2 callersMethodgetExecutor

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

↓ 2 callersMethodgetInitialResponse

java-client/src/main/java/org/apache/pegasus/security/SaslWrapper.java:58

↓ 2 callersFunctiongetNodeAddress

(n *util.PegasusNode)

admin-cli/client/meta.go:369

↓ 2 callersFunctiongetNodeReplicas

(client *executor.Client, replicaServer *NodesCapacity)

admin-cli/executor/toolkits/nodesbalancer/migrator.go:203

↓ 2 callersFunctiongetNodesMap

(client *Client)

admin-cli/executor/list_nodes.go:83

↓ 2 callersMethodgetRetryDelay

(long timeoutMs)

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

↓ 2 callersMethodgetScanner

Get Scanner for {startSortKey, stopSortKey} within hashKey @param tableName TableHandler name @param hashKey used to decide which partition to put th

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

↓ 2 callersMethodgetSessionResetTimeWindowSecs

session reset time window, If the timeout duration exceeds this value, the connection will be reset @return sessionResetTimeWindowSecs

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

↓ 2 callersMethodgetSubstring

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

↓ 2 callersMethodgetTotalRemainingReplicaCount

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

↓ 2 callersMethodgetValueMap

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

↓ 2 callersFunctionget_absolute_path

src/utils/filesystem.cpp:550

↓ 2 callersMethodget_app

src/redis_protocol/proxy_lib/proxy_layer.h:94

↓ 2 callersFunctionget_app_meta_backup_path

src/common/backup_common.cpp:65

↓ 2 callersMethodget_app_migration_info

src/meta/cluster_balance_policy.cpp:216

↓ 2 callersFunctionget_app_stat

src/shell/command_helper.h:1122

↓ 2 callersMethodget_backup_app_id

src/meta/backup_engine.h:80

↓ 2 callersFunctionget_backup_info_file

src/common/backup_common.cpp:50

↓ 2 callersMethodget_backup_manager

src/replica/replica.h:261

↓ 2 callersMethodget_backup_path

src/meta/meta_backup_service.cpp:1639

↓ 2 callersMethodget_balance_operation_count

src/meta/greedy_load_balancer.cpp:100

↓ 2 callersMethodget_ballot

src/replica/split/replica_split_manager.h:210

↓ 2 callersMethodget_buffer_count_on_send

get max buffer count needed by get_buffers_on_send(). may be invoked for mutiple times if the message is reused for resending.

src/runtime/rpc/message_parser.h:117

↓ 2 callersMethodget_buffers_on_send

src/runtime/rpc/raw_message_parser.cpp:123

↓ 2 callersMethodget_bulk_load_service

src/meta/meta_service.h:159

↓ 2 callersMethodget_bulk_load_status

src/replica/bulk_load/replica_bulk_loader.h:151

↓ 2 callersMethodget_checkpoint

helper routines to accelerate learning

src/replica/storage/simple_kv/simple_kv.server.impl.cpp:260

↓ 2 callersMethodget_cluster_balance_score

src/meta/server_state.cpp:2649

↓ 2 callersMethodget_current_backup_id

src/meta/backup_engine.h:79

↓ 2 callersMethodget_current_buffer

src/utils/binary_writer.cpp:112

↓ 2 callersFunctionget_date_to_string

src/server/available_detector.cpp:209

↓ 2 callersMethodget_disk_partitions_map

src/meta/cluster_balance_policy.cpp:429

↓ 2 callersMethodget_disk_tag

src/meta/meta_data.cpp:481

↓ 2 callersMethodget_duplication_path

Get zk path for duplication.

src/meta/duplication/meta_duplication_service.h:107

↓ 2 callersFunctionget_fs_manager

src/meta/test/misc/misc.h:51

↓ 2 callersMethodget_geo_app

src/redis_protocol/proxy_lib/proxy_layer.h:95

↓ 2 callersFunctionget_hour_to_string

src/server/available_detector.cpp:216

↓ 2 callersMethodget_initial_delay_ms

src/utils/metrics.h:1110

↓ 2 callersMethodget_last_manual_compact_finish_time

src/server/meta_store.cpp:65

↓ 2 callersMethodget_learn_start_decree

ThreadPool: THREAD_POOL_REPLICATION

src/replica/replica_learn.cpp:306

↓ 2 callersMethodget_manual_compact_status

src/replica/replica.cpp:550

↓ 2 callersMethodget_meta_split_status

src/replica/split/replica_split_manager.h:71

↓ 2 callersFunctionget_min_thread_setting_id

src/test/kill_test/data_verifier.cpp:82

↓ 2 callersFunctionget_minute_to_string

src/server/available_detector.cpp:223

↓ 2 callersMethodget_mutations

src/client_lib/mutation.cpp:85

↓ 2 callersMethodget_node_status

src/replica/replica_context.h:294

↓ 2 callersMethodget_partition_count

python-client/pypegasus/pgclient.py:390

↓ 2 callersFunctionget_perf_counter_handler

src/http/perf_counter_http_service.cpp:32

↓ 2 callersFunctionget_remote_chkpt_dir

src/common/backup_common.cpp:109

↓ 2 callersFunctionget_remote_chkpt_meta_file

src/common/backup_common.cpp:118

↓ 2 callersMethodget_request

java-client/src/main/java/org/apache/pegasus/operator/rrdb_check_and_set_operator.java:63

↓ 2 callersMethodget_response

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

↓ 2 callersMethodget_response

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

↓ 2 callersMethodget_response

java-client/src/main/java/org/apache/pegasus/operator/rrdb_put_operator.java:58

↓ 2 callersMethodget_session

src/zookeeper/zookeeper_session_mgr.cpp:58

↓ 2 callersMethodget_string_value_list

src/utils/configuration.cpp:366

↓ 2 callersFunctionget_table_name_from_app_name

src/runtime/ranger/ranger_resource_policy_manager.cpp:653

↓ 2 callersFunctionget_tcmalloc_numeric_property

Get tcmalloc numeric property (name is "prop") value. Return -1 if get property failed (property we used will be greater than zero) Properties can be

src/replica/replica_stub.cpp:2934

↓ 2 callersFunctionget_ttl

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

↓ 2 callersFunctionget_version_handler

src/http/builtin_http_calls.cpp:47

↓ 2 callersFunctiongpid_from_string

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

↓ 2 callersFunctiongpid_to_string

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

↓ 2 callersFunctionhandle_duplication_modify_response

src/shell/commands/duplication.cpp:190

↓ 2 callersMethodhas_collected

src/meta/meta_data.h:425

↓ 2 callersFunctionhas_seconds_expired

src/meta/meta_data.h:579

↓ 2 callersMethodhas_section

src/utils/configuration.cpp:444

↓ 2 callersMethodhas_tag

src/utils/flags.cpp:144

↓ 2 callersFunctionhex_digit_to_int

Helper function for sdssplitargs() that converts a hex digit into an * integer from 0 to 15 */

src/shell/sds/sds.c:903

↓ 2 callersFunctionhex_digit_to_int

src/base/pegasus_utils.cpp:116

↓ 2 callersFunctionhostname

src/utils/utils.cpp:123

↓ 2 callersFunctionin_white_list

in_white_list returns if the rpc code can be allowed to bypass negotiation.

src/runtime/security/negotiation_manager.cpp:51

↓ 2 callersMethodincr

(byte[] hashKey, byte[] sortKey, long increment, int ttlSeconds, int timeout)

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

↓ 2 callersMethodinit

src/runtime/security/sasl_server_wrapper.cpp:33

↓ 2 callersMethodinit

Initialize the client before you can use it. :return: (DeferredList) True when initialized succeed, others when failed.

python-client/pypegasus/pgclient.py:652

↓ 2 callersMethodinit

(String[] mechanims)

java-client/src/main/java/org/apache/pegasus/security/SaslWrapper.java:44

← previous next →1,701–1,800 of 8,667, ranked by callers