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 callersMethodset_last_manual_compact_finish_time

src/server/meta_store.cpp:179

↓ 2 callersMethodset_leader_for_test

src/failure_detector/failure_detector_multimaster.cpp:72

↓ 2 callersMethodset_log

src/replica/test/mock_utils.h:368

↓ 2 callersMethodset_name

src/runtime/task/task_worker.cpp:107

↓ 2 callersMethodset_options

src/server/pegasus_server_impl.cpp:3257

↓ 2 callersMethodset_partition_version

TODO(heyuchen): implement this function in further pull request

src/replica/test/mock_utils.h:88

↓ 2 callersMethodset_primary_partition_configuration

src/replica/test/mock_utils.h:178

↓ 2 callersMethodset_started

src/runtime/service_app.h:102

↓ 2 callersMethodsetstate

src/shell/argh.h:67

↓ 2 callersMethodsignal_waiters

src/runtime/task/task.cpp:226

↓ 2 callersMethodsort_key_count

Get the total sort key count under the hash_key. :param hash_key: (bytes) which hash key used for this API. :param timeout:

python-client/pypegasus/pgclient.py:809

↓ 2 callersFunctionspin_wait_condition

src/meta/test/misc/misc.cpp:427

↓ 2 callersFunctionsplit

src/utils/strings.cpp:201

↓ 2 callersFunctionsplit_to_sequence_container

src/utils/strings.cpp:274

↓ 2 callersMethodstart

java-client/src/main/java/org/apache/pegasus/security/Negotiation.java:51

↓ 2 callersMethodstart_1_replica

python-client/tests/test_integration.py:79

↓ 2 callersMethodstart_checkpoint

src/replica/backup/cold_backup_context.cpp:118

↓ 2 callersMethodstart_manual_compact_if_needed

src/server/pegasus_manual_compact_service.cpp:79

↓ 2 callersMethodstart_partition_split

src/meta/meta_split_service.cpp:59

↓ 2 callersFunctionstatistic_file_infos_under_dir

src/replica/replica_backup.cpp:375

↓ 2 callersMethodstep

src/runtime/security/sasl_server_wrapper.cpp:61

↓ 2 callersMethodstop_and_clear_cluster

python-client/tests/test_integration.py:61

↓ 2 callersMethodstore_app_info

src/replica/replica.cpp:593

↓ 2 callersFunctionstring_pattern_match

src/server/compaction_filter_rule.cpp:30

↓ 2 callersMethodsync_apps_from_remote_storage

src/meta/server_state.cpp:612

↓ 2 callersMethodtableOptions

java-client/src/main/java/org/apache/pegasus/rpc/InternalTableOptions.java:36

↓ 2 callersMethodtake_snapshot

src/utils/metrics.cpp:149

↓ 2 callersFunctiontake_snapshot_as_json

src/utils/metrics.h:338

↓ 2 callersFunctiontestMetaSessionMustQueryLeader

(t *testing.T, metaServers []string)

go-client/session/meta_session_test.go:62

↓ 2 callersMethodtestOneCreateApp

(String appName)

java-client/src/test/java/org/apache/pegasus/client/TestAdminClient.java:61

↓ 2 callersFunctiontestSingleKeyOperations

This is the integration test of the client. Please start the pegasus onebox before you running the tests.

go-client/pegasus/table_connector_test.go:44

↓ 2 callersFunctiontest_func_return_void

src/utils/test/fail_point_test.cpp:150

↓ 2 callersMethodtime_check_after_incomplete_scan

src/server/range_read_limiter.h:74

↓ 2 callersMethodtoString

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

↓ 2 callersMethodto_string

src/replica/mutation_log.h:313

↓ 2 callersMethodto_string

src/replica/mutation_log.cpp:1411

↓ 2 callersMethodtotal_ms

src/replica/replica_context.h:259

↓ 2 callersMethodtracker

src/replica/bulk_load/replica_bulk_loader.h:172

↓ 2 callersMethodtrigger_primary_parent_split

ThreadPool: THREAD_POOL_REPLICATION

src/replica/split/replica_split_manager.cpp:1156

↓ 2 callersMethodtrigger_secondary_parent_split

ThreadPool: THREAD_POOL_REPLICATION

src/replica/split/replica_split_manager.cpp:1222

↓ 2 callersMethodtruncate_read

discard read data

src/runtime/rpc/message_parser.h:60

↓ 2 callersMethodtryConfUpdate

tryConfUpdate makes an attempt to update table configuration by querying meta server.

go-client/pegasus/table_connector.go:752

↓ 2 callersMethodtryConnect

java-client/src/main/java/org/apache/pegasus/metrics/MetricsReporter.java:130

↓ 2 callersMethodtryConnect

(final rpc_address addr, FutureGroup<Void> futureGroup)

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

↓ 2 callersMethodtryDelayCall

(final ClientRequestRound round)

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

↓ 2 callersMethodtryDial

go-client/session/session.go:176

↓ 2 callersMethodtryExecuteCommand

(String command)

java-client/src/test/java/org/apache/pegasus/tools/Toollet.java:80

↓ 2 callersMethodtryLock

src/utils/hpc_locks/benaphore.h:81

↓ 2 callersMethodtry_lock

src/utils/synchronize.h:41

↓ 2 callersMethodtry_update

src/utils/uniq_timestamp_us.h:50

↓ 2 callersMethodttl

Get ttl(time to live) of the data. :param hash_key: (bytes) which hash key used for this API. :param sort_key: (bytes) which

python-client/pypegasus/pgclient.py:700

↓ 2 callersMethodunder_simulation

src/runtime/task/task_tracker.cpp:58

↓ 2 callersMethodunit

src/utils/metrics.h:591

