11 Star 23 Fork 11

Gitee 极速下载 / Pegasus

加入 Gitee
与超过 1200万 开发者一起发现、参与优秀开源项目,私有仓库也完全免费 :)
免费加入
此仓库是为了提升国内下载速度的镜像仓库,每日同步一次。 原始仓库: https://github.com/XiaoMi/pegasus
克隆/下载
贡献代码
同步代码
取消
提示: 由于 Git 不支持空文件夾,创建文件夹后会生成空的 .keep 文件
Loading...
README
Apache-2.0

pegasus-logo

Lint and build regularly License Releases

Note: The master branch may be in an unstable or even in a broken state during development. Please use GitHub Releases instead of the master branch in order to get stable binaries.

Apache Pegasus is a distributed key-value storage system which is designed to be:

  • horizontally scalable: distributed using hash-based partitioning
  • strongly consistent: ensured by PacificA consensus protocol
  • high-performance: using RocksDB as underlying storage engine
  • simple: well-defined, easy-to-use APIs

Background

Pegasus targets to fill the gap between Redis and HBase. As the former is in-memory, low latency, but does not provide a strong-consistency guarantee. And unlike the latter, Pegasus is entirely written in C++ and its write-path relies merely on the local filesystem.

Apart from the performance requirements, we also need a storage system to ensure multiple-level data safety and support fast data migration between data centers, automatic load balancing, and online partition split.

Features

  • Persistence of data: Each write is replicated three-way to different ReplicaServers before responding to the client. Using PacificA protocol, Pegasus has the ability for strong consistent replication and membership changes.

  • Automatic load balancing over ReplicaServers: Load balancing is a builtin function of MetaServer, which manages the distribution of replicas. When the cluster is in an inbalance state, the administrator can invoke a simple rebalance command that automatically schedules the replica migration.

  • Cold Backup: Pegasus supports an extensible backup and restore mechanism to ensure data safety. The location of snapshot could be a distributed filesystem like HDFS or local filesystem. The snapshot storing in the filesystem can be further used for analysis based on pegasus-spark.

  • Eventually-consistent intra-datacenter replication: This is a feature we called duplication. It allows a change made in the local cluster accesible after a short time period by the remote cluster. It help achieving higher availability of your service and gaining better performance by accessing only local cluster.

To start using Pegasus

See our documentation on the Pegasus Website.

Client drivers

Pegasus has support for several languages:

Contact us

  • Send emails to the Apache Pegasus developer mailing list: dev@pegasus.apache.org. This is the place where topics around development, community, and problems are officially discussed. Please remember to subscribe to the mailing list via dev-subscribe@pegasus.apache.org.

  • GitHub Issues: submit an issue when you have any idea to improve Pegasus, and when you encountered some bugs or problems.

Related Projects

Test tools:

Data import/export tools:

License

Copyright 2022 The Apache Software Foundation. Licensed under the Apache License, Version 2.0: http://www.apache.org/licenses/LICENSE-2.0

