Functions — github.com/apache/incubator-pegasus

CodeHub MCPcopy Create free account

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

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

⨍ Functions 8,667◇ Types & classes 2,204

↓ 2 callersMethodbatch_abort

src/server/pegasus_write_service.cpp:310

↓ 2 callersFunctionbatch_execute_multi_set

src/shell/command_helper.h:293

↓ 2 callersMethodbatch_prepare

src/server/pegasus_write_service.cpp:259

↓ 2 callersMethodbefore

(ClientRequestRound clientRequestRound, TableHandler tableHandler)

java-client/src/main/java/org/apache/pegasus/rpc/interceptor/TableInterceptor.java:27

↓ 2 callersMethodbegin_close_replica

src/replica/replica_stub.cpp:2394

↓ 2 callersFunctionbuf2signed

src/utils/string_conv.h:37

↓ 2 callersMethodbuffer

src/utils/blob.h:115

↓ 2 callersMethodbuffer_ptr

src/utils/blob.h:117

↓ 2 callersMethodcall

(final ClientRequestRound round)

java-client/src/main/java/org/apache/pegasus/rpc/async/TableHandler.java:413

↓ 2 callersMethodcall_ip

src/runtime/rpc/rpc_engine.cpp:649

↓ 2 callersMethodcancel

src/runtime/rpc/network.cpp:311

↓ 2 callersMethodcancel_pending_lock

src/zookeeper/lock_struct.cpp:759

↓ 2 callersFunctioncas_is_check_operand_needed

src/base/idl_utils.h:38

↓ 2 callersFunctionchangeDiskCleanerInterval

(client *executor.Client, replicaServer string, cleanInterval string)

admin-cli/executor/toolkits/diskbalancer/migrator.go:63

↓ 2 callersMethodchange_target_bucket

src/server/hotkey_collector.cpp:379

↓ 2 callersMethodcheck

src/meta/greedy_load_balancer.cpp:214

↓ 2 callersMethodcheckAndMutate

