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

↓ 27 callersMethodcall

(ctx context.Context, callFunc metaCallFunc)

go-client/session/meta_session.go:95

↓ 27 callersMethodcancel

src/runtime/task/task.cpp:307

↓ 27 callersFunctioncold_backup_status_to_string

src/replica/backup/cold_backup_context.cpp:41

↓ 27 callersFunctioncreate_task

src/runtime/task/async_calls.h:62

↓ 27 callersMethodenqueue

src/runtime/task/task.cpp:373

↓ 27 callersFunctionepoch_now

src/base/pegasus_utils.h:42

↓ 27 callersMethodget_request

src/runtime/task/task.h:425

↓ 27 callersFunctionhh_mm_today_to_unix_sec

local time `hh:mm` to unix timestamp. eg. `18:10` => `1525947000` when called on May 10, 2018, CST Return: -1 when invalid

src/utils/time_utils.h:124

↓ 27 callersFunctionis_empty

src/utils/strings.h:40

↓ 27 callersMethodmulti_set

Set multiple sort_keys-values under hash_key to be stored. :param hash_key: (bytes) which hash key used for this API. :param

python-client/pypegasus/pgclient.py:830

↓ 27 callersMethodresize

src/redis_protocol/proxy_lib/redis_parser.h:104

↓ 27 callersMethodto_std_string

src/runtime/rpc/rpc_address.h:119

↓ 27 callersMethodttl

