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
↓ 10 callers
Function
next_double01
\returns, as a double, a pseudo-random number in [0.0,1.0].
src/utils/rand.h:59
↓ 10 callers
Method
node
src/runtime/task/task.h:231
↓ 10 callers
Method
on_event
src/replica/storage/simple_kv/test/case.cpp:1291
↓ 10 callers
Function
pipe_execute
src/utils/process_utils.cpp:45
↓ 10 callers
Method
prepare
src/replica/prepare_list.cpp:78
↓ 10 callers
Method
queryConfig
(ctx context.Context, tableName string)
go-client/session/meta_session.go:44
↓ 10 callers
Method
remove
src/runtime/rpc/group_address.h:174
↓ 10 callers
Method
remove_path
src/block_service/test/block_service_mock.h:199
↓ 10 callers
Method
scanRange
get scan result for {startSortKey, stopSortKey} within hashKey @param hashKey used to decide which partition to put this k-v, @param startSortKey sta
java-client/src/main/java/org/apache/pegasus/client/PegasusTable.java:2175
↓ 10 callers
Function
sdsnewlen
Create a new sds string with the content specified by the 'init' pointer * and 'initlen'. * If NULL is used for 'init' the string is initialized wit
src/shell/sds/sds.c:84
↓ 10 callers
Method
set_partition_index
src/common/gpid.h:63
↓ 10 callers
Method
sortKeyCount
@param tableName TableHandler name @param hashKey used to decide which partition the key may exist. @return the count result for the hashKey @throws P
java-client/src/main/java/org/apache/pegasus/client/PegasusClientInterface.java:114
↓ 10 callers
Method
start
src/runtime/test/test_utils.h:135
↓ 10 callers
Method
start
src/meta/test/main.cpp:82
↓ 10 callers
Method
to_string
src/runtime/rpc/rpc_address.cpp:219
↓ 10 callers
Function
wrapRPCFailure
(resp rpcResponse, err error)
go-client/pegasus/op/utils.go:128
↓ 9 callers
Method
CheckAndSet
Atomically check and set value by key from the cluster. The value will be set if and only if check passed. The sort key for checking and setting can b
go-client/pegasus/table_connector.go:171
↓ 9 callers
Method
EncodeAll
encode string into a bytes
pegic/executor/util/encoding.go:33
↓ 9 callers
Method
GetRawAddress
()
go-client/idl/base/rpc_address.go:72
↓ 9 callers
Method
ListAvailableApps
ListAvailableApps lists only available tables.
admin-cli/client/meta.go:63
↓ 9 callers
Method
MultiGet
MultiGet/MultiGetOpt retrieves the multiple entries for `hashKey` + `sortKeys[i]` atomically in one operation. MultiGet is identical to MultiGetOpt ex
go-client/pegasus/table_connector.go:118
↓ 9 callers
Method
MultiSetOpt
(ctx context.Context, hashKey []byte, sortKeys [][]byte, values [][]byte, ttl time.Duration)
go-client/pegasus/table_connector.go:139
↓ 9 callers
Function
NewRpcConn
Returns an idle connection.
go-client/rpc/rpc_conn.go:202
↓ 9 callers
Method
TryConnect
This function is thread-safe.
go-client/rpc/rpc_conn.go:107
↓ 9 callers
Function
WrapError
WrapError wraps up the internal errors for ensuring that all types of errors returned by public interfaces are pegasus.PError.
go-client/pegasus/table_connector.go:329
↓ 9 callers
Method
Write
(oprot thrift.TProtocol)
go-client/session/codec.go:415
↓ 9 callers
Method
add_get_cu
src/server/capacity_unit_calculator.cpp:143
↓ 9 callers
Method
analyse_data
src/server/hotkey_collector.cpp:248
↓ 9 callers
Function
apply_update_request
apply request in request.type to request.config
src/meta/test/meta_partition_guardian_test.cpp:74
↓ 9 callers
Function
call
src/runtime/task/async_calls.h:145
↓ 9 callers
Function
call_remote_command
src/shell/command_helper.h:640
↓ 9 callers
Method
cend
string_view::cend() Returns a const iterator pointing just beyond the last character at the end of the `string_view`. This pointer acts as a placehol
src/utils/string_view.h:217
↓ 9 callers
Method
check_data
(self)
python-client/tests/test_integration.py:140
↓ 9 callers
Method
clear
src/zookeeper/lock_struct.cpp:120
↓ 9 callers
Method
clear_file_exist
make file not exist
src/block_service/test/block_service_mock.h:119
↓ 9 callers
Method
close
Close the scanner. Should be called when scan completed.
java-client/src/main/java/org/apache/pegasus/client/PegasusScannerInterface.java:56
↓ 9 callers
Method
connect
src/runtime/rpc/network.sim.cpp:78
↓ 9 callers
Method
create
Create a new instance of {@link ClientOptions} with default settings. @return a new instance of {@link ClientOptions} with default settings
java-client/src/main/java/org/apache/pegasus/client/ClientOptions.java:133
↓ 9 callers
Method
create
(String authProtocol, Properties config)
java-client/src/main/java/org/apache/pegasus/security/Credential.java:27
↓ 9 callers
Function
create_app_info
src/meta/test/state_sync_test.cpp:353
↓ 9 callers
Method
delete_node_recursively
src/meta/meta_state_service_utils.cpp:64
↓ 9 callers
Method
download
src/block_service/test/block_service_mock.h:100
↓ 9 callers
Function
drop_app
src/shell/commands/table_management.cpp:727
↓ 9 callers
Function
dsn_now_us
src/runtime/api_layer1.h:267
↓ 9 callers
Method
enqueue
src/runtime/rpc/rpc_task.cpp:66
↓ 9 callers
Method
forTest
()
java-client/src/main/java/org/apache/pegasus/rpc/InternalTableOptions.java:40
↓ 9 callers
Function
generate_hash_key_by_random
src/server/test/hotkey_collector_test.cpp:53
↓ 9 callers
Function
generate_string
src/test/bench_test/rand.cpp:38
↓ 9 callers
Method
getScanner
Get Scanner for {startSortKey, stopSortKey} within hashKey @param hashKey used to decide which partition to put this k-v, @param startSortKey start s
java-client/src/main/java/org/apache/pegasus/client/PegasusTableInterface.java:1339
↓ 9 callers
Method
getStatus
()
java-client/src/main/java/org/apache/pegasus/security/Negotiation.java:186
↓ 9 callers
Method
getValueLength
(byte[] value)
java-client/src/main/java/org/apache/pegasus/client/PegasusTable.java:2308
↓ 9 callers
Method
get_app_path
src/meta/server_state.h:313
↓ 9 callers
Method
get_balancer
src/meta/meta_service.h:153
↓ 9 callers
Function
get_flag_str
extern*/
src/utils/flags.cpp:397
↓ 9 callers
Method
get_id
src/utils/customizable_id.h:169
↓ 9 callers
Method
get_or_create_block_filesystem
src/block_service/block_service_manager.cpp:69
↓ 9 callers
Method
get_response
()
java-client/src/main/java/org/apache/pegasus/operator/query_cfg_operator.java:59
↓ 9 callers
Method
handleReplicaError
(err error, replica *session.ReplicaSession)
go-client/pegasus/table_connector.go:694
↓ 9 callers
Function
hostname_from_ip_port
src/utils/utils.cpp:108
↓ 9 callers
Method
isAllFetched
()
java-client/src/main/java/org/apache/pegasus/client/HashKeyData.java:56
↓ 9 callers
Method
is_logged
src/replica/mutation.h:86
↓ 9 callers
Method
iterate_snapshot
src/perf_counter/perf_counters.cpp:415
↓ 9 callers
Method
link
src/runtime/pipeline.h:178
↓ 9 callers
Method
lock_read
src/meta/server_state.cpp:2694
↓ 9 callers
Method
min_decree
src/replica/mutation_cache.h:56
↓ 9 callers
Method
multi_get
Get multiple values stored in <hash_key, sortkey> pairs. :param hash_key: (bytes) which hash key used for this API. :param s
python-client/pypegasus/pgclient.py:856
↓ 9 callers
Method
multi_set
src/client_lib/pegasus_client_impl.cpp:153
↓ 9 callers
Method
mutable_request
src/runtime/rpc/rpc_holder.h:120
↓ 9 callers
Function
newFakeCluster
(num int)
admin-cli/client/fake_cluster_test.go:46
↓ 9 callers
Function
newProposalAction
(target *util.PegasusNode, node *util.PegasusNode, cfgType admin.ConfigType)
admin-cli/client/meta.go:376
↓ 9 callers
Function
new_proposal_action
src/shell/command_helper.h:1373
↓ 9 callers
Method
on_expire
src/zookeeper/lock_struct.cpp:152
↓ 9 callers
Method
on_ping
src/failure_detector/test/failure_detector.cpp:141
↓ 9 callers
Method
parse_from_env
src/utils/throttling_controller.cpp:43
↓ 9 callers
Function
path_exists_internal
npath need to be a normalized path
src/utils/filesystem.cpp:175
↓ 9 callers
Function
print_usage
src/utils/test/nth_element_bench/nth_element_bench.cpp:38
↓ 9 callers
Method
remove_partition
src/meta/test/meta_bulk_load_ingestion_test.cpp:270
↓ 9 callers
Method
run
src/replica/duplication/test/ship_mutation_test.cpp:45
↓ 9 callers
Method
schedule
src/runtime/scheduler.cpp:245
↓ 9 callers
Function
sdssetlen
src/shell/sds/sds.h:133
↓ 9 callers
Method
session
src/zookeeper/distributed_lock_service_zookeeper.h:130
↓ 9 callers
Method
set_logged
src/replica/mutation.h:118
↓ 9 callers
Method
spin_wait_staging
src/meta/server_state.cpp:254
↓ 9 callers
Method
start_check
src/replica/backup/cold_backup_context.cpp:78
↓ 9 callers
Function
to_string
src/common/serialization_helper/thrift_helper.h:586
↓ 9 callers
Method
toggle_send_ping
src/failure_detector/test/failure_detector.cpp:120
↓ 9 callers
Function
trim_string
src/utils/strings.cpp:377
↓ 9 callers
Method
ttl
Get ttl time. @param tableName TableHandler name @param hashKey used to decide which partition to put this k-v, if null or length == 0, means no
java-client/src/main/java/org/apache/pegasus/client/PegasusClientInterface.java:548
↓ 9 callers
Function
type_from_string
src/shell/command_utils.h:82
↓ 9 callers
Method
wait_schedule
src/runtime/scheduler.cpp:229
↓ 9 callers
Method
write
src/meta/meta_state_service_simple.h:249
↓ 8 callers
Method
GetNode
GetNode returns the specified node if it exists.
admin-cli/util/pegasus_node.go:161
↓ 8 callers
Method
GetReplica
Create a new session to the replica server if no existing one.
go-client/session/replica_session.go:202
↓ 8 callers
Method
GetState
thread-safe
go-client/rpc/rpc_conn.go:93
↓ 8 callers
Method
ListNodes
()
admin-cli/client/meta.go:89
↓ 8 callers
Method
Marshal
Marshal returns the wire format of v.
go-client/rpc/codec.go:27
↓ 8 callers
Method
add
src/runtime/rpc/group_address.h:120
↓ 8 callers
Function
add_dup
src/shell/commands/duplication.cpp:49
↓ 8 callers
Method
allowed
src/runtime/security/meta_access_controller.cpp:91
↓ 8 callers
Method
alter_status
lock held
src/meta/duplication/duplication_info.cpp:88
← previous
next →
501–600 of 8,667, ranked by callers