MCPcopy Create free account
hub / github.com/apache/incubator-pegasus

github.com/apache/incubator-pegasus @v2.5.0

Chat with this repo
repository ↗ · DeepWiki ↗ · release v2.5.0 ↗ · + Follow
10,871 symbols 35,534 edges 1,217 files 1,588 documented · 15% updated 28d agov2.5.0 · 2023-12-11★ 2,060218 open issues

Browse by type

Functions 8,667 Types & classes 2,204
What it actually does AI analysis from the code graph — generated when you open this
loading…
README

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

Extension points exported contracts — how you extend this code

Core symbols most depended-on inside this repo

Shape

Method 6,956
Class 1,912
Function 1,711
Struct 119
Enum 110
Interface 40
FuncType 12
TypeAlias 11

Languages

C++75%
Java11%
Go10%
Python3%
C1%
TypeScript1%

Modules by API surface

java-client/src/main/java/org/apache/pegasus/client/PegasusTableInterface.java106 symbols
python-client/pypegasus/pgclient.py88 symbols
src/replica/test/mock_utils.h86 symbols
src/utils/metrics.h85 symbols
src/meta/server_state.cpp80 symbols
src/replica/storage/simple_kv/test/case.h78 symbols
admin-cli/client/meta.go78 symbols
src/replica/replica_stub.cpp77 symbols
src/meta/test/meta_bulk_load_service_test.cpp72 symbols
src/server/pegasus_server_impl.cpp70 symbols
go-client/pegasus/table_connector.go67 symbols
src/replica/split/test/replica_split_test.cpp60 symbols

For agents

$ claude mcp add incubator-pegasus \
  -- python -m otcore.mcp_server <graph>

⬇ download graph artifact

Ask about this repo answers extend the page