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
↓ 2 callers
Function
printPegasusRecord
printPegasusRecord prints bytes from pegasus in pretty and parsable form.
pegic/executor/context.go:112
↓ 2 callers
Function
print_current_scan_state
src/shell/commands/data_operations.cpp:2714
↓ 2 callers
Function
print_policy_entry
src/client/replication_ddl_client.cpp:1162
↓ 2 callers
Function
print_set
make sure T support cout << T;
src/client/replication_ddl_client.cpp:1146
↓ 2 callers
Function
privateMethodName
(methodName string)
go-client/generator/main.go:32
↓ 2 callers
Function
proposal_action_check_and_apply
src/meta/test/misc/misc.cpp:274
↓ 2 callers
Function
provider_basic_test
src/meta/test/meta_state/meta_state_service.cpp:56
↓ 2 callers
Function
provider_recursively_create_delete_test
src/meta/test/meta_state/meta_state_service.cpp:257
↓ 2 callers
Method
put
(currentAction *Action)
admin-cli/executor/toolkits/nodesmigrator/action.go:39
↓ 2 callers
Method
put
src/server/pegasus_scan_context.h:114
↓ 2 callers
Method
query_app_envs
src/server/pegasus_server_impl.cpp:2722
↓ 2 callers
Method
query_backup_policy
src/meta/meta_backup_service.cpp:1420
↓ 2 callers
Method
query_backup_status
src/meta/meta_backup_service.cpp:1711
↓ 2 callers
Method
query_bulk_load
src/client/replication_ddl_client.cpp:1634
↓ 2 callers
Method
query_duplication_handler
src/meta/meta_http_service.cpp:604
↓ 2 callers
Method
queue
src/runtime/task/task_worker.h:86
↓ 2 callers
Function
rand3Nodes
()
admin-cli/client/fake_cluster_test.go:62
↓ 2 callers
Method
read
src/block_service/fds/fds_service.cpp:636
↓ 2 callers
Method
read
src/block_service/local/local_service.cpp:374
↓ 2 callers
Method
read
src/common/serialization_helper/thrift_helper.h:187
↓ 2 callers
Method
read
(self, iprot)
python-client/pypegasus/base/ttypes.py:39
↓ 2 callers
Method
read_backup_metadata
src/replica/backup/cold_backup_context.cpp:485
↓ 2 callers
Method
read_buffer_capacity
get remaining buffer capacity
src/runtime/rpc/message_parser.h:54
↓ 2 callers
Method
read_current_chkpt_file
src/replica/backup/cold_backup_context.cpp:260
↓ 2 callers
Function
read_file
src/utils/filesystem.cpp:793
↓ 2 callers
Method
read_u8
src/utils/endians.h:113
↓ 2 callers
Method
recall_app
src/meta/server_state.cpp:1391
↓ 2 callers
Method
reconfig
src/meta/partition_guardian.cpp:94
↓ 2 callers
Method
recover_from_max_replica_count_env
ThreadPool: THREAD_POOL_META_SERVER
src/meta/server_state.cpp:3804
↓ 2 callers
Function
refreshShowHints
Helper of refreshSingleLine() and refreshMultiLine() to show hints * to the right of the prompt. */
src/shell/linenoise/linenoise.c:476
↓ 2 callers
Method
refresh_lock_cache
src/zookeeper/distributed_lock_service_zookeeper.cpp:253
↓ 2 callers
Method
register_child_on_meta
src/meta/meta_split_service.cpp:148
↓ 2 callers
Function
register_component_provider
src/runtime/tool_api.h:168
↓ 2 callers
Method
register_master
src/failure_detector/failure_detector.cpp:123
↓ 2 callers
Function
register_remote_command_rpc
src/remote_cmd/remote_command.cpp:60
↓ 2 callers
Method
release
src/utils/synchronize.h:137
↓ 2 callers
Method
release
src/runtime/serverlet.h:94
↓ 2 callers
Method
remote_chkpt_dir_exist
src/replica/backup/cold_backup_context.cpp:323
↓ 2 callers
Method
remove
src/common/fs_manager.cpp:118
↓ 2 callers
Method
remove_from_serving
src/meta/meta_data.cpp:452
↓ 2 callers
Method
remove_lock
src/zookeeper/lock_struct.cpp:133
↓ 2 callers
Method
remove_replica_on_meta_server
src/replica/replica_stub.cpp:1617
↓ 2 callers
Function
replicaNode
(addr *base.RPCAddress)
admin-cli/client/migrate_node.go:80
↓ 2 callers
Method
replica_name
src/replica/replica_base.h:50
↓ 2 callers
Method
replicas_count
src/common/fs_manager.cpp:86
↓ 2 callers
Method
reply
src/runtime/rpc/rpc_engine.cpp:727
↓ 2 callers
Method
reportMetrics
(final Channel channel)
java-client/src/main/java/org/apache/pegasus/metrics/MetricsReporter.java:178
↓ 2 callers
Method
reset_all
src/meta/meta_bulk_load_ingestion_context.cpp:196
↓ 2 callers
Method
reset_manual_compact_status
src/meta/meta_data.cpp:510
↓ 2 callers
Method
resolve_address
src/runtime/rpc/dns_resolver.cpp:76
↓ 2 callers
Method
response_client
src/replica/replica_stub.cpp:1690
↓ 2 callers
Method
restore_from_local_storage
src/meta/server_state.cpp:418
↓ 2 callers
Method
rpc
src/runtime/service_engine.h:69
↓ 2 callers
Method
run
(client *executor.Client, table string, balanceFactor int, origin *MigratorNode, targets []*util.PegasusNode,
admin-cli/executor/toolkits/nodesmigrator/migrator.go:48
↓ 2 callers
Method
run
src/runtime/pipeline.h:284
↓ 2 callers
Method
run
()
java-client/src/main/java/org/apache/pegasus/rpc/async/ReplicaSession.java:377
↓ 2 callers
Method
run_basic_cases
src/utils/test/long_adder_test.cpp:84
↓ 2 callers
Function
run_cmd
src/test/function_test/utils/utils.h:209
↓ 2 callers
Method
run_concurrent_cases
src/utils/test/long_adder_test.cpp:145
↓ 2 callers
Function
run_increment
src/utils/test/metrics_test.cpp:469
↓ 2 callers
Function
run_kinit
src/runtime/security/kinit_context.cpp:357
↓ 2 callers
Function
run_nth_element
src/utils/test/nth_element_bench/nth_element_bench.cpp:56
↓ 2 callers
Function
scanfCommand
src/shell/args.h:29
↓ 2 callers
Method
scheduleNextConnect
()
java-client/src/main/java/org/apache/pegasus/metrics/MetricsReporter.java:150
↓ 2 callers
Method
scheduleNextReport
(final Channel channel)
java-client/src/main/java/org/apache/pegasus/metrics/MetricsReporter.java:164
↓ 2 callers
Function
sdsalloc
sdsalloc() = sdsavail() + sdslen() */
src/shell/sds/sds.h:183
↓ 2 callers
Function
sdscatfmt
This function is similar to sdscatprintf, but much faster as it does * not rely on sprintf() family functions implemented by the libc that * are oft
src/shell/sds/sds.c:589
↓ 2 callers
Function
sdscatsds
Append the specified sds 't' to the existing sds 's'. * * After the call, the modified sds string is no longer valid and all the * references must
src/shell/sds/sds.c:409
↓ 2 callers
Function
sdscpy
Like sdscpylen() but 't' must be a null-termined string so that the length * of the string is obtained with strlen(). */
src/shell/sds/sds.c:428
↓ 2 callers
Function
sdsll2str
src/shell/sds/sds.c:439
↓ 2 callers
Function
sdssetalloc
src/shell/sds/sds.h:200
↓ 2 callers
Function
sdssplitargs
Split a line into arguments, where every argument can be in the * following programming-language REPL-alike form: * * foo bar "newline are supporte
src/shell/sds/sds.c:944
↓ 2 callers
Method
seek
(self, offset)
python-client/pypegasus/transport/protocol.py:70
↓ 2 callers
Method
selectNextOriginNode
()
admin-cli/executor/toolkits/nodesmigrator/migrator.go:107
↓ 2 callers
Method
selectNextTargetNode
(targets []*util.PegasusNode)
admin-cli/executor/toolkits/nodesmigrator/migrator.go:114
↓ 2 callers
Method
send
src/runtime/rpc/network.sim.cpp:104
↓ 2 callers
Function
sendQueryDiskInfoRequest
(client *Client, replicaServer string, tableName string)
admin-cli/executor/disk_info.go:63
↓ 2 callers
Method
send_beacon
src/failure_detector/failure_detector.cpp:569
↓ 2 callers
Method
send_data
(self, oprot, seqid)
python-client/pypegasus/operate/packet.py:106
↓ 2 callers
Method
send_request
src/meta/meta_service.h:187
↓ 2 callers
Method
set
Set value to be stored in <hash_key, sort_key>. :param hash_key: (bytes) which hash key used for this API. :param sort_key:
python-client/pypegasus/pgclient.py:761
↓ 2 callers
Method
setAllFetched
(final boolean allFetched)
java-client/src/main/java/org/apache/pegasus/client/PegasusTableInterface.java:197
↓ 2 callers
Method
setCheckValueReturned
(final boolean checkValueReturned)
java-client/src/main/java/org/apache/pegasus/client/PegasusTableInterface.java:601
↓ 2 callers
Method
setCheckValueReturned
(final boolean checkValueReturned)
java-client/src/main/java/org/apache/pegasus/client/PegasusTableInterface.java:698
↓ 2 callers
Function
setDatabase
set a bunch of data into Pegasus `allData` is a map of hashkey->sortkey->value
go-client/pegasus/scan_test.go:72
↓ 2 callers
Method
setMessageResponseFilter
(MessageResponseFilter filter)
java-client/src/main/java/org/apache/pegasus/rpc/async/ReplicaSession.java:98
↓ 2 callers
Method
setReady
(reader io.Reader, writer io.Writer)
go-client/rpc/rpc_conn.go:222
↓ 2 callers
Function
setRequestByOption
(options *MultiGetOptions, request *rrdb.MultiGetRequest)
go-client/pegasus/table_connector.go:384
↓ 2 callers
Method
setSetSucceed
(final boolean setSucceed)
java-client/src/main/java/org/apache/pegasus/client/PegasusTableInterface.java:767
↓ 2 callers
Method
setTimeout
(int t)
java-client/src/main/java/org/apache/pegasus/rpc/async/ClusterManager.java:136
↓ 2 callers
Method
setValues
(final List<Pair<byte[], byte[]>> values)
java-client/src/main/java/org/apache/pegasus/client/PegasusTableInterface.java:205
↓ 2 callers
Method
set_block_service
src/meta/backup_engine.cpp:92
↓ 2 callers
Method
set_client_username
src/runtime/rpc/network.cpp:526
↓ 2 callers
Method
set_error_code
src/runtime/task/task.h:220
↓ 2 callers
Method
set_extension
src/utils/extensible_object.h:61
↓ 2 callers
Method
set_id
src/replica/mutation.cpp:116
↓ 2 callers
Method
set_inactive_state_transient
src/replica/replica_init.cpp:330
↓ 2 callers
Method
set_ingestion_status
src/server/pegasus_server_impl.cpp:3479
↓ 2 callers
Method
set_is_ingestion
src/replica/test/mock_utils.h:196
↓ 2 callers
Method
set_is_sync_to_child
src/replica/mutation.h:169
← previous
next →
1,901–2,000 of 8,667, ranked by callers