Struct AlignStreamFrame 

pub struct AlignStreamFrame {
    pub sync_id: String,
    pub task_id: String,
    pub subtask_id: String,
    pub seq: u64,
    pub is_final: bool,
    pub source_nid: Option<String>,
    pub result: Option<Value>,
    pub error: Option<Value>,
    pub window_size: Option<u64>,
    pub ack_seq: Option<u64>,
    pub nak_seq: Option<u64>,
}

Fields

sync_id: String

task_id: String

subtask_id: String

seq: u64

is_final: bool

source_nid: Option<String>

result: Option<Value>

error: Option<Value>

window_size: Option<u64>

ack_seq: Option<u64>

nak_seq: Option<u64>

Implementations

impl AlignStreamFrame

pub fn frame_type() -> FrameType

pub fn error_code(&self) -> Option<&str>

pub fn error_message(&self) -> Option<&str>

pub fn to_dict(&self) -> FrameDict

pub fn from_dict(d: &FrameDict) -> NpsResult<Self>

Trait Implementations

impl Clone for AlignStreamFrame

fn clone(&self) -> AlignStreamFrame

Returns a duplicate of the value.

fn clone_from(&mut self, source: &Self)

Performs copy-assignment from source.

impl Debug for AlignStreamFrame

fn fmt(&self, f: &mut Formatter<'_>) -> Result

Formats the value using the given formatter.