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
35
36
37
38
39
40
41
42
43
44
45
46
47

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

//! Trait and types for shared (Send) extensions.

use crate::control::ExtensionControlMsg;
use crate::error::Error;
use crate::extension::EffectHandler;
use crate::shared::message::SharedReceiver;
use crate::terminal_state::TerminalState;
use async_trait::async_trait;

/// Shared (Send) control channel for extensions.
///
/// Wraps a [`SharedReceiver`] with shutdown-grace-period logic.
/// See [`crate::extension::ControlChannel`] for the implementation.
pub type ControlChannel = crate::extension::ControlChannel<SharedReceiver<ExtensionControlMsg>>;

/// A trait for extensions (Send variant).
///
/// Extensions are long-lived components hosted alongside the data path --
/// today at pipeline scope, and in the future at engine, pipeline-group,
/// or node scope -- that expose functionality (e.g., authentication,
/// service discovery) to other components.
///
/// Unlike receivers, processors, and exporters, extensions are NOT generic
/// over PData -- they never process PData.
///
/// # Thread Safety
///
/// The shared `Extension` trait requires the `Send` bound, enabling use in both
/// single-threaded and multi-threaded runtime contexts.
#[async_trait]
pub trait Extension: Send {
    /// Starts the extension.
    ///
    /// Extensions are started BEFORE receivers, processors, and exporters.
    ///
    /// # Errors
    ///
    /// Returns an [`Error`] if an unrecoverable error occurs.
    async fn start(
        self: Box<Self>,
        ctrl_chan: ControlChannel,
        effect_handler: EffectHandler,
    ) -> Result<TerminalState, Error>;
}