sync version of TTL, please refer to the async version {@link #asyncTTL(byte[], byte[], int)}

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

↓ 27 callersMethodwait

src/runtime/task/task.cpp:272

↓ 26 callersMethodTransform

src/server/hashkey_transform.h:40

↓ 26 callersFunctionbuf2double

src/utils/string_conv.h:144

↓ 26 callersFunctionclose

src/aio/file_io.cpp:50

↓ 26 callersMethodend_offset

end offset in the global space: end_offset = start_offset + file_size

src/replica/log_file.h:179

↓ 26 callersMethodfromIpPort

(String ipPort)

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

↓ 26 callersFunctionget_current_tid

src/utils/process_utils.h:59

↓ 26 callersMethodget_data

src/meta/meta_state_service_utils.cpp:95

↓ 26 callersFunctionget_node_state

src/meta/meta_data.h:447

↓ 26 callersMethodget_response

src/runtime/task/task.h:483

↓ 26 callersMethodleader

src/runtime/rpc/group_address.h:68

↓ 26 callersMethodpath

src/replica/replica_http_service.h:54

↓ 26 callersFunctionpegasus_key_hash

src/base/pegasus_key_schema.h:150

↓ 26 callersMethodrange

offset can be negative for buffer dereference

src/utils/blob.h:120

↓ 26 callersMethodtype

src/runtime/rpc/rpc_host_port.h:61

↓ 26 callersFunctionunescape_str

src/shell/commands/data_operations.cpp:2617

↓ 26 callersMethodvalue

src/utils/test/metrics_test.cpp:53

↓ 25 callersMethodPrint

(args ...interface{})

go-client/pegalog/logger.go:35

↓ 25 callersFunctioncreate_corresponding_receive

src/meta/test/meta_service_test_app.h:82

↓ 25 callersMethodfind_replica

src/replica/test/mock_utils.h:271

↓ 25 callersFunctionget_file_name

src/utils/filesystem.cpp:583

↓ 25 callersMethodid

src/runtime/task/task.h:224

↓ 25 callersMethodisEmpty

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

↓ 25 callersFunctionmequals

src/utils/strings.cpp:107

↓ 25 callersMethodread

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

↓ 25 callersMethodset_node_state

visited in protection of failure_detector::_lock

src/meta/meta_service.cpp:232

↓ 25 callersFunctiontime_ms_to_date_time

get date string with format of 'yyyy-MM-dd hh:mm:ss' from given timestamp(ms)

src/utils/time_utils.h:61

↓ 24 callersFunctiondestroy_message

release the dsn_message who's reference is 0

src/meta/test/meta_service_test_app.h:113

↓ 24 callersFunctiondsn_primary_address

src/runtime/service_api_c.cpp:142

↓ 24 callersFunctionget_config

src/meta/meta_data.h:468

↓ 24 callersFunctionis_secondary

src/common/replication_other_types.h:64

↓ 24 callersMethodset_filter

src/meta/test/meta_partition_guardian_test.cpp:147

↓ 24 callersMethodwait

src/utils/hpc_locks/sema.h:40

↓ 23 callersMethodGet

Get retrieves the entry for `hashKey` + `sortKey`. Returns nil if no entry matches. `hashKey` : CAN'T be nil or empty. `sortKey` : CAN'T be nil but CA

go-client/pegasus/table_connector.go:93

↓ 23 callersFunctionNewClient

NewClient creates a new instance of pegasus client. It panics if the configured addresses are illegal.

go-client/pegasus/client.go:53

↓ 23 callersMethodcancel_outstanding_tasks

src/runtime/task/task_tracker.cpp:112

↓ 23 callersMethodcompare

string_view::compare() Performs a lexicographical comparison between the `string_view` and another `dsn::string_view), returning -1 if `this` is less

src/utils/string_view.h:352

↓ 23 callersMethodfrom_string_ipv4

src/runtime/rpc/rpc_address.cpp:195

↓ 23 callersFunctionopen_read

src/replica/mutation_log_utils.cpp:39

↓ 23 callersMethodpartition_count

src/meta/meta_data.cpp:691

↓ 23 callersMethodskip

src/utils/endians.h:123

↓ 23 callersMethodtimeout

( String metaList, String tableName, Request request, int timeout, TimeoutException e)

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

↓ 23 callersMethodwrite

(TProtocol oprot)

java-client/src/main/java/org/apache/pegasus/base/blob.java:183

↓ 22 callersMethodCallWithGpid

Invoke an rpc call.

go-client/session/session.go:60

↓ 22 callersMethodQueryConfig

(tableName string)

admin-cli/client/meta.go:67

↓ 22 callersMethodenqueue

src/aio/aio_task.cpp:80

↓ 22 callersMethodlast_committed_decree

src/replica/split/replica_split_manager.h:211

↓ 22 callersMethodrpc_code

src/runtime/rpc/rpc_message.cpp:111

↓ 22 callersMethodvalue

src/common/gpid.h:44

↓ 21 callersMethodSet

Set the entry for `hashKey` + `sortKey` to `value`. If Set is called or `ttl` == 0, no data expiration is specified. `hashKey` : CAN'T be nil or empty

go-client/pegasus/table_connector.go:99

↓ 21 callersMethodadd_row

src/utils/output_utils.h:111

↓ 21 callersMethoddecode

src/common/json_helper.h:667

↓ 21 callersMethodgetGpidByHash

(long hashValue)

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

↓ 21 callersFunctionget_subfiles

src/utils/filesystem.cpp:325

↓ 21 callersFunctionhost_ipv4

src/runtime/test/address_test.cpp:40

↓ 21 callersMethodnewPromise

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

↓ 21 callersMethodopenTable

Open a table, and prepare the sessions and route-table to the replica-servers. <p>Please notice that pegasus support two kinds of API: 1. the client-

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

↓ 21 callersMethodread

(TProtocol iprot)

java-client/src/main/java/org/apache/pegasus/base/blob.java:175

↓ 21 callersMethodswap

src/utils/zlocks.h:133

↓ 20 callersMethodDel

Delete the entry for `hashKey` + `sortKey`. `hashKey` : CAN'T be nil or empty. `sortKey` : CAN'T be nil but CAN be empty.

go-client/pegasus/table_connector.go:105

↓ 20 callersMethodcancel

src/replica/backup/cold_backup_context.cpp:70

↓ 20 callersMethoddecode_from_value

src/geo/lib/latlng_codec.cpp:62

↓ 20 callersFunctionfrom_thrift_request_to_received_message

src/runtime/message_utils.h:65

↓ 20 callersMethodgenerateNextBytes

(byte[] hashKey)

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

↓ 20 callersFunctionget_config_context

src/meta/meta_data.h:484

↓ 20 callersMethodget_gpid

src/replica/replica_base.h:48

↓ 20 callersMethodget_logname

src/meta/meta_data.h:371

↓ 20 callersMethodget_replica_stub

src/replica/replica.h:245

↓ 20 callersMethodoperate

(self, op, timeout=None)

python-client/pypegasus/pgclient.py:92

↓ 20 callersFunctionpegasus_restore_key

restore hash_key and sort_key from rocksdb key. no data copied.

src/base/pegasus_key_schema.h:102

↓ 20 callersMethodset_leader

src/runtime/rpc/group_address.h:142

↓ 20 callersMethodthreadInterrupted

(String tableName, InterruptedException e)

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

↓ 20 callersMethodwrite

src/utils/blob.h:206

↓ 19 callersMethodClose

go-client/session/session.go:65

↓ 19 callersMethodError

admin-cli/client/remote_command.go:48

↓ 19 callersMethodadd_title

src/utils/output_utils.cpp:63

↓ 19 callersMethodbuild

Create a new instance of {@link ClientOptions}. @return new instance of {@link ClientOptions}.

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

↓ 19 callersMethodbuilder

Returns a new {@link ClientOptions.Builder} to construct {@link ClientOptions}. @return a new {@link ClientOptions.Builder} to construct {@link Clien

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

↓ 19 callersMethoddelete_node

src/meta/meta_state_service_utils.cpp:69

↓ 19 callersFunctiondsn_counter_type_to_string

src/perf_counter/perf_counter.cpp:33

↓ 19 callersMethodequals

java-client/src/main/java/org/apache/pegasus/base/blob.java:147

↓ 19 callersMethodfull_name

src/runtime/service_engine.h:82

↓ 19 callersMethodgetReplicaSession

(rpc_address address)

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

↓ 19 callersFunctionhh_mm_to_seconds

`hh:mm` (range in [00:00, 23:59]) to seconds since 00:00:00 eg. `01:00` => `3600` Return: -1 when invalid

src/utils/time_utils.h:111

↓ 19 callersMethodprimary_count

src/meta/meta_data.cpp:683

↓ 19 callersMethodrdbuf

src/shell/argh.h:82

↓ 19 callersMethodtracker

src/meta/server_state.h:222

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