# Licensed to the Apache Software Foundation (ASF) under one # or more contributor license agreements. See the NOTICE file # distributed with this work for additional information # regarding copyright ownership. The ASF licenses this file # to you under the Apache License, Version 2.0 (the # "License"); you may not use this file except in compliance # with the License. You may obtain a copy of the License at # # http://www.apache.org/licenses/LICENSE-2.0 # # Unless required by applicable law or agreed to in writing, # software distributed under the License is distributed on an # "AS IS" BASIS, WITHOUT WARRANTIES OR CONDITIONS OF ANY # KIND, either express or implied. See the License for the # specific language governing permissions and limitations # under the License. header: license: spdx-id: Apache-2.0 copyright-owner: Apache Software Foundation paths-ignore: # Configuration files that could not be added with copyright info (otherwise would lead to error). - '.rat-excludes' - '**/*.csv' - '**/*.json' # All the type of licenses of this project should be added to LICENSE. - 'DISCLAIMER' - 'LICENSE' - 'NOTICE' # Change log. - 'HISTORY.md' # Template files of issues and pull requests for Github. - '.github/ISSUE_TEMPLATE/bug_report.md' - '.github/ISSUE_TEMPLATE/feature-request.md' - '.github/ISSUE_TEMPLATE/general_question.md' - '.github/pull_request_template.md' # Image files for docs. - '**/*.jpg' - '**/*.png' # Files in pdf format. - '**/*.pdf' # Special files for golang. - '**/go.sum' # TODO(wangdan): Generated files for go client, could generate dynamically? - 'go-client/idl/base/GoUnusedProtection__.go' - 'go-client/idl/base/dsn_err_string.go' - 'go-client/idl/base/rocskdb_err_string.go' # Special files for nodejs. - '**/.npmigonre' # Special files for python. - 'python-client/requirement.txt' # Text files used for tests and could not be added with copyright info (otherwise would lead to error). - 'src/aio/test/copy_source.txt' - 'src/runtime/test/command.txt' - 'src/failure_detector/test/gtest.filter' - 'src/meta/test/meta_state/gtest.filter' - 'src/meta/test/suite1' - 'src/meta/test/suite2' - 'src/nfs/test/nfs_test_file1' - 'src/nfs/test/nfs_test_file2' - 'src/runtime/test/gtest.filter' # Used for tests and should be empty, or ignore all comment lines (otherwise would lead to error). - 'src/utils/test/config-empty.ini' # Binary files used for tests and could not be added with copyright info (otherwise would lead to error). - 'src/replica/duplication/test/log.1.0.handle_real_private_log' - 'src/replica/duplication/test/log.1.0.handle_real_private_log2' - 'src/replica/duplication/test/log.1.0.all_loaded_are_write_empties' # Used for patches for thirdparties. - 'thirdparty/fix_jemalloc_for_m1_on_macos.patch' - 'thirdparty/fix_libevent_for_macos.patch' - 'thirdparty/fix_rocksdb-cmake-PORTABLE-option.patch' - 'thirdparty/fix_snappy-Wsign-compare-warning.patch' - 'thirdparty/fix_s2_build_with_absl_and_gtest.patch' - 'thirdparty/fix_thrift_for_cpp11.patch' # TODO(yingchun): shell/* files are import from thirdparties, we can move them to thirdparty later. # Copyright (c) 2016, Adi Shavit - 'src/shell/argh.h' # Copyright (c) 2010-2016, Salvatore Sanfilippo, etc. - 'src/shell/linenoise/linenoise.c' # Copyright (c) 2010-2014, Salvatore Sanfilippo, etc. - 'src/shell/linenoise/linenoise.h' # Copyright (c) 2006-2015, Salvatore Sanfilippo, etc. - 'src/shell/sds/sds.c' - 'src/shell/sds/sds.h' - 'src/shell/sds/sdsalloc.h' # Copyright (c) Facebook, Inc - 'src/utils/TokenBucket.h' - 'src/utils/test/TokenBucketTest.cpp' - 'src/utils/test/TokenBucketTest.h' # https://github.com/preshing/modern-cpp-threading/blob/master/LICENSE - 'src/utils/hpc_locks/autoreseteventcondvar.h' # https://github.com/preshing/cpp11-on-multicore/blob/master/LICENSE - 'src/utils/hpc_locks/autoresetevent.h' - 'src/utils/hpc_locks/benaphore.h' - 'src/utils/hpc_locks/bitfield.h' - 'src/utils/hpc_locks/readme.txt' - 'src/utils/hpc_locks/rwlock.h' - 'src/utils/hpc_locks/sema.h' # Copyright (c) 2011 The Chromium Authors - 'src/utils/safe_strerror_posix.h' # Copyright (c) 2012 The Chromium Authors - 'src/runtime/build_config.h' - 'src/utils/test/autoref_ptr_test.cpp' # Copyright (c) 2006-2009 The Chromium Authors - 'src/utils/safe_strerror_posix.cpp' # Copyright (c) 2010-2011, Rob Jansen - 'cmake_modules/FindRT.cmake' - 'cmake_modules/FindDL.cmake' # Copyright (c) 2017 Guillaume Papin - 'scripts/run-clang-format.py' # The MIT License (MIT), Copyright (c) 2015 Microsoft Corporation - 'cmake_modules/BaseFunctions.cmake' - 'docs/rdsn-README.md' - 'idl/command.thrift' - 'idl/dsn.layer2.thrift' - 'idl/dsn.thrift' - 'idl/metadata.thrift' - 'idl/meta_admin.thrift' - 'idl/replica_admin.thrift' - 'scripts/compile_thrift.py' - 'scripts/learn_stat.py' - 'src/runtime/api_layer1.h' - 'src/runtime/api_task.h' - 'src/utils/api_utilities.h' - 'src/runtime/app_model.h' - 'src/common/json_helper.h' - 'src/runtime/rpc/rpc_stream.h' - 'src/runtime/rpc/serialization.h' - 'src/common/serialization_helper/dsn_types.h' - 'src/common/serialization_helper/thrift_helper.h' - 'src/runtime/serverlet.h' - 'src/runtime/service_app.h' - 'src/utils/distributed_lock_service.h' - 'src/failure_detector/failure_detector.h' - 'src/failure_detector/fd.client.h' - 'src/failure_detector/fd.code.definition.h' - 'src/failure_detector/fd.server.h' - 'src/failure_detector/failure_detector_multimaster.h' - 'src/meta/meta_state_service.h' - 'src/nfs/nfs_node.h' - 'src/meta/meta_service_app.h' - 'src/tools/mutation_log_tool.h' - 'src/client/partition_resolver.h' - 'src/replica/replica_base.h' - 'src/common/replica_envs.h' - 'src/common/replication.codes.h' - 'src/replica/replication_app_base.h' - 'src/client/replication_ddl_client.h' - 'src/common/replication_enums.h' - 'src/common/replication_other_types.h' - 'src/replica/replication_service_app.h' - 'src/common/storage_serverlet.h' - 'src/perf_counter/perf_counter.h' - 'src/perf_counter/perf_counter_wrapper.h' - 'src/perf_counter/perf_counters.h' - 'src/aio/aio_task.h' - 'src/runtime/task/async_calls.h' - 'src/utils/command_manager.h' - 'src/runtime/env_provider.h' - 'src/aio/file_io.h' - 'src/runtime/task/future_types.h' - 'src/runtime/global_config.h' - 'src/common/gpid.h' - 'src/runtime/rpc/group_address.h' - 'src/utils/logging_provider.h' - 'src/runtime/rpc/message_parser.h' - 'src/runtime/rpc/network.h' - 'src/runtime/rpc/rpc_address.cpp' - 'src/runtime/rpc/rpc_address.h' - 'src/runtime/rpc/rpc_message.h' - 'src/runtime/task/task.h' - 'src/runtime/task/task_code.h' - 'src/runtime/task/task_queue.h' - 'src/runtime/task/task_spec.h' - 'src/runtime/task/task_tracker.h' - 'src/runtime/task/task_worker.h' - 'src/utils/thread_access_checker.h' - 'src/utils/threadpool_code.h' - 'src/utils/threadpool_spec.h' - 'src/runtime/task/timer_service.h' - 'src/utils/uniq_timestamp_us.h' - 'src/utils/zlocks.h' - 'src/runtime/nativerun.h' - 'src/runtime/node_scoper.h' - 'src/runtime/providers.common.h' - 'src/runtime/simulator.h' - 'src/runtime/tool_api.h' - 'src/runtime/fault_injector.h' - 'src/runtime/profiler.h' - 'src/runtime/tracer.h' - 'src/utils/autoref_ptr.h' - 'src/utils/binary_reader.h' - 'src/utils/binary_writer.h' - 'src/utils/blob.h' - 'src/utils/chrono_literals.h' - 'src/utils/config_api.h' - 'src/utils/config_helper.h' - 'src/utils/configuration.h' - 'src/utils/crc.h' - 'src/utils/customizable_id.h' - 'src/utils/enum_helper.h' - 'src/utils/error_code.h' - 'src/utils/errors.h' - 'src/utils/exp_delay.h' - 'src/utils/extensible_object.h' - 'src/utils/factory_store.h' - 'src/utils/filesystem.h' - 'src/utils/fixed_size_buffer_pool.h' - 'src/utils/function_traits.h' - 'src/utils/join_point.h' - 'src/utils/link.h' - 'src/utils/optional.h' - 'src/utils/ports.h' - 'src/utils/priority_queue.h' - 'src/utils/singleton_store.h' - 'src/utils/strings.h' - 'src/utils/synchronize.h' - 'src/utils/utils.h' - 'src/utils/work_queue.h' - 'src/utils/time_utils.h' - 'src/aio/CMakeLists.txt' - 'src/aio/aio_provider.cpp' - 'src/aio/aio_provider.h' - 'src/aio/disk_engine.cpp' - 'src/aio/disk_engine.h' - 'src/aio/file_io.cpp' - 'src/aio/native_linux_aio_provider.cpp' - 'src/aio/native_linux_aio_provider.h' - 'src/aio/test/CMakeLists.txt' - 'src/aio/test/aio.cpp' - 'src/aio/test/clear.sh' - 'src/aio/test/config.ini' - 'src/aio/test/run.sh' - 'src/block_service/test/config-test.ini' - 'src/client/CMakeLists.txt' - 'src/client/partition_resolver.cpp' - 'src/client/partition_resolver_manager.cpp' - 'src/client/partition_resolver_manager.h' - 'src/client/partition_resolver_simple.cpp' - 'src/client/partition_resolver_simple.h' - 'src/client/replication_ddl_client.cpp' - 'src/common/CMakeLists.txt' - 'src/common/consensus.thrift' - 'src/common/fs_manager.cpp' - 'src/common/replication_common.cpp' - 'src/common/replication_common.h' - 'src/common/test/CMakeLists.txt' - 'src/common/test/config-test.ini' - 'src/common/test/duplication_common_test.cpp' - 'src/common/test/main.cpp' - 'src/common/test/run.sh' - 'src/failure_detector/CMakeLists.txt' - 'src/failure_detector/failure_detector.cpp' - 'src/failure_detector/failure_detector_multimaster.cpp' - 'src/failure_detector/fd.thrift' - 'src/failure_detector/test/CMakeLists.txt' - 'src/failure_detector/test/clear.sh' - 'src/failure_detector/test/config-test.ini' - 'src/failure_detector/test/config-whitelist-test-failed.ini' - 'src/failure_detector/test/config-whitelist-test.ini' - 'src/failure_detector/test/failure_detector.cpp' - 'src/failure_detector/test/main.cpp' - 'src/failure_detector/test/run.sh' - 'src/http/http_message_parser.cpp' - 'src/http/http_message_parser.h' - 'src/http/test/run.sh' - 'src/meta/CMakeLists.txt' - 'src/meta/distributed_lock_service_simple.cpp' - 'src/meta/distributed_lock_service_simple.h' - 'src/meta/dump_file.h' - 'src/meta/greedy_load_balancer.cpp' - 'src/meta/greedy_load_balancer.h' - 'src/meta/meta_data.cpp' - 'src/meta/meta_data.h' - 'src/meta/meta_options.cpp' - 'src/meta/meta_options.h' - 'src/meta/meta_server_failure_detector.cpp' - 'src/meta/meta_server_failure_detector.h' - 'src/meta/meta_service.cpp' - 'src/meta/meta_service.h' - 'src/meta/meta_service_app.cpp' - 'src/meta/meta_state_service_simple.cpp' - 'src/meta/meta_state_service_simple.h' - 'src/meta/meta_state_service_zookeeper.cpp' - 'src/meta/meta_state_service_zookeeper.h' - 'src/meta/server_load_balancer.cpp' - 'src/meta/server_load_balancer.h' - 'src/meta/server_state.cpp' - 'src/meta/server_state.h' - 'src/meta/test/CMakeLists.txt' - 'src/meta/test/balancer_simulator/CMakeLists.txt' - 'src/meta/test/balancer_simulator/balancer_simulator.cpp' - 'src/meta/test/balancer_validator.cpp' - 'src/meta/test/clear.sh' - 'src/meta/test/config-test.ini' - 'src/meta/test/dump_file.cpp' - 'src/meta/test/duplication_info_test.cpp' - 'src/meta/test/json_compacity.cpp' - 'src/meta/test/meta_app_envs_test.cpp' - 'src/meta/test/meta_data.cpp' - 'src/meta/test/meta_duplication_service_test.cpp' - 'src/meta/test/meta_partition_guardian_test.cpp' - 'src/meta/test/meta_service_test_app.h' - 'src/meta/test/meta_split_service_test.cpp' - 'src/meta/test/meta_state/CMakeLists.txt' - 'src/meta/test/meta_state/clear.sh' - 'src/meta/test/meta_state/config-test.ini' - 'src/meta/test/meta_state/main.cpp' - 'src/meta/test/meta_state/meta_state_service.cpp' - 'src/meta/test/meta_state/run.sh' - 'src/meta/test/meta_state_service_utils_test.cpp' - 'src/meta/test/misc/misc.cpp' - 'src/meta/test/misc/misc.h' - 'src/meta/test/run.sh' - 'src/meta/test/server_state_test.cpp' - 'src/meta/test/state_sync_test.cpp' - 'src/meta/test/update_configuration_test.cpp' - 'src/nfs/CMakeLists.txt' - 'src/nfs/nfs.thrift' - 'src/nfs/nfs_client_impl.cpp' - 'src/nfs/nfs_client_impl.h' - 'src/nfs/nfs_code_definition.h' - 'src/nfs/nfs_node.cpp' - 'src/nfs/nfs_node_simple.cpp' - 'src/nfs/nfs_node_simple.h' - 'src/nfs/nfs_server_impl.cpp' - 'src/nfs/nfs_server_impl.h' - 'src/nfs/test/CMakeLists.txt' - 'src/nfs/test/clear.sh' - 'src/nfs/test/config.ini' - 'src/nfs/test/main.cpp' - 'src/nfs/test/run.sh' - 'src/perf_counter/CMakeLists.txt' - 'src/perf_counter/perf_counter.cpp' - 'src/perf_counter/perf_counters.cpp' - 'src/perf_counter/test/CMakeLists.txt' - 'src/perf_counter/test/clear.sh' - 'src/perf_counter/test/perf_counter_test.cpp' - 'src/perf_counter/test/perf_counters_test.cpp' - 'src/perf_counter/test/run.sh' - 'src/remote_cmd/CMakeLists.txt' - 'src/replica/CMakeLists.txt' - 'src/replica/backup/test/config-test.ini' - 'src/replica/backup/test/run.sh' - 'src/replica/bulk_load/test/config-test.ini' - 'src/replica/bulk_load/test/run.sh' - 'src/replica/duplication/test/config-test.ini' - 'src/replica/duplication/test/run.sh' - 'src/replica/log_file.cpp' - 'src/replica/log_file.h' - 'src/replica/log_file_stream.h' - 'src/replica/mutation.cpp' - 'src/replica/mutation.h' - 'src/replica/mutation_cache.cpp' - 'src/replica/mutation_cache.h' - 'src/replica/mutation_log.cpp' - 'src/replica/mutation_log.h' - 'src/replica/mutation_log_utils.cpp' - 'src/replica/mutation_log_utils.h' - 'src/replica/prepare_list.cpp' - 'src/replica/prepare_list.h' - 'src/replica/replica.cpp' - 'src/replica/replica.h' - 'src/replica/replica_2pc.cpp' - 'src/replica/replica_check.cpp' - 'src/replica/replica_chkpt.cpp' - 'src/replica/replica_config.cpp' - 'src/replica/replica_context.cpp' - 'src/replica/replica_context.h' - 'src/replica/replica_failover.cpp' - 'src/replica/replica_init.cpp' - 'src/replica/replica_learn.cpp' - 'src/replica/replica_stub.cpp' - 'src/replica/replica_stub.h' - 'src/replica/replication_app_base.cpp' - 'src/replica/replication_service_app.cpp' - 'src/replica/split/test/config-test.ini' - 'src/replica/split/test/run.sh' - 'src/replica/storage/CMakeLists.txt' - 'src/replica/storage/simple_kv/CMakeLists.txt' - 'src/replica/storage/simple_kv/clear.sh' - 'src/replica/storage/simple_kv/config.ini' - 'src/replica/storage/simple_kv/run.sh' - 'src/replica/storage/simple_kv/simple_kv.app.example.h' - 'src/replica/storage/simple_kv/simple_kv.client.h' - 'src/replica/storage/simple_kv/simple_kv.code.definition.h' - 'src/replica/storage/simple_kv/simple_kv.main.cpp' - 'src/replica/storage/simple_kv/simple_kv.server.h' - 'src/replica/storage/simple_kv/simple_kv.server.impl.cpp' - 'src/replica/storage/simple_kv/simple_kv.server.impl.h' - 'src/replica/storage/simple_kv/simple_kv.thrift' - 'src/replica/storage/simple_kv/test/CMakeLists.txt' - 'src/replica/storage/simple_kv/test/README.md' - 'src/replica/storage/simple_kv/test/addcase.sh' - 'src/replica/storage/simple_kv/test/case-000.act' - 'src/replica/storage/simple_kv/test/case-000.ini' - 'src/replica/storage/simple_kv/test/case-001.act' - 'src/replica/storage/simple_kv/test/case-001.ini' - 'src/replica/storage/simple_kv/test/case-002.act' - 'src/replica/storage/simple_kv/test/case-002.ini' - 'src/replica/storage/simple_kv/test/case-003.act' - 'src/replica/storage/simple_kv/test/case-003.ini' - 'src/replica/storage/simple_kv/test/case-004.act' - 'src/replica/storage/simple_kv/test/case-004.ini' - 'src/replica/storage/simple_kv/test/case-005.act' - 'src/replica/storage/simple_kv/test/case-005.ini' - 'src/replica/storage/simple_kv/test/case-006.act' - 'src/replica/storage/simple_kv/test/case-006.ini' - 'src/replica/storage/simple_kv/test/case-100.act' - 'src/replica/storage/simple_kv/test/case-100.ini' - 'src/replica/storage/simple_kv/test/case-101.act' - 'src/replica/storage/simple_kv/test/case-101.ini' - 'src/replica/storage/simple_kv/test/case-102.act' - 'src/replica/storage/simple_kv/test/case-102.ini' - 'src/replica/storage/simple_kv/test/case-103.act' - 'src/replica/storage/simple_kv/test/case-103.ini' - 'src/replica/storage/simple_kv/test/case-104.act' - 'src/replica/storage/simple_kv/test/case-104.ini' - 'src/replica/storage/simple_kv/test/case-105.act' - 'src/replica/storage/simple_kv/test/case-105.ini' - 'src/replica/storage/simple_kv/test/case-106.act' - 'src/replica/storage/simple_kv/test/case-106.ini' - 'src/replica/storage/simple_kv/test/case-107.act' - 'src/replica/storage/simple_kv/test/case-107.ini' - 'src/replica/storage/simple_kv/test/case-108.act' - 'src/replica/storage/simple_kv/test/case-108.ini' - 'src/replica/storage/simple_kv/test/case-109.act' - 'src/replica/storage/simple_kv/test/case-109.ini' - 'src/replica/storage/simple_kv/test/case-200.act' - 'src/replica/storage/simple_kv/test/case-200.ini' - 'src/replica/storage/simple_kv/test/case-201.act' - 'src/replica/storage/simple_kv/test/case-201.ini' - 'src/replica/storage/simple_kv/test/case-202-0.act' - 'src/replica/storage/simple_kv/test/case-202-0.ini' - 'src/replica/storage/simple_kv/test/case-202-1.act' - 'src/replica/storage/simple_kv/test/case-202-1.ini' - 'src/replica/storage/simple_kv/test/case-203-0.act' - 'src/replica/storage/simple_kv/test/case-203-0.ini' - 'src/replica/storage/simple_kv/test/case-204.act' - 'src/replica/storage/simple_kv/test/case-204.ini' - 'src/replica/storage/simple_kv/test/case-205.act' - 'src/replica/storage/simple_kv/test/case-205.ini' - 'src/replica/storage/simple_kv/test/case-206.act' - 'src/replica/storage/simple_kv/test/case-206.ini' - 'src/replica/storage/simple_kv/test/case-207.act' - 'src/replica/storage/simple_kv/test/case-207.ini' - 'src/replica/storage/simple_kv/test/case-208.act' - 'src/replica/storage/simple_kv/test/case-208.ini' - 'src/replica/storage/simple_kv/test/case-209.act' - 'src/replica/storage/simple_kv/test/case-209.ini' - 'src/replica/storage/simple_kv/test/case-210.act' - 'src/replica/storage/simple_kv/test/case-210.ini' - 'src/replica/storage/simple_kv/test/case-211.act' - 'src/replica/storage/simple_kv/test/case-211.ini' - 'src/replica/storage/simple_kv/test/case-212.act' - 'src/replica/storage/simple_kv/test/case-212.ini' - 'src/replica/storage/simple_kv/test/case-213.act' - 'src/replica/storage/simple_kv/test/case-213.ini' - 'src/replica/storage/simple_kv/test/case-214.act' - 'src/replica/storage/simple_kv/test/case-214.ini' - 'src/replica/storage/simple_kv/test/case-215.act' - 'src/replica/storage/simple_kv/test/case-215.ini' - 'src/replica/storage/simple_kv/test/case-216.act' - 'src/replica/storage/simple_kv/test/case-216.ini' - 'src/replica/storage/simple_kv/test/case-300-0.act' - 'src/replica/storage/simple_kv/test/case-300-0.ini' - 'src/replica/storage/simple_kv/test/case-300-1.act' - 'src/replica/storage/simple_kv/test/case-300-1.ini' - 'src/replica/storage/simple_kv/test/case-300-2.act' - 'src/replica/storage/simple_kv/test/case-300-2.ini' - 'src/replica/storage/simple_kv/test/case-301.act' - 'src/replica/storage/simple_kv/test/case-301.ini' - 'src/replica/storage/simple_kv/test/case-302.act' - 'src/replica/storage/simple_kv/test/case-302.ini' - 'src/replica/storage/simple_kv/test/case-303.act' - 'src/replica/storage/simple_kv/test/case-303.ini' - 'src/replica/storage/simple_kv/test/case-304.act' - 'src/replica/storage/simple_kv/test/case-304.ini' - 'src/replica/storage/simple_kv/test/case-305.act' - 'src/replica/storage/simple_kv/test/case-305.ini' - 'src/replica/storage/simple_kv/test/case-306.act' - 'src/replica/storage/simple_kv/test/case-306.ini' - 'src/replica/storage/simple_kv/test/case-307.act' - 'src/replica/storage/simple_kv/test/case-307.ini' - 'src/replica/storage/simple_kv/test/case-400.act' - 'src/replica/storage/simple_kv/test/case-400.ini' - 'src/replica/storage/simple_kv/test/case-401.act' - 'src/replica/storage/simple_kv/test/case-401.ini' - 'src/replica/storage/simple_kv/test/case-402.act' - 'src/replica/storage/simple_kv/test/case-402.ini' - 'src/replica/storage/simple_kv/test/case-600.act' - 'src/replica/storage/simple_kv/test/case-600.ini' - 'src/replica/storage/simple_kv/test/case-601.act' - 'src/replica/storage/simple_kv/test/case-601.ini' - 'src/replica/storage/simple_kv/test/case-602.act' - 'src/replica/storage/simple_kv/test/case-602.ini' - 'src/replica/storage/simple_kv/test/case-603.act' - 'src/replica/storage/simple_kv/test/case-603.ini' - 'src/replica/storage/simple_kv/test/case.cpp' - 'src/replica/storage/simple_kv/test/case.h' - 'src/replica/storage/simple_kv/test/checker.cpp' - 'src/replica/storage/simple_kv/test/checker.h' - 'src/replica/storage/simple_kv/test/clear.sh' - 'src/replica/storage/simple_kv/test/client.cpp' - 'src/replica/storage/simple_kv/test/client.h' - 'src/replica/storage/simple_kv/test/common.cpp' - 'src/replica/storage/simple_kv/test/common.h' - 'src/replica/storage/simple_kv/test/config.ini' - 'src/replica/storage/simple_kv/test/injector.cpp' - 'src/replica/storage/simple_kv/test/injector.h' - 'src/replica/storage/simple_kv/test/run.sh' - 'src/replica/storage/simple_kv/test/simple_kv.main.cpp' - 'src/replica/storage/simple_kv/test/simple_kv.server.impl.cpp' - 'src/replica/storage/simple_kv/test/simple_kv.server.impl.h' - 'src/replica/test/CMakeLists.txt' - 'src/replica/test/config-test.ini' - 'src/replica/test/mock_utils.h' - 'src/replica/test/mutation_log_learn_test.cpp' - 'src/replica/test/mutation_log_test.cpp' - 'src/replica/test/replica_test_base.h' - 'src/replica/test/replication_service_test_app.h' - 'src/replica/test/run.sh' - 'src/runtime/CMakeLists.txt' - 'src/runtime/core_main.cpp' - 'src/runtime/env.sim.cpp' - 'src/runtime/env.sim.h' - 'src/runtime/fault_injector.cpp' - 'src/runtime/global_config.cpp' - 'src/runtime/message_utils.cpp' - 'src/runtime/nativerun.cpp' - 'src/runtime/profiler.cpp' - 'src/runtime/profiler_header.h' - 'src/runtime/providers.common.cpp' - 'src/runtime/rpc/CMakeLists.txt' - 'src/runtime/rpc/asio_net_provider.cpp' - 'src/runtime/rpc/asio_net_provider.h' - 'src/runtime/rpc/asio_rpc_session.cpp' - 'src/runtime/rpc/asio_rpc_session.h' - 'src/runtime/rpc/dsn_message_parser.cpp' - 'src/runtime/rpc/dsn_message_parser.h' - 'src/runtime/rpc/message_parser.cpp' - 'src/runtime/rpc/message_parser_manager.h' - 'src/runtime/rpc/network.cpp' - 'src/runtime/rpc/network.sim.cpp' - 'src/runtime/rpc/network.sim.h' - 'src/runtime/rpc/raw_message_parser.cpp' - 'src/runtime/rpc/raw_message_parser.h' - 'src/runtime/rpc/rpc_engine.cpp' - 'src/runtime/rpc/rpc_engine.h' - 'src/runtime/rpc/rpc_message.cpp' - 'src/runtime/rpc/rpc_task.cpp' - 'src/runtime/rpc/thrift_message_parser.cpp' - 'src/runtime/rpc/thrift_message_parser.h' - 'src/runtime/scheduler.cpp' - 'src/runtime/scheduler.h' - 'src/runtime/service_api_c.cpp' - 'src/runtime/service_engine.cpp' - 'src/runtime/service_engine.h' - 'src/runtime/simulator.cpp' - 'src/runtime/task/CMakeLists.txt' - 'src/runtime/task/hpc_task_queue.cpp' - 'src/runtime/task/hpc_task_queue.h' - 'src/runtime/task/simple_task_queue.cpp' - 'src/runtime/task/simple_task_queue.h' - 'src/runtime/task/task.cpp' - 'src/runtime/task/task_code.cpp' - 'src/runtime/task/task_engine.cpp' - 'src/runtime/task/task_engine.h' - 'src/runtime/task/task_engine.sim.cpp' - 'src/runtime/task/task_engine.sim.h' - 'src/runtime/task/task_queue.cpp' - 'src/runtime/task/task_spec.cpp' - 'src/runtime/task/task_tracker.cpp' - 'src/runtime/task/task_worker.cpp' - 'src/runtime/test/CMakeLists.txt' - 'src/runtime/test/address_test.cpp' - 'src/runtime/test/async_call.cpp' - 'src/runtime/test/clear.sh' - 'src/runtime/test/config-test-corrupt-message.ini' - 'src/runtime/test/config-test-sim.ini' - 'src/runtime/test/config-test.ini' - 'src/runtime/test/corrupt_message.cpp' - 'src/runtime/test/lpc.cpp' - 'src/runtime/test/main.cpp' - 'src/runtime/test/message_utils_test.cpp' - 'src/runtime/test/netprovider.cpp' - 'src/runtime/test/pipeline_test.cpp' - 'src/runtime/test/rpc.cpp' - 'src/runtime/test/rpc_holder_test.cpp' - 'src/runtime/test/rpc_message.cpp' - 'src/runtime/test/run.sh' - 'src/runtime/test/service_api_c.cpp' - 'src/runtime/test/sim_lock.cpp' - 'src/runtime/test/task_engine.cpp' - 'src/runtime/test_utils.h' - 'src/runtime/threadpool_code.cpp' - 'src/runtime/tool_api.cpp' - 'src/runtime/tracer.cpp' - 'src/runtime/zlocks.cpp' - 'src/tools/CMakeLists.txt' - 'src/tools/mutation_log_tool.cpp' - 'src/utils/CMakeLists.txt' - 'src/utils/binary_reader.cpp' - 'src/utils/binary_writer.cpp' - 'src/utils/command_manager.cpp' - 'src/utils/config_api.cpp' - 'src/utils/configuration.cpp' - 'src/utils/coredump.h' - 'src/utils/coredump.posix.cpp' - 'src/utils/crc.cpp' - 'src/utils/error_code.cpp' - 'src/utils/filesystem.cpp' - 'src/utils/gpid.cpp' - 'src/utils/lockp.std.h' - 'src/utils/logging.cpp' - 'src/utils/shared_io_service.h' - 'src/utils/simple_logger.cpp' - 'src/utils/simple_logger.h' - 'src/utils/strings.cpp' - 'src/utils/test/CMakeLists.txt' - 'src/utils/test/clear.sh' - 'src/utils/test/config-bad-section.ini' - 'src/utils/test/config-dup-key.ini' - 'src/utils/test/config-dup-section.ini' - 'src/utils/test/config-no-key.ini' - 'src/utils/test/config-no-section.ini' - 'src/utils/test/config-null-section.ini' - 'src/utils/test/config-sample.ini' - 'src/utils/test/config-unmatch-section.ini' - 'src/utils/test/configuration.cpp' - 'src/utils/test/env.cpp' - 'src/utils/test/file_utils.cpp' - 'src/utils/test/fmt_logging_test.cpp' - 'src/utils/test/join_point_test.cpp' - 'src/utils/test/json_helper_test.cpp' - 'src/utils/test/lock.std.cpp' - 'src/utils/test/logger.cpp' - 'src/utils/test/logging.cpp' - 'src/utils/test/output_utils_test.cpp' - 'src/utils/test/priority_queue.cpp' - 'src/utils/test/run.sh' - 'src/utils/test/sema.cpp' - 'src/utils/test/string_conv_test.cpp' - 'src/utils/test/time_utils_test.cpp' - 'src/utils/test/utils.cpp' - 'src/utils/thread_access_checker.cpp' - 'src/utils/utils.cpp' - 'src/utils/zlock_provider.h' - 'src/zookeeper/CMakeLists.txt' - 'src/zookeeper/distributed_lock_service_zookeeper.cpp' - 'src/zookeeper/distributed_lock_service_zookeeper.h' - 'src/zookeeper/lock_struct.cpp' - 'src/zookeeper/lock_struct.h' - 'src/zookeeper/lock_types.h' - 'src/zookeeper/test/CMakeLists.txt' - 'src/zookeeper/test/clear.sh' - 'src/zookeeper/test/config-test.ini' - 'src/zookeeper/test/distributed_lock_zookeeper.cpp' - 'src/zookeeper/test/main.cpp' - 'src/zookeeper/test/run.sh' - 'src/zookeeper/zookeeper_error.cpp' - 'src/zookeeper/zookeeper_error.h' - 'src/zookeeper/zookeeper_session.cpp' - 'src/zookeeper/zookeeper_session.h' - 'src/zookeeper/zookeeper_session_mgr.cpp' - 'src/zookeeper/zookeeper_session_mgr.h' comment: on-failure

简介

Pegasus 是小米云存储团队开发的一个分布式 Key-Value 存储系统,最初的动机是弥补 HBase 在可用性和性能上的不足 展开 收起
C/C++ 等 6 种语言
Apache-2.0
取消

发行版

暂无发行版

贡献者

全部

近期动态

加载更多
不能加载更多了
C/C++
1
https://gitee.com/mirrors/Pegasus.git
git@gitee.com:mirrors/Pegasus.git
mirrors
Pegasus
Pegasus
master

搜索帮助