MCPcopy Create free account

hub / github.com/apache/incubator-pegasus / functions

Functions8,667 in github.com/apache/incubator-pegasus

↓ 8 callersMethodappend_mutation
src/replica/log_block.cpp:40
↓ 8 callersMethodassertScanResult
( int startIndex, int stopIndex, boolean expectAllFetched, PegasusTable.ScanRangeResul
java-client/src/test/java/org/apache/pegasus/client/TestBasic.java:2766
↓ 8 callersMethodasyncGet
Get value for a specific (hashKey, sortKey) pair, async version @param hashKey used to decide which partition the key may exist if null or empty, mea
java-client/src/main/java/org/apache/pegasus/client/PegasusTableInterface.java:175
↓ 8 callersMethodasyncSend
( client_operator op, Runnable callbackFunc, long timeoutInMilliseconds, boolean isBac
java-client/src/main/java/org/apache/pegasus/rpc/async/ReplicaSession.java:102
↓ 8 callersMethodbody_size
src/runtime/rpc/rpc_message.h:215
↓ 8 callersFunctioncheck_output
src/utils/test/output_utils_test.cpp:130
↓ 8 callersFunctionchkpt_get_dir_name
src/server/pegasus_server_impl.cpp:126
↓ 8 callersMethodclear_up_write_batch
src/server/rocksdb_wrapper.cpp:212
↓ 8 callersFunctioncompare
src/test/function_test/utils/utils.h:133
↓ 8 callersFunctioncreate_fake_rpc_response
src/failure_detector/test/failure_detector.cpp:624
↓ 8 callersMethodcreate_replica_dir_if_necessary
src/common/fs_manager.cpp:444
↓ 8 callersFunctioncreate_rpc_response_task
src/runtime/task/async_calls.h:111
↓ 8 callersMethoddetect_hotkey
src/client/replication_ddl_client.cpp:1651
↓ 8 callersMethoddump
src/utils/configuration.cpp:390
↓ 8 callersMethodempty
src/nfs/nfs_client_impl.h:267
↓ 8 callersFunctionexecute
src/utils/test/metrics_test.cpp:412
↓ 8 callersMethodgetAddress
()
java-client/src/main/java/org/apache/pegasus/rpc/async/ReplicaSession.java:174
↓ 8 callersMethodgetAddressFromSession
(List<ReplicaSession> sessions)
java-client/src/test/java/org/apache/pegasus/rpc/async/MetaSessionTest.java:121
↓ 8 callersMethodgetInt
(Properties config, String key, int defaultValue)
java-client/src/main/java/org/apache/pegasus/util/PropertyUtils.java:34
↓ 8 callersMethodgetMetaSession
()
java-client/src/main/java/org/apache/pegasus/rpc/async/ClusterManager.java:94
↓ 8 callersMethodgetUnorderedScanners
Get Scanners for all data in database @param maxScannerCount how many scanner expected @param options scan options like batchSize @return scanners, c
java-client/src/main/java/org/apache/pegasus/client/PegasusTableInterface.java:1351
↓ 8 callersFunctionget_current_physical_time_ns
get current physical timestamp in ns
src/utils/time_utils.h:86
↓ 8 callersMethodget_dir_node
src/common/fs_manager.cpp:185
↓ 8 callersFunctionget_duplication_cluster_id
extern*/
src/common/duplication_common.cpp:128
↓ 8 callersFunctionget_last_component
src/utils/strings.cpp:115
↓ 8 callersMethodget_next
scan the next k-v pair for the scanner. :return: (tuple<tuple<hash_key, sort_key>, value> or None) all the sort_keys
python-client/pypegasus/pgclient.py:434
↓ 8 callersMethodget_partition_version
src/replica/split/replica_split_manager.h:63
↓ 8 callersMethodget_replica
src/replica/test/replica_disk_migrate_test.cpp:66
↓ 8 callersFunctionget_time
return time in us.
src/test/kill_test/data_verifier.cpp:75
↓ 8 callersMethodhandleQueryConfigResp
(resp *replication.QueryCfgResponse)
go-client/pegasus/table_connector.go:261
↓ 8 callersMethodid
src/replica/duplication/replica_duplicator.h:100
↓ 8 callersMethodincr
Atomically increment value. @param tableName the table name. @param hashKey the hash key to increment. @param sortKey the sort key to increment. @par
java-client/src/main/java/org/apache/pegasus/client/PegasusClientInterface.java:566
↓ 8 callersMethodincrement
src/utils/test/long_adder_test.cpp:205
↓ 8 callersMethodindex
src/runtime/task/task_queue.h:84
↓ 8 callersMethodinit_ordered_address_ids
src/meta/load_balance_policy.cpp:705
↓ 8 callersFunctioninitialize
src/shell/main.cpp:683
↓ 8 callersFunctioninitialize
src/test/pressure_test/main.cpp:227
↓ 8 callersMethodis_altering
This function should only be used for testing. Not thread-safe.
src/meta/duplication/duplication_info.h:184
↓ 8 callersMethodis_invalid_status
if this duplication is in valid status.
src/meta/duplication/duplication_info.h:101
↓ 8 callersFunctionis_member
src/common/replication_other_types.h:69
↓ 8 callersMethodlist_apps
src/meta/server_state.cpp:1444
↓ 8 callersMethodlock
src/runtime/task/task_engine.sim.cpp:145
↓ 8 callersFunctionmemmatch
This is significantly faster for case-sensitive matches with very few possible matches. See unit test for benchmarks.
src/utils/string_view.cpp:67
↓ 8 callersMethodmultiSet
Set multiple value under the same hash key. @param tableName table name @param hashKey used to decide which partition to put this k-v, should not be
java-client/src/main/java/org/apache/pegasus/client/PegasusClientInterface.java:368
↓ 8 callersMethodmultiSet
sync version of MultiSet, please refer to the async version {@link #asyncMultiSet(byte[], List, int, int)} and {@link #asyncMultiSet(byte[], List, int
java-client/src/main/java/org/apache/pegasus/client/PegasusTableInterface.java:1102
↓ 8 callersMethodnode_exist
src/meta/meta_state_service_simple.cpp:443
↓ 8 callersFunctionntoh
src/utils/endians.h:34
↓ 8 callersMethodpaused
src/runtime/pipeline.h:149
↓ 8 callersMethodpossible_leader
src/runtime/rpc/group_address.h:162
↓ 8 callersMethodprivate_log
src/replica/replica.h:243
↓ 8 callersFunctionremote_command_set_bool_flag
if args are empty, then return the old flag; otherwise set the proper "flag" according to args
src/utils/command_manager.h:106
↓ 8 callersMethodremove
src/utils/link.h:155
↓ 8 callersFunctionsdsHdrSize
src/shell/sds/sds.c:42
↓ 8 callersFunctionsdsMakeRoomFor
Enlarge the free space at the end of the sds string so that the caller * is sure that after calling this function can overwrite up to addlen * bytes
src/shell/sds/sds.c:197
↓ 8 callersFunctionsdsavail
src/shell/sds/sds.h:107
↓ 8 callersMethodsend
(negotiation_status status, blob msg)
java-client/src/main/java/org/apache/pegasus/security/Negotiation.java:56
↓ 8 callersMethodsend_message
src/runtime/rpc/network.cpp:279
↓ 8 callersMethodset_secondary_bulk_load_state
src/replica/test/mock_utils.h:186
↓ 8 callersMethodset_start_decree
src/replica/duplication/mutation_batch.cpp:133
↓ 8 callersMethodsplitting
src/meta/meta_data.h:385
↓ 8 callersMethodtotal_size
src/replica/mutation_log.cpp:914
↓ 8 callersMethodtryNotifyFailureWithSeqID
(int seqID, error_code.error_types errno, boolean isTimeoutTask)
java-client/src/main/java/org/apache/pegasus/rpc/async/ReplicaSession.java:300
↓ 8 callersMethodupload
src/block_service/test/block_service_mock.h:83
↓ 8 callersMethodwrite
src/server/rocksdb_wrapper.cpp:166
↓ 7 callersMethodClose
This function is thread-safe.
go-client/rpc/rpc_conn.go:142
↓ 7 callersMethodMustGetReplica
MustGetReplica returns a replica node even if it doens't exist before. User should assure the validity of the given info.
admin-cli/util/pegasus_node.go:148
↓ 7 callersMethodaddress
src/runtime/rpc/network.sim.h:93
↓ 7 callersMethodalter_progress
src/meta/duplication/duplication_info.cpp:123
↓ 7 callersMethodapp_mutation_2pc_min_replica_count
src/common/replication_common.cpp:157
↓ 7 callersFunctionapply
src/utils/absl/utility/utility.h:192
↓ 7 callersMethodasyncMultiGet
( byte[] hashKey, List<byte[]> sortKeys, int maxFetchCount, int maxFetchSize, bo
java-client/src/main/java/org/apache/pegasus/client/PegasusTable.java:241
↓ 7 callersMethodbuild
src/meta/load_balance_policy.h:182
↓ 7 callersFunctioncall_one_way_typed
src/runtime/task/async_calls.h:187
↓ 7 callersMethodcan_continue
src/meta/app_balance_policy.cpp:147
↓ 7 callersMethodcapture_raw_key
src/server/hotkey_collector.cpp:228
↓ 7 callersMethodcheck_all_partitions
src/meta/server_state.cpp:2473
↓ 7 callersFunctioncheck_and_put
src/test/function_test/utils/utils.h:88
↓ 7 callersMethodclear
src/failure_detector/test/failure_detector.cpp:126
↓ 7 callersMethodcommit
ordered commit
src/replica/prepare_list.cpp:150
↓ 7 callersMethodcommit
send and commit batched requests no-atomically, but terminate immediately if any error occurs. @param requests generic for request @throws PException
java-client/src/main/java/org/apache/pegasus/client/request/Batch.java:49
↓ 7 callersMethodcomputation
src/runtime/service_engine.h:70
↓ 7 callersFunctioncreate_aio_task
src/aio/file_io.h:66
↓ 7 callersMethodcreate_file
src/block_service/fds/fds_service.cpp:275
↓ 7 callersMethodcurrent_server_contact
------------------ inline implementation --------------------------------
src/failure_detector/failure_detector_multimaster.h:82
↓ 7 callersMethoddetach
src/zookeeper/zookeeper_session.cpp:195
↓ 7 callersMethoddownload_file
src/block_service/block_service_manager.cpp:135
↓ 7 callersMethodencode
src/utils/metrics.h:682
↓ 7 callersFunctionescape_sds_argv
src/shell/commands/data_operations.cpp:2624
↓ 7 callersMethodeval
src/utils/fail_point.cpp:159
↓ 7 callersMethodfail_mode
src/meta/duplication/duplication_info.h:98
↓ 7 callersMethodfile_exist
make file exist,
src/block_service/test/block_service_mock.h:113
↓ 7 callersFunctionfill_nodes
type: all | replica-server | meta-server
src/shell/command_helper.h:616
↓ 7 callersMethodfind_replica_dir
src/common/fs_manager.cpp:420
↓ 7 callersMethodflush
src/replica/test/mock_utils.h:454
↓ 7 callersMethodfrom
src/runtime/pipeline.h:211
↓ 7 callersMethodgetHash
(byte[] data)
java-client/src/main/java/org/apache/pegasus/rpc/Table.java:31
↓ 7 callersMethodget_all_keys
src/utils/configuration.cpp:274
↓ 7 callersMethodget_app
src/replica/replica.h:234
↓ 7 callersMethodget_ballot
src/replica/mutation.h:110
↓ 7 callersFunctionget_current_tool
src/runtime/service_api_c.cpp:321
← previousnext →601–700 of 8,667, ranked by callers