sync version of CheckAndMutate, please refer to the async version {@link #asyncCheckAndMutate(byte[], byte[], CheckType, byte[], Mutations, CheckAndMu

java-client/src/main/java/org/apache/pegasus/client/PegasusTableInterface.java:1301

↓ 2 callersMethodcheckAndPut

( TreeMap<String, TreeMap<String, String>> data, String hashKey, String sortKey, String value)

java-client/src/test/java/org/apache/pegasus/client/PegasusScannerTest.java:500

↓ 2 callersMethodcheckIfNoPrimary

(client *executor.Client)

admin-cli/executor/toolkits/nodesmigrator/nodes.go:76

↓ 2 callersMethodcheckMultiValueCount

(byte[] hashKey, int count)

java-client/src/main/java/org/apache/pegasus/tools/WriteLimiter.java:162

↓ 2 callersMethodcheckMultiValueSize

(byte[] hashKey, int length)

java-client/src/main/java/org/apache/pegasus/tools/WriteLimiter.java:178

↓ 2 callersFunctioncheck_arena_marks

src/utils/test/je_ctl_test.cpp:53

↓ 2 callersFunctioncheck_base_stats_marks_with_end

src/utils/test/je_ctl_test.cpp:39

↓ 2 callersFunctioncheck_configs_marks

src/utils/test/je_ctl_test.cpp:45

↓ 2 callersFunctioncheck_dir_rw

src/utils/filesystem.cpp:925

↓ 2 callersFunctioncheck_in_cluster

src/shell/main.cpp:657

↓ 2 callersFunctioncheck_log_files_continuity

src/replica/mutation_log_utils.h:74

↓ 2 callersFunctioncheck_pegasus_key_hash

src/base/pegasus_key_schema.h:176

↓ 2 callersMethodcheck_possible_work

src/replica/mutation.cpp:420

↓ 2 callersFunctioncheck_ranger_resource_policy_allowed

src/runtime/ranger/ranger_resource_policy.cpp:97

↓ 2 callersFunctioncheck_wait_safety

src/runtime/zlocks.cpp:54

↓ 2 callersMethodclearDatabase

java-client/src/test/java/org/apache/pegasus/client/PegasusScannerTest.java:462

↓ 2 callersMethodcommit

send and commit batched requests no-atomically, but terminate immediately if any error occurs. @param requests generic for request @param responses g

java-client/src/main/java/org/apache/pegasus/client/request/BatchWithResponse.java:52

↓ 2 callersMethodcommit_buffer

write buffer for rpc_write_stream is allocated from a per-thread pool, and it is expected that the per-thread pool cannot allocated two outstanding bu

src/runtime/rpc/rpc_stream.h:99

↓ 2 callersMethodcommit_log_block

src/replica/log_file.cpp:261

↓ 2 callersMethodcompare

( TreeMap<String, TreeMap<String, String>> data, TreeMap<String, TreeMap<String, String>> base)

java-client/src/test/java/org/apache/pegasus/client/PegasusScannerTest.java:526

↓ 2 callersMethodcompare_and_set

src/utils/long_adder.h:41

↓ 2 callersMethodconsumeWithBorrowNonBlocking

* Reserve tokens and return time to wait for in order for the reservation to * be compatible with the bucket configuration. */

src/utils/TokenBucket.h:459

↓ 2 callersMethodcontain

(selectReplica string)

admin-cli/executor/toolkits/nodesbalancer/migrator.go:181

↓ 2 callersMethodcontinue_current_backup_unlocked

src/meta/meta_backup_service.cpp:683

↓ 2 callersMethodcontrol_bulk_load

src/client/replication_ddl_client.cpp:1624

↓ 2 callersFunctioncontrol_bulk_load_helper

helper function for pause/restart bulk load

src/shell/commands/bulk_load.cpp:128

↓ 2 callersMethodcontrol_meta_function_level

src/client/replication_ddl_client.cpp:861

↓ 2 callersFunctionconvert

(client *executor.Client, nodes []string)

admin-cli/executor/toolkits/nodesmigrator/migrator.go:334

↓ 2 callersMethodconvert_from

src/replica/storage/simple_kv/test/common.cpp:334

↓ 2 callersMethodcopy

src/utils/errors.h:157

↓ 2 callersMethodcopy_checkpoint_to_dir

src/replica/test/mock_utils.h:68

↓ 2 callersMethodcopy_mutation

ThreadPool: THREAD_POOL_REPLICATION

src/replica/split/replica_split_manager.cpp:1251

↓ 2 callersFunctioncorrupt_data

src/runtime/fault_injector.cpp:229

↓ 2 callersFunctioncreateNewMigrator

(client *executor.Client, from []string, to []string)

admin-cli/executor/toolkits/nodesmigrator/migrator.go:302

↓ 2 callersFunctioncreate_message_from_request_blob

Reads the requests's name, seqid, and TMessageType from the binary data, and constructs a `message_ex` object.

src/runtime/rpc/thrift_message_parser.cpp:103

↓ 2 callersMethodcreate_response

src/redis_protocol/proxy_lib/proxy_layer.cpp:148

↓ 2 callersMethodcreator

src/server/compaction_operation.h:100

↓ 2 callersMethodcredential

credential info. Defaults to {@literal null} @param credential credential @return {@code this}

java-client/src/main/java/org/apache/pegasus/client/ClientOptions.java:384

↓ 2 callersMethodcure

src/meta/partition_guardian.cpp:64

↓ 2 callersMethodcure

src/meta/test/meta_partition_guardian_test.cpp:772

↓ 2 callersMethoddecrease_left_potential_secondary_ack_count

src/replica/mutation.h:124

↓ 2 callersMethoddecrement

src/utils/test/long_adder_test.cpp:212

↓ 2 callersMethoddelay_recv

--------- inline implementation -------------- return true if delay applied.

src/runtime/rpc/network.h:347

↓ 2 callersMethoddequeue

src/runtime/task/hpc_task_queue.cpp:53

↓ 2 callersFunctiondisk_remove_useless_dirs

src/replica/disk_cleaner.cpp:73

↓ 2 callersFunctiondisk_status_to_error_code

src/common/fs_manager.cpp:73

↓ 2 callersMethoddowngradeAllReplicaToSecondary

(client *executor.Client)

admin-cli/executor/toolkits/nodesmigrator/nodes.go:53

↓ 2 callersFunctiondowngradeNode

(meta Meta, node *util.PegasusNode, downgradedParts *[]*base.Gpid)

admin-cli/client/migrate_node.go:144

↓ 2 callersFunctiondsn_config_get_all_sections

src/utils/config_api.cpp:79

↓ 2 callersFunctiondsn_config_get_value_double

src/utils/config_api.cpp:71

↓ 2 callersFunctiondsn_config_set

src/utils/config_api.cpp:102

↓ 2 callersMethoddsn_crc64

java-client/src/main/java/org/apache/pegasus/tools/Tools.java:103

↓ 2 callersMethoddsn_gpid_to_thread_hash

(int app_id, int partition_index)

java-client/src/main/java/org/apache/pegasus/tools/Tools.java:115

↓ 2 callersFunctiondsn_log_init

src/utils/logging.cpp:72

↓ 2 callersFunctiondsn_logf

src/utils/logging.cpp:112

↓ 2 callersMethoddsn_logv

src/utils/simple_logger.cpp:126

↓ 2 callersFunctiondump_disk_load

src/meta/load_balance_policy.cpp:44

↓ 2 callersMethoddump_to_json

src/shell/command_helper.h:1298

↓ 2 callersFunctionduplication_entry_to_json

TODO(wutao1): implement our C++ version of `TSimpleJSONProtocol` if there're more cases for converting thrift to JSON

src/common/duplication_common.cpp:135

↓ 2 callersFunctionduplication_query_response_to_string

src/common/duplication_common.cpp:161

↓ 2 callersFunctionenableRawMode

Raw mode: 1960 magic shit. */

src/shell/linenoise/linenoise.c:218

↓ 2 callersFunctionencode_as_json

src/utils/metrics.h:328

↓ 2 callersMethodengine

src/runtime/rpc/network.h:133

↓ 2 callersMethodentity_type

src/utils/metrics.h:585

↓ 2 callersMethodequals_to

src/meta/duplication/duplication_info.h:187

↓ 2 callersFunctionevent_type_to_string

src/replica/storage/simple_kv/test/case.cpp:365

↓ 2 callersFunctionexec_tests

src/runtime/test/test_utils.h:80

↓ 2 callersFunctionexecuteCommand

(c *grumble.Context, ntype session.NodeType)

admin-cli/cmd/server_config.go:69

↓ 2 callersFunctionexecuteRemoteCommand

(c *grumble.Context, ntype session.NodeType)

admin-cli/cmd/remote_command.go:69

↓ 2 callersMethodexist

Check value exist. :param hash_key: (bytes) which hash key used for this API. :param sort_key: (bytes) which sort key used f

python-client/pypegasus/pgclient.py:723

↓ 2 callersFunctionextractMultiGetResult

(res *op.MultiGetResult)

go-client/pegasus/table_connector.go:419

↓ 2 callersFunctionextract_expire_ts

src/base/test/value_schema_test.cpp:40

↓ 2 callersMethodextract_field

src/base/value_schema_v1.cpp:34

↓ 2 callersFunctionextract_symbols_from_binary

src/http/pprof_http_service.cpp:79

↓ 2 callersMethodfalconPerfCounterTags

Additional tags for falcon metrics. For example: "cluster=c3srv-ad,job=recommend-service-history". Defaults to empty string, see {@link #DEFAULT_FALCO

java-client/src/main/java/org/apache/pegasus/client/ClientOptions.java:334

↓ 2 callersMethodfalconPushInterval

The interval to report metrics to local falcon agent, must be positive. Defaults to {@literal 10s}, see {@link #DEFAULT_FALCON_PUSH_INTERVAL}. @param

java-client/src/main/java/org/apache/pegasus/client/ClientOptions.java:346

↓ 2 callersFunctionfillDiskCapacity

(client *Client, replicaServer string, resp *radmin.QueryDiskInfoResponse, diskTag string, print bool)

admin-cli/executor/disk_info.go:113

↓ 2 callersFunctionfillNodesInfo

(nodes map[string]*nodeInfoStruct, partitions []*replication.PartitionConfiguration)

admin-cli/executor/list_nodes.go:99

↓ 2 callersMethodfillReplicasInfo

(client *executor.Client, table string, gpid *base.Gpid, addr string, balanceType migrator.BalanceType)

admin-cli/executor/toolkits/nodesmigrator/migrator.go:176

↓ 2 callersFunctionfill_string

set/get/scan/del fill string in prefix, until with size(len)

src/test/pressure_test/main.cpp:76

↓ 2 callersFunctionfilterStringWithPrefix

filterStringWithPrefix returns strings with the same prefix. This function is commonly used for the auto-completion of commands.

pegic/interactive/cmd/init.go:59

↓ 2 callersMethodfinalize

src/meta/meta_state_service_zookeeper.cpp:180

↓ 2 callersMethodfindByThriftId

Find the _Fields constant that matches fieldId, or null if its not found.

java-client/src/main/java/org/apache/pegasus/base/rpc_address.java:60

↓ 2 callersMethodfindByThriftId

Find the _Fields constant that matches fieldId, or null if its not found.

java-client/src/main/java/org/apache/pegasus/base/task_code.java:56

← previous next →1,601–1,700 of 8,667, ranked by callers