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

↓ 3 callersMethodQueryConfig

QueryConfig queries table configuration from the leader of meta servers. If the leader was changed, it retries for other servers until it finds the tr

go-client/session/meta_session.go:108

↓ 3 callersMethodQueryDiskInfo

QueryDiskInfo is auto-generated

go-client/session/radmin_rpc_types.go:31

↓ 3 callersMethodReplica

Replica returns a ReplicaSession if this node is a ReplicaServer. Will initialize the TCP connection.

admin-cli/util/pegasus_node.go:64

↓ 3 callersMethodSetColumnValueFunc

SetColumnValueFunc configures ColumnValueFunc

admin-cli/tabular/template.go:112

↓ 3 callersMethodSetCommonColumns

SetCommonColumns sets the columns that are exactly the same among sections. This is a conveninence util to prevent repeatedly declaring the column for

admin-cli/tabular/template.go:121

↓ 3 callersMethodUpdateAppEnvs

(tableName string, envs map[string]string)

admin-cli/client/meta.go:73

↓ 3 callersMethod__init__

(self, name, container, timeout)

python-client/pypegasus/pgclient.py:308

↓ 3 callersMethodadd

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

↓ 3 callersMethodadd_message

src/test/bench_test/statistics.cpp:128

↓ 3 callersMethodadd_multi_put_cu

src/server/capacity_unit_calculator.cpp:289

↓ 3 callersMethodadd_multi_remove_cu

src/server/capacity_unit_calculator.cpp:309

↓ 3 callersMethodadd_new_dir_node

src/common/fs_manager.cpp:393

↓ 3 callersMethodadd_non_primary_replica

src/replica/test/mock_utils.h:263

↓ 3 callersMethodadd_replica

src/replica/test/mock_utils.h:254

↓ 3 callersMethodadd_work

src/replica/mutation.cpp:364

↓ 3 callersFunctionappend_line

(filePath, appends)

scripts/collector_table_counter_gen.py:54

↓ 3 callersFunctionassertReplicasNotOnSameNode

ensure 3-replica for every partitions are not distributed on the same node.

admin-cli/client/fake_cluster_test.go:141

↓ 3 callersMethodasyncDel

(byte[] hashKey, byte[] sortKey, int timeout)

java-client/src/main/java/org/apache/pegasus/client/PegasusTable.java:634

↓ 3 callersMethodasyncExecute

(client_operator op, Runnable callbackFunc, int maxExecuteCount)

java-client/src/main/java/org/apache/pegasus/rpc/async/MetaSession.java:116

↓ 3 callersMethodasyncGet

(byte[] hashKey, byte[] sortKey, int timeout /* ms */)

java-client/src/main/java/org/apache/pegasus/client/PegasusTable.java:151

↓ 3 callersMethodasyncMultiGet

get multiple key-values under the same hashKey, async version @param hashKey used to decide which partition the key may exist should not be null or e

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

↓ 3 callersMethodasyncNextInternal

java-client/src/main/java/org/apache/pegasus/client/PegasusScanner.java:320

↓ 3 callersMethodasync_multi_del

src/client_lib/pegasus_client_impl.cpp:704

↓ 3 callersMethodasync_search_radial

src/geo/lib/geo_client.cpp:457

↓ 3 callersMethodbalance

src/meta/test/dummy_balancer.h:30

↓ 3 callersMethodbatchGet

Batch get values of different keys. Will terminate immediately if any error occurs. @deprecated Retained only for backward compatibility, will be rem

java-client/src/main/java/org/apache/pegasus/client/PegasusClientInterface.java:143

↓ 3 callersMethodbatchMultiGet

Batch get multiple values under the same hash key. Will terminate immediately if any error occurs. @deprecated Retained only for backward compatibili

java-client/src/main/java/org/apache/pegasus/client/PegasusClientInterface.java:254

↓ 3 callersMethodbatchSet

Batch set lots of values. Will terminate immediately if any error occurs. @deprecated Retained only for backward compatibility, will be removed later

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

↓ 3 callersMethodbatch_remove

