azure_messaging_eventhubs 0.16.0

Rust client for Azure Eventhubs Service
Documentation 
1
2
3
4
5
6
7
8
9
10
11
12
13
14
15
16
17
18
19
20
21
22
23
24
25
26
27
28
29
30
31
32
33
34
35
36
37
38
39
40
41
42
43
44
45
46
47
48
49
50
51

// Copyright (c) Microsoft Corporation. All Rights reserved
// Licensed under the MIT license.

#![recursion_limit = "128"]
#![warn(missing_docs)]
#![doc = include_str!("../README.md")]
#![cfg_attr(docsrs, feature(doc_cfg))]

#[cfg(feature = "in_memory_checkpoint_store")]
mod in_memory_checkpoint_store;

mod common;
mod consumer;
/// Error types for the Event Hubs service.
pub mod error;
mod event_processor;
mod producer;

/// Types sent to and received from the Event Hubs service.
pub mod models;
pub use consumer::{
    ConsumerClient, EventReceiver, OpenReceiverOptions, StartLocation, StartPosition,
};
pub use producer::{
    batch::{EventDataBatch, EventDataBatchOptions},
    buffered::{
        BufferedProducerClient, EnqueueEventOptions, SendBatchFailedContext,
        SendBatchSucceededContext,
    },
    ProducerClient, SendBatchOptions, SendEventOptions, SendMessageOptions,
};

/// Event Hubs processor related types.
pub mod processor {
    pub use crate::event_processor::partition_client::PartitionClient;
    pub use crate::event_processor::CheckpointStore;
}
pub use event_processor::{processor::EventProcessor, CheckpointStore, ProcessorStrategy};
/// Builders for producer client and consumer client.
pub mod builders {
    pub use crate::consumer::builders::ConsumerClientBuilder;
    pub use crate::event_processor::processor::builders::EventProcessorBuilder;
    pub use crate::producer::buffered::builders::BufferedProducerClientBuilder;
    pub use crate::producer::builders::ProducerClientBuilder;
}
pub use common::connection_string::ConnectionString;
pub use common::retry::RetryOptions;
pub use error::{EventHubsError, Result};

#[cfg(feature = "in_memory_checkpoint_store")]
pub use in_memory_checkpoint_store::InMemoryCheckpointStore;