otel-arrow-dfe-engine 0.61.0

Async pipeline engine
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

// Copyright The OpenTelemetry Authors
// SPDX-License-Identifier: Apache-2.0

//! Topic module: broker, topic state, subscription, and related types.

mod backend;
mod binding;
mod broker;
mod handle;
mod subscription;
#[allow(clippy::module_inception)] // topic/topic.rs holds the core topic-state internals.
mod topic;
mod topic_set;
mod types;

#[cfg(test)]
mod tests;

pub use backend::{InMemoryBackend, SubscriptionBackend, TopicBackend, TopicState};
pub use binding::PipelineTopicBinding;
pub use broker::TopicBroker;
pub use handle::{TopicHandle, TrackedTopicPublisher};
pub use otel_arrow_dfe_config::topic::{
    TopicAckPropagationMode, TopicBroadcastAckMode, TopicBroadcastOnLagPolicy,
    TopicQueueOnFullPolicy,
};
pub use otel_arrow_dfe_config::{SubscriptionGroupName, TopicName};
pub use subscription::{Delivery, RecvDelivery, Subscription};
pub use topic_set::TopicSet;
pub use types::{
    AckFromResult, BroadcastSubscriberId, Envelope, PublishOutcome, RecvItem, SubscriberOptions,
    SubscriptionMode, TopicOptions, TopicPublishOutcomeConfig, TrackedPublishOutcome,
    TrackedPublishPermit, TrackedPublishReceipt, TrackedPublishTracker, TrackedTryPublishOutcome,
};