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
Method
initTableConfiguration
(query_cfg_response resp)
java-client/src/main/java/org/apache/pegasus/rpc/async/TableHandler.java:155
↓ 2 callers
Method
init_checkpoint
ThreadPool: THREAD_POOL_REPLICATION
src/replica/replica_chkpt.cpp:220
↓ 2 callers
Method
init_disk
src/meta/test/meta_bulk_load_ingestion_test.cpp:65
↓ 2 callers
Function
init_sasl
src/runtime/security/sasl_init.cpp:126
↓ 2 callers
Method
initialize
src/zookeeper/lock_struct.cpp:112
↓ 2 callers
Method
initialize_start
src/replica/replica_stub.cpp:852
↓ 2 callers
Method
inject_error
src/replica/replica_check.cpp:271
↓ 2 callers
Method
insert_before
insert me before existing link node o [p (this) o]
src/utils/link.h:128
↓ 2 callers
Method
install
src/runtime/tracer.cpp:299
↓ 2 callers
Function
is_directory_empty
src/utils/filesystem.cpp:779
↓ 2 callers
Method
is_duplication_follower
src/replica/replica.h:256
↓ 2 callers
Function
is_engine_ready
src/runtime/service_api_c.cpp:319
↓ 2 callers
Method
is_from_balancer
return the action in acts & whether the action is from balancer
src/meta/meta_data.h:127
↓ 2 callers
Function
is_hex_digit
Helper function for sdssplitargs() that returns non zero if 'c' * is a valid hex digit. */
src/shell/sds/sds.c:896
↓ 2 callers
Function
is_name_ignored
(name)
scripts/check_license.py:84
↓ 2 callers
Method
is_need_duplicate
src/replica/duplication/replica_follower.h:52
↓ 2 callers
Function
is_partition_config_equal
src/common/replication_other_types.h:73
↓ 2 callers
Function
is_path_ignored
(path)
scripts/check_license.py:72
↓ 2 callers
Method
is_stale
src/utils/metrics.cpp:189
↓ 2 callers
Function
is_trailing_space
src/utils/strings.cpp:152
↓ 2 callers
Method
is_under_backuping
src/meta/meta_backup_service.cpp:904
↓ 2 callers
Method
issueBackupMetas
(ctx context.Context)
go-client/session/meta_call.go:125
↓ 2 callers
Method
issueSingleMeta
issueSingleMeta returns false if we should try another meta
go-client/session/meta_call.go:109
↓ 2 callers
Function
json_decode_map
src/common/json_helper.h:459
↓ 2 callers
Function
json_decode_set
src/common/json_helper.h:475
↓ 2 callers
Function
json_encode_map
src/common/json_helper.h:446
↓ 2 callers
Function
kth_percentile_to_nth_index
src/utils/metrics.h:1026
↓ 2 callers
Method
last_prepared_decree
src/replica/replica.cpp:454
↓ 2 callers
Method
left_potential_secondary_ack_count
src/replica/mutation.h:97
↓ 2 callers
Method
less_primaries
src/meta/server_load_balancer.cpp:57
↓ 2 callers
Function
linenoiseBeep
Beep, used for completion when there is nothing to complete or when all * the choices were already shown. */
src/shell/linenoise/linenoise.c:328
↓ 2 callers
Function
linenoiseEditDelete
Delete the character at the right of the cursor without altering the cursor * position. Basically this is what happens with the "Delete" keyboard key
src/shell/linenoise/linenoise.c:724
↓ 2 callers
Function
linenoiseEditMoveLeft
Move cursor on the left. */
src/shell/linenoise/linenoise.c:665
↓ 2 callers
Function
linenoiseEditMoveRight
Move cursor on the right. */
src/shell/linenoise/linenoise.c:673
↓ 2 callers
Function
list_all_files
extern*/
src/replica/mutation_log_utils.cpp:53
↓ 2 callers
Method
lock
src/utils/hpc_locks/benaphore.h:69
↓ 2 callers
Method
login
()
java-client/src/main/java/org/apache/pegasus/security/KerberosProtocol.java:150
↓ 2 callers
Method
loop_op
(self)
python-client/tests/test_integration.py:132
↓ 2 callers
Function
marshall_thrift_binary
src/common/serialization_helper/thrift_helper.h:725
↓ 2 callers
Function
marshall_thrift_internal
src/common/serialization_helper/thrift_helper.h:692
↓ 2 callers
Method
marshalling
src/redis_protocol/proxy_lib/redis_parser.cpp:1309
↓ 2 callers
Method
max
static*/
src/utils/error_code.cpp:32
↓ 2 callers
Method
max_gced_decree
src/replica/mutation_log.cpp:877
↓ 2 callers
Function
mean_stddev
src/utils/math.cpp:30
↓ 2 callers
Method
metricsToJson
()
java-client/src/main/java/org/apache/pegasus/metrics/MetricsPool.java:92
↓ 2 callers
Method
multiDel
sync version of MultiDel, please refer to the async version {@link #asyncMultiDel(byte[], List, int)}
java-client/src/main/java/org/apache/pegasus/client/PegasusTableInterface.java:1202
↓ 2 callers
Method
multiGet
( byte[] hashKey, List<byte[]> sortKeys, int maxFetchCount, int maxFetchSize, int timeout)
java-client/src/main/java/org/apache/pegasus/client/PegasusTable.java:1297
↓ 2 callers
Method
multiGetSortKeys
Get multiple sort keys under the same hash key. @param tableName table name @param hashKey used to decide which partition to put this k-v, should not
java-client/src/main/java/org/apache/pegasus/client/PegasusClientInterface.java:297
↓ 2 callers
Method
name
()
java-client/src/main/java/org/apache/pegasus/operator/client_operator.java:101
↓ 2 callers
Method
net_delay_milliseconds
src/runtime/rpc/network.sim.cpp:197
↓ 2 callers
Function
newMetaCall
(lead int, metas []*metaSession, callFunc metaCallFunc)
go-client/session/meta_call.go:52
↓ 2 callers
Function
newPegasusScannerImpl
(table *pegasusTableConnector, gpidSlice []*base.Gpid, hashSlice []uint64, options *ScannerOptions, startKey
go-client/pegasus/scanner.go:95
↓ 2 callers
Function
newScanCommand
(c *grumble.Context)
pegic/interactive/cmd/scan.go:78
↓ 2 callers
Method
new_message_parser
src/runtime/rpc/network.cpp:562
↓ 2 callers
Method
newly_remove_primary
src/meta/server_load_balancer.cpp:103
↓ 2 callers
Method
next_app_id
util function
src/meta/server_state.h:306
↓ 2 callers
Function
no_registered_function_error_notice
src/runtime/rpc/serialization.h:38
↓ 2 callers
Function
node_to_address
src/replica/storage/simple_kv/test/common.cpp:106
↓ 2 callers
Method
notifyCallerAndDrop
(req *requestListener)
go-client/session/session.go:214
↓ 2 callers
Method
notify_replica_state_update
src/replica/replica_stub.cpp:2463
↓ 2 callers
Method
now_timestamp
src/server/pegasus_manual_compact_service.cpp:217
↓ 2 callers
Method
onAuthSucceed
()
java-client/src/main/java/org/apache/pegasus/rpc/async/ReplicaSession.java:390
↓ 2 callers
Method
onConnected
(ReplicaSession session)
java-client/src/main/java/org/apache/pegasus/rpc/interceptor/ReplicaSessionInterceptor.java:25
↓ 2 callers
Method
onRecvRpcResponse
(error_code err, scan_response response)
java-client/src/main/java/org/apache/pegasus/client/PegasusScanner.java:283
↓ 2 callers
Method
onRecvScanResponse
(response *rrdb.ScanResponse, err error)
go-client/pegasus/scanner.go:260
↓ 2 callers
Method
onSendMessage
(ReplicaSession session, final ReplicaSession.RequestEntry entry)
java-client/src/main/java/org/apache/pegasus/rpc/interceptor/ReplicaSessionInterceptor.java:29
↓ 2 callers
Method
on_backup_reply
src/meta/backup_engine.cpp:251
↓ 2 callers
Method
on_batched_write_requests
src/server/pegasus_server_impl.cpp:317
↓ 2 callers
Method
on_client_read
src/replica/replica.cpp:244
↓ 2 callers
Method
on_client_write
src/replica/replica_2pc.cpp:120
↓ 2 callers
Method
on_copy_mutation_reply
ThreadPool: THREAD_POOL_REPLICATION
src/replica/split/replica_split_manager.cpp:1343
↓ 2 callers
Method
on_disk_migrate
src/replica/replica_stub.cpp:1130
↓ 2 callers
Method
on_disk_stat
src/replica/replica_stub.cpp:2041
↓ 2 callers
Method
on_duplication_sync_reply
src/replica/duplication/duplication_sync_timer.cpp:89
↓ 2 callers
Method
on_meta_server_connected
src/replica/replica_stub.cpp:1445
↓ 2 callers
Method
on_query_bulk_load_status
src/meta/meta_service.cpp:1220
↓ 2 callers
Method
on_start_bulk_load
src/meta/meta_service.cpp:1189
↓ 2 callers
Method
on_state_change
src/replica/storage/simple_kv/test/case.cpp:1372
↓ 2 callers
Method
on_work_completed
called when the current operation is completed, which triggers further round of operations as returned
src/utils/work_queue.h:77
↓ 2 callers
Method
on_write
src/replica/backup/cold_backup_context.cpp:946
↓ 2 callers
Method
on_write_completed
src/aio/disk_engine.cpp:130
↓ 2 callers
Method
only_copy_primary
src/meta/load_balance_policy.h:295
↓ 2 callers
Method
open_new_internal
src/replica/replication_app_base.cpp:312
↓ 2 callers
Method
open_replica
src/replica/test/replica_disk_migrate_test.cpp:138
↓ 2 callers
Function
overwrite_file
src/replica/test/mutation_log_test.cpp:93
↓ 2 callers
Method
owner_delete_prepare
src/runtime/task/task_tracker.h:214
↓ 2 callers
Method
parent_handle_child_catch_up
ThreadPool: THREAD_POOL_REPLICATION
src/replica/split/replica_split_manager.cpp:621
↓ 2 callers
Method
parse_compression_types
src/server/pegasus_server_impl.cpp:2983
↓ 2 callers
Function
parse_kv_map
src/utils/strings.cpp:317
↓ 2 callers
Method
partition_count
src/meta/server_load_balancer.h:75
↓ 2 callers
Function
pegasus_update_expire_ts
Update expire_ts in rocksdb value with given version. The value schema must be in v0 or v1.
src/base/pegasus_value_schema.h:99
↓ 2 callers
Method
pop_one
src/utils/link.h:96
↓ 2 callers
Method
prepare_buffer_header
src/runtime/rpc/rpc_message.cpp:384
↓ 2 callers
Method
prepare_on_send
src/runtime/rpc/dsn_message_parser.cpp:111
↓ 2 callers
Method
prepare_thrift_header
(self, body_length)
python-client/pypegasus/operate/packet.py:77
↓ 2 callers
Method
prepare_ts_ms
src/replica/mutation.h:138
↓ 2 callers
Method
primary_address
src/runtime/service_app.h:100
↓ 2 callers
Method
primary_count
src/meta/server_load_balancer.h:71
↓ 2 callers
Method
primary_parent_handle_stop_split
ThreadPool: THREAD_POOL_REPLICATION
src/replica/split/replica_split_manager.cpp:1432
↓ 2 callers
Function
printNodesInfo
(client *Client, nodes map[string]*nodeInfoStruct)
admin-cli/executor/list_nodes.go:120
← previous
next →
1,801–1,900 of 8,667, ranked by callers