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

↓ 7 callersMethodget_duplication_manager

src/replica/replica.h:254

↓ 7 callersMethodget_function_level

src/meta/meta_service.h:161

↓ 7 callersFunctionget_hash_from_request

src/server/pegasus_mutation_duplicator.cpp:71

↓ 7 callersMethodget_ip

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

↓ 7 callersMethodget_message_on_receive

src/http/http_message_parser.cpp:160

↓ 7 callersMethodget_pool

task management routines

src/runtime/task/task_engine.h:122

↓ 7 callersMethodget_replica_follower

src/replica/replica.h:286

↓ 7 callersMethodget_response

java-client/src/main/java/org/apache/pegasus/operator/rrdb_check_and_mutate_operator.java:59

↓ 7 callersFunctionget_unix_sec_today_midnight

get unix timestamp of today's zero o'clock. eg. `1525881600` returned when called on May 10, 2018, CST

src/utils/time_utils.h:97

↓ 7 callersFunctionget_worker_and_master

src/failure_detector/test/failure_detector.cpp:279

↓ 7 callersMethodignore_checkpoint

ignore generating checkpoint and switch backward status. ColdBackupCheckpointing --> ColdBackupChecked Returns: - true if status is successfully chang

src/replica/backup/cold_backup_context.h:197

↓ 7 callersMethodinit_private_log

src/replica/test/mock_utils.h:139

↓ 7 callersMethodinit_progress

src/meta/duplication/duplication_info.cpp:114

↓ 7 callersMethodinitialize_bulk_load_service

ThreadPool: THREAD_POOL_META_SERVER

src/meta/meta_bulk_load_service.cpp:86

↓ 7 callersMethodis_client

Whether this session is launched on client side.

src/runtime/rpc/network.h:226

↓ 7 callersMethodis_primary

src/replica/replication_app_base.cpp:269

↓ 7 callersFunctionjson_encode

src/utils/output_utils.cpp:30

↓ 7 callersMethodlist_dir

src/block_service/test/block_service_mock.h:153

↓ 7 callersMethodmove_all_mutations

src/replica/duplication/mutation_batch.cpp:137

↓ 7 callersMethodmulti_put

src/server/pegasus_write_service.cpp:174

↓ 7 callersMethodmulti_remove

src/server/pegasus_write_service.cpp:190

↓ 7 callersFunctionnewNodeSession

(addr string, ntype NodeType)

go-client/session/session.go:137

↓ 7 callersMethodparse_from

src/utils/gpid.cpp:33

↓ 7 callersMethodread

src/block_service/test/block_service_mock.h:63

↓ 7 callersFunctionrecover

src/shell/commands/recovery.cpp:45

↓ 7 callersFunctionregister_rpc_access_type

Register access types of 'rpc_codes' as 'ac_type' to 'ac_type_of_rpc'. TODO(wanghao): A better way is to define the ac_type when defining rpc, and tra

src/runtime/ranger/ranger_resource_policy_manager.cpp:113

↓ 7 callersMethodremove

Remove the entire <hash_key, sort_key>-value in pegasus. :param hash_key: (bytes) which hash key used for this API. :param s

python-client/pypegasus/pgclient.py:786

↓ 7 callersFunctionremove_file_name

src/utils/filesystem.cpp:561

↓ 7 callersMethodremove_replica

src/common/fs_manager.cpp:338

↓ 7 callersMethodreset

src/utils/metrics.h:928

↓ 7 callersMethodsignal

src/runtime/zlocks.cpp:178

↓ 7 callersMethodsplit_replica_error_handler

ThreadPool: THREAD_POOL_REPLICATION

src/replica/replica_stub.cpp:3056

↓ 7 callersMethodsplit_replica_exec

ThreadPool: THREAD_POOL_REPLICATION

src/replica/replica_stub.cpp:3062

↓ 7 callersMethodsubString

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

↓ 7 callersMethodtask_tracker

src/runtime/task/task_tracker.cpp:37

↓ 7 callersMethodto_string

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

↓ 7 callersMethodtracker

src/replica/replica.h:247

↓ 7 callersMethodtruncate

src/replica/prepare_list.cpp:65

↓ 7 callersMethodtryConnect

Connects to remote host if it is currently disconnected. @return a nullable ChannelFuture.

java-client/src/main/java/org/apache/pegasus/rpc/async/ReplicaSession.java:188

↓ 7 callersMethodtry_lock

src/runtime/task/task_engine.sim.cpp:164

↓ 7 callersMethodtype

src/utils/metrics.h:587

↓ 7 callersMethodtype

src/replica/storage/simple_kv/test/case.h:417

↓ 7 callersMethodunlock

src/utils/synchronize.h:42

↓ 7 callersMethodunlock_write

src/runtime/zlocks.cpp:152

↓ 7 callersMethodupdate_status_if_needed

src/replica/duplication/replica_duplicator.cpp:149

↓ 7 callersFunctionvalidate_filter

return true if the data is valid for the filter

src/shell/command_helper.h:239

↓ 6 callersMethodDecodeAll

decode from bytes to string

pegic/executor/util/encoding.go:36

↓ 6 callersMethodFatal

(args ...interface{})

go-client/pegalog/logger.go:33

↓ 6 callersMethodGetAllNodes

GetAllNodes returns all nodes that matches the type. The result could be inconsistent with the latest cluster state. Please use MetaManager.ListNodes

admin-cli/util/pegasus_node.go:193

↓ 6 callersMethodMultiDel

MultiDel deletes the multiple entries under `hashKey` all atomically in one operation. `hashKey` / `sortKeys` : CAN'T be nil or empty. `sortKeys[i]` :

go-client/pegasus/table_connector.go:144

