Struct UpstreamConfig 

#[non_exhaustive]
pub struct UpstreamConfig {
    pub session_id: String,
    pub ack_interval: Duration,
    pub expiry_interval: Duration,
    pub data_ids: Vec<DataId>,
    pub qos: QoS,
    pub persist: bool,
    pub flush_policy: FlushPolicy,
    pub close_timeout: Duration,
    pub send_data_points_callback: Option<SendDataPointsCallback>,
    pub receive_ack_callback: Option<ReceiveAckCallback>,
    pub resumed_callback: Option<UpstreamResumedCallback>,
}

アップストリーム設定

Fields (Non-exhaustive)

Non-exhaustive structs could have additional fields added in future. Therefore, non-exhaustive structs cannot be constructed in external crates using the traditional Struct { .. } syntax; cannot be matched against without a wildcard ..; and struct update syntax will not work.

session_id: String

セッションID

ack_interval: Duration

Ack間隔

expiry_interval: Duration

ストリーム再開の有効期限

data_ids: Vec<DataId>

データIDエイリアスの設定に用いるデータIDのリスト

qos: QoS

ストリームのQoS

persist: bool

永続化の設定

flush_policy: FlushPolicy

フラッシュポリシー

close_timeout: Duration

クローズのタイムアウト

send_data_points_callback: Option<SendDataPointsCallback>

アップストリームチャンクのフラッシュのコールバック

receive_ack_callback: Option<ReceiveAckCallback>

Ackの受信のコールバック

resumed_callback: Option<UpstreamResumedCallback>

アップストリームの再開のコールバック

Trait Implementations

impl Clone for UpstreamConfig

fn clone(&self) -> UpstreamConfig

Returns a duplicate of the value.

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

Performs copy-assignment from source.

impl Default for UpstreamConfig

fn default() -> Self

Returns the “default value” for a type.