opcua_types/service_types/
monitored_item_modify_result.rs1#![allow(unused_attributes)]
9use std::io::{Read, Write};
10#[allow(unused_imports)]
11use crate::{
12 encoding::*,
13 basic_types::*,
14 service_types::impls::MessageInfo,
15 node_ids::ObjectId,
16 status_codes::StatusCode,
17 extension_object::ExtensionObject,
18};
19
20#[derive(Debug, Clone, PartialEq)]
21pub struct MonitoredItemModifyResult {
22 pub status_code: StatusCode,
23 pub revised_sampling_interval: f64,
24 pub revised_queue_size: u32,
25 pub filter_result: ExtensionObject,
26}
27
28impl MessageInfo for MonitoredItemModifyResult {
29 fn object_id(&self) -> ObjectId {
30 ObjectId::MonitoredItemModifyResult_Encoding_DefaultBinary
31 }
32}
33
34impl BinaryEncoder<MonitoredItemModifyResult> for MonitoredItemModifyResult {
35 fn byte_len(&self) -> usize {
36 let mut size = 0;
37 size += self.status_code.byte_len();
38 size += self.revised_sampling_interval.byte_len();
39 size += self.revised_queue_size.byte_len();
40 size += self.filter_result.byte_len();
41 size
42 }
43
44 #[allow(unused_variables)]
45 fn encode<S: Write>(&self, stream: &mut S) -> EncodingResult<usize> {
46 let mut size = 0;
47 size += self.status_code.encode(stream)?;
48 size += self.revised_sampling_interval.encode(stream)?;
49 size += self.revised_queue_size.encode(stream)?;
50 size += self.filter_result.encode(stream)?;
51 Ok(size)
52 }
53
54 #[allow(unused_variables)]
55 fn decode<S: Read>(stream: &mut S, decoding_options: &DecodingOptions) -> EncodingResult<Self> {
56 let status_code = StatusCode::decode(stream, decoding_options)?;
57 let revised_sampling_interval = f64::decode(stream, decoding_options)?;
58 let revised_queue_size = u32::decode(stream, decoding_options)?;
59 let filter_result = ExtensionObject::decode(stream, decoding_options)?;
60 Ok(MonitoredItemModifyResult {
61 status_code,
62 revised_sampling_interval,
63 revised_queue_size,
64 filter_result,
65 })
66 }
67}