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 callersMethodupdate

src/utils/flags.cpp:122

↓ 3 callersMethodupdateAppEnvs

(req *admin.UpdateAppEnvRequest)

admin-cli/client/meta.go:235

↓ 3 callersMethodupdate_configuration

src/replica/replica_config.cpp:621

↓ 3 callersMethodupdate_local_configuration_with_no_ballot_change

src/replica/replica_config.cpp:1032

↓ 3 callersMethodupdate_state

python-client/pypegasus/pgclient.py:679

↓ 3 callersFunctionvalidateSortKeys

(sortKeys [][]byte)

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

↓ 3 callersFunctionvalidateTTL

(TTL time.Duration)

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

↓ 3 callersFunctionvec_equal

src/meta/test/meta_data.cpp:91

↓ 3 callersMethodwait

src/utils/synchronize.h:126

↓ 3 callersMethodwaitCondition

(BoolCallable callable, int seconds)

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

↓ 3 callersFunctionwaitTableReady

(c *Client, tableName string, partitionCount int, replicaCount int)

admin-cli/executor/create_table.go:49

↓ 3 callersMethodwaitUntilSessionReady

(ctx context.Context)

go-client/session/session.go:320

↓ 3 callersMethodwait_until_cluster_health

python-client/tests/test_integration.py:95

↓ 3 callersMethodwrite

src/block_service/test/block_service_mock.h:46

↓ 3 callersMethodwrite

src/common/serialization_helper/thrift_helper.h:247

↓ 3 callersMethodwrite_batch_delete

src/server/rocksdb_wrapper.cpp:193

↓ 3 callersMethodwrite_batch_put_ctx

src/server/rocksdb_wrapper.cpp:112

↓ 3 callersMethodwrite_file_header

src/replica/log_file.cpp:402

↓ 3 callersFunctionwrite_vector

src/aio/file_io.cpp:118

↓ 2 callersMethodAddDisk

AddDisk is auto-generated

go-client/session/radmin_rpc_types.go:63

↓ 2 callersMethodCancelBulkLoad

(tableName string, forced bool)

admin-cli/client/meta.go:122

↓ 2 callersMethodCancelPartitionSplit

(tableName string, oldPartitionCount int)

admin-cli/client/meta.go:112

↓ 2 callersMethodClearAppEnvs

(tableName string, clearPrefix string)

admin-cli/client/meta.go:75

↓ 2 callersMethodClearBulkLoad

(tableName string)

admin-cli/client/meta.go:124

↓ 2 callersMethodClose

admin-cli/client/meta.go:60

↓ 2 callersFunctionDowngradeNode

DowngradeNode sets all secondaries from the specified node to inactive state. NOTE: this step requires that the node has no primary, otherwise error i

admin-cli/client/migrate_node.go:130

↓ 2 callersMethodDropApp

(tableName string, reserveSeconds int64)

admin-cli/client/meta.go:81

↓ 2 callersMethodError

go-client/idl/base/error_code.go:119

↓ 2 callersMethodGetPerfSession

(addr string, ntype session.NodeType)

admin-cli/util/pegasus_node.go:206

↓ 2 callersFunctionGetTablePartitions

(client *Client, tableName string)

admin-cli/executor/table_partitions.go:35

↓ 2 callersMethodGetUnorderedScanners

Get Scanners for all data in pegasus, the count of scanners will be no more than maxSplitCount

go-client/pegasus/table_connector.go:163

↓ 2 callersMethodIterateAll

IterateAll iterates over the table according to the command.

pegic/executor/scan.go:44

↓ 2 callersFunctionMigratePrimariesOut

MigratePrimariesOut migrates all primaries out from the specified node. Internally, for every partition it merely swaps the roles of primary and secon

admin-cli/client/migrate_node.go:88

↓ 2 callersFunctionNewReadStream

(reader io.Reader)

go-client/rpc/stream_in.go:88

↓ 2 callersFunctionNewTabWriter

