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

↓ 6 callersFunctiongetstatusoutput

python-client/tests/test_integration.py:29

↓ 6 callersMethodhas

src/common/fs_manager.cpp:109

↓ 6 callersFunctionhostname_from_ip

src/utils/utils.cpp:62

↓ 6 callersFunctionincrement_by

src/utils/test/metrics_test.cpp:424

↓ 6 callersMethodinject_drop_message

src/runtime/rpc/network.cpp:602

↓ 6 callersMethodipv4_str

src/runtime/rpc/rpc_address.cpp:180

↓ 6 callersMethodisInvalid

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

↓ 6 callersMethodis_enable_ranger_acl

src/runtime/security/access_controller.cpp:49

↓ 6 callersMethodis_initialized

src/runtime/rpc/rpc_holder.h:112

↓ 6 callersFunctionis_primary

src/common/replication_other_types.h:60

↓ 6 callersMethodis_update_leader_automatically

src/runtime/rpc/group_address.h:75

↓ 6 callersFunctionis_zookeeper_timeout

src/zookeeper/lock_struct.cpp:70

↓ 6 callersMethodissue_new_backup_unlocked

src/meta/meta_backup_service.cpp:768

↓ 6 callersFunctionje_dump_stats

src/utils/je_ctl.cpp:95

↓ 6 callersFunctionjob_type_str

src/test/kill_test/job.h:37

↓ 6 callersMethodlistApps

Get app infos in the Pegasus cluster @param listAppInfoType 'LT_AVAILABLE_APPS' means to return only available tables, 'LT_ALL_APPS' means to ret

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

↓ 6 callersMethodlock

src/utils/synchronize.h:40

↓ 6 callersMethodmatch

src/runtime/ranger/ranger_resource_policy.cpp:26

↓ 6 callersMethodmax_commit_on_disk

src/replica/mutation_log.cpp:870

↓ 6 callersMethodmetrics

src/utils/metrics.cpp:90

↓ 6 callersMethodmultiDel

Delete specified sort keys under the same hash key. @param tableName table name @param hashKey used to decide which partition to put this k-v, should

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

↓ 6 callersFunctionnewFakeNodeSession

(reader io.Reader, writer io.Writer)

go-client/session/session_test.go:41

↓ 6 callersFunctionnew_mutation_duplicator

src/replica/duplication/mutation_duplicator.h:86

↓ 6 callersMethodnode

src/runtime/rpc/network.cpp:550

↓ 6 callersMethodonFinishQueryMeta

(final MetaRequestRound round)

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

↓ 6 callersMethodon_error

src/meta/meta_state_service_utils_impl.h:78

↓ 6 callersMethodopen

src/common/serialization_helper/thrift_helper.h:53

↓ 6 callersMethodopenTable

(String name, InternalTableOptions internalTableOptions)

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

↓ 6 callersMethodoperate

(client_operator op, int retryCount)

java-client/src/main/java/org/apache/pegasus/rpc/Meta.java:25

↓ 6 callersFunctionparse_app_pegasus_perf_counter_name

src/shell/command_helper.h:669

↓ 6 callersMethodpop

src/meta/test/balancer_simulator/balancer_simulator.cpp:64

↓ 6 callersFunctionprint_header

src/utils/simple_logger.cpp:76

↓ 6 callersFunctionprocess_start_millis

if you call these functions before "main" function, the memory space for these variables have been allocated, but the values aren't initialized as the

src/utils/process_utils.cpp:112

↓ 6 callersMethodrandomString

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

↓ 6 callersMethodread_commit

src/runtime/rpc/rpc_message.cpp:487

↓ 6 callersMethodread_next

TODO(wutao1): use string_view instead of using blob. WARNING: the resulted blob is not guaranteed to be reference counted. possible error_code: ERR_OK

src/replica/log_file_stream.h:77

↓ 6 callersMethodread_next_buffer

src/meta/dump_file.h:112

