Struct UpdateTopicConfigCasRequestHeader 

pub struct UpdateTopicConfigCasRequestHeader {
    pub topic: CheetahString,
    pub expected_version: u64,
    pub read_queue_nums: Option<i32>,
    pub write_queue_nums: Option<i32>,
    pub order: Option<bool>,
}

Closed, version-checked Topic configuration patch.

This header intentionally excludes permission, attributes, message type, routing scope, deletion, cleanup, and raw configuration fields. The Broker preserves those values from the current Topic configuration and rejects an empty patch. A distinct request code keeps the legacy generic Topic upsert behavior unchanged and makes older Brokers reject this operation.

Fields

topic: CheetahString

expected_version: u64

read_queue_nums: Option<i32>

write_queue_nums: Option<i32>

order: Option<bool>

Trait Implementations

impl Clone for UpdateTopicConfigCasRequestHeader

fn clone(&self) -> Self

Returns a duplicate of the value.

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

Performs copy-assignment from source.

impl CommandCustomHeader for UpdateTopicConfigCasRequestHeader

where CheetahString: HeaderValue, u64: HeaderValue, i32: HeaderValue, bool: HeaderValue, UpdateTopicConfigCasRequestHeader: 'static,

fn check_fields(&self) -> Result<(), Error>

Checks the fields of the implementing type.

fn to_map(&self) -> Option<HeaderMap>

Converts the implementing type to a map.

fn encode_into_map(&self, out: &mut HeaderMap)

Appends this header’s extension fields to an existing map.

fn try_encode_into_map( &self, out: &mut HeaderMap, ) -> Result<(), ProtocolContractViolation>

Validates and appends this header’s fields to an existing map.

fn resolve_wire_key(&self, key: &str) -> Option<ResolvedHeaderKey>

Resolves a canonical key or decode alias for typed headers.

fn canonical_wire_key(&self, key: &str) -> Option<&'static str>

Resolves a key and returns its canonical wire key.

fn contains_wire_key(&self, key: &str) -> bool

Returns whether a canonical key or alias belongs to this header schema.

fn encoded_len_hint(&self) -> usize

Returns a saturating extension-field payload capacity hint.

fn encode_capability(&self) -> HeaderEncodeCapability

Returns the authoritative encoding path for this header.

fn encode_direct_binary( &self, _out: &mut BytesMut, ) -> Result<(), ProtocolContractViolation>

Appends this header directly to a ROCKETMQ extension-field payload.

fn supports_direct_json_fields(&self) -> bool

Returns whether this header can write its complete JSON extension-field object without first materializing a HeaderMap.

fn encode_direct_json_fields( &self, _out: &mut BytesMut, ) -> Result<(), ProtocolContractViolation>

Writes this header as one complete JSON extension-field object.

fn write_if_not_null(&self, out: &mut BytesMut, key: &str, value: &str)

Writes the provided key to the out buffer if the value is not empty.

fn encode_fast(&mut self, out: &mut BytesMut)

Compatibility adapter for the legacy mutable fast-encoding API.

fn decode_fast( &mut self, _fields: &HashMap<CheetahString, CheetahString>, ) -> Result<()>

A placeholder function for fast decoding.

fn support_fast_codec(&self) -> bool

Indicates whether the implementing type supports fast codec.

fn get_and_check_not_none( &self, map: &HashMap<CheetahString, CheetahString>, field: &CheetahString, ) -> Result<CheetahString>

Retrieves the value associated with the specified field from the provided map.

fn get_and_check_not_none_ref<'a>( &self, map: &'a HashMap<CheetahString, CheetahString>, field: &CheetahString, ) -> Result<&'a CheetahString>

Retrieves a borrowed value associated with the specified field from the provided map.

impl Debug for UpdateTopicConfigCasRequestHeader

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

Formats the value using the given formatter.

impl Default for UpdateTopicConfigCasRequestHeader

fn default() -> Self

Returns the “default value” for a type.

impl<'de> Deserialize<'de> for UpdateTopicConfigCasRequestHeader

