Struct ydb_grpc::ydb_proto::pers_queue::v1::streaming_write_server_message::InitResponse

pub struct InitResponse {
    pub last_sequence_number: i64,
    pub session_id: String,
    pub topic: String,
    pub cluster: String,
    pub partition_id: i64,
    pub block_format_version: i64,
    pub supported_codecs: Vec<i32>,
    pub max_flush_window_size: i64,
    pub max_block_size: i64,
    pub connection_meta: Vec<u8>,
}

Response for handshake.

Fields

last_sequence_number: i64

Last persisted message’s sequence number for this message group.

session_id: String

Unique identifier of write session. Used for debug purposes.

topic: String

Path of topic that matched for this write session. Used for debug purposes, will be the same as in Init request from client.

cluster: String

Write session is established to this cluster. Client data will be in instance of topic in this cluster.

partition_id: i64

Identifier of partition that is matched for this write session.

block_format_version: i64

Block (see StreamingWriteClientMessage.WriteRequest.blocks_data) format version supported by server or configured for a topic. Client must write data only with them.

supported_codecs: Vec<i32>

Client can only use compression codecs from this set to write messages to topic, session will be closed with BAD_REQUEST otherwise.

max_flush_window_size: i64

Maximal flush window size choosed by server. Size of uncompressed data not sended to server must not be bigger than flush window size. In other words, this is maximal size of gap inside uncompressed data, which is not sended to server yet. will be 2048kb

max_block_size: i64

How big blocks per stream could be(in uncompressed size). When block contains more than max_block_size of uncompressed data - block must be truncated. will be 512kb

connection_meta: Vec<u8>

Opaque blob, used for fast reconnects.

Implementations

impl InitResponse

pub fn supported_codecs(
    &self
) -> FilterMap<Cloned<Iter<'_, i32>>, fn(_: i32) -> Option<Codec>>

Returns an iterator which yields the valid enum values contained in supported_codecs.

pub fn push_supported_codecs(&mut self, value: Codec)

Appends the provided enum value to supported_codecs.

Trait Implementations

impl Clone for InitResponse

fn clone(&self) -> InitResponse

Returns a copy of the value.

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

Performs copy-assignment from source.

impl Debug for InitResponse

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

Formats the value using the given formatter.

impl Default for InitResponse

fn default() -> Self

Returns the “default value” for a type.

impl<'de> Deserialize<'de> for InitResponse

fn deserialize<__D>(__deserializer: __D) -> Result<Self, __D::Error> where
    __D: Deserializer<'de>, 

Deserialize this value from the given Serde deserializer.

impl Message for InitResponse

fn encoded_len(&self) -> usize

Returns the encoded length of the message without a length delimiter.

fn clear(&mut self)

Clears the message, resetting all fields to their default.

fn encode<B>(&self, buf: &mut B) -> Result<(), EncodeError> where
    B: BufMut, 

Encodes the message to a buffer.

fn encode_to_vec(&self) -> Vec<u8, Global>

Encodes the message to a newly allocated buffer.

fn encode_length_delimited<B>(&self, buf: &mut B) -> Result<(), EncodeError> where
    B: BufMut, 

Encodes the message with a length-delimiter to a buffer.

fn encode_length_delimited_to_vec(&self) -> Vec<u8, Global>

Encodes the message with a length-delimiter to a newly allocated buffer.

fn decode<B>(buf: B) -> Result<Self, DecodeError> where
    B: Buf,
    Self: Default, 

Decodes an instance of the message from a buffer.

fn decode_length_delimited<B>(buf: B) -> Result<Self, DecodeError> where
    B: Buf,
    Self: Default, 

Decodes a length-delimited instance of the message from the buffer.

fn merge<B>(&mut self, buf: B) -> Result<(), DecodeError> where
    B: Buf, 

Decodes an instance of the message from a buffer, and merges it into self.

fn merge_length_delimited<B>(&mut self, buf: B) -> Result<(), DecodeError> where
    B: Buf, 

Decodes a length-delimited instance of the message from buffer, and merges it into self.

impl PartialEq<InitResponse> for InitResponse

fn eq(&self, other: &InitResponse) -> bool

This method tests for self and other values to be equal, and is used by ==.

fn ne(&self, other: &InitResponse) -> bool

This method tests for !=.

impl Serialize for InitResponse

fn serialize<__S>(&self, __serializer: __S) -> Result<__S::Ok, __S::Error> where
    __S: Serializer, 

Serialize this value into the given Serde serializer.

impl StructuralPartialEq for InitResponse