↓ 6 callersFunctionrequireUseTable

(run func(*grumble.Context) error)

pegic/interactive/cmd/init.go:45

↓ 6 callersMethodreset_records

src/meta/test/backup_test.cpp:88

↓ 6 callersMethodresolveHost

(String hostPort)

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

↓ 6 callersFunctionrun

src/shell/main.cpp:710

↓ 6 callersMethodrun

src/meta/meta_state_service_utils_impl.h:168

↓ 6 callersMethodrun_pipeline

src/runtime/pipeline.h:265

↓ 6 callersMethodrw_ptr

src/runtime/rpc/rpc_message.cpp:506

↓ 6 callersFunctionsdsdup

Duplicate an sds string. */

src/shell/sds/sds.c:153

↓ 6 callersFunctionsdsrange

Turn the string into a smaller (or equal) string containing only the * substring specified by the 'start' and 'end' indexes. * * start and end can

src/shell/sds/sds.c:724

↓ 6 callersMethodset_task_environment

src/replica/duplication/mutation_duplicator.h:78

↓ 6 callersMethodstatus

src/replica/duplication/replica_duplicator.h:141

↓ 6 callersMethodstop

Stop this timer

src/utils/timer.h:37

↓ 6 callersMethodstop

src/server/info_collector.cpp:144

↓ 6 callersMethodsupportBackupRequest

java-client/src/main/java/org/apache/pegasus/operator/read_operator.java:29

↓ 6 callersMethodsync_apps_to_remote_storage

caller should ensure all apps are in staging: creating, dropping

src/meta/server_state.cpp:529

↓ 6 callersMethodtracker

Holds its own tracker, so that other tasks won't be effected when this duplication is removed.

src/replica/duplication/replica_duplicator.h:126

↓ 6 callersMethodtrigger_manual_emergency_checkpoint

ThreadPool: THREAD_POOL_REPLICATION

src/replica/replica_chkpt.cpp:179

↓ 6 callersMethodtype

src/base/value_field.h:52

↓ 6 callersMethodupdate_confirmed_decree_if_secondary

src/replica/duplication/replica_duplicator_manager.cpp:133

↓ 6 callersMethodwaitAllCompleteOrOneFail

(int timeoutMillis)

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

↓ 6 callersMethodwait_all

src/replica/duplication/test/duplication_test_base.h:86

↓ 6 callersMethodwait_ongoing_task

src/replica/log_file_stream.h:176

↓ 6 callersFunctionworker_set_leader

src/failure_detector/test/failure_detector.cpp:319

↓ 6 callersMethodwrite_batch_put

src/server/rocksdb_wrapper.cpp:104

↓ 5 callersMethodConnState

go-client/session/session.go:150

↓ 5 callersMethodListTables

(ctx context.Context)

go-client/admin/client.go:40

↓ 5 callersMethodMetaControl

(level admin.MetaFunctionLevel)

admin-cli/client/meta.go:69

↓ 5 callersMethodMockMarshal

(marshal MarshalFunc)

go-client/session/codec.go:404

↓ 5 callersMethodMultiGetRange

MultiGetRange retrieves the multiple entries under `hashKey`, between range (`startSortKey`, `stopSortKey`), atomically in one operation. startSortKe

go-client/pegasus/table_connector.go:132

↓ 5 callersMethodMultiGetRangeOpt

(ctx context.Context, hashKey []byte, startSortKey []byte, stopSortKey []byte, options *MultiGetOptions)

go-client/pegasus/table_connector.go:133

↓ 5 callersMethodMultiSet

MultiSet sets the multiple entries for `hashKey` + `sortKeys[i]` atomically in one operation. `hashKey` / `sortKeys` / `values` : CAN'T be nil or empt

go-client/pegasus/table_connector.go:138

↓ 5 callersFunctionNewScanOptions

NewScanOptions returns the default ScannerOptions.

go-client/pegasus/scanner.go:84

