Enum Type 

#[repr(i32)]
pub enum Type {
    Connect = 2,
    Connected = 3,
    Subscribe = 4,
    Producer = 5,
    Send = 6,
    SendReceipt = 7,
    SendError = 8,
    Message = 9,
    Ack = 10,
    Flow = 11,
    Unsubscribe = 12,
    Success = 13,
    Error = 14,
    CloseProducer = 15,
    CloseConsumer = 16,
    ProducerSuccess = 17,
    Ping = 18,
    Pong = 19,
    RedeliverUnacknowledgedMessages = 20,
    PartitionedMetadata = 21,
    PartitionedMetadataResponse = 22,
    Lookup = 23,
    LookupResponse = 24,
    ConsumerStats = 25,
    ConsumerStatsResponse = 26,
    ReachedEndOfTopic = 27,
    Seek = 28,
    GetLastMessageId = 29,
    GetLastMessageIdResponse = 30,
    ActiveConsumerChange = 31,
    GetTopicsOfNamespace = 32,
    GetTopicsOfNamespaceResponse = 33,
    GetSchema = 34,
    GetSchemaResponse = 35,
    AuthChallenge = 36,
    AuthResponse = 37,
    AckResponse = 38,
    GetOrCreateSchema = 39,
    GetOrCreateSchemaResponse = 40,
    NewTxn = 50,
    NewTxnResponse = 51,
    AddPartitionToTxn = 52,
    AddPartitionToTxnResponse = 53,
    AddSubscriptionToTxn = 54,
    AddSubscriptionToTxnResponse = 55,
    EndTxn = 56,
    EndTxnResponse = 57,
    EndTxnOnPartition = 58,
    EndTxnOnPartitionResponse = 59,
    EndTxnOnSubscription = 60,
    EndTxnOnSubscriptionResponse = 61,
}

Variants

Connect = 2

Connected = 3

Subscribe = 4

Producer = 5

Send = 6

SendReceipt = 7

SendError = 8

Message = 9

Ack = 10

Flow = 11

Unsubscribe = 12

Success = 13

Error = 14

CloseProducer = 15

CloseConsumer = 16

ProducerSuccess = 17

Ping = 18

Pong = 19

RedeliverUnacknowledgedMessages = 20

PartitionedMetadata = 21

PartitionedMetadataResponse = 22

Lookup = 23

LookupResponse = 24

ConsumerStats = 25

ConsumerStatsResponse = 26

ReachedEndOfTopic = 27

Seek = 28

GetLastMessageId = 29

GetLastMessageIdResponse = 30

ActiveConsumerChange = 31

GetTopicsOfNamespace = 32

GetTopicsOfNamespaceResponse = 33

GetSchema = 34

GetSchemaResponse = 35

AuthChallenge = 36

AuthResponse = 37

AckResponse = 38

GetOrCreateSchema = 39

GetOrCreateSchemaResponse = 40

NewTxn = 50

transaction related

NewTxnResponse = 51

AddPartitionToTxn = 52

AddPartitionToTxnResponse = 53

AddSubscriptionToTxn = 54

AddSubscriptionToTxnResponse = 55

EndTxn = 56

EndTxnResponse = 57

EndTxnOnPartition = 58

EndTxnOnPartitionResponse = 59

EndTxnOnSubscription = 60

EndTxnOnSubscriptionResponse = 61

Implementations

impl Type

pub fn is_valid(value: i32) -> bool

Returns true if value is a variant of Type.

pub fn from_i32(value: i32) -> Option<Type>

Converts an i32 to a Type, or None if value is not a valid variant.

Trait Implementations

impl Clone for Type

fn clone(&self) -> Type

Returns a duplicate of the value.

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

Performs copy-assignment from source.

impl Copy for Type

impl Debug for Type

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

Formats the value using the given formatter.

impl Default for Type

fn default() -> Type

Returns the “default value” for a type.

impl Eq for Type

impl From<Type> for i32

fn from(value: Type) -> i32

Converts to this type from the input type.

impl Hash for Type

fn hash<__H: Hasher>(&self, state: &mut __H)

Feeds this value into the given Hasher.

fn hash_slice<H>(data: &[Self], state: &mut H)

where H: Hasher, Self: Sized,

Feeds a slice of this type into the given Hasher.

impl Ord for Type

fn cmp(&self, other: &Type) -> Ordering

This method returns an Ordering between self and other.

fn max(self, other: Self) -> Self

where Self: Sized,

Compares and returns the maximum of two values.

fn min(self, other: Self) -> Self

where Self: Sized,

Compares and returns the minimum of two values.

fn clamp(self, min: Self, max: Self) -> Self

where Self: Sized,

Restrict a value to a certain interval.

impl PartialEq for Type

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

Equality operator ==.

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

Inequality operator !=.

impl PartialOrd for Type

fn partial_cmp(&self, other: &Type) -> Option<Ordering>

This method returns an ordering between self and other values if one exists.

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

Tests less than (for self and other) and is used by the < operator.

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

Tests less than or equal to (for self and other) and is used by the <= operator.

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

Tests greater than (for self and other) and is used by the > operator.

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

Tests greater than or equal to (for self and other) and is used by the >= operator.

impl StructuralPartialEq for Type

impl TryFrom<i32> for Type

type Error = ()

The type returned in the event of a conversion error.

fn try_from(value: i32) -> Result<Self, ()>

Performs the conversion.