(writer io.Writer, header []string)

admin-cli/tabular/printer.go:72

↓ 2 callersMethodPauseBulkLoad

(tableName string)

admin-cli/client/meta.go:118

↓ 2 callersMethodPausePartitionSplit

(tableName string, parentPidx int)

admin-cli/client/meta.go:108

↓ 2 callersFunctionPrintAllSummary

(client *Client, tableName string, tableStatus admin.BulkLoadStatus)

admin-cli/executor/bulk_load.go:275

↓ 2 callersMethodPropose

(gpid *base.Gpid, action admin.ConfigType, target *util.PegasusNode, node *util.PegasusNode)

admin-cli/client/meta.go:95

↓ 2 callersMethodQueryBackupStatus

(tableID int, backupID int64)

admin-cli/client/meta.go:99

↓ 2 callersMethodQueryBulkLoad

(tableName string)

admin-cli/client/meta.go:116

↓ 2 callersMethodQueryDuplication

(tableName string)

admin-cli/client/meta.go:87

↓ 2 callersMethodQueryManualCompaction

(tableName string)

admin-cli/client/meta.go:128

↓ 2 callersMethodQuerySplitStatus

(tableName string)

admin-cli/client/meta.go:106

↓ 2 callersMethodRPCAddress

admin-cli/util/pegasus_node.go:83

↓ 2 callersMethodRestartBulkLoad

(tableName string)

admin-cli/client/meta.go:120

↓ 2 callersMethodRestartPartitionSplit

(tableName string, parentPidx int)

admin-cli/client/meta.go:110

↓ 2 callersMethodSession

Session returns a tcp session to the node. Will initialize the TCP connection.

admin-cli/util/pegasus_node.go:76

↓ 2 callersFunctionSetMetaLevelSteady

admin-cli/client/migrate_node.go:39

↓ 2 callersMethodSetPartitionVersion

src/server/key_ttl_compaction_filter.h:174

↓ 2 callersMethodSetUnresponsiveHandler

SetUnresponsiveHandler inits the UnresponsiveHandler.

go-client/session/replica_session.go:197

↓ 2 callersMethodStartBulkLoad

(tableName string, clusterName string, providerType string, rootPath string)

admin-cli/client/meta.go:114

↓ 2 callersMethodStartManualCompaction

(tableName string, targetLevel int, maxRunningCount int, bottommost bool)

admin-cli/client/meta.go:126

↓ 2 callersMethodStartPartitionSplit

(tableName string, newPartitionCount int)

admin-cli/client/meta.go:104

↓ 2 callersMethodTimeout

go-client/session/session_timeout_test.go:42

↓ 2 callersMethodWrite

invoke an asynchronous write for message.

go-client/rpc/stream_out.go:40

↓ 2 callersFunctionWritePadding

src/utils/string_view.cpp:27

↓ 2 callersFunctionabFree

src/shell/linenoise/linenoise.c:470

↓ 2 callersFunctionabInit

src/shell/linenoise/linenoise.c:456

↓ 2 callersMethodaccess_controller_allowed

src/replica/replica.cpp:604

↓ 2 callersMethodadd

src/http/http_call_registry.h:51

↓ 2 callersMethodadd

(byte[] sortKey, byte[] value)

java-client/src/main/java/org/apache/pegasus/client/request/MultiSet.java:46

↓ 2 callersFunctionadd_backup_policy

src/shell/commands/cold_backup.cpp:42

↓ 2 callersMethodadd_backup_policy

src/meta/meta_backup_service.cpp:1244

↓ 2 callersMethodadd_batch_get_cu

src/server/capacity_unit_calculator.cpp:194

↓ 2 callersMethodadd_duplication

This call will not recreate if the duplication with the same app name and remote end point already exists. ThreadPool(WRITE): THREAD_POOL_META_STATE

src/meta/duplication/meta_duplication_service.cpp:154

↓ 2 callersMethodadd_edge

