Struct SigningEventSink 

pub struct SigningEventSink { /* private fields */ }

EventSink wrapper that signs each emitted CloudEvent and forwards a transport-wrapper CloudEvent of type SIGNED_ENVELOPE_TRANSPORT_TYPE.

Implementations

impl SigningEventSink

pub fn from_env(inner: Arc<dyn EventSink>) -> Arc<dyn EventSink>

Parse CELLOS_EVENT_SIGNING + CELLOS_EVENT_SIGNING_KID + CELLOS_EVENT_SIGNING_KEY_BASE64 and return a wrapped sink if all three are valid, otherwise return inner unwrapped.

Backwards-compatible thin wrapper over SigningEventSink::from_env_with_warnings for callers that don’t need to surface the structured warnings (existing in-module unit tests, the sink_composition_chain integration test). Composition root MUST use from_env_with_warnings so misconfig is observable under CELLOS_STRICT_CONFIG=1 (U1-04).

pub fn from_env_with_warnings( inner: Arc<dyn EventSink>, ) -> (Arc<dyn EventSink>, Vec<EventSigningConfigWarning>)

Same parsing as SigningEventSink::from_env but additionally returns a Vec<EventSigningConfigWarning> capturing every WARN-and-fall-back decision. The composition root threads these into the supervisor’s StartupConfigWarnings accumulator so a misconfigured event_signing triggers CELLOS_STRICT_CONFIG=1 startup failure (U1-04 / reviewer wave 2 finding bebc77b) rather than silently degrading to passthrough.

Each disable path also emits the legacy tracing::warn! so log-based alerting keeps working unchanged.

Trait Implementations

impl EventSink for SigningEventSink

fn emit<'life0, 'life1, 'async_trait>( &'life0 self, event: &'life1 CloudEventV1, ) -> Pin<Box<dyn Future<Output = Result<(), CellosError>> + Send + 'async_trait>>

where Self: 'async_trait, 'life0: 'async_trait, 'life1: 'async_trait,