Struct ReplicateRequestEncoder 

pub struct ReplicateRequestEncoder<'a> { /* private fields */ }

Implementations

impl<'a> ReplicateRequestEncoder<'a>

pub fn wrap(self, buf: WriteBuf<'a>, offset: usize) -> Self

pub fn encoded_length(&self) -> usize

pub fn header(self, offset: usize) -> MessageHeaderEncoder<Self>

pub fn control_session_id(&mut self, value: i64)

primitive field ‘controlSessionId’

• min value: -9223372036854775807
• max value: 9223372036854775807
• null value: -9223372036854775808
• characterEncoding: null
• semanticType: null
• encodedOffset: 0
• encodedLength: 8
• version: 0

pub fn correlation_id(&mut self, value: i64)

primitive field ‘correlationId’

• min value: -9223372036854775807
• max value: 9223372036854775807
• null value: -9223372036854775808
• characterEncoding: null
• semanticType: null
• encodedOffset: 8
• encodedLength: 8
• version: 0

pub fn src_recording_id(&mut self, value: i64)

primitive field ‘srcRecordingId’

• min value: -9223372036854775807
• max value: 9223372036854775807
• null value: -9223372036854775808
• characterEncoding: null
• semanticType: null
• encodedOffset: 16
• encodedLength: 8
• version: 0

pub fn dst_recording_id(&mut self, value: i64)

primitive field ‘dstRecordingId’

• min value: -9223372036854775807
• max value: 9223372036854775807
• null value: -9223372036854775808
• characterEncoding: null
• semanticType: null
• encodedOffset: 24
• encodedLength: 8
• version: 0

pub fn src_control_stream_id(&mut self, value: i32)

primitive field ‘srcControlStreamId’

• min value: -2147483647
• max value: 2147483647
• null value: -2147483648
• characterEncoding: null
• semanticType: null
• encodedOffset: 32
• encodedLength: 4
• version: 0

pub fn src_control_channel(&mut self, value: &[u8])

VAR_DATA ENCODER - character encoding: ‘US-ASCII’

pub fn live_destination(&mut self, value: &[u8])

VAR_DATA ENCODER - character encoding: ‘US-ASCII’

Trait Implementations

impl<'a> Debug for ReplicateRequestEncoder<'a>

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

Formats the value using the given formatter.

impl<'a> Default for ReplicateRequestEncoder<'a>

fn default() -> ReplicateRequestEncoder<'a>

Returns the “default value” for a type.

impl<'a> Encoder<'a> for ReplicateRequestEncoder<'a>

fn get_limit(&self) -> usize

fn set_limit(&mut self, limit: usize)

impl<'a> Writer<'a> for ReplicateRequestEncoder<'a>

fn get_buf_mut(&mut self) -> &mut WriteBuf<'a>