pub struct AlterTopicRequest {Show 13 fields
pub operation_params: Option<OperationParams>,
pub path: String,
pub alter_partitioning_settings: Option<AlterPartitioningSettings>,
pub set_retention_period: Option<Duration>,
pub set_retention_storage_mb: Option<i64>,
pub set_supported_codecs: Option<SupportedCodecs>,
pub set_partition_write_speed_bytes_per_second: Option<i64>,
pub set_partition_write_burst_bytes: Option<i64>,
pub alter_attributes: HashMap<String, String>,
pub add_consumers: Vec<Consumer>,
pub drop_consumers: Vec<String>,
pub alter_consumers: Vec<AlterConsumer>,
pub set_metering_mode: i32,
}
Expand description
Update existing topic request sent from client to server.
Fields§
§operation_params: Option<OperationParams>
§path: String
Topic path.
alter_partitioning_settings: Option<AlterPartitioningSettings>
partitioning_settings
set_retention_period: Option<Duration>
Retention settings. Currently, only one limit may be set, so other should not be set. How long data in partition should be stored. Must be greater than 0 and less than limit for this database. Default limit - 36 hours.
set_retention_storage_mb: Option<i64>
How much data in partition should be stored. Must be greater than 0 and less than limit for this database.
set_supported_codecs: Option<SupportedCodecs>
List of allowed codecs for writers. Writes with codec not from this list are forbidden. If empty, codec compatibility check for the topic is disabled.
set_partition_write_speed_bytes_per_second: Option<i64>
Partition write speed in bytes per second. Must be less than database limit. Default limit - 1 MB/s.
set_partition_write_burst_bytes: Option<i64>
Burst size for write in partition, in bytes. Must be less than database limit. Default limit - 1 MB.
alter_attributes: HashMap<String, String>
User and server attributes of topic. Server attributes starts from “_” and will be validated by server. Leave the value blank to drop an attribute.
add_consumers: Vec<Consumer>
Add consumers.
drop_consumers: Vec<String>
Remove consumers (by their names)
alter_consumers: Vec<AlterConsumer>
Alter consumers
set_metering_mode: i32
Set metering mode for topic in serverless database.
Implementations§
Source§impl AlterTopicRequest
impl AlterTopicRequest
Sourcepub fn set_retention_storage_mb(&self) -> i64
pub fn set_retention_storage_mb(&self) -> i64
Returns the value of set_retention_storage_mb
, or the default value if set_retention_storage_mb
is unset.
Sourcepub fn set_partition_write_speed_bytes_per_second(&self) -> i64
pub fn set_partition_write_speed_bytes_per_second(&self) -> i64
Returns the value of set_partition_write_speed_bytes_per_second
, or the default value if set_partition_write_speed_bytes_per_second
is unset.
Sourcepub fn set_partition_write_burst_bytes(&self) -> i64
pub fn set_partition_write_burst_bytes(&self) -> i64
Returns the value of set_partition_write_burst_bytes
, or the default value if set_partition_write_burst_bytes
is unset.
Sourcepub fn set_metering_mode(&self) -> MeteringMode
pub fn set_metering_mode(&self) -> MeteringMode
Returns the enum value of set_metering_mode
, or the default if the field is set to an invalid enum value.
Sourcepub fn set_set_metering_mode(&mut self, value: MeteringMode)
pub fn set_set_metering_mode(&mut self, value: MeteringMode)
Sets set_metering_mode
to the provided enum value.
Trait Implementations§
Source§impl Clone for AlterTopicRequest
impl Clone for AlterTopicRequest
Source§fn clone(&self) -> AlterTopicRequest
fn clone(&self) -> AlterTopicRequest
1.0.0 · Source§fn clone_from(&mut self, source: &Self)
fn clone_from(&mut self, source: &Self)
source
. Read moreSource§impl Debug for AlterTopicRequest
impl Debug for AlterTopicRequest
Source§impl Default for AlterTopicRequest
impl Default for AlterTopicRequest
Source§impl<'de> Deserialize<'de> for AlterTopicRequest
impl<'de> Deserialize<'de> for AlterTopicRequest
Source§fn deserialize<__D>(__deserializer: __D) -> Result<Self, __D::Error>where
__D: Deserializer<'de>,
fn deserialize<__D>(__deserializer: __D) -> Result<Self, __D::Error>where
__D: Deserializer<'de>,
Source§impl Message for AlterTopicRequest
impl Message for AlterTopicRequest
Source§fn encoded_len(&self) -> usize
fn encoded_len(&self) -> usize
Source§fn encode<B>(&self, buf: &mut B) -> Result<(), EncodeError>
fn encode<B>(&self, buf: &mut B) -> Result<(), EncodeError>
Source§fn encode_to_vec(&self) -> Vec<u8> ⓘwhere
Self: Sized,
fn encode_to_vec(&self) -> Vec<u8> ⓘwhere
Self: Sized,
Source§fn encode_length_delimited<B>(&self, buf: &mut B) -> Result<(), EncodeError>
fn encode_length_delimited<B>(&self, buf: &mut B) -> Result<(), EncodeError>
Source§fn encode_length_delimited_to_vec(&self) -> Vec<u8> ⓘwhere
Self: Sized,
fn encode_length_delimited_to_vec(&self) -> Vec<u8> ⓘwhere
Self: Sized,
Source§fn decode<B>(buf: B) -> Result<Self, DecodeError>
fn decode<B>(buf: B) -> Result<Self, DecodeError>
Source§fn decode_length_delimited<B>(buf: B) -> Result<Self, DecodeError>
fn decode_length_delimited<B>(buf: B) -> Result<Self, DecodeError>
Source§fn merge<B>(&mut self, buf: B) -> Result<(), DecodeError>
fn merge<B>(&mut self, buf: B) -> Result<(), DecodeError>
self
. Read moreSource§fn merge_length_delimited<B>(&mut self, buf: B) -> Result<(), DecodeError>
fn merge_length_delimited<B>(&mut self, buf: B) -> Result<(), DecodeError>
self
.Source§impl PartialEq for AlterTopicRequest
impl PartialEq for AlterTopicRequest
Source§impl Serialize for AlterTopicRequest
impl Serialize for AlterTopicRequest
impl StructuralPartialEq for AlterTopicRequest
Auto Trait Implementations§
impl Freeze for AlterTopicRequest
impl RefUnwindSafe for AlterTopicRequest
impl Send for AlterTopicRequest
impl Sync for AlterTopicRequest
impl Unpin for AlterTopicRequest
impl UnwindSafe for AlterTopicRequest
Blanket Implementations§
Source§impl<T> BorrowMut<T> for Twhere
T: ?Sized,
impl<T> BorrowMut<T> for Twhere
T: ?Sized,
Source§fn borrow_mut(&mut self) -> &mut T
fn borrow_mut(&mut self) -> &mut T
Source§impl<T> CloneToUninit for Twhere
T: Clone,
impl<T> CloneToUninit for Twhere
T: Clone,
Source§impl<T> Instrument for T
impl<T> Instrument for T
Source§fn instrument(self, span: Span) -> Instrumented<Self>
fn instrument(self, span: Span) -> Instrumented<Self>
Source§fn in_current_span(self) -> Instrumented<Self>
fn in_current_span(self) -> Instrumented<Self>
Source§impl<T> IntoRequest<T> for T
impl<T> IntoRequest<T> for T
Source§fn into_request(self) -> Request<T>
fn into_request(self) -> Request<T>
T
in a tonic::Request