Code
Hub
Workspaces
Following
Trending
Connect
MCP
copy
Create free account
hub
/
github.com/apache/incubator-pegasus
/ functions
Functions
8,667 in github.com/apache/incubator-pegasus
⨍
Functions
8,667
◇
Types & classes
2,204
↓ 18 callers
Method
assign_group
src/runtime/rpc/rpc_address.cpp:156
↓ 18 callers
Method
buffer
src/runtime/rpc/message_parser.h:69
↓ 18 callers
Method
generateKey
(byte[] hashKey, byte[] sortKey)
java-client/src/main/java/org/apache/pegasus/client/PegasusClient.java:113
↓ 18 callers
Method
get_mutation_by_decree
src/replica/mutation_cache.cpp:148
↓ 18 callers
Function
init
src/runtime/security/init.cpp:63
↓ 18 callers
Method
length
()
java-client/src/main/java/org/apache/pegasus/rpc/async/TByteBufTransport.java:52
↓ 18 callers
Method
metaServers
The list of meta server addresses, separated by commas, See {@link #DEFAULT_META_SERVERS}. @param metaServers must not be {@literal null} or empty. @
java-client/src/main/java/org/apache/pegasus/client/ClientOptions.java:281
↓ 18 callers
Method
read
src/utils/blob.h:197
↓ 18 callers
Function
refreshLine
Calls the two low level functions refreshSingleLine() or * refreshMultiLine() according to the selected mode. */
src/shell/linenoise/linenoise.c:628
↓ 18 callers
Method
reset
src/runtime/rpc/rpc_host_port.cpp:89
↓ 18 callers
Method
when_connected
src/failure_detector/test/failure_detector.cpp:121
↓ 17 callers
Method
TCPAddr
TCPAddr returns the tcp address of the node
admin-cli/util/pegasus_node.go:49
↓ 17 callers
Function
abAppend
src/shell/linenoise/linenoise.c:461
↓ 17 callers
Method
addr
src/meta/meta_data.h:427
↓ 17 callers
Method
create_file
src/block_service/test/block_service_mock.h:175
↓ 17 callers
Method
disk_migrator
Disk migrator
src/replica/replica.h:284
↓ 17 callers
Method
get_size
src/block_service/test/block_service_mock.h:42
↓ 17 callers
Method
mark_read
called after read to mark data occupied
src/runtime/rpc/message_parser.h:57
↓ 17 callers
Function
new_proposal_action
src/meta/greedy_load_balancer.h:100
↓ 17 callers
Function
pegasus_extract_user_data
Extracts user value from a raw rocksdb value. In order to avoid data copy, the ownership of `raw_value` will be transferred into `user_data`. \param u
src/base/pegasus_value_schema.h:68
↓ 17 callers
Method
read_buffer_ptr
-------------------- msg reader --------------------
src/runtime/rpc/message_parser.cpp:148
↓ 17 callers
Method
read_u32
src/utils/endians.h:117
↓ 17 callers
Method
replica_dir
src/common/fs_manager.cpp:104
↓ 17 callers
Method
sortkey_count
src/client_lib/pegasus_client_impl.cpp:582
↓ 17 callers
Method
unlock
src/runtime/zlocks.cpp:109
↓ 17 callers
Method
update_progress
src/replica/duplication/replica_duplicator.cpp:201
↓ 17 callers
Function
wrapHintIntoError
Some responses have not only error-code but also a string-type "hint" that can tells the error details. This function wraps the "hint" into error.
admin-cli/client/meta.go:144
↓ 16 callers
Method
CombinedAddr
CombinedAddr returns a string combining with tcp address and hostname.
admin-cli/util/pegasus_node.go:54
↓ 16 callers
Method
asyncOperate
(client_operator op, ClientOPCallback callback, int timeoutMs)
java-client/src/main/java/org/apache/pegasus/rpc/Table.java:66
↓ 16 callers
Function
buf2uint32
src/utils/string_conv.h:117
↓ 16 callers
Method
cleanup
src/replica/replica_context.cpp:51
↓ 16 callers
Method
clear
clear the real perf-counter object. call this function if you want free the counter before the wrapper's destructor is called
src/perf_counter/perf_counter_wrapper.h:70
↓ 16 callers
Function
collect_replica
src/meta/meta_data.cpp:181
↓ 16 callers
Function
create_file
src/utils/filesystem.cpp:498
↓ 16 callers
Method
create_response
src/runtime/rpc/rpc_message.cpp:339
↓ 16 callers
Function
generate_node_list
Generates `size` of node addresses, each with port value in range [start_port, start_port + size]
src/meta/test/misc/misc.h:70
↓ 16 callers
Method
handleReplicaException
( Request request, DefaultPromise promise, client_operator op, Table table, int timeout)
java-client/src/main/java/org/apache/pegasus/client/PegasusTable.java:2212
↓ 16 callers
Method
hash
(byte[] key)
java-client/src/main/java/org/apache/pegasus/rpc/KeyHasher.java:27
↓ 16 callers
Method
ip
src/runtime/rpc/rpc_address.h:130
↓ 16 callers
Method
is_invalid
src/runtime/rpc/rpc_host_port.h:65
↓ 16 callers
Function
move_message_to_blob
Move the content inside message `m` into a blob.
src/runtime/message_utils.h:34
↓ 16 callers
Method
name
()
java-client/src/main/java/org/apache/pegasus/rpc/async/ReplicaSession.java:170
↓ 16 callers
Function
path_exists
src/utils/filesystem.cpp:204
↓ 16 callers
Method
pop
pop one request from this queue. return nullptr if no valid request found.
src/nfs/nfs_client_impl.h:234
↓ 16 callers
Function
random32
src/meta/test/misc/misc.cpp:55
↓ 16 callers
Function
sdscatlen
Append the specified binary-safe string pointed by 't' of 'len' bytes to the * end of the specified sds string 's'. * * After the call, the passed
src/shell/sds/sds.c:386
↓ 16 callers
Method
set_app_envs
src/meta/server_state.cpp:2737
↓ 16 callers
Method
to_string
src/replica/duplication/replica_duplicator.cpp:128
↓ 15 callers
Method
Render
Render template output
admin-cli/tabular/template.go:127
↓ 15 callers
Method
add
src/meta/meta_bulk_load_ingestion_context.cpp:110
↓ 15 callers
Method
append
src/replica/test/mock_utils.h:443
↓ 15 callers
Function
change_dup_status
src/shell/commands/duplication.cpp:208
↓ 15 callers
Method
delay_milliseconds
src/runtime/task/task.h:229
↓ 15 callers
Method
field
src/utils/string_splitter.h:156
↓ 15 callers
Method
fromString
(String ipPort)
java-client/src/main/java/org/apache/pegasus/base/rpc_address.java:129
↓ 15 callers
Method
getValues
()
java-client/src/main/java/org/apache/pegasus/client/PegasusTableInterface.java:201
↓ 15 callers
Method
get_integer_value
src/perf_counter/perf_counter_atomic.h:196
↓ 15 callers
Method
get_pidx
()
java-client/src/main/java/org/apache/pegasus/base/gpid.java:114
↓ 15 callers
Method
get_port
()
java-client/src/main/java/org/apache/pegasus/base/rpc_address.java:124
↓ 15 callers
Method
get_scanner
src/client_lib/pegasus_client_impl.cpp:1147
↓ 15 callers
Method
max_decree
src/replica/mutation_log.cpp:858
↓ 15 callers
Method
prototype
src/utils/metrics.h:669
↓ 15 callers
Method
rend
string_view::rend() Returns a reverse iterator pointing just before the first character at the beginning of the `string_view`. This pointer acts as a
src/utils/string_view.h:230
↓ 15 callers
Method
reset
src/utils/long_adder_bench/long_adder_bench.cpp:47
↓ 15 callers
Method
reset
src/runtime/zlocks.cpp:210
↓ 15 callers
Method
set_app_id
src/common/gpid.h:61
↓ 15 callers
Method
set_delay
src/runtime/task/task.h:221
↓ 14 callers
Method
add
src/replica/duplication/mutation_batch.cpp:103
↓ 14 callers
Method
assign_ipv4
src/runtime/rpc/rpc_address.h:88
↓ 14 callers
Method
consume
* Attempts to consume some number of tokens. Tokens are first added to the * bucket based on the time elapsed since the last attempt to consume t
src/utils/TokenBucket.h:424
↓ 14 callers
Method
count
src/utils/priority_queue.h:84
↓ 14 callers
Function
duplication_status_to_string
extern*/
src/common/duplication_common.cpp:50
↓ 14 callers
Method
get_children
src/meta/meta_state_service_utils.cpp:103
↓ 14 callers
Method
get_global_counter
src/perf_counter/perf_counters.cpp:189
↓ 14 callers
Method
get_pidx
(self)
python-client/pypegasus/base/ttypes.py:343
↓ 14 callers
Method
get_response
()
java-client/src/main/java/org/apache/pegasus/operator/rrdb_get_operator.java:56
↓ 14 callers
Method
get_transferred_size
src/aio/aio_task.h:101
↓ 14 callers
Method
mutations
src/replica/log_block.h:113
↓ 14 callers
Function
parse_filter_type
src/shell/command_helper.h:227
↓ 14 callers
Method
pop_front
src/meta/meta_data.cpp:279
↓ 14 callers
Method
read_pod
src/utils/binary_reader.h:97
↓ 14 callers
Method
remove_counter
src/perf_counter/perf_counters.cpp:225
↓ 14 callers
Function
sdsnew
Create a new sds string starting from a null terminated C string. */
src/shell/sds/sds.c:147
↓ 14 callers
Method
served_as
src/meta/meta_data.cpp:699
↓ 14 callers
Function
spin_wait_condition
src/failure_detector/test/failure_detector.cpp:262
↓ 14 callers
Method
visit
src/zookeeper/zookeeper_session.cpp:226
↓ 14 callers
Method
wait
src/runtime/zlocks.cpp:180
↓ 14 callers
Method
write
(self, oprot)
python-client/pypegasus/base/ttypes.py:42
↓ 13 callers
Method
Next
Grabs the next entry.
go-client/pegasus/scanner.go:55
↓ 13 callers
Method
TTL
Returns ttl(time-to-live) in seconds: -1 if ttl is not set; -2 if entry doesn't exist. `hashKey` : CAN'T be nil or empty. `sortKey` : CAN'T be nil but
go-client/pegasus/table_connector.go:149
↓ 13 callers
Method
add_backup_history
src/meta/meta_backup_service.cpp:844
↓ 13 callers
Method
add_scan_cu
src/server/capacity_unit_calculator.cpp:220
↓ 13 callers
Method
async_set
src/geo/lib/geo_client.cpp:158
↓ 13 callers
Function
clear
src/failure_detector/test/failure_detector.cpp:333
↓ 13 callers
Method
clear
src/runtime/rpc/thrift_message_parser.h:43
↓ 13 callers
Method
create_app
src/meta/server_state.cpp:1115
↓ 13 callers
Method
drop_app
src/meta/server_state.cpp:1241
↓ 13 callers
Method
getMetaList
()
java-client/src/main/java/org/apache/pegasus/rpc/async/MetaSession.java:327
↓ 13 callers
Method
get_fs_manager
src/replica/replica_stub.h:271
↓ 13 callers
Method
get_response
()
java-client/src/main/java/org/apache/pegasus/operator/rrdb_check_and_set_operator.java:59
← previous
next →
301–400 of 8,667, ranked by callers