MCPcopy Create free account

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

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

↓ 2 callersFunctionprintPegasusRecord
printPegasusRecord prints bytes from pegasus in pretty and parsable form.
pegic/executor/context.go:112
↓ 2 callersFunctionprint_current_scan_state
src/shell/commands/data_operations.cpp:2714
↓ 2 callersFunctionprint_policy_entry
src/client/replication_ddl_client.cpp:1162
↓ 2 callersFunctionprint_set
make sure T support cout << T;
src/client/replication_ddl_client.cpp:1146
↓ 2 callersFunctionprivateMethodName
(methodName string)
go-client/generator/main.go:32
↓ 2 callersFunctionproposal_action_check_and_apply
src/meta/test/misc/misc.cpp:274
↓ 2 callersFunctionprovider_basic_test
src/meta/test/meta_state/meta_state_service.cpp:56
↓ 2 callersFunctionprovider_recursively_create_delete_test
src/meta/test/meta_state/meta_state_service.cpp:257
↓ 2 callersMethodput
(currentAction *Action)
admin-cli/executor/toolkits/nodesmigrator/action.go:39
↓ 2 callersMethodput
src/server/pegasus_scan_context.h:114
↓ 2 callersMethodquery_app_envs
src/server/pegasus_server_impl.cpp:2722
↓ 2 callersMethodquery_backup_policy
src/meta/meta_backup_service.cpp:1420
↓ 2 callersMethodquery_backup_status
src/meta/meta_backup_service.cpp:1711
↓ 2 callersMethodquery_bulk_load
src/client/replication_ddl_client.cpp:1634
↓ 2 callersMethodquery_duplication_handler
src/meta/meta_http_service.cpp:604
↓ 2 callersMethodqueue
src/runtime/task/task_worker.h:86
↓ 2 callersFunctionrand3Nodes
()
admin-cli/client/fake_cluster_test.go:62
↓ 2 callersMethodread
src/block_service/fds/fds_service.cpp:636
↓ 2 callersMethodread
src/block_service/local/local_service.cpp:374
↓ 2 callersMethodread
src/common/serialization_helper/thrift_helper.h:187
↓ 2 callersMethodread
(self, iprot)
python-client/pypegasus/base/ttypes.py:39
↓ 2 callersMethodread_backup_metadata
src/replica/backup/cold_backup_context.cpp:485
↓ 2 callersMethodread_buffer_capacity
get remaining buffer capacity
src/runtime/rpc/message_parser.h:54
↓ 2 callersMethodread_current_chkpt_file
src/replica/backup/cold_backup_context.cpp:260
↓ 2 callersFunctionread_file
src/utils/filesystem.cpp:793
↓ 2 callersMethodread_u8
src/utils/endians.h:113
↓ 2 callersMethodrecall_app
src/meta/server_state.cpp:1391
↓ 2 callersMethodreconfig
src/meta/partition_guardian.cpp:94
↓ 2 callersMethodrecover_from_max_replica_count_env
ThreadPool: THREAD_POOL_META_SERVER
src/meta/server_state.cpp:3804
↓ 2 callersFunctionrefreshShowHints
Helper of refreshSingleLine() and refreshMultiLine() to show hints * to the right of the prompt. */
src/shell/linenoise/linenoise.c:476
↓ 2 callersMethodrefresh_lock_cache
src/zookeeper/distributed_lock_service_zookeeper.cpp:253
↓ 2 callersMethodregister_child_on_meta
src/meta/meta_split_service.cpp:148
↓ 2 callersFunctionregister_component_provider
src/runtime/tool_api.h:168
↓ 2 callersMethodregister_master
src/failure_detector/failure_detector.cpp:123
↓ 2 callersFunctionregister_remote_command_rpc
src/remote_cmd/remote_command.cpp:60
↓ 2 callersMethodrelease
src/utils/synchronize.h:137
↓ 2 callersMethodrelease
src/runtime/serverlet.h:94
↓ 2 callersMethodremote_chkpt_dir_exist
src/replica/backup/cold_backup_context.cpp:323
↓ 2 callersMethodremove
src/common/fs_manager.cpp:118
↓ 2 callersMethodremove_from_serving
src/meta/meta_data.cpp:452
↓ 2 callersMethodremove_lock
src/zookeeper/lock_struct.cpp:133
↓ 2 callersMethodremove_replica_on_meta_server
src/replica/replica_stub.cpp:1617
↓ 2 callersFunctionreplicaNode
(addr *base.RPCAddress)
admin-cli/client/migrate_node.go:80
↓ 2 callersMethodreplica_name
src/replica/replica_base.h:50
↓ 2 callersMethodreplicas_count
src/common/fs_manager.cpp:86
↓ 2 callersMethodreply
src/runtime/rpc/rpc_engine.cpp:727
↓ 2 callersMethodreportMetrics
(final Channel channel)
java-client/src/main/java/org/apache/pegasus/metrics/MetricsReporter.java:178
↓ 2 callersMethodreset_all
src/meta/meta_bulk_load_ingestion_context.cpp:196
↓ 2 callersMethodreset_manual_compact_status
src/meta/meta_data.cpp:510
↓ 2 callersMethodresolve_address
src/runtime/rpc/dns_resolver.cpp:76
↓ 2 callersMethodresponse_client
src/replica/replica_stub.cpp:1690
↓ 2 callersMethodrestore_from_local_storage
src/meta/server_state.cpp:418
↓ 2 callersMethodrpc
src/runtime/service_engine.h:69
↓ 2 callersMethodrun
(client *executor.Client, table string, balanceFactor int, origin *MigratorNode, targets []*util.PegasusNode,
admin-cli/executor/toolkits/nodesmigrator/migrator.go:48
↓ 2 callersMethodrun
src/runtime/pipeline.h:284
↓ 2 callersMethodrun
()
java-client/src/main/java/org/apache/pegasus/rpc/async/ReplicaSession.java:377
↓ 2 callersMethodrun_basic_cases
src/utils/test/long_adder_test.cpp:84
↓ 2 callersFunctionrun_cmd
src/test/function_test/utils/utils.h:209
↓ 2 callersMethodrun_concurrent_cases
src/utils/test/long_adder_test.cpp:145
↓ 2 callersFunctionrun_increment
src/utils/test/metrics_test.cpp:469
↓ 2 callersFunctionrun_kinit
src/runtime/security/kinit_context.cpp:357
↓ 2 callersFunctionrun_nth_element
src/utils/test/nth_element_bench/nth_element_bench.cpp:56
↓ 2 callersFunctionscanfCommand
src/shell/args.h:29
↓ 2 callersMethodscheduleNextConnect
()
java-client/src/main/java/org/apache/pegasus/metrics/MetricsReporter.java:150
↓ 2 callersMethodscheduleNextReport
(final Channel channel)
java-client/src/main/java/org/apache/pegasus/metrics/MetricsReporter.java:164
↓ 2 callersFunctionsdsalloc
sdsalloc() = sdsavail() + sdslen() */
src/shell/sds/sds.h:183
↓ 2 callersFunctionsdscatfmt
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 callersFunctionsdscatsds
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 callersFunctionsdscpy
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 callersFunctionsdsll2str
src/shell/sds/sds.c:439
↓ 2 callersFunctionsdssetalloc
src/shell/sds/sds.h:200
↓ 2 callersFunctionsdssplitargs
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 callersMethodseek
(self, offset)
python-client/pypegasus/transport/protocol.py:70
↓ 2 callersMethodselectNextOriginNode
()
admin-cli/executor/toolkits/nodesmigrator/migrator.go:107
↓ 2 callersMethodselectNextTargetNode
(targets []*util.PegasusNode)
admin-cli/executor/toolkits/nodesmigrator/migrator.go:114
↓ 2 callersMethodsend
src/runtime/rpc/network.sim.cpp:104
↓ 2 callersFunctionsendQueryDiskInfoRequest
(client *Client, replicaServer string, tableName string)
admin-cli/executor/disk_info.go:63
↓ 2 callersMethodsend_beacon
src/failure_detector/failure_detector.cpp:569
↓ 2 callersMethodsend_data
(self, oprot, seqid)
python-client/pypegasus/operate/packet.py:106
↓ 2 callersMethodsend_request
src/meta/meta_service.h:187
↓ 2 callersMethodset
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 callersMethodsetAllFetched
(final boolean allFetched)
java-client/src/main/java/org/apache/pegasus/client/PegasusTableInterface.java:197
↓ 2 callersMethodsetCheckValueReturned
(final boolean checkValueReturned)
java-client/src/main/java/org/apache/pegasus/client/PegasusTableInterface.java:601
↓ 2 callersMethodsetCheckValueReturned
(final boolean checkValueReturned)
java-client/src/main/java/org/apache/pegasus/client/PegasusTableInterface.java:698
↓ 2 callersFunctionsetDatabase
set a bunch of data into Pegasus `allData` is a map of hashkey->sortkey->value
go-client/pegasus/scan_test.go:72
↓ 2 callersMethodsetMessageResponseFilter
(MessageResponseFilter filter)
java-client/src/main/java/org/apache/pegasus/rpc/async/ReplicaSession.java:98
↓ 2 callersMethodsetReady
(reader io.Reader, writer io.Writer)
go-client/rpc/rpc_conn.go:222
↓ 2 callersFunctionsetRequestByOption
(options *MultiGetOptions, request *rrdb.MultiGetRequest)
go-client/pegasus/table_connector.go:384
↓ 2 callersMethodsetSetSucceed
(final boolean setSucceed)
java-client/src/main/java/org/apache/pegasus/client/PegasusTableInterface.java:767
↓ 2 callersMethodsetTimeout
(int t)
java-client/src/main/java/org/apache/pegasus/rpc/async/ClusterManager.java:136
↓ 2 callersMethodsetValues
(final List<Pair<byte[], byte[]>> values)
java-client/src/main/java/org/apache/pegasus/client/PegasusTableInterface.java:205
↓ 2 callersMethodset_block_service
src/meta/backup_engine.cpp:92
↓ 2 callersMethodset_client_username
src/runtime/rpc/network.cpp:526
↓ 2 callersMethodset_error_code
src/runtime/task/task.h:220
↓ 2 callersMethodset_extension
src/utils/extensible_object.h:61
↓ 2 callersMethodset_id
src/replica/mutation.cpp:116
↓ 2 callersMethodset_inactive_state_transient
src/replica/replica_init.cpp:330
↓ 2 callersMethodset_ingestion_status
src/server/pegasus_server_impl.cpp:3479
↓ 2 callersMethodset_is_ingestion
src/replica/test/mock_utils.h:196
↓ 2 callersMethodset_is_sync_to_child
src/replica/mutation.h:169
← previousnext →1,901–2,000 of 8,667, ranked by callers