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

↓ 62 callersMethodbegin

string_view::begin() Returns an iterator pointing to the first character at the beginning of the `string_view`, or `end()` if the `string_view` is em

src/utils/string_view.h:197

↓ 61 callersMethodgetSingletonClient

Get the singleton client instance with default config path of "resource:///pegasus.properties". After used, should call PegasusClientFactory.closeSing

java-client/src/main/java/org/apache/pegasus/client/PegasusClientFactory.java:84

↓ 61 callersMethodget_count

src/utils/autoref_ptr.h:88

↓ 61 callersMethodremote_address

src/runtime/rpc/network.h:228

↓ 61 callersMethodset

(byte[] sortKey, byte[] value, int ttlSeconds)

java-client/src/main/java/org/apache/pegasus/client/Mutations.java:46

↓ 61 callersMethodto_string

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

↓ 60 callersMethodstatus

src/replica/replica.h:233

↓ 59 callersMethodcode

src/utils/errors.h:109

↓ 58 callersMethodPrintf

(format string, args ...interface{})

go-client/pegalog/logger.go:36

↓ 58 callersMethodput_partition

src/meta/meta_data.cpp:621

↓ 57 callersMethodreset

src/server/test/capacity_unit_calculator_test.cpp:88

↓ 56 callersMethodset

Set value. @param tableName TableHandler name @param hashKey used to decide which partition to put this k-v, if null or length == 0, means no has

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

↓ 55 callersMethodClose

go-client/pegasus/client.go:34

↓ 55 callersMethodport

src/runtime/rpc/rpc_host_port.h:63

↓ 54 callersMethodcontains

src/runtime/rpc/group_address.h:191

↓ 54 callersMethodgroup_address

src/runtime/rpc/rpc_address.h:136

↓ 54 callersFunctionmarshall

src/runtime/rpc/serialization.h:54

↓ 54 callersFunctionnext_u32

\returns, as an uint32_t, a non-negative pseudo-random number in [min, max].

src/utils/rand.h:46

↓ 53 callersMethodadd

src/utils/link.h:49

↓ 53 callersFunctionsafe_strerror

src/utils/safe_strerror_posix.cpp:109

↓ 52 callersMethodcreate_node

src/meta/meta_state_service_utils.cpp:56

↓ 52 callersMethodenqueue_with

src/runtime/task/task.h:394

↓ 51 callersMethodfd

src/failure_detector/test/failure_detector.cpp:218

↓ 51 callersMethodgetValue

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

↓ 51 callersMethodreset

src/meta/meta_backup_service.h:229

↓ 51 callersMethodstart_offset

start offset in the global space

src/replica/log_file.h:181

↓ 49 callersFunctioncreate_directory

src/utils/filesystem.cpp:437

↓ 48 callersMethodcount

src/runtime/rpc/group_address.h:197

↓ 48 callersFunctioncreate_app

src/shell/commands/table_management.cpp:666

↓ 48 callersFunctiondsn_exit

src/runtime/service_api_c.cpp:220

↓ 48 callersMethodonly_one_thread_access

src/utils/thread_access_checker.cpp:37

↓ 48 callersFunctionsetup

src/utils/fail_point.cpp:98

↓ 47 callersMethodput

src/replica/mutation_cache.cpp:69

↓ 46 callersFunctionteardown

src/utils/fail_point.cpp:100

↓ 45 callersMethodgetTable

(String tableName)

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

↓ 44 callersMethodcall

java-client/src/test/java/org/apache/pegasus/tools/Toollet.java:155

↓ 43 callersFunctionbuf2uint64

src/utils/string_conv.h:122

↓ 43 callersMethodcloseSingletonClient

Close the singleton client instance. @throws PException throws exception if any error occurs.

java-client/src/main/java/org/apache/pegasus/client/PegasusClientFactory.java:172

↓ 43 callersMethodinstantiate

src/utils/metrics.cpp:216

↓ 42 callersMethodcode

src/runtime/task/task.h:226

↓ 42 callersMethodget_meta_storage

src/meta/meta_service.h:149

↓ 42 callersMethodregister_command

src/utils/command_manager.cpp:41

↓ 41 callersFunctionsdslen

src/shell/sds/sds.h:90

↓ 40 callersMethodString

String returns name of the encoding.

pegic/executor/util/encoding.go:39

↓ 40 callersFunctionequals

src/utils/strings.cpp:51

↓ 40 callersMethodprogress

src/replica/duplication/replica_duplicator.h:105

↓ 40 callersMethodreset

src/replica/prepare_list.cpp:59

↓ 40 callersMethodto_string

src/runtime/task/task_code.cpp:122

↓ 39 callersFunctionbuf2int64

src/utils/string_conv.h:112

↓ 39 callersFunctionsds_to_string

src/shell/args.h:50

↓ 38 callersMethodexecute

Execute the hooks sequentially.

