Struct TriggerHandles 

pub struct TriggerHandles {
    pub topic_repo: Arc<TopicRepo>,
    pub publisher: Arc<Publisher>,
    pub subscriber: Arc<Subscriber>,
}

Trigger-stream handles attached to the gRPC server. The caller constructs these once per deployment (sharing one broker, publisher, subscriber, and topic catalog repo across every connection).

Kept as a public struct because integration tests still wire trigger handles manually for fixtures that need to drive a stubbed broker. Production code goes through runtime::OssServer which derives the same handles from the engine session.

Fields

topic_repo: Arc<TopicRepo>

publisher: Arc<Publisher>

subscriber: Arc<Subscriber>