pub struct AgentUplinkState {
pub enabled: bool,
pub kind: String,
pub target: Option<String>,
pub source: String,
pub output_write_failing: bool,
}Expand description
Agent 实际生效的采集输出状态(agent → 网关,自报)。
与 AgentUplinkGrant 是一对:grant 说「控制面要它怎样」,这里说「它实际成了怎样」。
为什么必须由 agent 上报:网关知道自己下发了什么,但不知道 agent 生效成什么 ——
grant 可能还没拉到、可能被本机总闸拦住、可能目标连不上。这与
AgentStatusReport::discovery_policy_version 是同一类事实(「我发布了哪一版」≠「它生效了哪一版」)。
Fields§
§enabled: bool生效输出的总闸:false = 待命(不读源、不写本地采集输出、不上送)。
kind: String生效输出类型:file | tcp(grant 覆盖本机 kind 之后的结果)。
target: Option<String>生效目标(tcp 且有目标时)。None = 本地文件输出,或 tcp 但没有目标。
source: String这份生效状态的来源:grant(控制面下发)| local(未下发,用本机配置)。
有了它,平台才能区分「控制面没启用」与「启用了但 agent 没听从」(后者才是故障)。
output_write_failing: bool最近的出口写失败是否尚未恢复(细节在 agent 日志里:目标与原因)。
Trait Implementations§
Source§impl Clone for AgentUplinkState
impl Clone for AgentUplinkState
Source§fn clone(&self) -> AgentUplinkState
fn clone(&self) -> AgentUplinkState
Returns a duplicate of the value. Read more
1.0.0 (const: unstable) · Source§fn clone_from(&mut self, source: &Self)
fn clone_from(&mut self, source: &Self)
Performs copy-assignment from
source. Read moreSource§impl Debug for AgentUplinkState
impl Debug for AgentUplinkState
Source§impl<'de> Deserialize<'de> for AgentUplinkState
impl<'de> Deserialize<'de> for AgentUplinkState
Source§fn deserialize<__D>(
__deserializer: __D,
) -> Result<AgentUplinkState, <__D as Deserializer<'de>>::Error>where
__D: Deserializer<'de>,
fn deserialize<__D>(
__deserializer: __D,
) -> Result<AgentUplinkState, <__D as Deserializer<'de>>::Error>where
__D: Deserializer<'de>,
Deserialize this value from the given Serde deserializer. Read more
impl Eq for AgentUplinkState
Source§impl JumoItem for AgentUplinkState
impl JumoItem for AgentUplinkState
Source§fn jumo_id() -> Option<&'static str>
fn jumo_id() -> Option<&'static str>
稳定身份:模型条目的全名(如
"Control.Gateway.Management.GatewayHealth")。 Read moreSource§fn jumo_kind() -> &'static str
fn jumo_kind() -> &'static str
.mju item kind:
"struct", "state", "enum", "variant",
"event", "message", "failure", "cap", "actor", "module",
"interface", "storage", "command", "dataflow", "lifecycle",
"layer", "dependency_rule", "decision", "failure_policy",
"flow", "verify", "target". Read moreSource§fn jumo_domain() -> &'static str
fn jumo_domain() -> &'static str
Domain name, e.g.
"Business", "Storage".Source§fn jumo_module() -> Option<&'static str>
fn jumo_module() -> Option<&'static str>
Module name, e.g.
"Design.JumoCore".Source§fn jumo_role() -> Option<&'static str>
fn jumo_role() -> Option<&'static str>
Message role, if kind is
"message": "command", "query", "response".Source§fn jumo_identity() -> Option<&'static str>
fn jumo_identity() -> Option<&'static str>
Failure identity path, if kind is
"failure", e.g. "payment.timeout".Source§fn jumo_storage_kind() -> Option<&'static str>
fn jumo_storage_kind() -> Option<&'static str>
Storage kind, if kind is
"storage":
"table", "document", "key_value", "queue", "object",
"search", "graph", "cache".Source§fn jumo_durability() -> Option<&'static str>
fn jumo_durability() -> Option<&'static str>
Storage durability, if kind is
"storage":
"transient", "persistent", "derived".Source§fn jumo_parent() -> Option<&'static str>
fn jumo_parent() -> Option<&'static str>
Actor parent name, if kind is
"actor", e.g. "User".Source§fn jumo_description() -> Option<&'static str>
fn jumo_description() -> Option<&'static str>
Failure description text, if kind is
"failure".Source§fn jumo_unique_fields() -> &'static [&'static str]
fn jumo_unique_fields() -> &'static [&'static str]
Field names marked
#[jumo(unique)].Source§impl PartialEq for AgentUplinkState
impl PartialEq for AgentUplinkState
Source§impl Serialize for AgentUplinkState
impl Serialize for AgentUplinkState
Source§fn serialize<__S>(
&self,
__serializer: __S,
) -> Result<<__S as Serializer>::Ok, <__S as Serializer>::Error>where
__S: Serializer,
fn serialize<__S>(
&self,
__serializer: __S,
) -> Result<<__S as Serializer>::Ok, <__S as Serializer>::Error>where
__S: Serializer,
Serialize this value into the given Serde serializer. Read more
impl StructuralPartialEq for AgentUplinkState
Auto Trait Implementations§
impl Freeze for AgentUplinkState
impl RefUnwindSafe for AgentUplinkState
impl Send for AgentUplinkState
impl Sync for AgentUplinkState
impl Unpin for AgentUplinkState
impl UnsafeUnpin for AgentUplinkState
impl UnwindSafe for AgentUplinkState
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