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
↓ 1 callersMethodMultiGetOpt
(ctx context.Context, hashKey []byte, sortKeys [][]byte, options *MultiGetOptions)
go-client/pegasus/table_connector.go:395
↓ 1 callersMethodMultiGetRangeOpt
(ctx context.Context, hashKey []byte, startSortKey []byte, stopSortKey []byte, options *MultiGetOptions)
go-client/pegasus/table_connector.go:409
↓ 1 callersMethodMultiSetOpt
(ctx context.Context, hashKey []byte, sortKeys [][]byte, values [][]byte, ttl time.Duration)
go-client/pegasus/table_connector.go:441
↓ 1 callersFunctionNew
New creates a tablewriter.Table and allows customizing the table. Each element should be a simple struct (not pointer) with a number of fields. Each
admin-cli/tabular/printer.go:47
↓ 1 callersFunctionNewLogrusLogger
NewLogrusLogger creates a new LogrusLogger.
go-client/pegalog/logrus_logger.go:47
↓ 1 callersFunctionNewPegasusCodec
()
go-client/session/codec.go:44
↓ 1 callersFunctionNewRPCAddress
(ip net.IP, port int)
go-client/idl/base/rpc_address.go:34
↓ 1 callersFunctionNewRemoteCmdClient
NewRemoteCmdClient returns an instance of RemoteCmdClient.
go-client/admin/remote_cmd_client.go:34
↓ 1 callersMethodNext
(toRead int)
go-client/rpc/stream_in.go:71
↓ 1 callersFunctionPrintAllCleanupFlag
(client *Client, resp *admin.QueryBulkLoadResponse, detailed bool)
admin-cli/executor/bulk_load.go:240
↓ 1 callersFunctionPrintAllDownloading
(client *Client, resp *admin.QueryBulkLoadResponse, detailed bool)
admin-cli/executor/bulk_load.go:116
↓ 1 callersFunctionPrintAllIngestion
(client *Client, resp *admin.QueryBulkLoadResponse, detailed bool)
admin-cli/executor/bulk_load.go:170
↓ 1 callersFunctionPrintAllOthers
(client *Client, resp *admin.QueryBulkLoadResponse, detailed bool)
admin-cli/executor/bulk_load.go:215
↓ 1 callersFunctionPrintSingleCleanupFlag
(client *Client, resp *admin.QueryBulkLoadResponse, partitionIndex int, detailed bool)
admin-cli/executor/bulk_load.go:366
↓ 1 callersFunctionPrintSingleDownloading
(client *Client, resp *admin.QueryBulkLoadResponse, partitionIndex int, detailed bool)
admin-cli/executor/bulk_load.go:288
↓ 1 callersFunctionPrintSingleIngesting
(client *Client, resp *admin.QueryBulkLoadResponse, partitionIndex int, detailed bool)
admin-cli/executor/bulk_load.go:337
↓ 1 callersFunctionPrintSinglePausing
(client *Client, resp *admin.QueryBulkLoadResponse, partitionIndex int, detailed bool)
admin-cli/executor/bulk_load.go:397
↓ 1 callersFunctionQueryAllNodesDiskInfo
(client *Client, tableName string)
admin-cli/executor/disk_info.go:83
↓ 1 callersFunctionQueryDiskCapacityInfo
(client *executor.Client, replicaServer string)
admin-cli/executor/toolkits/diskbalancer/migrator.go:87
↓ 1 callersFunctionQueryReplicaDataVersion
(client *Client, table string)
admin-cli/executor/table_version.go:47
↓ 1 callersFunctionRPC_MOCKING
src/server/test/pegasus_mutation_duplicator_test.cpp:396
↓ 1 callersMethodRead
([]byte)
go-client/session/session_timeout_test.go:50
↓ 1 callersMethodRead
(iprot thrift.TProtocol)
go-client/idl/base/error_code.go:123
↓ 1 callersMethodRead
(iprot thrift.TProtocol)
go-client/idl/base/gpid.go:32
↓ 1 callersFunctionReadRpcResponse
(conn *rpc.RpcConn, codec rpc.Codec)
go-client/session/codec.go:469
↓ 1 callersFunctionReadZkData
(zkConn *zk.Conn, root string, table string)
admin-cli/executor/toolkits/tablemigrator/switcher.go:89
↓ 1 callersMethodRecallApp
(originTableID int, newTableName string)
admin-cli/client/meta.go:91
↓ 1 callersMethodRestoreApp
(oldClusterName string, oldTableName string, oldTableID int, backupID int64, providerType string, newTableNa
admin-cli/client/meta.go:101
↓ 1 callersMethodScan
(ctx context.Context, gpid *base.Gpid, partitionHash uint64, request *rrdb.ScanRequest)
go-client/session/replica_session.go:126
↓ 1 callersFunctionSetAppEnv
SetAppEnv command
admin-cli/executor/table_env.go:63
↓ 1 callersMethodSetDefaultTTL
src/server/key_ttl_compaction_filter.h:165
↓ 1 callersMethodSetPartitionIndex
src/server/key_ttl_compaction_filter.h:170
↓ 1 callersMethodSetPegasusDataVersion
src/server/key_ttl_compaction_filter.h:160
↓ 1 callersFunctionSetRPCTimeout
SetRPCTimeout is the global timeout setting of RPC.
admin-cli/client/options.go:27
↓ 1 callersMethodSetTTL
(ctx context.Context, hashKey []byte, sortKey []byte, value []byte, ttl time.Duration)
go-client/pegasus/table_connector.go:368
↓ 1 callersMethodSetValidatePartitionHash
src/server/key_ttl_compaction_filter.h:166
↓ 1 callersFunctionShowPartitionCount
(client *Client, tableName string)
admin-cli/executor/table_partitions.go:60
↓ 1 callersMethodStartBackupApp
(tableID int, providerType string, backupPath string)
admin-cli/client/meta.go:97
↓ 1 callersMethodString
()
go-client/session/codec.go:414
↓ 1 callersMethodString
()
go-client/idl/base/dsn_err_string.go:14
↓ 1 callersMethodString
()
go-client/idl/base/rocskdb_err_string.go:15
↓ 1 callersFunctionSwitchMetaAddrs
(client *executor.Client, zkAddr string, zkRoot string, tableName string, targetAddrs string)
admin-cli/executor/toolkits/tablemigrator/switcher.go:34
↓ 1 callersMethodTEST_set_repeat_delay
src/replica/duplication/load_from_private_log.h:76
↓ 1 callersMethodTTL
-2 means entry not found.
go-client/pegasus/table_connector.go:453
↓ 1 callersMethodTilNow
()
go-client/session/codec.go:448
↓ 1 callersMethodTrace
()
go-client/session/codec.go:441
↓ 1 callersMethodValidate
Validate if ScanCommand is valid.
pegic/executor/scan.go:107
↓ 1 callersMethodValidate
()
go-client/pegasus/op/op.go:31
↓ 1 callersFunctionWriteZkData
(zkConn *zk.Conn, root string, table string, cluster string, addrs string)
admin-cli/executor/toolkits/tablemigrator/switcher.go:109
↓ 1 callersFunction__err_cb_bind_and_enqueue
src/meta/meta_state_service_simple.cpp:77
↓ 1 callersMethod__init__
(self, message, errs=None)
scripts/run-clang-format.py:127
↓ 1 callersMethod__init__
(self, trans, func, rbuf_size=DEFAULT_BUFFER)
python-client/pypegasus/transport/protocol.py:43
↓ 1 callersMethodabandonIt
(error_code.error_types err, TMessage header)
java-client/src/main/java/org/apache/pegasus/rpc/async/ReplicaSession.java:472
↓ 1 callersMethodack_parent
ThreadPool: THREAD_POOL_REPLICATION
src/replica/split/replica_split_manager.cpp:1329
↓ 1 callersMethodack_prepare_message
src/replica/replica_2pc.cpp:780
↓ 1 callersMethodacquire_leader_lock
src/meta/meta_server_failure_detector.cpp:148
↓ 1 callersFunctionacquire_prefix
if str = "prefix.xxx" then return prefix else return ""
src/meta/test/server_state_test.cpp:79
↓ 1 callersMethodadd
src/perf_counter/perf_counter_atomic.h:174
↓ 1 callersMethodadd
(byte[] sortKey)
java-client/src/main/java/org/apache/pegasus/client/request/MultiDelete.java:42
↓ 1 callersMethodadd
(byte[] sortKey)
java-client/src/main/java/org/apache/pegasus/client/request/MultiGet.java:42
↓ 1 callersMethodaddDuplication
(ctx context.Context, req *admin.DuplicationAddRequest)
go-client/session/admin_rpc_types.go:180
↓ 1 callersMethodaddTimer
(final int seqID, long timeoutInMillseconds)
java-client/src/main/java/org/apache/pegasus/rpc/async/ReplicaSession.java:374
↓ 1 callersMethodadd_allow_list
src/failure_detector/failure_detector.cpp:306
↓ 1 callersMethodadd_checker
src/runtime/scheduler.cpp:212
↓ 1 callersMethodadd_dup
src/client/replication_ddl_client.cpp:1378
↓ 1 callersMethodadd_event
src/runtime/scheduler.cpp:57
↓ 1 callersMethodadd_group_validator
src/utils/flags.cpp:284
↓ 1 callersFunctionadd_hook
(name, path, func, args)
scripts/compile_thrift.py:212
↓ 1 callersMethodadd_log_file
src/replica/test/mock_utils.h:431
↓ 1 callersMethodadd_meta_server
(self, meta_addr)
python-client/pypegasus/pgclient.py:249
↓ 1 callersMethodadd_ref
src/zookeeper/zookeeper_session.h:168
↓ 1 callersMethodadd_replica
src/common/fs_manager.cpp:255
↓ 1 callersMethodadd_system_event
src/runtime/scheduler.cpp:75
↓ 1 callersMethodadd_task
src/runtime/scheduler.cpp:182
↓ 1 callersMethodadd_timer
src/runtime/task/task_engine.cpp:138
↓ 1 callersMethodadd_validator
src/utils/flags.cpp:274
↓ 1 callersFunctionaddr2host
src/base/pegasus_utils.cpp:35
↓ 1 callersMethodaddress
src/runtime/rpc/asio_net_provider.h:110
↓ 1 callersMethodaddress_to_node_name
src/replica/storage/simple_kv/test/checker.cpp:386
↓ 1 callersMethodadjust_dropped_size
src/meta/test/update_configuration_test.cpp:296
↓ 1 callersMethodadjust_proposal
src/meta/meta_data.cpp:476
↓ 1 callersFunctionaggregateNodeState
(resp *replication.QueryCfgResponse, nodesPtr *map[string]*NodeState)
admin-cli/client/replica_health.go:99
↓ 1 callersFunctionaggregateTableHealthInfo
(resp *replication.QueryCfgResponse)
admin-cli/client/replica_health.go:72
↓ 1 callersMethodapp_envs_basic_test
src/meta/test/server_state_test.cpp:89
↓ 1 callersMethodapp_name
src/replica/replica_base.h:52
↓ 1 callersMethodappend_if_valid_for_query
src/meta/duplication/duplication_info.cpp:234
↓ 1 callersMethodappend_sync
---------- call RPC_SIMPLE_KV_SIMPLE_KV_APPEND ------------ - synchronous
src/replica/storage/simple_kv/simple_kv.client.h:121
↓ 1 callersMethodapply_balancer
src/meta/server_load_balancer.cpp:191
↓ 1 callersMethodapply_balancer_test
src/meta/test/update_configuration_test.cpp:397
↓ 1 callersMethodapply_set
src/replica/storage/simple_kv/test/case.cpp:214
↓ 1 callersMethodasync
Run this stage asynchronously in its environment.
src/runtime/pipeline.h:258
↓ 1 callersMethodasyncBatchGet
(batch_get_request request, int timeout)
java-client/src/main/java/org/apache/pegasus/client/PegasusTable.java:483
↓ 1 callersMethodasyncCheckAndMutate
( byte[] hashKey, byte[] checkSortKey, CheckType checkType, byte[] checkOperand,
java-client/src/main/java/org/apache/pegasus/client/PegasusTable.java:883
↓ 1 callersMethodasyncCheckAndSet
( byte[] hashKey, byte[] checkSortKey, CheckType checkType, byte[] checkOperand,
java-client/src/main/java/org/apache/pegasus/client/PegasusTable.java:773
↓ 1 callersMethodasyncCommit
(Request request)
java-client/src/main/java/org/apache/pegasus/client/request/AbstractBatch.java:55
↓ 1 callersMethodasyncCompareExchange
( byte[] hashKey, byte[] sortKey, byte[] expectedValue, byte[] desiredValue, int
java-client/src/main/java/org/apache/pegasus/client/PegasusTable.java:986
↓ 1 callersMethodasyncExist
(byte[] hashKey, byte[] sortKey, int timeout)
java-client/src/main/java/org/apache/pegasus/client/PegasusTable.java:92
↓ 1 callersMethodasyncMultiGetSortKeys
get all the sortKeys for the same hashKey @param hashKey used to decide which partition the key may exist should not be null or empty. @param maxFetc
java-client/src/main/java/org/apache/pegasus/client/PegasusTableInterface.java:379
↓ 1 callersMethodasyncNext
()
java-client/src/main/java/org/apache/pegasus/client/PegasusScanner.java:161
↓ 1 callersMethodasyncNextBatch
()
java-client/src/main/java/org/apache/pegasus/client/PegasusScanner.java:247
← previousnext →2,101–2,200 of 8,667, ranked by callers