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