Struct nakadion::publisher::Publisher

pub struct Publisher<C> { /* fields omitted */ }

Publishes events with retries

PublishApi

The publisher implements PublishApi. If the trait method is used for publishing no retries are done on partial successes. Retries are only done on io errors and server errors or on auth errors if retry_on_auth_errors is set to true.

Implementations

impl<C> Publisher<C> where
    C: PublishApi + Send + Sync + 'static, 

pub fn new(api_client: C) -> Self

Creates a new Publisher with the default configuration.

pub fn from_env_prefixed<T: AsRef<str>>(
    api_client: C,
    prefix: T
) -> Result<Self, Error>

Creates a new Publisher from the environment.

Environment variables must be prefixed with the given prefix. See PublisherConfig::from_env_prefixed

pub fn from_env(api_client: C) -> Result<Self, Error>

Creates a new Publisher from the environment.

Environment variables must be prefixed “NAKADION”. See PublisherConfig::from_env

pub fn with_config(api_client: C, config: PublisherConfig) -> Self

pub fn set_logger<L: Logger>(&mut self, logger: L)

pub fn logger<L: Logger>(self, logger: L) -> Self

pub fn instrumentation(self, instr: Instrumentation) -> Self

pub fn set_instrumentation(&mut self, instr: Instrumentation)

Trait Implementations

impl<C: Clone> Clone for Publisher<C>

fn clone(&self) -> Publisher<C>

Returns a copy of the value.

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

Performs copy-assignment from source.

impl<C> PublishApi for Publisher<C> where
    C: PublishApi + Send + Sync + 'static, 

fn publish_events_batch<'a, B: Into<Bytes>, T: Into<FlowId>>(
    &'a self,
    event_type: &'a EventTypeName,
    events: B,
    flow_id: T
) -> PublishFuture<'a>

Publishes a batch of Events of this EventType. All items must be of the EventType identified by name.

impl<C> PublishesSerializedEvents for Publisher<C> where
    C: PublishApi + Send + Sync + 'static, 

fn publish_serialized_events<'a>(
    &'a self,
    event_type: &'a EventTypeName,
    events: &[Bytes],
    flow_id: FlowId
) -> PublishFuture<'a>

Publishes the serialized events.