Struct WsJsonSourceSpec 

pub struct WsJsonSourceSpec {
    pub name: Cow<'static, str>,
    pub url: Cow<'static, str>,
    pub subscribe_message: Option<Cow<'static, [u8]>>,
    pub schema: Vec<Field>,
    pub event_time_key: Cow<'static, str>,
    pub emit_mode: EmitMode,
}

Connector source specification for a WebSocket-JSON live feed.

Fields

name: Cow<'static, str>

url: Cow<'static, str>

subscribe_message: Option<Cow<'static, [u8]>>

schema: Vec<Field>

event_time_key: Cow<'static, str>

emit_mode: EmitMode

Implementations

impl WsJsonSourceSpec

pub fn new( name: impl Into<Cow<'static, str>>, url: impl Into<Cow<'static, str>>, event_time_key: impl Into<Cow<'static, str>>, ) -> Self

pub fn schema(self, schema: Vec<Field>) -> Self

pub fn subscribe_message(self, msg: impl Into<Cow<'static, [u8]>>) -> Self

pub fn emit_mode(self, mode: EmitMode) -> Self

pub fn validate(&self) -> Result<(), String>

Trait Implementations

impl Clone for WsJsonSourceSpec

fn clone(&self) -> WsJsonSourceSpec

Returns a duplicate of the value.

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

Performs copy-assignment from source.

impl Debug for WsJsonSourceSpec

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

Formats the value using the given formatter.