fn deserialize<__D>(__deserializer: __D) -> Result<Self, __D::Error>

where __D: Deserializer<'de>,

Deserialize this value from the given Serde deserializer.

impl Eq for UpdateTopicConfigCasRequestHeader

impl FromMap for UpdateTopicConfigCasRequestHeader

where CheetahString: HeaderValue, u64: HeaderValue, i32: HeaderValue, bool: HeaderValue, UpdateTopicConfigCasRequestHeader: 'static,

const SUPPORTS_HEADER_FIELD_SOURCE: bool = true

Whether production decode may call Self::from_field_source without first materializing the compatibility map.

type Error = Error

type Target = UpdateTopicConfigCasRequestHeader

fn from(map: &HeaderMap) -> Result<Self::Target, Self::Error>

Converts the implementing type from a map.

fn from_field_source( source: &dyn HeaderFieldSource, ) -> Result<Self::Target, Self::Error>

Converts the implementing type from a borrowed field source.

impl HeaderCodec for UpdateTopicConfigCasRequestHeader

where CheetahString: HeaderValue, u64: HeaderValue, i32: HeaderValue, bool: HeaderValue, UpdateTopicConfigCasRequestHeader: 'static,

const TYPE_ID: &'static str = "rocketmq_protocol::protocol::header::update_topic_config_cas_request_header::UpdateTopicConfigCasRequestHeader"

Stable, fully qualified Rust schema identifier.

const HEADER_NAME: &'static str = "UpdateTopicConfigCasRequestHeader"

Rust header name used in diagnostics.

const JAVA_CLASS: Option<&'static str> = None

Fully qualified Java peer when one is declared.

const FIELD_COUNT_HINT: usize = 5usize

Recursive upper bound used to reserve map entries.

const LOCAL_FIELD_SPECS: &'static [HeaderFieldSpec]

Fields declared directly by this header, in stable binary order.

const LOCAL_FLATTEN_SPECS: &'static [HeaderFlattenSpec]

Flatten groups declared directly by this header, in stable binary order.

const FAST_ENABLED: bool = false

Whether direct binary generation was requested for the schema.

fn visit_field_specs(visitor: &mut dyn FnMut(&HeaderFieldSpec))

Visits field schemas declared here and recursively by flattened headers.

fn visit_flatten_specs(visitor: &mut dyn FnMut(&HeaderFlattenSpec))

Visits flatten schemas declared here and recursively by flattened headers.

fn resolve_wire_key(key: &str) -> Option<ResolvedHeaderKey>

Resolves a canonical key or alias to its owning typed field.

fn validate_for_wire(&self) -> Result<(), ProtocolContractViolation>

Validates this header layer before it writes to a wire destination.

fn encode_into<__RequestHeaderSink: EncodeSink>( &self, sink: &mut __RequestHeaderSink, ) -> Result<(), ProtocolContractViolation>

Appends canonical fields to a statically dispatched destination.

fn decode_from_map(map: &HeaderMap) -> Result<Self, ProtocolContractViolation>

Decodes this header from borrowed extension fields.

fn decode_from_source( source: &dyn HeaderFieldSource, ) -> Result<Self, ProtocolContractViolation>

Decodes this header directly from a borrowed field source.

fn contains_any_field(map: &HeaderMap) -> bool

Returns whether this header or any flattened child owns a present key.

fn encoded_len_hint(&self) -> usize

Estimates the encoded ROCKETMQ extension-field payload length.

fn contains_any_field_source(source: &dyn HeaderFieldSource) -> bool

Returns whether this header or a flattened child owns a source field.

fn canonical_wire_key(key: &str) -> Option<&'static str>

Resolves a key and returns its canonical wire key.

fn contains_wire_key(key: &str) -> bool

Returns whether a canonical key or alias belongs to this schema.

impl PartialEq for UpdateTopicConfigCasRequestHeader

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

Equality operator ==.

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

Inequality operator !=.

impl Serialize for UpdateTopicConfigCasRequestHeader

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 UpdateTopicConfigCasRequestHeader