src/server/pegasus_write_service.cpp:284

↓ 3 callersMethodbytesCompare

(byte[] left, byte[] right)

java-client/src/main/java/org/apache/pegasus/client/PegasusClient.java:176

↓ 3 callersFunctioncalc_disk_load

src/meta/load_balance_policy.cpp:62

↓ 3 callersMethodcalc_potential_moving

src/meta/load_balance_policy.cpp:318

↓ 3 callersMethodcancel_sync

src/meta/meta_data.cpp:312

↓ 3 callersMethodcatch_up_with_private_logs

in non-replication thread

src/replica/replica_chkpt.cpp:370

↓ 3 callersMethodcheckSingleHashKey

(byte[] hashKey)

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

↓ 3 callersMethodcheckSingleSortKey

(byte[] hashKey, byte[] sortKey)

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

↓ 3 callersMethodcheckSingleValue

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

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

↓ 3 callersFunctioncheck_base_stats_marks

This function does not check "End" mark, since sometimes returned message is very long while the buffer may not have enough space: the message will be

src/utils/test/je_ctl_test.cpp:32

↓ 3 callersMethodcheck_status_and_authz

src/meta/meta_service.h:449

↓ 3 callersMethodcleanup_split_states

src/replica/replica_context.cpp:173

↓ 3 callersMethodclear_app_envs

src/meta/server_state.cpp:2869

↓ 3 callersMethodclear_workers

src/failure_detector/failure_detector.cpp:553

↓ 3 callersMethodclientType

java-client/src/main/java/org/apache/pegasus/client/PegasusAbstractClient.java:50

↓ 3 callersMethodcloseServer

(rpc_address server)

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

↓ 3 callersMethodcloseSession

java-client/src/main/java/org/apache/pegasus/rpc/async/MetaSession.java:151

↓ 3 callersMethodcommit

src/replica/duplication/mutation_batch.cpp:57

↓ 3 callersMethodcommitWaitAllComplete

send and commit batched requests no-atomically, try wait for all requests done until timeout even if some other error occurs. @param requests generic

java-client/src/main/java/org/apache/pegasus/client/request/Batch.java:61

↓ 3 callersMethodcomplete_checkpoint

src/replica/backup/cold_backup_context.cpp:143

↓ 3 callersFunctioncompute_ttl_seconds

src/shell/command_helper.h:283

↓ 3 callersMethodconcurrent

(acts *MigrateActions)

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

↓ 3 callersMethodconsumeOrDrain

* Similar to consume, but always consumes some number of tokens. If the * bucket contains enough tokens - consumes toConsume tokens. Otherwise

src/utils/TokenBucket.h:442

↓ 3 callersMethodcontain

(gpid *base.Gpid)

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

↓ 3 callersMethodcopyOf

