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

↓ 5 callersFunctionfrom_zerror

src/zookeeper/zookeeper_error.cpp:43

↓ 5 callersMethodfull_name

src/perf_counter/perf_counter.h:101

↓ 5 callersMethodgenerate_replica_ptr

helper functions

src/replica/test/mock_utils.h:283

↓ 5 callersMethodgetAppID

java-client/src/main/java/org/apache/pegasus/rpc/Table.java:52

↓ 5 callersMethodgetCredential

credential info. Defaults to {@literal null} @return credential

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

↓ 5 callersMethodgetPartitionCount

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

↓ 5 callersFunctionget_backup_path

src/common/backup_common.cpp:45

↓ 5 callersMethodget_blob_hash

(self, blob_key)

python-client/pypegasus/pgclient.py:373

↓ 5 callersFunctionget_current_cluster_id

src/server/pegasus_write_service.h:59

↓ 5 callersMethodget_dir_node

src/replica/replica.h:295

↓ 5 callersMethodget_hashkey_hash

(self, hash_key)

python-client/pypegasus/pgclient.py:368

↓ 5 callersMethodget_leader

src/meta/meta_server_failure_detector.cpp:102

↓ 5 callersMethodget_learn_state

src/replica/mutation_log.cpp:1084

↓ 5 callersFunctionget_localtime

src/utils/time_utils.h:40

↓ 5 callersMethodget_log_file_map

src/replica/mutation_log.cpp:1649

↓ 5 callersFunctionget_newly_partitions

src/meta/server_load_balancer.cpp:133

↓ 5 callersFunctionget_partition_count

src/meta/cluster_balance_policy.cpp:43

↓ 5 callersMethodget_percentile

src/perf_counter/perf_counter_atomic.h:197

↓ 5 callersMethodget_policy

src/meta/meta_backup_service.cpp:929

↓ 5 callersMethodget_remaining_size

src/utils/binary_reader.h:81

↓ 5 callersFunctionget_replica_backup_path

src/common/backup_common.cpp:55

↓ 5 callersMethodget_response

java-client/src/main/java/org/apache/pegasus/operator/batch_get_operator.java:67

↓ 5 callersMethodget_response

java-client/src/main/java/org/apache/pegasus/operator/rrdb_ttl_operator.java:56

↓ 5 callersMethodget_scanner

Get scanner for hash_key, start from start_sort_key, and stop at stop_sort_key. Whether the scanner include the start_sort_key and st

python-client/pypegasus/pgclient.py:990

↓ 5 callersFunctionget_subpaths

src/utils/filesystem.cpp:255

↓ 5 callersMethodget_token_bucket

src/utils/token_buckets.cpp:25

↓ 5 callersFunctionget_value

generate base on hashkey and sortkey

src/test/pressure_test/main.cpp:103

↓ 5 callersMethodget_value_schema

src/base/value_schema_manager.cpp:48

↓ 5 callersMethodinitialize

src/block_service/test/block_service_mock.h:151

↓ 5 callersMethodinitialize

src/common/fs_manager.cpp:206

↓ 5 callersMethodinitialize_data_structure

src/meta/server_state.cpp:800

↓ 5 callersMethodisAppHealthy

Judge If An App Is 'healthy'(every partition of the app has enough replicas specified by the 'replicaCount' parameter) @param appName App name which

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

↓ 5 callersMethodis_empty

src/runtime/task/task.h:233

↓ 5 callersMethodis_eof

src/utils/binary_reader.h:79

↓ 5 callersFunctionis_node_alive

src/meta/meta_data.h:460

↓ 5 callersMethodis_started

src/runtime/service_app.h:99

↓ 5 callersMethodis_sync_to_child

src/replica/mutation.h:170

↓ 5 callersMethodis_valid

src/test/function_test/partition_split_test/test_split.cpp:115

↓ 5 callersMethodlock

src/zookeeper/distributed_lock_service_zookeeper.cpp:147

↓ 5 callersMethodmatcher

src/runtime/rpc/rpc_engine.h:178

↓ 5 callersFunctionnewMetaSession

go-client/session/session_test.go:48

↓ 5 callersFunctionnewNodeSessionAddr

(addr string, ntype NodeType)

go-client/session/session.go:114

↓ 5 callersMethodon_duplicate_reply

src/server/pegasus_mutation_duplicator.cpp:153

↓ 5 callersMethodon_get

src/server/pegasus_server_impl.cpp:328

↓ 5 callersMethodon_partition_reset

src/replica/mutation_log.cpp:1006

↓ 5 callersMethodoneMetricToJson

(FalconMetric metric, StringBuilder output)

java-client/src/main/java/org/apache/pegasus/metrics/MetricsPool.java:79

↓ 5 callersMethodoperate_1_server

(cls, op_type, server_type, index)

python-client/tests/test_integration.py:69

↓ 5 callersFunctionparse_as

src/utils/metrics.cpp:244

↓ 5 callersMethodparse_from_string

src/utils/fail_point.cpp:113

↓ 5 callersFunctionpegasus_generate_next_blob

src/base/pegasus_key_schema.h:65

↓ 5 callersFunctionprintEndingContext

(run func(*grumble.Context) error)

pegic/interactive/cmd/init.go:69

