MCPcopy Create free account

hub / github.com/apache/incubator-pegasus / functions

Functions8,667 in github.com/apache/incubator-pegasus

↓ 10 callersFunctionnext_double01
\returns, as a double, a pseudo-random number in [0.0,1.0].
src/utils/rand.h:59
↓ 10 callersMethodnode
src/runtime/task/task.h:231
↓ 10 callersMethodon_event
src/replica/storage/simple_kv/test/case.cpp:1291
↓ 10 callersFunctionpipe_execute
src/utils/process_utils.cpp:45
↓ 10 callersMethodprepare
src/replica/prepare_list.cpp:78
↓ 10 callersMethodqueryConfig
(ctx context.Context, tableName string)
go-client/session/meta_session.go:44
↓ 10 callersMethodremove
src/runtime/rpc/group_address.h:174
↓ 10 callersMethodremove_path
src/block_service/test/block_service_mock.h:199
↓ 10 callersMethodscanRange
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 callersFunctionsdsnewlen
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 callersMethodset_partition_index
src/common/gpid.h:63
↓ 10 callersMethodsortKeyCount
@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 callersMethodstart
src/runtime/test/test_utils.h:135
↓ 10 callersMethodstart
src/meta/test/main.cpp:82
↓ 10 callersMethodto_string
src/runtime/rpc/rpc_address.cpp:219
↓ 10 callersFunctionwrapRPCFailure
(resp rpcResponse, err error)
go-client/pegasus/op/utils.go:128
↓ 9 callersMethodCheckAndSet
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 callersMethodEncodeAll
encode string into a bytes
pegic/executor/util/encoding.go:33
↓ 9 callersMethodGetRawAddress
()
go-client/idl/base/rpc_address.go:72
↓ 9 callersMethodListAvailableApps
ListAvailableApps lists only available tables.
admin-cli/client/meta.go:63
↓ 9 callersMethodMultiGet
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 callersMethodMultiSetOpt
(ctx context.Context, hashKey []byte, sortKeys [][]byte, values [][]byte, ttl time.Duration)
go-client/pegasus/table_connector.go:139
↓ 9 callersFunctionNewRpcConn
Returns an idle connection.
go-client/rpc/rpc_conn.go:202
↓ 9 callersMethodTryConnect
This function is thread-safe.
go-client/rpc/rpc_conn.go:107
↓ 9 callersFunctionWrapError
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 callersMethodWrite
(oprot thrift.TProtocol)
go-client/session/codec.go:415
↓ 9 callersMethodadd_get_cu
src/server/capacity_unit_calculator.cpp:143
↓ 9 callersMethodanalyse_data
src/server/hotkey_collector.cpp:248
↓ 9 callersFunctionapply_update_request
apply request in request.type to request.config
src/meta/test/meta_partition_guardian_test.cpp:74
↓ 9 callersFunctioncall
src/runtime/task/async_calls.h:145
↓ 9 callersFunctioncall_remote_command
src/shell/command_helper.h:640
↓ 9 callersMethodcend
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 callersMethodcheck_data
(self)
python-client/tests/test_integration.py:140
↓ 9 callersMethodclear
src/zookeeper/lock_struct.cpp:120
↓ 9 callersMethodclear_file_exist
make file not exist
src/block_service/test/block_service_mock.h:119
↓ 9 callersMethodclose
Close the scanner. Should be called when scan completed.
java-client/src/main/java/org/apache/pegasus/client/PegasusScannerInterface.java:56
↓ 9 callersMethodconnect
src/runtime/rpc/network.sim.cpp:78
↓ 9 callersMethodcreate
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 callersMethodcreate
(String authProtocol, Properties config)
java-client/src/main/java/org/apache/pegasus/security/Credential.java:27
↓ 9 callersFunctioncreate_app_info
src/meta/test/state_sync_test.cpp:353
↓ 9 callersMethoddelete_node_recursively
src/meta/meta_state_service_utils.cpp:64
↓ 9 callersMethoddownload
src/block_service/test/block_service_mock.h:100
↓ 9 callersFunctiondrop_app
src/shell/commands/table_management.cpp:727
↓ 9 callersFunctiondsn_now_us
src/runtime/api_layer1.h:267
↓ 9 callersMethodenqueue
src/runtime/rpc/rpc_task.cpp:66
↓ 9 callersMethodforTest
()
java-client/src/main/java/org/apache/pegasus/rpc/InternalTableOptions.java:40
↓ 9 callersFunctiongenerate_hash_key_by_random
src/server/test/hotkey_collector_test.cpp:53
↓ 9 callersFunctiongenerate_string
src/test/bench_test/rand.cpp:38
↓ 9 callersMethodgetScanner
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 callersMethodgetStatus
()
java-client/src/main/java/org/apache/pegasus/security/Negotiation.java:186
↓ 9 callersMethodgetValueLength
(byte[] value)
java-client/src/main/java/org/apache/pegasus/client/PegasusTable.java:2308
↓ 9 callersMethodget_app_path
src/meta/server_state.h:313
↓ 9 callersMethodget_balancer
src/meta/meta_service.h:153
↓ 9 callersFunctionget_flag_str
extern*/
src/utils/flags.cpp:397
↓ 9 callersMethodget_id
src/utils/customizable_id.h:169
↓ 9 callersMethodget_or_create_block_filesystem
src/block_service/block_service_manager.cpp:69
↓ 9 callersMethodget_response
()
java-client/src/main/java/org/apache/pegasus/operator/query_cfg_operator.java:59
↓ 9 callersMethodhandleReplicaError
(err error, replica *session.ReplicaSession)
go-client/pegasus/table_connector.go:694
↓ 9 callersFunctionhostname_from_ip_port
src/utils/utils.cpp:108
↓ 9 callersMethodisAllFetched
()
java-client/src/main/java/org/apache/pegasus/client/HashKeyData.java:56
↓ 9 callersMethodis_logged
src/replica/mutation.h:86
↓ 9 callersMethoditerate_snapshot
src/perf_counter/perf_counters.cpp:415
↓ 9 callersMethodlink
src/runtime/pipeline.h:178
↓ 9 callersMethodlock_read
src/meta/server_state.cpp:2694
↓ 9 callersMethodmin_decree
src/replica/mutation_cache.h:56
↓ 9 callersMethodmulti_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 callersMethodmulti_set
src/client_lib/pegasus_client_impl.cpp:153
↓ 9 callersMethodmutable_request
src/runtime/rpc/rpc_holder.h:120
↓ 9 callersFunctionnewFakeCluster
(num int)
admin-cli/client/fake_cluster_test.go:46
↓ 9 callersFunctionnewProposalAction
(target *util.PegasusNode, node *util.PegasusNode, cfgType admin.ConfigType)
admin-cli/client/meta.go:376
↓ 9 callersFunctionnew_proposal_action
src/shell/command_helper.h:1373
↓ 9 callersMethodon_expire
src/zookeeper/lock_struct.cpp:152
↓ 9 callersMethodon_ping
src/failure_detector/test/failure_detector.cpp:141
↓ 9 callersMethodparse_from_env
src/utils/throttling_controller.cpp:43
↓ 9 callersFunctionpath_exists_internal
npath need to be a normalized path
src/utils/filesystem.cpp:175
↓ 9 callersFunctionprint_usage
src/utils/test/nth_element_bench/nth_element_bench.cpp:38
↓ 9 callersMethodremove_partition
src/meta/test/meta_bulk_load_ingestion_test.cpp:270
↓ 9 callersMethodrun
src/replica/duplication/test/ship_mutation_test.cpp:45
↓ 9 callersMethodschedule
src/runtime/scheduler.cpp:245
↓ 9 callersFunctionsdssetlen
src/shell/sds/sds.h:133
↓ 9 callersMethodsession
src/zookeeper/distributed_lock_service_zookeeper.h:130
↓ 9 callersMethodset_logged
src/replica/mutation.h:118
↓ 9 callersMethodspin_wait_staging
src/meta/server_state.cpp:254
↓ 9 callersMethodstart_check
src/replica/backup/cold_backup_context.cpp:78
↓ 9 callersFunctionto_string
src/common/serialization_helper/thrift_helper.h:586
↓ 9 callersMethodtoggle_send_ping
src/failure_detector/test/failure_detector.cpp:120
↓ 9 callersFunctiontrim_string
src/utils/strings.cpp:377
↓ 9 callersMethodttl
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 callersFunctiontype_from_string
src/shell/command_utils.h:82
↓ 9 callersMethodwait_schedule
src/runtime/scheduler.cpp:229
↓ 9 callersMethodwrite
src/meta/meta_state_service_simple.h:249
↓ 8 callersMethodGetNode
GetNode returns the specified node if it exists.
admin-cli/util/pegasus_node.go:161
↓ 8 callersMethodGetReplica
Create a new session to the replica server if no existing one.
go-client/session/replica_session.go:202
↓ 8 callersMethodGetState
thread-safe
go-client/rpc/rpc_conn.go:93
↓ 8 callersMethodListNodes
()
admin-cli/client/meta.go:89
↓ 8 callersMethodMarshal
Marshal returns the wire format of v.
go-client/rpc/codec.go:27
↓ 8 callersMethodadd
src/runtime/rpc/group_address.h:120
↓ 8 callersFunctionadd_dup
src/shell/commands/duplication.cpp:49
↓ 8 callersMethodallowed
src/runtime/security/meta_access_controller.cpp:91
↓ 8 callersMethodalter_status
lock held
src/meta/duplication/duplication_info.cpp:88
← previousnext →501–600 of 8,667, ranked by callers