↓ 5 callersMethodSortKeyCount

Returns the count of sortkeys under hashkey. `hashKey`: CAN'T be nil or empty.

go-client/pegasus/table_connector.go:176

↓ 5 callersMethodString

* todo(jiashuo1) maybe need delete func (m *MigratorNode) primaryCount() int { count := 0 for _, replica := range m.replicas { if replica.operatio

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

↓ 5 callersMethodadd_check_and_set_cu

src/server/capacity_unit_calculator.cpp:339

↓ 5 callersMethodadd_count

src/server/range_read_limiter.h:83

↓ 5 callersMethodadd_mutation_if_valid

src/replica/duplication/mutation_batch.cpp:162

↓ 5 callersMethodas_primary

src/replica/test/mock_utils.h:155

↓ 5 callersMethodasyncMultiDel

(byte[] hashKey, final List<byte[]> sortKeys, int timeout)

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

↓ 5 callersMethodblob_count

src/replica/log_block.h:111

↓ 5 callersFunctionbuf2unsigned

src/utils/string_conv.h:68

↓ 5 callersFunctioncheck_if_ts_expired

\return true if expired

src/base/pegasus_value_schema.h:113

↓ 5 callersFunctionclearDatabase

(t *testing.T, tb TableConnector)

go-client/pegasus/scan_test.go:39

↓ 5 callersMethodclear_context

src/block_service/test/block_service_mock.h:133

↓ 5 callersMethodcollect_serving_replica

src/meta/meta_data.cpp:462

↓ 5 callersMethodcompareSortMap

( NavigableMap<String, String> data, NavigableMap<String, String> base, String hashKey)

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

↓ 5 callersMethodcompress

Compresses the `src` and returns the compressed. @throws RuntimeException if compression failed.

java-client/src/main/java/org/apache/pegasus/tools/ZstdWrapper.java:55

↓ 5 callersMethodconsume_buffer

mark the tailing `sz` of bytes are consumed and discardable.

src/runtime/rpc/message_parser.h:63

↓ 5 callersMethodcreate_node_recursively

src/meta/meta_state_service_utils.cpp:43

↓ 5 callersMethoddata

string_view::data() Returns a pointer to the underlying character array (which is of course stored elsewhere). Note that `string_view::data()` may co

src/utils/string_view.h:285

↓ 5 callersFunctiondecode_node_perf_counter_info

src/shell/command_helper.h:1029

↓ 5 callersMethoddecompress

Decompresses the `src` and returns the original. @param src not null nor empty, or IllegalArgumentException will be thrown. @throws PException if dec

java-client/src/main/java/org/apache/pegasus/tools/ZstdWrapper.java:65

↓ 5 callersFunctiondsn_counter_type_from_string

src/perf_counter/perf_counter.cpp:40

↓ 5 callersFunctiondsn_rpc_call

src/runtime/service_api_c.cpp:156

↓ 5 callersFunctiondsn_rpc_unregiser_handler

src/runtime/service_api_c.cpp:151

↓ 5 callersFunctionencodeHashKeySortKey

(hashKey []byte, sortKey []byte)

go-client/pegasus/util.go:29

↓ 5 callersFunctionencodeHashKeySortKey

(hashKey []byte, sortKey []byte)

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

↓ 5 callersMethodengine

src/runtime/task/task_engine.h:82

↓ 5 callersFunctionerase_map_elem_by_id

src/meta/meta_bulk_load_service.cpp:1420

↓ 5 callersMethodexit

src/replica/storage/simple_kv/test/checker.cpp:238

↓ 5 callersMethodfail_checkpoint

src/replica/backup/cold_backup_context.cpp:128

↓ 5 callersMethodfind_log_file_to_start

src/replica/duplication/load_from_private_log.cpp:124

↓ 5 callersMethodfinished_ops

src/test/bench_test/statistics.cpp:71

← previous next →801–900 of 8,667, ranked by callers