Create a copy of {@literal options} @param options the original @return A new instance of {@link ClientOptions} containing the values of {@literal op

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

↓ 3 callersMethodcount

src/replica/mutation_cache.h:58

↓ 3 callersFunctioncrc32_concat

src/utils/crc.cpp:452

↓ 3 callersFunctioncrc64_calc

src/utils/crc.cpp:464

↓ 3 callersMethodcreate_child_replica_dir

src/common/fs_manager.cpp:476

↓ 3 callersFunctioncreate_directory_component

src/utils/filesystem.cpp:421

↓ 3 callersMethodcreate_locknode

src/zookeeper/lock_struct.cpp:590

↓ 3 callersFunctioncreate_meta_access_controller

src/runtime/security/access_controller.cpp:56

↓ 3 callersMethodcreate_server_session

src/runtime/rpc/network.sim.h:101

↓ 3 callersMethoddata_aggregate

src/server/hotspot_partition_calculator.cpp:71

↓ 3 callersMethoddata_analyse

src/server/hotspot_partition_calculator.cpp:159

↓ 3 callersMethoddefault_hash

(cls, hash_key)

python-client/pypegasus/pgclient.py:565

↓ 3 callersFunctiondisableRawMode

src/shell/linenoise/linenoise.c:253

↓ 3 callersMethoddoNext

(ctx context.Context)

go-client/pegasus/scanner.go:163

↓ 3 callersMethoddo_restore

src/client/replication_ddl_client.cpp:963

↓ 3 callersMethoddo_update_partition_confirmed

src/meta/duplication/meta_duplication_service.cpp:489

↓ 3 callersMethoddropApp

(String appName, int reserveSeconds)

java-client/src/main/java/org/apache/pegasus/client/PegasusAdminClientInterface.java:74

↓ 3 callersFunctiondsn_config_get_value_uint64

src/utils/config_api.cpp:55

↓ 3 callersFunctiondsn_mimic_app

src/runtime/service_api_c.cpp:231

↓ 3 callersFunctiondsn_rpc_call_one_way

src/runtime/service_api_c.cpp:185

↓ 3 callersFunctiondsn_rpc_forward

src/runtime/service_api_c.cpp:199

↓ 3 callersMethodenablePerfCounter

Whether to enable performance statistics. If true, the client will periodically report metrics to local falcon agent (currently we only support falcon

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

↓ 3 callersMethodenqueue

src/utils/priority_queue.h:58

↓ 3 callersMethodentities

src/utils/metrics.cpp:396

↓ 3 callersMethodequals

(Object options)

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

↓ 3 callersFunctionerrMsg

admin-cli/cmd/server_config.go:93

↓ 3 callersMethodevaluateChallenge

(final byte[] data)

java-client/src/main/java/org/apache/pegasus/security/SaslWrapper.java:73

↓ 3 callersMethodexecute

src/utils/test/long_adder_test.cpp:219

↓ 3 callersFunctionexpireTsSeconds

(ttl time.Duration)

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

↓ 3 callersFunctionextract_time_tag

src/base/test/value_schema_test.cpp:47

↓ 3 callersMethodfail_mode

src/replica/duplication/replica_duplicator.h:95

↓ 3 callersFunctionfatal_error

scripts/collector_table_counter_gen.py:49

↓ 3 callersFunctionfile_eq_compare

src/block_service/test/fds_service_test.cpp:62

↓ 3 callersFunctionfile_tree_walk

src/utils/filesystem.cpp:157

↓ 3 callersMethodfilter

src/server/compaction_operation.cpp:57

↓ 3 callersFunctionfindNodeInFakeCluster

(pn *util.PegasusNode)

admin-cli/client/fake_meta_test.go:183

↓ 3 callersMethodfor_each_primary

src/meta/meta_data.cpp:643

↓ 3 callersMethodforward

src/runtime/rpc/rpc_engine.cpp:828

↓ 3 callersMethodfrom_string

(self, host_port)

python-client/pypegasus/base/ttypes.py:268

↓ 3 callersMethodfront

string_view::front() Returns the first element of a `string_view`.

src/utils/string_view.h:271

↓ 3 callersFunctiongenerate_timetag

Generates timetag in host endian. \see comment on pegasus_value_generator::generate_value_v1

src/base/pegasus_value_schema.h:44

↓ 3 callersFunctiongenerate_value

src/base/test/value_schema_test.cpp:54

↓ 3 callersMethodgetFalconPerfCounterTags

Additional tags for falcon metrics. Defaults to empty string. @return additional tags for falcon metrics.

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

↓ 3 callersMethodgetFalconPushInterval

The interval to report metrics to local falcon agent. Defaults to {@literal 10s}. @return the interval to report metrics to local falcon agent.

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

↓ 3 callersMethodgetGpidByHash

(long hashValue)

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

↓ 3 callersMethodgetMatchMechanism

(String respString)

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

↓ 3 callersMethodgetMetaQueryTimeout

The timeout for query meta server. Defaults to {@literal 5000ms}. @return the timeout for query meta server.

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

↓ 3 callersMethodgetOperationTimeout

The timeout for failing to finish an operation. Defaults to {@literal 1000ms}. @return the timeout for failing to finish an operation.

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

← previous next →1,201–1,300 of 8,667, ranked by callers