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 callersMethodasyncMultiDel

delete mutiple values for a specific hashKey, async version @param hashKey used to decide which partition the key may exist if null or empty, means n

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

↓ 4 callersMethodasyncMultiSet

Set key-values for a specific hashKey, async version @param hashKey used to decide which partition the key may exist if null or empty, means no hash

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

↓ 4 callersMethodasyncMultiSet

( byte[] hashKey, List<Pair<byte[], byte[]>> values, int ttlSeconds, int timeout)

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

↓ 4 callersMethodasyncSet

( byte[] hashKey, byte[] sortKey, byte[] value, int ttlSeconds, int timeout /* ms */)

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

↓ 4 callersMethodasyncSortKeyCount

Count the sortkeys for a specific hashKey, async version @param hashKey used to decide which partition the key may exist should not be null or empty

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

↓ 4 callersMethodasyncWorkers

The number of background worker threads, must be positive. Internally it is the number of Netty NIO threads for handling RPC events between client and

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

↓ 4 callersMethodasync_multi_get

src/client_lib/pegasus_client_impl.cpp:333

↓ 4 callersMethodasync_multi_set

src/client_lib/pegasus_client_impl.cpp:172

↓ 4 callersMethodasync_next

src/client_lib/pegasus_scanner_impl.cpp:140

↓ 4 callersMethodattributes

src/utils/metrics.cpp:84

↓ 4 callersMethodbatch_commit

src/server/pegasus_write_service.cpp:301

↓ 4 callersMethodbatch_put

src/server/pegasus_write_service.cpp:267

↓ 4 callersMethodbroadcast_group_check

src/replica/replica_check.cpp:103

↓ 4 callersFunctionbuild_group

src/runtime/test/rpc.cpp:54

↓ 4 callersMethodcallback_function1

src/runtime/test/async_call.cpp:77

↓ 4 callersMethodcheck

src/meta/test/dummy_balancer.h:31

↓ 4 callersMethodcheckStatus

(negotiation_status status, negotiation_status expected_status)

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

↓ 4 callersMethodcheck_backup_on_remote

run in REPLICATION_LONG thread

src/replica/backup/cold_backup_context.cpp:186

↓ 4 callersMethodcheck_exist

src/replica/replica_context.cpp:141

↓ 4 callersMethodclose

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

↓ 4 callersMethodcloseSession

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

↓ 4 callersMethodcommit_log_blocks

src/replica/log_file.cpp:271

↓ 4 callersMethodcompareExchange

Atomically compare and exchange value by key. <p>- if the original value for the key is equal to the expected value, then update it with the desired

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

↓ 4 callersMethodconsume_token

src/utils/token_bucket_throttling_controller.cpp:36

↓ 4 callersFunctionconvert_to_ratio

src/shell/commands/table_management.cpp:60

↓ 4 callersMethodcopy

src/runtime/rpc/rpc_message.cpp:206

↓ 4 callersMethodcopy_remote_files

src/nfs/nfs_node.cpp:71

↓ 4 callersMethodcrbegin

