Struct nakadion::Nakadion
[−]
[src]
pub struct Nakadion { /* fields omitted */ }
Methods
impl Nakadion
[src]
pub fn start_with<HF, C, A>(
subscription_id: SubscriptionId,
streaming_client: C,
api_client: A,
handler_factory: HF,
commit_strategy: CommitStrategy
) -> Result<Nakadion, Error> where
C: StreamingClient + Clone + Sync + Send + 'static,
A: ApiClient + Clone + Sync + Send + 'static,
HF: HandlerFactory + Sync + Send + 'static,
[src]
subscription_id: SubscriptionId,
streaming_client: C,
api_client: A,
handler_factory: HF,
commit_strategy: CommitStrategy
) -> Result<Nakadion, Error> where
C: StreamingClient + Clone + Sync + Send + 'static,
A: ApiClient + Clone + Sync + Send + 'static,
HF: HandlerFactory + Sync + Send + 'static,
pub fn start<HF, P>(
config: NakadionConfig,
handler_factory: HF,
access_token_provider: P
) -> Result<Nakadion, Error> where
HF: HandlerFactory + Sync + Send + 'static,
P: ProvidesAccessToken + Send + Sync + 'static,
[src]
config: NakadionConfig,
handler_factory: HF,
access_token_provider: P
) -> Result<Nakadion, Error> where
HF: HandlerFactory + Sync + Send + 'static,
P: ProvidesAccessToken + Send + Sync + 'static,