↓ 2 callersMethodunlock

src/meta/distributed_lock_service_simple.cpp:224

↓ 2 callersFunctionunmarshall_thrift_binary

src/common/serialization_helper/thrift_helper.h:747

↓ 2 callersFunctionunmarshall_thrift_internal

src/common/serialization_helper/thrift_helper.h:706

↓ 2 callersMethodupdateConf

Update configuration of this table.

go-client/pegasus/table_connector.go:246

↓ 2 callersMethodupdate_app_max_replica_count

src/replica/replica_config.cpp:1112

↓ 2 callersMethodupdate_bool_envs

src/replica/replica_config.cpp:543

↓ 2 callersFunctionupdate_config

src/http/http_server.cpp:48

↓ 2 callersMethodupdate_disk_stat

src/common/fs_manager.cpp:127

↓ 2 callersMethodupdate_init_info_ballot_and_decree

src/replica/replica_config.cpp:1158

↓ 2 callersMethodupdate_user_specified_compaction

src/server/pegasus_server_impl.cpp:2949

↓ 2 callersMethodvalidate

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

↓ 2 callersMethodvalidate

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

↓ 2 callersMethodvalidate

java-client/src/main/java/org/apache/pegasus/base/blob.java:198

↓ 2 callersMethodvalidate

java-client/src/main/java/org/apache/pegasus/base/error_code.java:297

↓ 2 callersMethodvalidateSingleSet

(byte[] hashKey, byte[] sortKey, byte[] value)

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

↓ 2 callersFunctionvalidate_app_env

src/meta/app_env_validator.cpp:56

↓ 2 callersFunctionverify_file_size

src/utils/filesystem.cpp:853

↓ 2 callersFunctionvirtual_send_message

src/runtime/rpc/network.sim.cpp:84

↓ 2 callersMethodwaitAllComplete

wait for all requests done even if some error occurs @param results if one request success, it should be pair(null, result), otherwise, pair(PExc

java-client/src/main/java/org/apache/pegasus/client/FutureGroup.java:82

↓ 2 callersMethodwait_all

Await for all running tasks to complete.

src/runtime/pipeline.h:152

↓ 2 callersFunctionwait_response

src/runtime/test/netprovider.cpp:113

↓ 2 callersFunctionwhen_update_replicas

src/meta/meta_data.cpp:86

↓ 2 callersMethodwithTTLSeconds

(int ttlSeconds)

java-client/src/main/java/org/apache/pegasus/client/request/Set.java:41

↓ 2 callersMethodwrite

src/block_service/hdfs/hdfs_service.cpp:351

↓ 2 callersMethodwrite

src/block_service/local/local_service.cpp:317

↓ 2 callersMethodwrite

src/aio/disk_engine.cpp:114

↓ 2 callersFunctionwrite_blob_to_file

src/replica/replication_app_base.cpp:78

↓ 1 callersMethodCall

Call a remote command.

go-client/admin/remote_cmd_client.go:41

↓ 1 callersMethodClearScanner

(ctx context.Context, gpid *base.Gpid, partitionHash uint64, contextId int64)

go-client/session/replica_session.go:137

↓ 1 callersFunctionConnectTable

ConnectTable queries for the configuration of the given table, and set up connection to the replicas which the table locates on.

go-client/pegasus/table_connector.go:222

↓ 1 callersFunctionConvertReplicaCapacityStruct

(replicaCapacityInfos []interface{})

admin-cli/executor/disk_info.go:217

↓ 1 callersMethodDecompress

pegic/executor/util/compression.go:32

↓ 1 callersMethodDelAppEnvs

(tableName string, keys []string)

admin-cli/client/meta.go:77

↓ 1 callersMethodDelete

(byte[] hashKey, byte[] sortKey)

java-client/src/main/java/org/apache/pegasus/client/request/Delete.java:30

↓ 1 callersFunctionDiskBeforeSplit

(client *Client, tableName string)

admin-cli/executor/partition_split.go:126

↓ 1 callersMethodEnableFilter

src/server/key_ttl_compaction_filter.h:164

↓ 1 callersMethodGet

(ctx context.Context, hashKey []byte, sortKey []byte)

go-client/pegasus/table_connector.go:357

↓ 1 callersFunctionGetAddrInfo

src/runtime/rpc/rpc_host_port.cpp:44

↓ 1 callersFunctionGetAppEnv

(c *Client, useTable string, envName string)

admin-cli/executor/table_env.go:44

↓ 1 callersFunctionGetDiskInfo

(client *Client, infoType DiskInfoType, replicaServer string, tableName string, diskTag string, print bool)

admin-cli/executor/disk_info.go:47

↓ 1 callersMethodGetError

go-client/pegasus/op/utils.go:125

↓ 1 callersFunctionGetTableHealthInfo

GetTableHealthInfo return *TableHealthInfo from meta.

admin-cli/client/replica_health.go:53

↓ 1 callersMethodLen

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

↓ 1 callersMethodListApps

(status admin.AppStatus)

admin-cli/client/meta.go:189

↓ 1 callersFunctionListPrimariesOnNode

(meta Meta, node *util.PegasusNode, tableName string)

admin-cli/client/migrate_node.go:65

↓ 1 callersFunctionMarshallPegasusRpc

(codec rpc.Codec, seqId int32, gpid *base.Gpid, partitionHash uint64, args RpcRequestArgs, name string, timeou

go-client/session/codec.go:452

↓ 1 callersMethodMultiDelete

(ctx context.Context, gpid *base.Gpid, partitionHash uint64, request *rrdb.MultiRemoveRequest)

go-client/session/replica_session.go:93

← previous next →2,001–2,100 of 8,667, ranked by callers