string_view::crbegin() Returns a const reverse iterator pointing to the last character at the end of the `string_view`, or `crend()` if the `string_v

src/utils/string_view.h:236

↓ 4 callersMethodcreateApp

Create A new pegasus app which is not stateless However the successful execution of the interface does not guarantee the fully healthy of every partit

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

↓ 4 callersFunctioncreate_mock_replica

src/replica/test/mock_utils.h:234

↓ 4 callersFunctioncreate_put_request

src/server/test/message_utils.h:41

↓ 4 callersMethoddel_app_envs

src/meta/server_state.cpp:2799

↓ 4 callersMethoddequeue

src/utils/priority_queue.h:69

↓ 4 callersMethoddequeue_with_timeout

src/utils/priority_queue.h:136

↓ 4 callersMethoddistance

src/geo/lib/geo_client.cpp:945

↓ 4 callersFunctiondsn_config_get_all_keys

src/utils/config_api.cpp:89

↓ 4 callersMethoddump_from_remote_storage

src/meta/server_state.cpp:371

↓ 4 callersMethodduplicate_checkpoint

ThreadPool: THREAD_POOL_REPLICATION_LONG

src/replica/duplication/replica_follower.cpp:84

↓ 4 callersFunctionduplication_fail_mode_to_string

src/common/duplication_common.cpp:59

↓ 4 callersMethodduration_time

src/server/range_read_limiter.h:88

↓ 4 callersFunctionencode_error_as_json

src/utils/metrics.cpp:257

↓ 4 callersMethodexceed_limit

src/server/range_read_limiter.h:86

↓ 4 callersMethodexec

src/runtime/task/task.cpp:474

↓ 4 callersFunctionfake_rpc_call

src/meta/test/meta_service_test_app.h:157

↓ 4 callersMethodfetch

src/server/pegasus_scan_context.h:122

↓ 4 callersFunctionfilterStringWithPrefix

filterStringWithPrefix returns strings with the same prefix. This function is commonly used for the auto-completion of commands.

admin-cli/cmd/utils.go:26

↓ 4 callersMethodfind_from_serving

src/meta/meta_data.cpp:437

↓ 4 callersFunctionfinish

src/failure_detector/test/failure_detector.cpp:354

↓ 4 callersFunctionflip_map

src/utils/utils.h:112

↓ 4 callersMethodflush

src/utils/simple_logger.cpp:145

↓ 4 callersFunctionfrom_blob_to_received_msg

src/runtime/message_utils.h:51

↓ 4 callersFunctionfrom_blob_to_thrift

src/runtime/message_utils.h:74

↓ 4 callersMethodgarbage_collection

src/replica/mutation_log.cpp:1278

↓ 4 callersFunctiongenerate_balancer_request

src/meta/load_balance_policy.cpp:126

↓ 4 callersFunctiongenerate_node_mapper

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

↓ 4 callersFunctiongenerate_random_string

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

↓ 4 callersMethodget

go-client/pegalog/logger.go:73

↓ 4 callersMethodgetActualValue

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

↓ 4 callersMethodgetAsyncWorkers

The number of background worker threads. Internally it is the number of Netty NIO threads for handling RPC events between client and Replica Servers.

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

↓ 4 callersMethodgetEventLoopGroupInstance

(int threadsCount)

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

↓ 4 callersMethodgetMetaList

java-client/src/main/java/org/apache/pegasus/client/PegasusClient.java:108

↓ 4 callersMethodgetMetaServers

The list of meta server addresses, separated by commas. @return the list of meta server addresses.

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

↓ 4 callersMethodgetPartition

(partitionHash uint64)

go-client/pegasus/table_connector.go:670

↓ 4 callersMethodgetProtocol

get the authentiation protocol supported

java-client/src/main/java/org/apache/pegasus/security/Credential.java:41

↓ 4 callersMethodget_all_sections

src/utils/configuration.cpp:266

↓ 4 callersMethodget_app_id

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

↓ 4 callersFunctionget_app_metadata_file

src/common/backup_common.cpp:74

↓ 4 callersMethodget_bulk_loader

src/replica/replica.h:268

↓ 4 callersMethodget_cluster_name

src/client_lib/pegasus_client_impl.cpp:78

↓ 4 callersFunctionget_current_chkpt_file

src/common/backup_common.cpp:92

↓ 4 callersFunctionget_help_handler

src/http/builtin_http_calls.cpp:34

↓ 4 callersMethodget_last_flushed_decree

src/server/meta_store.cpp:47

↓ 4 callersMethodget_lockdir_nodes

src/zookeeper/lock_struct.cpp:515

↓ 4 callersMethodget_op_status

src/meta/test/meta_bulk_load_service_test.cpp:496

↓ 4 callersMethodget_partition_guardian

src/meta/meta_service.h:154

↓ 4 callersMethodget_partition_index

src/client/partition_resolver_simple.cpp:451

↓ 4 callersMethodget_peer_addr

python-client/pypegasus/pgclient.py:68

↓ 4 callersMethodget_request

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

↓ 4 callersMethodget_result

src/meta/meta_state_service_zookeeper.cpp:141

↓ 4 callersFunctionget_short_status

src/shell/commands/bulk_load.cpp:248

↓ 4 callersMethodget_size

src/block_service/local/local_service.cpp:271

↓ 4 callersFunctionget_skew

src/meta/cluster_balance_policy.cpp:67

↓ 4 callersMethodget_split_manager

Partition Split

src/replica/replica.h:279

↓ 4 callersMethodget_value<double>

src/utils/configuration.h:132

↓ 4 callersMethodhandleWriteLimiterException

(DefaultPromise promise, String message)

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

↓ 4 callersMethodhandle_local_failure

src/replica/replica_failover.cpp:55

↓ 4 callersFunctionhas_ext

src/http/pprof_http_service.cpp:70

↓ 4 callersMethodhas_key

src/utils/configuration.cpp:455

↓ 4 callersFunctionhas_tag

src/utils/flags.cpp:392

↓ 4 callersFunctionhost_name_resolve

src/client/replication_ddl_client.cpp:512

↓ 4 callersFunctionhttp_status_code_to_string

src/http/http_server.cpp:61

↓ 4 callersMethodinitialize

src/replica/replica_stub.cpp:577

↓ 4 callersMethodinner_read

src/utils/binary_reader.cpp:99

↓ 4 callersMethodis_cleaned

src/replica/replica_context.cpp:87

↓ 4 callersMethodis_in_progress

src/meta/backup_engine.cpp:378

↓ 4 callersMethodlast_durable_decree

src/replica/duplication/test/replica_duplicator_test.cpp:67

↓ 4 callersFunctionlast_write_time

src/utils/filesystem.cpp:642

↓ 4 callersFunctionlinenoiseEditHistoryNext

src/shell/linenoise/linenoise.c:700

↓ 4 callersFunctionlinenoiseEditMoveEnd

Move cursor to the end of the line. */

src/shell/linenoise/linenoise.c:689

↓ 4 callersFunctionlistSortKeysFrom

(t *testing.T, tb TableConnector, hashKey []byte, startSortKey, stopSortKey []byte, opts *ScannerOptions)

go-client/pegasus/scan_test.go:154

← previous next →1,001–1,100 of 8,667, ranked by callers