Crates.io | paddler |
lib.rs | paddler |
version | 1.0.0 |
source | src |
created_at | 2024-11-21 11:49:38.748755 |
updated_at | 2024-11-21 11:49:38.748755 |
description | Stateful load balancer custom-tailored for llama.cpp |
homepage | |
repository | https://github.com/distantmagic/paddler |
max_upload_size | |
id | 1456059 |
size | 233,482 |
[!IMPORTANT]
Big chances! Paddler is rewritten into Rust (from Golang) and uses Pingora framework for the networking stack.Version
1.0.0
brings some minor API changes and reporting improvements.The next plan is to introduce a supervisor who does not just monitor llamas.cpp instances, but to also manage them (replace models without dropping requests, etc.).
Paddler is an open-source, production-ready, stateful load balancer and reverse proxy designed to optimize servers running llama.cpp.
Typical load balancing strategies like round robin and least connections are ineffective for llama.cpp servers, which utilize continuous batching algorithms and allow to configure slots to handle multiple requests concurrently.
Paddler is designed to support llama.cpp-specific features like slots. It works by maintaining a stateful load balancer aware of each server's available slots, ensuring efficient request distribution.
[!NOTE] In simple terms, the
slots
in llama.cpp refer to predefined memory slices within the server that handle individual requests. When a request comes in, it is assigned to an available slot for processing. They are predictable and highly configurable.You can learn more about them in llama.cpp server documentation.
Paddler's aware of each server's available slots, ensuring efficient request ("R") distribution
llama.cpp instances need to be registered in Paddler. Paddler’s agents should be installed alongside llama.cpp instances so that they can report their slots status to the load balancer.
The sequence repeats for each agent:
sequenceDiagram
participant loadbalancer as Paddler Load Balancer
participant agent as Paddler Agent
participant llamacpp as llama.cpp
agent->>llamacpp: Hey, are you alive?
llamacpp-->>agent: Yes, this is my slots status
agent-->>loadbalancer: llama.cpp is still working
loadbalancer->>llamacpp: I have a request for you to handle
Download the latest release for Linux, Mac, or Windows from the releases page.
On Linux, if you want Paddler to be accessible system-wide, rename the downloaded executable to /usr/bin/paddler
(or /usr/local/bin/paddler
).
Slots endpoint is required to be enabled in llama.cpp. To do so, run llama.cpp with the --slots
flag.
The next step is to run Paddler’s agents. Agents register your llama.cpp instances in Paddler and monitor the slots of llama.cpp instances. They should be installed on the same host as your server that runs llama.cpp.
An agent needs a few pieces of information:
external-llamacpp-addr
tells how the load balancer can connect to the llama.cpp instancelocal-llamacpp-addr
tells how the agent can connect to the llama.cpp instancemanagement-addr
tell where the agent should report the slots statusRun the following to start a Paddler’s agent (replace the hosts and ports with your own server addresses when deploying):
./paddler agent \
--external-llamacpp-addr 127.0.0.1:8088 \
--local-llamacpp-addr 127.0.0.1:8088 \
--management-addr 127.0.0.1:8085
With the --name
flag, you can assign each agent a custom name. This name will be displayed in the management dashboard and not used for any other purpose.
If your llama.cpp instance requires an API key, you can provide it with the --local-llamacpp-api-key
flag.
Load balancer collects data from agents and exposes reverse proxy to the outside world.
It requires two sets of flags:
management-addr
tells where the load balancer should listen for updates from agentsreverseproxy-addr
tells how load balancer can be reached from the outside hostsTo start the load balancer, run:
./paddler balancer \
--management-addr 127.0.0.1:8085 \
--reverseproxy-addr 196.168.2.10:8080
management-host
and management-port
in agents should be the same as in the load balancer.
You can enable dashboard to see the status of the agents with
--management-dashboard-enable
flag. If enabled, it is available at the
management server address under /dashboard
path.
[!NOTE] Available since v1.0.0
By default, Paddler blocks access to /slots
endpoint, even if it is enabled in llama.cpp
, because it exposes a lot of sensistive information about the server, and should only be used internally. If you want to expose it anyway, you can use the --slots-endpoint-enable
flag.
Host
Header.
[!NOTE] Available since v0.8.0
In some cases (see: #20), you might want to rewrite the Host
header.
In such cases, you can use the --rewrite-host-header
flag. If used, Paddler will use the external
host provided by agents instead of the balancer host when forwarding the requests.
Paddler balancer endpoint aggregates the slots of all llama.cpp
instances and reports the total number of available and processing slots.
Aggregated health status is available at the /api/v1/agents
endpoint of the management server.
[!NOTE] Available since v0.3.0
Load balancer's buffered requests allow your infrastructure to scale from zero hosts by providing an additional metric (unhandled requests).
It also gives your infrastructure some additional time to add additional hosts. For example, if your autoscaler is setting up an additional server, putting an incoming request on hold for 60 seconds might give it a chance to be handled even though there might be no available llama.cpp instances at the moment of issuing it.
Scaling from zero hosts is especially suitable for low-traffic projects because it allows you to cut costs on your infrastructure—you won't be paying your cloud provider anything if you are not using your service at the moment.
https://github.com/distantmagic/paddler/assets/1286785/34b93e4c-0746-4eed-8be3-cd698e15cbf9
Although Paddler integrates with the StatsD protocol, you can preview the cluster's state using a built-in dashboard.
[!NOTE] Available since v0.3.0
[!TIP] If you keep your stack self-hosted you can use Prometheus with StatsD exporter to handle the incoming metrics.
[!TIP] This feature works with AWS CloudWatch Agent as well.
Paddler supports the following StatsD metrics:
requests_buffered
number of buffered requests since the last report (resets after each report)slots_idle
total idle slotsslots_processing
total slots processing requestsAll of them use gauge
internally.
StatsD metrics need to be enabled with the following flags:
./paddler balancer \
# .. put all the other flags here ...
--statsd-addr=127.0.0.1:8125
If you do not provide the --statsd-addr
flag, the StatsD metrics will not be collected.
The first stable release! Paddler is now rewritten in Rust and uses the Pingora framework for the networking stack. A few minor API changes and reporting improvements are introduced (documented in the README). API and configuration are now stable, and won't be changed until version 2.0.0
.
This is a stability/quality release. The next plan is to introduce a supervisor who does not just monitor llama.cpp instances, but to also manage them.
Requires llama.cpp version b4027 or above.
This update is a minor release to make Paddler compatible with /slots
endpoint changes introduced in llama.cpp b4027.
Requires llama.cpp version b4027 or above.
Latest supported llama.cpp release: b4026
--local-llamacpp-api-key
flag to balancer to support llama.cpp API keys (see: #23)--rewrite-host-header
flag to balancer to rewrite the Host
header in forwarded requests (see: #20)Requires at least b3606 llama.cpp release.
Adjusted to handle breaking changes in llama.cpp /health
endpoint: https://github.com/ggerganov/llama.cpp/pull/9056
Instead of using the /health
endpoint to monitor slot statuses, starting from this version, Paddler uses the /slots
endpoint to monitor llama.cpp instances.
Paddler's /health
endpoint remains unchanged.
Latest supported llama.cpp release: b3604
Thank you, @ScottMcNaught, for the help with debugging the issues! :)
/v1/chat/completions
)panic
ked in some scenarios when the underlying llama.cpp
instance was abruptly closed during the generation of completion tokensI initially wanted to use Raft consensus algorithm (thus Paddler, because it paddles on a Raft), but eventually, I dropped that idea. The name stayed, though.
Later, people started sending me a "that's a paddlin'" clip from The Simpsons, and I just embraced it.
Discord: https://discord.gg/kysUzFqSCK