src/meta/load_balance_policy.cpp:534

↓ 2 callersMethodadd_incr_cu

src/server/capacity_unit_calculator.cpp:326

↓ 2 callersMethodadd_prepare_request

src/replica/mutation.h:89

↓ 2 callersMethodadd_put_cu

src/server/capacity_unit_calculator.cpp:268

↓ 2 callersMethodadd_remove_cu

src/server/capacity_unit_calculator.cpp:280

↓ 2 callersMethodadd_size

src/server/range_read_limiter.h:84

↓ 2 callersMethodadd_tag

src/utils/flags.cpp:143

↓ 2 callersMethodafter

( ClientRequestRound clientRequestRound, error_code.error_types errno, TableHandler tableHan

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

↓ 2 callersMethodaggregate

src/shell/command_helper.h:737

↓ 2 callersFunctionaggregateReplicaInfo

(meta Meta, tableName string, nodes *map[string]*NodeState)

admin-cli/client/replica_health.go:61

↓ 2 callersMethodall_checkpoint_has_prepared

src/meta/duplication/duplication_info.h:164

↓ 2 callersMethodall_rules_match

src/server/compaction_operation.cpp:32

↓ 2 callersMethodall_tasks_success

src/runtime/task/task_tracker.h:166

↓ 2 callersMethodalloc_buffer

src/zookeeper/zookeeper_session.cpp:91

↓ 2 callersMethodapply_checkpoint

src/replica/replication_app_base.cpp:372

↓ 2 callersFunctionapply_helper

src/utils/absl/utility/utility.h:150

↓ 2 callersMethodappro_data_bytes

src/replica/mutation.h:143

↓ 2 callersMethodas_secondary

src/replica/test/mock_utils.h:157

↓ 2 callersFunctionassertNoMissingReplicaInCluster

(t *testing.T, expectedTotalPartitions int)

admin-cli/client/fake_cluster_test.go:158

↓ 2 callersMethodassign_cure_proposal

src/meta/meta_data.cpp:294

↓ 2 callersMethodasyncCall

(final MetaRequestRound round)

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

↓ 2 callersMethodasyncIncr

atomically increment value by key, async version @param hashKey the hash key to increment. @param sortKey the sort key to increment. @param increment

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

↓ 2 callersMethodasyncIncr

( byte[] hashKey, byte[] sortKey, long increment, int ttlSeconds, int timeout)

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

↓ 2 callersMethodasyncNext

Get the next item asynchronously. @return A future for current op. <p>Future return: On success: if scan haven't reached the end then return the

java-client/src/main/java/org/apache/pegasus/client/PegasusScannerInterface.java:53

↓ 2 callersMethodasyncTTL

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

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

↓ 2 callersFunctionasync_call_remote

src/remote_cmd/remote_command.cpp:45

↓ 2 callersMethodasync_learn_ms

src/replica/replica_context.h:263

↓ 2 callersMethodasync_multi_get_sortkeys

src/client_lib/pegasus_client_impl.cpp:517

↓ 2 callersMethodattach

src/zookeeper/zookeeper_session.cpp:164

↓ 2 callersMethodbackupRequestDelayMs

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

↓ 2 callersMethodbackupRequestTask

java-client/src/main/java/org/apache/pegasus/rpc/async/ClientRequestRound.java:80

↓ 2 callersFunctionbackup_get_dir_name

backup/backup.<policy_name>.<backup_id>.<decree>.<timestamp>

src/replica/replica_backup.cpp:267

↓ 2 callersMethodbatchGetByPartitions

Batch get values of different keys. Will wait for all requests done even if some error occurs. @param keys hashKey and sortKey pair list. @param resu

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

↓ 2 callersMethodbatchSet2

Batch set lots of values. Will wait for all requests done even if some error occurs. @deprecated Retained only for backward compatibility, will be re

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

← previous next →1,501–1,600 of 8,667, ranked by callers