SDKs

Reference implementations for building SGP pipelines.

Alpha

The Python SDK is in development. The code below reflects the proposed surface.

Python

pip install signal-gating-protocol

from sgp import Channel
from sgp.gates import Gate, filter, dedupe, throttle

pipeline = Gate.chain(
    filter(lambda s: s.priority >= 3),
    dedupe(key=lambda s: s.payload["id"], ttl=30),
    throttle(rate=10, per="second"),
)

async with Channel("sensor.events") as ch:
    async for signal in ch.gated(pipeline):
        await agent.handle(signal)

View on GitHub

Integration pattern

All SGP SDKs follow a common shape:

1. Connect — open a Channel to a signal source.
2. Compose — build a Gate pipeline from the built-in or custom gates.
3. Consume — iterate the gated channel and pass results to your agent.
4. Coordinate — for multi-agent workflows, assemble channels into a Mesh topology.

More SDKs

Additional language SDKs are planned. Watch the GitHub organization for announcements.