src/utils/join_point.h:102

↓ 38 callersMethodinit_global_counter

init global counter create counters globally.

src/perf_counter/perf_counter_wrapper.h:92

↓ 38 callersMethodok

Return a success status. This function is almost zero-cost since the returned object contains merely a null pointer.

src/utils/errors.h:90

↓ 37 callersMethodclear

src/server/hotkey_collector.cpp:360

↓ 37 callersMethodget_aio_context

The ownership of `aio_context` is held by `aio_task`.

src/aio/aio_task.h:104

↓ 37 callersFunctionopen

src/aio/file_io.cpp:40

↓ 37 callersMethodset_tracker

src/runtime/task/task.h:222

↓ 37 callersMethodwrite_pod

src/utils/binary_writer.h:102

↓ 36 callersMethodget_remote_storage

NOTE: prefer using mss::meta_storage instead.

src/meta/meta_service.h:148

↓ 36 callersMethodlast_durable_decree

src/replica/replica.cpp:452

↓ 35 callersMethodcall_op

src/client/partition_resolver.h:60

↓ 35 callersMethodindex

src/replica/log_file.h:183

↓ 35 callersMethodstatus

helper functions

src/replica/split/replica_split_manager.h:209

↓ 34 callersMethodclear

src/utils/blob.h:179

↓ 34 callersMethoddescription

src/utils/errors.h:100

↓ 34 callersFunctionfile_size

src/utils/filesystem.cpp:392

↓ 34 callersMethodopen

src/replica/mutation_log.cpp:519

↓ 34 callersMethodset_data

src/meta/meta_state_service_utils.cpp:87

↓ 34 callersMethodtracker

src/replica/split/replica_split_manager.h:212

↓ 34 callersFunctionwrite

src/aio/file_io.cpp:98

↓ 33 callersFunctiondsn_config_get_value_bool

src/utils/config_api.cpp:47

↓ 33 callersMethodget_buffer

src/utils/binary_writer.cpp:91

↓ 33 callersMethodoutput

src/utils/output_utils.cpp:97

↓ 33 callersFunctionupdate_flag

src/utils/flags.cpp:387

↓ 32 callersMethodget_app

src/meta/server_state.h:151

↓ 32 callersMethodget_gpid

src/replica/test/replica_test_base.h:88

↓ 32 callersFunctionrename_path

src/utils/filesystem.cpp:379

↓ 32 callersMethodset_invalid

src/runtime/rpc/rpc_address.cpp:166

↓ 31 callersMethodGetAddress

go-client/idl/base/rpc_address.go:68

↓ 31 callersMethodOpenTable

Open the specific pegasus table. If the table was opened before, it will reuse the previous connection to the table.

go-client/pegasus/client.go:38

↓ 31 callersFunctiondefer

src/utils/defer.h:67

↓ 31 callersFunctioniequals

src/utils/strings.cpp:63

↓ 31 callersMethodinitialize

src/meta/meta_options.cpp:78

↓ 31 callersMethodwrite

src/replica/storage/simple_kv/simple_kv.client.h:104

↓ 30 callersFunctionbuf2bool

src/utils/string_conv.h:127

↓ 30 callersMethodcallMeta

`callback` always accepts non-nil `resp`.

admin-cli/client/meta.go:158

↓ 30 callersFunctiondsn_run_config

src/runtime/service_api_c.cpp:214

↓ 30 callersMethodfinalize

src/test/function_test/throttle_test/test_throttle.cpp:125

↓ 30 callersFunctionsdsfree

Free an sds string. No operation is performed if 's' is NULL. */

src/shell/sds/sds.c:158

↓ 29 callersMethoddsn_request

src/runtime/rpc/rpc_holder.h:138

↓ 29 callersMethodduration_ms

src/replica/replica_context.h:225

↓ 29 callersFunctionenqueue_timer

src/runtime/task/async_calls.h:95

↓ 29 callersMethodincr

sync version of Incr, please refer to the async version {@link #asyncIncr(byte[], byte[], long, int, int)}

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

↓ 29 callersMethodnotify

src/utils/synchronize.h:99

↓ 29 callersFunctionread

src/aio/file_io.cpp:70

↓ 28 callersFunctioncall

src/runtime/rpc/rpc_holder.h:363

↓ 28 callersMethodempty

src/meta/test/balancer_simulator/balancer_simulator.cpp:72

↓ 28 callersFunctionnext_u64

\returns, as an uint64_t, a non-negative pseudo-random number in [0, n). If n == 0, it returns 0.

src/utils/rand.h:35

↓ 27 callersFunctionDEFINE_TASK_CODE_RPC

src/runtime/test/netprovider.cpp:79

↓ 27 callersMethodcall

(ctx context.Context, args RpcRequestArgs, rpcName string)

go-client/session/meta_session.go:40

← previous next →101–200 of 8,667, ranked by callers