#[non_exhaustive]pub struct EndTxnRequest {
pub transactional_id: TransactionalId,
pub producer_id: ProducerId,
pub producer_epoch: i16,
pub committed: bool,
pub unknown_tagged_fields: BTreeMap<i32, Bytes>,
}
Expand description
Valid versions: 0-4
Fields (Non-exhaustive)§
This struct is marked as non-exhaustive
Struct { .. }
syntax; cannot be matched against without a wildcard ..
; and struct update syntax will not work.transactional_id: TransactionalId
The ID of the transaction to end.
Supported API versions: 0-4
producer_id: ProducerId
The producer ID.
Supported API versions: 0-4
producer_epoch: i16
The current epoch associated with the producer.
Supported API versions: 0-4
committed: bool
True if the transaction was committed, false if it was aborted.
Supported API versions: 0-4
unknown_tagged_fields: BTreeMap<i32, Bytes>
Other tagged fields
Implementations§
Source§impl EndTxnRequest
impl EndTxnRequest
Sourcepub fn with_transactional_id(self, value: TransactionalId) -> Self
pub fn with_transactional_id(self, value: TransactionalId) -> Self
Sets transactional_id
to the passed value.
The ID of the transaction to end.
Supported API versions: 0-4
Sourcepub fn with_producer_id(self, value: ProducerId) -> Self
pub fn with_producer_id(self, value: ProducerId) -> Self
Sets producer_id
to the passed value.
The producer ID.
Supported API versions: 0-4
Sourcepub fn with_producer_epoch(self, value: i16) -> Self
pub fn with_producer_epoch(self, value: i16) -> Self
Sets producer_epoch
to the passed value.
The current epoch associated with the producer.
Supported API versions: 0-4
Sourcepub fn with_committed(self, value: bool) -> Self
pub fn with_committed(self, value: bool) -> Self
Sets committed
to the passed value.
True if the transaction was committed, false if it was aborted.
Supported API versions: 0-4
Sourcepub fn with_unknown_tagged_fields(self, value: BTreeMap<i32, Bytes>) -> Self
pub fn with_unknown_tagged_fields(self, value: BTreeMap<i32, Bytes>) -> Self
Sets unknown_tagged_fields to the passed value.
Sourcepub fn with_unknown_tagged_field(self, key: i32, value: Bytes) -> Self
pub fn with_unknown_tagged_field(self, key: i32, value: Bytes) -> Self
Inserts an entry into unknown_tagged_fields.
Trait Implementations§
Source§impl Clone for EndTxnRequest
impl Clone for EndTxnRequest
Source§fn clone(&self) -> EndTxnRequest
fn clone(&self) -> EndTxnRequest
1.0.0 · Source§fn clone_from(&mut self, source: &Self)
fn clone_from(&mut self, source: &Self)
source
. Read moreSource§impl Debug for EndTxnRequest
impl Debug for EndTxnRequest
Source§impl Decodable for EndTxnRequest
Available on crate feature broker
only.
impl Decodable for EndTxnRequest
broker
only.Source§impl Default for EndTxnRequest
impl Default for EndTxnRequest
Source§impl Encodable for EndTxnRequest
Available on crate feature client
only.
impl Encodable for EndTxnRequest
client
only.Source§impl From<EndTxnRequest> for RequestKind
Available on crate feature messages_enums
only.
impl From<EndTxnRequest> for RequestKind
messages_enums
only.Source§fn from(value: EndTxnRequest) -> RequestKind
fn from(value: EndTxnRequest) -> RequestKind
Source§impl HeaderVersion for EndTxnRequest
impl HeaderVersion for EndTxnRequest
Source§fn header_version(version: i16) -> i16
fn header_version(version: i16) -> i16
Source§impl Message for EndTxnRequest
impl Message for EndTxnRequest
Source§const VERSIONS: VersionRange
const VERSIONS: VersionRange
Source§const DEPRECATED_VERSIONS: Option<VersionRange> = None
const DEPRECATED_VERSIONS: Option<VersionRange> = None
Source§impl PartialEq for EndTxnRequest
impl PartialEq for EndTxnRequest
Source§impl Request for EndTxnRequest
Available on crate features client
and broker
only.
impl Request for EndTxnRequest
client
and broker
only.