↓ 5 callersMethodpush

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

↓ 5 callersMethodput_front

src/utils/join_point.h:76

↓ 5 callersMethodremove_partition

src/meta/meta_data.cpp:633

↓ 5 callersFunctionreseed_thread_local_rng

src/utils/rand.cpp:31

↓ 5 callersFunctionretryFailOver

retryFailOver retries the operation when it encounters replica fail-over, until context reaches deadline.

go-client/pegasus/retry_failover.go:32

↓ 5 callersFunctionrun

src/runtime/service_api_c.cpp:380

↓ 5 callersFunctionsdsempty

Create an empty (zero length) sds string. Even in this case the string * always has an implicit null term. */

src/shell/sds/sds.c:142

↓ 5 callersFunctionsdsinclen

src/shell/sds/sds.h:157

↓ 5 callersMethodset_context

src/block_service/test/block_service_mock.h:125

↓ 5 callersMethodset_partition_status

src/replica/test/mock_utils.h:171

↓ 5 callersMethodset_policy

src/meta/meta_backup_service.cpp:913

↓ 5 callersMethodset_replicas_collect_flag

src/meta/meta_data.h:426

↓ 5 callersMethodset_result

src/server/result_writer.cpp:45

↓ 5 callersFunctionshutdownReplica

(meta Meta, gpid *base.Gpid, node *base.RPCAddress)

admin-cli/client/replica_health_test.go:38

↓ 5 callersMethodsignal

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

↓ 5 callersFunctionspin_wait

src/runtime/test/async_call.cpp:212

↓ 5 callersMethodtake_snapshot

src/perf_counter/perf_counters.cpp:368

↓ 5 callersMethodtid

src/replica/mutation.h:85

↓ 5 callersMethodto

src/base/pegasus_utils.h:64

↓ 5 callersMethodto_json_blob

src/meta/duplication/duplication_info.cpp:185

↓ 5 callersMethodtop

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

↓ 5 callersFunctiontracer_log_flow_error

src/runtime/tracer.cpp:255

↓ 5 callersMethodtry_lock_meta_op_status

src/meta/meta_service.cpp:271

↓ 5 callersFunctionvalidateSortKey

(sortKey []byte)

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

↓ 5 callersFunctionverify_file

src/utils/filesystem.cpp:823

↓ 5 callersMethodwhen_disconnected

src/failure_detector/test/failure_detector.cpp:122

↓ 5 callersMethodwrite_to

src/replica/mutation.cpp:192

↓ 4 callersMethodBalance

(gpid *base.Gpid, opType BalanceType, from *util.PegasusNode, to *util.PegasusNode)

admin-cli/client/meta.go:93

↓ 4 callersMethodBatchGet

Gets values from a batch of CompositeKeys. Internally it distributes each key into a Get call and wait until all returned. `keys`: CAN'T be nil or em

go-client/pegasus/table_connector.go:193

↓ 4 callersMethodCall

Call a remote command to an existing session.

go-client/admin/remote_cmd_client.go:56

↓ 4 callersMethodDiskMigrate

DiskMigrate is auto-generated

go-client/session/radmin_rpc_types.go:47

↓ 4 callersMethodDropTable

(ctx context.Context, tableName string)

go-client/admin/client.go:38

↓ 4 callersMethodListApps

(status admin.AppStatus)

admin-cli/client/meta.go:65

↓ 4 callersMethodMockUnMarshal

(unmarshal UnmarshalFunc)

go-client/session/codec.go:408

↓ 4 callersMethodModifyDuplication

(tableName string, dupid int, status admin.DuplicationStatus)

admin-cli/client/meta.go:83

↓ 4 callersFunctionNewClient

NewClient returns an instance of Client.

go-client/admin/client.go:56

↓ 4 callersFunctionOverloaded

src/utils/test/autoref_ptr_test.cpp:120

↓ 4 callersFunctionPrintSingleSummary

(client *Client, tableName string, pidx int32, partitionStatus admin.BulkLoadStatus)

admin-cli/executor/bulk_load.go:426

↓ 4 callersMethodPut

(ctx context.Context, gpid *base.Gpid, partitionHash uint64, update *rrdb.UpdateRequest)

go-client/session/replica_session.go:48

↓ 4 callersMethodWrite

(msgBytes []byte)

go-client/rpc/rpc_conn.go:154

↓ 4 callersFunction__lock_cb_bind_and_enqueue

src/meta/distributed_lock_service_simple.cpp:47

↓ 4 callersMethodadd_bytes

src/test/bench_test/statistics.cpp:139

↓ 4 callersMethodadd_sortkey_count_cu

src/server/capacity_unit_calculator.cpp:244

↓ 4 callersMethodadd_sub_tracer

src/utils/latency_tracer.cpp:173

↓ 4 callersMethodadd_ttl_cu

src/server/capacity_unit_calculator.cpp:256

↓ 4 callersFunctionapp_mapper_compare

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

↓ 4 callersMethodappend_buffer

src/meta/dump_file.h:86

↓ 4 callersMethodasyncCommitRequests

(List<Request> requests)

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

↓ 4 callersMethodasyncDel

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

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

← previous next →901–1,000 of 8,667, ranked by callers