↓ 6 callersMethodMultiGetOpt

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

go-client/pegasus/table_connector.go:119

↓ 6 callersMethodName

NOTE: You must change the name if Transform() algorithm changed.

src/server/hashkey_transform.h:38

↓ 6 callersMethodRead

(iprot thrift.TProtocol)

go-client/session/codec.go:421

↓ 6 callersMethodRead

Read is not intended to be cancellable using context by outside user. The only approach to cancel the operation is to close the connection. If the cur

go-client/rpc/rpc_conn.go:180

↓ 6 callersFunctionResolveMetaAddr

ResolveMetaAddr into a list of TCP4 addresses. Error is returned if the given `addrs` are not either a list of valid TCP4 addresses, or a resolvable h

go-client/session/addr.go:29

↓ 6 callersMethodSetTTL

(ctx context.Context, hashKey []byte, sortKey []byte, value []byte, ttl time.Duration)

go-client/pegasus/table_connector.go:100

↓ 6 callersMethodadd_check_and_mutate_cu

src/server/capacity_unit_calculator.cpp:361

↓ 6 callersMethodadd_client_request

src/replica/mutation.cpp:162

↓ 6 callersMethodadd_list

src/runtime/rpc/group_address.h:46

↓ 6 callersFunctionaddress_to_node

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

↓ 6 callersMethodappend

src/replica/storage/simple_kv/simple_kv.client.h:138

↓ 6 callersMethodasyncExist

Check value existence for a specific (hashKey, sortKey) pair of current table, async version @param hashKey used to decide which partition the key ma

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

↓ 6 callersMethodasyncSet

Set value for a specific (hashKey, sortKey) pair, async version @param hashKey used to decide which partition the key may exist if null or empty, mea

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

↓ 6 callersMethodasync_del

src/geo/lib/geo_client.cpp:310

↓ 6 callersMethodcan_select

src/meta/app_balance_policy.cpp:164

↓ 6 callersMethodcapture_data

src/server/hotkey_collector.cpp:342

↓ 6 callersMethodcheckAndPutSortMap

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

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

↓ 6 callersFunctioncheck_if_record_expired

\return true if expired

src/base/pegasus_value_schema.h:119

↓ 6 callersFunctioncheck_map_contains

src/perf_counter/test/perf_counters_test.cpp:117

↓ 6 callersMethodclear

src/runtime/scheduler.cpp:108

↓ 6 callersFunctionconstruct_replica

src/meta/meta_data.cpp:124

↓ 6 callersFunctioncopy_file

src/replica/test/mutation_log_test.cpp:69

↓ 6 callersMethodcrc64

(cls, data, offset, length)

python-client/pypegasus/pgclient.py:556

↓ 6 callersFunctioncrc64Hash

go-client/pegasus/util.go:66

↓ 6 callersMethodcreate_file

src/replica/test/backup_block_service_mock.h:44

↓ 6 callersMethoddelRange

Delete key-values within range of startSortKey and stopSortKey under hashKey. Will terminate immediately if any error occurs. @param tableName table

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

↓ 6 callersMethoddo_recovery

src/client/replication_ddl_client.cpp:892

↓ 6 callersFunctiondsn_percentile_type_from_string

src/perf_counter/perf_counter.cpp:57

↓ 6 callersFunctiondsn_run

run the system with arguments config [-cargs k1=v1;k2=v2] [-app_list app_name1@index1;app_name2@index] e.g., config.ini -app_list replica@1 to start t

src/runtime/service_api_c.cpp:270

↓ 6 callersMethodempty

src/server/test/hotkey_collector_test.cpp:112

↓ 6 callersMethodepoch_now

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

↓ 6 callersMethodexecute

(client_operator op, int maxExecuteCount)

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

↓ 6 callersMethodexecute_balance

src/meta/load_balance_policy.cpp:357

↓ 6 callersMethodfind

src/http/http_call_registry.h:35

↓ 6 callersFunctionfind_outlier_index

68–95–99.7 rule, same algorithm as hotspot_partition_calculator::stat_histories_analyse extern*/

src/server/hotkey_collector.cpp:80

↓ 6 callersFunctionflush

src/aio/file_io.cpp:61

↓ 6 callersMethodflush

src/replica/log_file.cpp:202

↓ 6 callersMethodfor_each_partition

src/meta/meta_data.cpp:657

↓ 6 callersMethodgenerate_key

(cls, hash_key, sort_key)

python-client/pypegasus/pgclient.py:589

↓ 6 callersMethodgenerate_value

src/base/value_schema_v1.cpp:69

↓ 6 callersMethodgetErrorType

java-client/src/main/java/org/apache/pegasus/rpc/ReplicationException.java:51

↓ 6 callersMethodgetLong

(Properties config, String key, long defaultValue)

java-client/src/main/java/org/apache/pegasus/util/PropertyUtils.java:43

↓ 6 callersMethodgetMetaServiceError

(client_operator metaQueryOp)

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

↓ 6 callersMethodgetMutations

java-client/src/main/java/org/apache/pegasus/client/Mutations.java:69

↓ 6 callersFunctionget_database_name_from_app_name

src/runtime/ranger/ranger_resource_policy_manager.cpp:643

↓ 6 callersMethodget_ingestion_status

src/replica/test/mock_utils.h:198

↓ 6 callersMethodget_meta_service

src/meta/meta_backup_service.h:355

↓ 6 callersMethodget_replica_config

src/replica/replica_context.cpp:130

↓ 6 callersMethodget_smart_wrapper

src/client_lib/pegasus_scanner_impl.cpp:161

↓ 6 callersMethodget_value<bool>

src/utils/configuration.h:212

← previous next →701–800 of 8,667, ranked by callers