Struct RyuRelaySource 

pub struct RyuRelaySource;

RyuRelay — the managed push relay (the default). Core opens an outbound SSE subscription to apps/server; Composio POSTs to a public ingress URL and the server fans the payload out over that stream, which Core dispatches in-process. The register + SSE-client loop live in [super::ryu_relay]; this source delegates to them.

Implementations

impl RyuRelaySource

pub fn new() -> Self

Trait Implementations

impl Clone for RyuRelaySource

fn clone(&self) -> RyuRelaySource

Returns a duplicate of the value.

fn clone_from(&mut self, source: &Self)

Performs copy-assignment from source.

impl Debug for RyuRelaySource

fn fmt(&self, f: &mut Formatter<'_>) -> Result

Formats the value using the given formatter.

impl Default for RyuRelaySource

fn default() -> RyuRelaySource

Returns the “default value” for a type.

impl WebhookIngress for RyuRelaySource

fn kind(&self) -> IngressKind

Which backend this is.

async fn start(&self) -> Result<()>

Start (or adopt) the backend so webhooks can arrive. May be a no-op (the OwnRelay case) or error gracefully when the backing infra is absent.

async fn public_url(&self) -> Result<String>

The public URL Composio should POST to (ends in WEBHOOK_PATH).