pub struct RustCollectorIngress;Expand description
Rust 侧 collector 入口。
所有进入 core 管线的 RawEvent 都必须通过此入口,无论来自
apps 侧 (JSONL/JNI/socket) 还是 Rust 系统采集器。SourceTier
由入口权威决定,并随 IngestedRawEvent 一路传递到脱敏器。
Implementations§
Source§impl RustCollectorIngress
impl RustCollectorIngress
Sourcepub fn accept(
&self,
envelope: CollectorEnvelope,
) -> Result<IngestedRawEvent, CollectorIngressError>
pub fn accept( &self, envelope: CollectorEnvelope, ) -> Result<IngestedRawEvent, CollectorIngressError>
校验并解包来自 apps 侧或外部系统的 envelope。
envelope 中声明的 source_tier 会随事件一并返回,供下游脱敏器
与策略层使用。
Sourcepub fn accept_internal(
&self,
raw: RawEvent,
_source: &str,
_captured_at_ms: i64,
) -> IngestedRawEvent
pub fn accept_internal( &self, raw: RawEvent, _source: &str, _captured_at_ms: i64, ) -> IngestedRawEvent
包装来自 Rust 系统采集器的事件。
内部采集器是受信来源,固定标记为 SourceTier::Daemon。
source 和 captured_at_ms 当前仅用于调用方诊断,
未来可在 envelope 化改造后接入 Trace。
Trait Implementations§
Source§impl Debug for RustCollectorIngress
impl Debug for RustCollectorIngress
Source§impl Default for RustCollectorIngress
impl Default for RustCollectorIngress
Source§fn default() -> RustCollectorIngress
fn default() -> RustCollectorIngress
Returns the “default value” for a type. Read more
Auto Trait Implementations§
impl Freeze for RustCollectorIngress
impl RefUnwindSafe for RustCollectorIngress
impl Send for RustCollectorIngress
impl Sync for RustCollectorIngress
impl Unpin for RustCollectorIngress
impl UnsafeUnpin for RustCollectorIngress
impl UnwindSafe for RustCollectorIngress
Blanket Implementations§
Source§impl<T> BorrowMut<T> for Twhere
T: ?Sized,
impl<T> BorrowMut<T> for Twhere
T: ?Sized,
Source§fn borrow_mut(&mut self) -> &mut T
fn borrow_mut(&mut self) -> &mut T
Mutably borrows from an owned value. Read more