Struct EventPublisher
pub struct EventPublisher { /* private fields */ }Expand description
Direct SDK publisher. Existing target/group parsing is the sole routing authority. One endpoint failure does not prevent deliveries to other endpoints.
Implementations§
§impl EventPublisher
impl EventPublisher
pub fn from_config( path: Option<&Path>, target: &str, ) -> Result<EventPublisher, AppError>
pub fn from_target( config: &OmniConfig, target: &str, ) -> Result<EventPublisher, AppError>
pub fn from_endpoints_with(
endpoints: Vec<ResolvedEndpoint>,
token: impl FnMut(&str) -> Option<String>,
) -> Result<EventPublisher, AppError>
pub fn from_endpoints_with( endpoints: Vec<ResolvedEndpoint>, token: impl FnMut(&str) -> Option<String>, ) -> Result<EventPublisher, AppError>
Pure credential-provider seam for embedding/tests; does not mutate env.
pub fn publish( &mut self, event: &SemanticEvent, ) -> Result<Vec<Delivery>, AppError>
pub fn close(&mut self)
Auto Trait Implementations§
impl Freeze for EventPublisher
impl RefUnwindSafe for EventPublisher
impl Send for EventPublisher
impl Sync for EventPublisher
impl Unpin for EventPublisher
impl UnsafeUnpin for EventPublisher
impl UnwindSafe for EventPublisher
Blanket Implementations§
Source§impl<T> BorrowMut<T> for Twhere
T: ?Sized,
impl<T> BorrowMut<T> for Twhere
T: ?Sized,
Source§fn borrow_mut(&mut self) -> &mut T
fn borrow_mut(&mut self) -> &mut T
Mutably borrows from an owned value. Read more