🥮 mooncakes.io

    pangbit/moonpulsar/proto does not have a README file

    AuthData

    source
    pub(all) struct AuthData {
      auth_method_name : String?
      auth_data : Bytes?
    } derive(Eq, 
    Debug    )

    impl Default for AuthData
    impl ToJson for AuthData
    impl Read for AuthData
    impl Sized for AuthData
    impl Write for AuthData

    AuthData::AuthData

    source
    #alias(new, deprecated="`new` is deprecated, use `AuthData` instead")
    fn AuthData::AuthData(auth_method_name? : String, auth_data? : Bytes) -> AuthData

    AuthData::default

    source
    fn AuthData::default() -> AuthData

    AuthData::equal

    source
    #deprecated("Use `==` instead")
    fn AuthData::equal(AuthData, AuthData) -> Bool

    AuthData::from_json

    source

    AuthData::not_equal

    source
    #deprecated("Use `!=` instead")
    fn AuthData::not_equal(x : AuthData, y : AuthData) -> Bool

    AuthData::read

    source

    AuthData::read_with_limit

    source

    AuthData::size_of

    source
    fn AuthData::size_of(self : AuthData) -> UInt

    AuthData::to_json

    source
    fn AuthData::to_json(self : AuthData) -> Json

    AuthData::to_repr

    source

    AuthData::write

    source
    fn AuthData::write(self : AuthData, writer : &
    Writer    ) -> Unit raise

    AuthMethod

    source
    pub(all) enum AuthMethod {
      AuthMethodNone
      AuthMethodYcaV1
      AuthMethodAthens
    } derive(Eq, 
    Debug    )

    impl Sized for AuthMethod

    AuthMethod::default

    source
    fn AuthMethod::default() -> AuthMethod

    AuthMethod::equal

    source
    #deprecated("Use `==` instead")
    fn AuthMethod::equal(AuthMethod, AuthMethod) -> Bool

    AuthMethod::from_enum

    source

    AuthMethod::from_json

    source

    AuthMethod::not_equal

    source
    #deprecated("Use `!=` instead")
    fn AuthMethod::not_equal(x : AuthMethod, y : AuthMethod) -> Bool

    AuthMethod::size_of

    source
    fn AuthMethod::size_of(self : AuthMethod) -> UInt

    AuthMethod::to_enum

    source

    AuthMethod::to_json

    source
    fn AuthMethod::to_json(self : AuthMethod) -> Json

    AuthMethod::to_repr

    source

    BaseCommand

    source
    pub(all) struct BaseCommand {
      type_ : BaseCommand_Type
      connect : CommandConnect?
      connected : CommandConnected?
      subscribe : CommandSubscribe?
      producer : CommandProducer?
      send : CommandSend?
      send_receipt : CommandSendReceipt?
      send_error : CommandSendError?
      message : CommandMessage?
      ack : CommandAck?
      flow : CommandFlow?
      unsubscribe : CommandUnsubscribe?
      success : CommandSuccess?
      error : CommandError?
      close_producer : CommandCloseProducer?
      close_consumer : CommandCloseConsumer?
      producer_success : CommandProducerSuccess?
      ping : CommandPing?
      pong : CommandPong?
      redeliver_unacknowledged_messages : CommandRedeliverUnacknowledgedMessages?
      partition_metadata : CommandPartitionedTopicMetadata?
      partition_metadata_response : CommandPartitionedTopicMetadataResponse?
      lookup_topic : CommandLookupTopic?
      lookup_topic_response : CommandLookupTopicResponse?
      consumer_stats : CommandConsumerStats?
      consumer_stats_response : CommandConsumerStatsResponse?
      reached_end_of_topic : CommandReachedEndOfTopic?
      seek : CommandSeek?
      get_last_message_id : CommandGetLastMessageId?
      get_last_message_id_response : CommandGetLastMessageIdResponse?
      active_consumer_change : CommandActiveConsumerChange?
      get_topics_of_namespace : CommandGetTopicsOfNamespace?
      get_topics_of_namespace_response : CommandGetTopicsOfNamespaceResponse?
      get_schema : CommandGetSchema?
      get_schema_response : CommandGetSchemaResponse?
      auth_challenge : CommandAuthChallenge?
      auth_response : CommandAuthResponse?
      ack_response : CommandAckResponse?
      get_or_create_schema : CommandGetOrCreateSchema?
      get_or_create_schema_response : CommandGetOrCreateSchemaResponse?
      new_txn : CommandNewTxn?
      new_txn_response : CommandNewTxnResponse?
      add_partition_to_txn : CommandAddPartitionToTxn?
      add_partition_to_txn_response : CommandAddPartitionToTxnResponse?
      add_subscription_to_txn : CommandAddSubscriptionToTxn?
      add_subscription_to_txn_response : CommandAddSubscriptionToTxnResponse?
      end_txn : CommandEndTxn?
      end_txn_response : CommandEndTxnResponse?
      end_txn_on_partition : CommandEndTxnOnPartition?
      end_txn_on_partition_response : CommandEndTxnOnPartitionResponse?
      end_txn_on_subscription : CommandEndTxnOnSubscription?
      end_txn_on_subscription_response : CommandEndTxnOnSubscriptionResponse?
      tc_client_connect_request : CommandTcClientConnectRequest?
      tc_client_connect_response : CommandTcClientConnectResponse?
      watch_topic_list : CommandWatchTopicList?
      watch_topic_list_success : CommandWatchTopicListSuccess?
      watch_topic_update : CommandWatchTopicUpdate?
      watch_topic_list_close : CommandWatchTopicListClose?
      topic_migrated : CommandTopicMigrated?
      scalable_topic_lookup : CommandScalableTopicLookup?
      scalable_topic_update : CommandScalableTopicUpdate?
      scalable_topic_close : CommandScalableTopicClose?
      scalable_topic_subscribe : CommandScalableTopicSubscribe?
      scalable_topic_subscribe_response : CommandScalableTopicSubscribeResponse?
      scalable_topic_assignment_update : CommandScalableTopicAssignmentUpdate?
      watch_scalable_topics : CommandWatchScalableTopics?
      watch_scalable_topics_update : CommandWatchScalableTopicsUpdate?
      watch_scalable_topics_close : CommandWatchScalableTopicsClose?
      watch_tc_assignments : CommandWatchTcAssignments?
      watch_tc_assignments_update : CommandWatchTcAssignmentsUpdate?
      watch_tc_assignments_close : CommandWatchTcAssignmentsClose?
      scalable_topic_unsubscribe : CommandScalableTopicUnsubscribe?
    } derive(Eq, 
    Debug    )

    impl Read for BaseCommand

    BaseCommand::BaseCommand

    source
    #alias(new, deprecated="`new` is deprecated, use `BaseCommand` instead")
    fn BaseCommand::BaseCommand(type_ : BaseCommand_Type, connect? : CommandConnect, connected? : CommandConnected, subscribe? : CommandSubscribe, producer? : CommandProducer, send? : CommandSend, send_receipt? : CommandSendReceipt, send_error? : CommandSendError, message? : CommandMessage, ack? : CommandAck, flow? : CommandFlow, unsubscribe? : CommandUnsubscribe, success? : CommandSuccess, error? : CommandError, close_producer? : CommandCloseProducer, close_consumer? : CommandCloseConsumer, producer_success? : CommandProducerSuccess, ping? : CommandPing, pong? : CommandPong, redeliver_unacknowledged_messages? : CommandRedeliverUnacknowledgedMessages, partition_metadata? : CommandPartitionedTopicMetadata, partition_metadata_response? : CommandPartitionedTopicMetadataResponse, lookup_topic? : CommandLookupTopic, lookup_topic_response? : CommandLookupTopicResponse, consumer_stats? : CommandConsumerStats, consumer_stats_response? : CommandConsumerStatsResponse, reached_end_of_topic? : CommandReachedEndOfTopic, seek? : CommandSeek, get_last_message_id? : CommandGetLastMessageId, get_last_message_id_response? : CommandGetLastMessageIdResponse, active_consumer_change? : CommandActiveConsumerChange, get_topics_of_namespace? : CommandGetTopicsOfNamespace, get_topics_of_namespace_response? : CommandGetTopicsOfNamespaceResponse, get_schema? : CommandGetSchema, get_schema_response? : CommandGetSchemaResponse, auth_challenge? : CommandAuthChallenge, auth_response? : CommandAuthResponse, ack_response? : CommandAckResponse, get_or_create_schema? : CommandGetOrCreateSchema, get_or_create_schema_response? : CommandGetOrCreateSchemaResponse, new_txn? : CommandNewTxn, new_txn_response? : CommandNewTxnResponse, add_partition_to_txn? : CommandAddPartitionToTxn, add_partition_to_txn_response? : CommandAddPartitionToTxnResponse, add_subscription_to_txn? : CommandAddSubscriptionToTxn, add_subscription_to_txn_response? : CommandAddSubscriptionToTxnResponse, end_txn? : CommandEndTxn, end_txn_response? : CommandEndTxnResponse, end_txn_on_partition? : CommandEndTxnOnPartition, end_txn_on_partition_response? : CommandEndTxnOnPartitionResponse, end_txn_on_subscription? : CommandEndTxnOnSubscription, end_txn_on_subscription_response? : CommandEndTxnOnSubscriptionResponse, tc_client_connect_request? : CommandTcClientConnectRequest, tc_client_connect_response? : CommandTcClientConnectResponse, watch_topic_list? : CommandWatchTopicList, watch_topic_list_success? : CommandWatchTopicListSuccess, watch_topic_update? : CommandWatchTopicUpdate, watch_topic_list_close? : CommandWatchTopicListClose, topic_migrated? : CommandTopicMigrated, scalable_topic_lookup? : CommandScalableTopicLookup, scalable_topic_update? : CommandScalableTopicUpdate, scalable_topic_close? : CommandScalableTopicClose, scalable_topic_subscribe? : CommandScalableTopicSubscribe, scalable_topic_subscribe_response? : CommandScalableTopicSubscribeResponse, scalable_topic_assignment_update? : CommandScalableTopicAssignmentUpdate, watch_scalable_topics? : CommandWatchScalableTopics, watch_scalable_topics_update? : CommandWatchScalableTopicsUpdate, watch_scalable_topics_close? : CommandWatchScalableTopicsClose, watch_tc_assignments? : CommandWatchTcAssignments, watch_tc_assignments_update? : CommandWatchTcAssignmentsUpdate, watch_tc_assignments_close? : CommandWatchTcAssignmentsClose, scalable_topic_unsubscribe? : CommandScalableTopicUnsubscribe) -> BaseCommand

    BaseCommand::default

    source
    fn BaseCommand::default() -> BaseCommand

    BaseCommand::equal

    source
    #deprecated("Use `==` instead")
    fn BaseCommand::equal(BaseCommand, BaseCommand) -> Bool

    BaseCommand::from_json

    source

    BaseCommand::not_equal

    source
    #deprecated("Use `!=` instead")
    fn BaseCommand::not_equal(x : BaseCommand, y : BaseCommand) -> Bool

    BaseCommand::read

    source

    BaseCommand::read_with_limit

    source

    BaseCommand::size_of

    source
    fn BaseCommand::size_of(self : BaseCommand) -> UInt

    BaseCommand::to_json

    source
    fn BaseCommand::to_json(self : BaseCommand) -> Json

    BaseCommand::to_repr

    source

    BaseCommand::write

    source
    fn BaseCommand::write(self : BaseCommand, writer : &
    Writer    ) -> Unit raise

    BaseCommand_Type

    source
    pub(all) enum BaseCommand_Type {
      CONNECT
      CONNECTED
      SUBSCRIBE
      PRODUCER
      SEND
      SEND_RECEIPT
      SEND_ERROR
      MESSAGE
      ACK
      FLOW
      UNSUBSCRIBE
      SUCCESS
      ERROR
      CLOSE_PRODUCER
      CLOSE_CONSUMER
      PRODUCER_SUCCESS
      PING
      PONG
      REDELIVER_UNACKNOWLEDGED_MESSAGES
      PARTITIONED_METADATA
      PARTITIONED_METADATA_RESPONSE
      LOOKUP
      LOOKUP_RESPONSE
      CONSUMER_STATS
      CONSUMER_STATS_RESPONSE
      REACHED_END_OF_TOPIC
      SEEK
      GET_LAST_MESSAGE_ID
      GET_LAST_MESSAGE_ID_RESPONSE
      ACTIVE_CONSUMER_CHANGE
      GET_TOPICS_OF_NAMESPACE
      GET_TOPICS_OF_NAMESPACE_RESPONSE
      GET_SCHEMA
      GET_SCHEMA_RESPONSE
      AUTH_CHALLENGE
      AUTH_RESPONSE
      ACK_RESPONSE
      GET_OR_CREATE_SCHEMA
      GET_OR_CREATE_SCHEMA_RESPONSE
      NEW_TXN
      NEW_TXN_RESPONSE
      ADD_PARTITION_TO_TXN
      ADD_PARTITION_TO_TXN_RESPONSE
      ADD_SUBSCRIPTION_TO_TXN
      ADD_SUBSCRIPTION_TO_TXN_RESPONSE
      END_TXN
      END_TXN_RESPONSE
      END_TXN_ON_PARTITION
      END_TXN_ON_PARTITION_RESPONSE
      END_TXN_ON_SUBSCRIPTION
      END_TXN_ON_SUBSCRIPTION_RESPONSE
      TC_CLIENT_CONNECT_REQUEST
      TC_CLIENT_CONNECT_RESPONSE
      WATCH_TOPIC_LIST
      WATCH_TOPIC_LIST_SUCCESS
      WATCH_TOPIC_UPDATE
      WATCH_TOPIC_LIST_CLOSE
      TOPIC_MIGRATED
      SCALABLE_TOPIC_LOOKUP
      SCALABLE_TOPIC_UPDATE
      SCALABLE_TOPIC_CLOSE
      SCALABLE_TOPIC_SUBSCRIBE
      SCALABLE_TOPIC_SUBSCRIBE_RESPONSE
      SCALABLE_TOPIC_ASSIGNMENT_UPDATE
      WATCH_SCALABLE_TOPICS
      WATCH_SCALABLE_TOPICS_UPDATE
      WATCH_SCALABLE_TOPICS_CLOSE
      WATCH_TC_ASSIGNMENTS
      WATCH_TC_ASSIGNMENTS_UPDATE
      WATCH_TC_ASSIGNMENTS_CLOSE
      SCALABLE_TOPIC_UNSUBSCRIBE
    } derive(Eq, 
    Debug    )

    BaseCommand_Type::default

    source

    BaseCommand_Type::equal

    source
    #deprecated("Use `==` instead")
    fn BaseCommand_Type::equal(BaseCommand_Type, BaseCommand_Type) -> Bool

    BaseCommand_Type::from_enum

    source

    BaseCommand_Type::from_json

    source

    BaseCommand_Type::not_equal

    source
    #deprecated("Use `!=` instead")
    fn BaseCommand_Type::not_equal(x : BaseCommand_Type, y : BaseCommand_Type) -> Bool

    BaseCommand_Type::size_of

    source
    fn BaseCommand_Type::size_of(self : BaseCommand_Type) -> UInt

    BaseCommand_Type::to_enum

    source

    BaseCommand_Type::to_json

    source
    fn BaseCommand_Type::to_json(self : BaseCommand_Type) -> Json

    BaseCommand_Type::to_repr

    source

    BrokerEntryMetadata

    source
    pub(all) struct BrokerEntryMetadata {
      broker_timestamp : UInt64?
      index : UInt64?
    } derive(Eq, 
    Debug    )

    BrokerEntryMetadata::BrokerEntryMetadata

    source
    #alias(new, deprecated="`new` is deprecated, use `BrokerEntryMetadata` instead")
    fn BrokerEntryMetadata::BrokerEntryMetadata(broker_timestamp? : UInt64, index? : UInt64) -> BrokerEntryMetadata

    BrokerEntryMetadata::default

    source

    BrokerEntryMetadata::equal

    source
    #deprecated("Use `==` instead")
    fn BrokerEntryMetadata::equal(BrokerEntryMetadata, BrokerEntryMetadata) -> Bool

    BrokerEntryMetadata::from_json

    source

    BrokerEntryMetadata::not_equal

    source
    #deprecated("Use `!=` instead")
    fn BrokerEntryMetadata::not_equal(x : BrokerEntryMetadata, y : BrokerEntryMetadata) -> Bool

    BrokerEntryMetadata::read

    source

    BrokerEntryMetadata::read_with_limit

    source

    BrokerEntryMetadata::size_of

    source
    fn BrokerEntryMetadata::size_of(self : BrokerEntryMetadata) -> UInt

    BrokerEntryMetadata::to_json

    source

    BrokerEntryMetadata::to_repr

    source

    BrokerEntryMetadata::write

    source

    CommandAck

    source
    pub(all) struct CommandAck {
      consumer_id : UInt64
      ack_type : CommandAck_AckType
      message_id : Array[MessageIdData]
      validation_error : CommandAck_ValidationError?
      properties : Array[KeyLongValue]
      txnid_least_bits : UInt64?
      txnid_most_bits : UInt64?
      request_id : UInt64?
    } derive(Eq, 
    Debug    )

    impl Read for CommandAck
    impl Sized for CommandAck
    impl Write for CommandAck

    CommandAck::CommandAck

    source
    #alias(new, deprecated="`new` is deprecated, use `CommandAck` instead")
    fn CommandAck::CommandAck(consumer_id : UInt64, ack_type : CommandAck_AckType, message_id : Array[MessageIdData], validation_error? : CommandAck_ValidationError, properties : Array[KeyLongValue], txnid_least_bits? : UInt64, txnid_most_bits? : UInt64, request_id? : UInt64) -> CommandAck

    CommandAck::default

    source
    fn CommandAck::default() -> CommandAck

    CommandAck::equal

    source
    #deprecated("Use `==` instead")
    fn CommandAck::equal(CommandAck, CommandAck) -> Bool

    CommandAck::from_json

    source

    CommandAck::not_equal

    source
    #deprecated("Use `!=` instead")
    fn CommandAck::not_equal(x : CommandAck, y : CommandAck) -> Bool

    CommandAck::read

    source

    CommandAck::read_with_limit

    source

    CommandAck::size_of

    source
    fn CommandAck::size_of(self : CommandAck) -> UInt

    CommandAck::to_json

    source
    fn CommandAck::to_json(self : CommandAck) -> Json

    CommandAck::to_repr

    source

    CommandAck::write

    source
    fn CommandAck::write(self : CommandAck, writer : &
    Writer    ) -> Unit raise

    CommandAckResponse

    source
    pub(all) struct CommandAckResponse {
      consumer_id : UInt64
      txnid_least_bits : UInt64?
      txnid_most_bits : UInt64?
      error : ServerError?
      message : String?
      request_id : UInt64?
    } derive(Eq, 
    Debug    )

    CommandAckResponse::CommandAckResponse

    source
    #alias(new, deprecated="`new` is deprecated, use `CommandAckResponse` instead")
    fn CommandAckResponse::CommandAckResponse(consumer_id : UInt64, txnid_least_bits? : UInt64, txnid_most_bits? : UInt64, error? : ServerError, message? : String, request_id? : UInt64) -> CommandAckResponse

    CommandAckResponse::default

    source

    CommandAckResponse::equal

    source
    #deprecated("Use `==` instead")
    fn CommandAckResponse::equal(CommandAckResponse, CommandAckResponse) -> Bool

    CommandAckResponse::from_json

    source

    CommandAckResponse::not_equal

    source
    #deprecated("Use `!=` instead")
    fn CommandAckResponse::not_equal(x : CommandAckResponse, y : CommandAckResponse) -> Bool

    CommandAckResponse::read

    source

    CommandAckResponse::read_with_limit

    source

    CommandAckResponse::size_of

    source
    fn CommandAckResponse::size_of(self : CommandAckResponse) -> UInt

    CommandAckResponse::to_json

    source

    CommandAckResponse::to_repr

    source

    CommandAckResponse::write

    source

    CommandAck_AckType

    source
    pub(all) enum CommandAck_AckType {
      Individual
      Cumulative
    } derive(Eq, 
    Debug    )

    CommandAck_AckType::default

    source

    CommandAck_AckType::equal

    source
    #deprecated("Use `==` instead")
    fn CommandAck_AckType::equal(CommandAck_AckType, CommandAck_AckType) -> Bool

    CommandAck_AckType::from_enum

    source

    CommandAck_AckType::from_json

    source

    CommandAck_AckType::not_equal

    source
    #deprecated("Use `!=` instead")
    fn CommandAck_AckType::not_equal(x : CommandAck_AckType, y : CommandAck_AckType) -> Bool

    CommandAck_AckType::size_of

    source
    fn CommandAck_AckType::size_of(self : CommandAck_AckType) -> UInt

    CommandAck_AckType::to_enum

    source

    CommandAck_AckType::to_json

    source

    CommandAck_AckType::to_repr

    source

    CommandAck_ValidationError

    source
    pub(all) enum CommandAck_ValidationError {
      UncompressedSizeCorruption
      DecompressionError
      ChecksumMismatch
      BatchDeSerializeError
      DecryptionError
    } derive(Eq, 
    Debug    )

    CommandAck_ValidationError::default

    source

    CommandAck_ValidationError::equal

    source
    #deprecated("Use `==` instead")
    fn CommandAck_ValidationError::equal(CommandAck_ValidationError, CommandAck_ValidationError) -> Bool

    CommandAck_ValidationError::from_enum

    source

    CommandAck_ValidationError::from_json

    source

    CommandAck_ValidationError::not_equal

    source
    #deprecated("Use `!=` instead")
    fn CommandAck_ValidationError::not_equal(x : CommandAck_ValidationError, y : CommandAck_ValidationError) -> Bool

    CommandAck_ValidationError::size_of

    source

    CommandAck_ValidationError::to_enum

    source

    CommandAck_ValidationError::to_json

    source

    CommandAck_ValidationError::to_repr

    source

    CommandActiveConsumerChange

    source
    pub(all) struct CommandActiveConsumerChange {
      consumer_id : UInt64
      is_active : Bool?
    } derive(Eq, 
    Debug    )

    CommandActiveConsumerChange::CommandActiveConsumerChange

    source
    #alias(new, deprecated="`new` is deprecated, use `CommandActiveConsumerChange` instead")
    fn CommandActiveConsumerChange::CommandActiveConsumerChange(consumer_id : UInt64, is_active? : Bool) -> CommandActiveConsumerChange

    CommandActiveConsumerChange::default

    source

    CommandActiveConsumerChange::equal

    source

    CommandActiveConsumerChange::from_json

    source

    CommandActiveConsumerChange::not_equal

    source
    #deprecated("Use `!=` instead")
    fn CommandActiveConsumerChange::not_equal(x : CommandActiveConsumerChange, y : CommandActiveConsumerChange) -> Bool

    CommandActiveConsumerChange::read

    source

    CommandActiveConsumerChange::read_with_limit

    source

    CommandActiveConsumerChange::size_of

    source

    CommandActiveConsumerChange::to_json

    source

    CommandActiveConsumerChange::to_repr

    source

    CommandActiveConsumerChange::write

    source

    CommandAddPartitionToTxn

    source
    pub(all) struct CommandAddPartitionToTxn {
      request_id : UInt64
      txnid_least_bits : UInt64?
      txnid_most_bits : UInt64?
      partitions : Array[String]
      scalable : Bool?
    } derive(Eq, 
    Debug    )

    CommandAddPartitionToTxn::CommandAddPartitionToTxn

    source
    #alias(new, deprecated="`new` is deprecated, use `CommandAddPartitionToTxn` instead")
    fn CommandAddPartitionToTxn::CommandAddPartitionToTxn(request_id : UInt64, txnid_least_bits? : UInt64, txnid_most_bits? : UInt64, partitions : Array[String], scalable? : Bool) -> CommandAddPartitionToTxn

    CommandAddPartitionToTxn::default

    source

    CommandAddPartitionToTxn::equal

    source
    #deprecated("Use `==` instead")
    fn CommandAddPartitionToTxn::equal(CommandAddPartitionToTxn, CommandAddPartitionToTxn) -> Bool

    CommandAddPartitionToTxn::from_json

    source

    CommandAddPartitionToTxn::not_equal

    source
    #deprecated("Use `!=` instead")
    fn CommandAddPartitionToTxn::not_equal(x : CommandAddPartitionToTxn, y : CommandAddPartitionToTxn) -> Bool

    CommandAddPartitionToTxn::read

    source

    CommandAddPartitionToTxn::read_with_limit

    source

    CommandAddPartitionToTxn::size_of

    source

    CommandAddPartitionToTxn::to_json

    source

    CommandAddPartitionToTxn::to_repr

    source

    CommandAddPartitionToTxn::write

    source

    CommandAddPartitionToTxnResponse

    source
    pub(all) struct CommandAddPartitionToTxnResponse {
      request_id : UInt64
      txnid_least_bits : UInt64?
      txnid_most_bits : UInt64?
      error : ServerError?
      message : String?
    } derive(Eq, 
    Debug    )

    CommandAddPartitionToTxnResponse::CommandAddPartitionToTxnResponse

    source
    #alias(new, deprecated="`new` is deprecated, use `CommandAddPartitionToTxnResponse` instead")
    fn CommandAddPartitionToTxnResponse::CommandAddPartitionToTxnResponse(request_id : UInt64, txnid_least_bits? : UInt64, txnid_most_bits? : UInt64, error? : ServerError, message? : String) -> CommandAddPartitionToTxnResponse

    CommandAddPartitionToTxnResponse::default

    source

    CommandAddPartitionToTxnResponse::equal

    source

    CommandAddPartitionToTxnResponse::from_json

    source

    CommandAddPartitionToTxnResponse::not_equal

    source
    #deprecated("Use `!=` instead")
    fn CommandAddPartitionToTxnResponse::not_equal(x : CommandAddPartitionToTxnResponse, y : CommandAddPartitionToTxnResponse) -> Bool

    CommandAddPartitionToTxnResponse::read

    source

    CommandAddPartitionToTxnResponse::read_with_limit

    source

    CommandAddPartitionToTxnResponse::size_of

    source

    CommandAddPartitionToTxnResponse::to_json

    source

    CommandAddPartitionToTxnResponse::to_repr

    source

    CommandAddPartitionToTxnResponse::write

    source

    CommandAddSubscriptionToTxn

    source
    pub(all) struct CommandAddSubscriptionToTxn {
      request_id : UInt64
      txnid_least_bits : UInt64?
      txnid_most_bits : UInt64?
      subscription : Array[Subscription]
      scalable : Bool?
    } derive(Eq, 
    Debug    )

    CommandAddSubscriptionToTxn::CommandAddSubscriptionToTxn

    source
    #alias(new, deprecated="`new` is deprecated, use `CommandAddSubscriptionToTxn` instead")
    fn CommandAddSubscriptionToTxn::CommandAddSubscriptionToTxn(request_id : UInt64, txnid_least_bits? : UInt64, txnid_most_bits? : UInt64, subscription : Array[Subscription], scalable? : Bool) -> CommandAddSubscriptionToTxn

    CommandAddSubscriptionToTxn::default

    source

    CommandAddSubscriptionToTxn::equal

    source

    CommandAddSubscriptionToTxn::from_json

    source

    CommandAddSubscriptionToTxn::not_equal

    source
    #deprecated("Use `!=` instead")
    fn CommandAddSubscriptionToTxn::not_equal(x : CommandAddSubscriptionToTxn, y : CommandAddSubscriptionToTxn) -> Bool

    CommandAddSubscriptionToTxn::read

    source

    CommandAddSubscriptionToTxn::read_with_limit

    source

    CommandAddSubscriptionToTxn::size_of

    source

    CommandAddSubscriptionToTxn::to_json

    source

    CommandAddSubscriptionToTxn::to_repr

    source

    CommandAddSubscriptionToTxn::write

    source

    CommandAddSubscriptionToTxnResponse

    source
    pub(all) struct CommandAddSubscriptionToTxnResponse {
      request_id : UInt64
      txnid_least_bits : UInt64?
      txnid_most_bits : UInt64?
      error : ServerError?
      message : String?
    } derive(Eq, 
    Debug    )

    CommandAddSubscriptionToTxnResponse::CommandAddSubscriptionToTxnResponse

    source
    #alias(new, deprecated="`new` is deprecated, use `CommandAddSubscriptionToTxnResponse` instead")
    fn CommandAddSubscriptionToTxnResponse::CommandAddSubscriptionToTxnResponse(request_id : UInt64, txnid_least_bits? : UInt64, txnid_most_bits? : UInt64, error? : ServerError, message? : String) -> CommandAddSubscriptionToTxnResponse

    CommandAddSubscriptionToTxnResponse::default

    source

    CommandAddSubscriptionToTxnResponse::equal

    source

    CommandAddSubscriptionToTxnResponse::from_json

    source

    CommandAddSubscriptionToTxnResponse::not_equal

    source

    CommandAddSubscriptionToTxnResponse::read

    source

    CommandAddSubscriptionToTxnResponse::read_with_limit

    source

    CommandAddSubscriptionToTxnResponse::size_of

    source

    CommandAddSubscriptionToTxnResponse::to_json

    source

    CommandAddSubscriptionToTxnResponse::to_repr

    source

    CommandAddSubscriptionToTxnResponse::write

    source

    CommandAuthChallenge

    source
    pub(all) struct CommandAuthChallenge {
      server_version : String?
      challenge : AuthData?
      protocol_version : Int?
    } derive(Eq, 
    Debug    )

    CommandAuthChallenge::CommandAuthChallenge

    source
    #alias(new, deprecated="`new` is deprecated, use `CommandAuthChallenge` instead")
    fn CommandAuthChallenge::CommandAuthChallenge(server_version? : String, challenge? : AuthData, protocol_version? : Int) -> CommandAuthChallenge

    CommandAuthChallenge::default

    source

    CommandAuthChallenge::equal

    source
    #deprecated("Use `==` instead")
    fn CommandAuthChallenge::equal(CommandAuthChallenge, CommandAuthChallenge) -> Bool

    CommandAuthChallenge::from_json

    source

    CommandAuthChallenge::not_equal

    source
    #deprecated("Use `!=` instead")
    fn CommandAuthChallenge::not_equal(x : CommandAuthChallenge, y : CommandAuthChallenge) -> Bool

    CommandAuthChallenge::read

    source

    CommandAuthChallenge::read_with_limit

    source

    CommandAuthChallenge::size_of

    source
    fn CommandAuthChallenge::size_of(self : CommandAuthChallenge) -> UInt

    CommandAuthChallenge::to_json

    source

    CommandAuthChallenge::to_repr

    source

    CommandAuthChallenge::write

    source

    CommandAuthResponse

    source
    pub(all) struct CommandAuthResponse {
      client_version : String?
      response : AuthData?
      protocol_version : Int?
    } derive(Eq, 
    Debug    )

    CommandAuthResponse::CommandAuthResponse

    source
    #alias(new, deprecated="`new` is deprecated, use `CommandAuthResponse` instead")
    fn CommandAuthResponse::CommandAuthResponse(client_version? : String, response? : AuthData, protocol_version? : Int) -> CommandAuthResponse

    CommandAuthResponse::default

    source

    CommandAuthResponse::equal

    source
    #deprecated("Use `==` instead")
    fn CommandAuthResponse::equal(CommandAuthResponse, CommandAuthResponse) -> Bool

    CommandAuthResponse::from_json

    source

    CommandAuthResponse::not_equal

    source
    #deprecated("Use `!=` instead")
    fn CommandAuthResponse::not_equal(x : CommandAuthResponse, y : CommandAuthResponse) -> Bool

    CommandAuthResponse::read

    source

    CommandAuthResponse::read_with_limit

    source

    CommandAuthResponse::size_of

    source
    fn CommandAuthResponse::size_of(self : CommandAuthResponse) -> UInt

    CommandAuthResponse::to_json

    source

    CommandAuthResponse::to_repr

    source

    CommandAuthResponse::write

    source

    CommandCloseConsumer

    source
    pub(all) struct CommandCloseConsumer {
      consumer_id : UInt64
      request_id : UInt64
      assigned_broker_service_url : String?
      assigned_broker_service_url_tls : String?
    } derive(Eq, 
    Debug    )

    CommandCloseConsumer::CommandCloseConsumer

    source
    #alias(new, deprecated="`new` is deprecated, use `CommandCloseConsumer` instead")
    fn CommandCloseConsumer::CommandCloseConsumer(consumer_id : UInt64, request_id : UInt64, assigned_broker_service_url? : String, assigned_broker_service_url_tls? : String) -> CommandCloseConsumer

    CommandCloseConsumer::default

    source

    CommandCloseConsumer::equal

    source
    #deprecated("Use `==` instead")
    fn CommandCloseConsumer::equal(CommandCloseConsumer, CommandCloseConsumer) -> Bool

    CommandCloseConsumer::from_json

    source

    CommandCloseConsumer::not_equal

    source
    #deprecated("Use `!=` instead")
    fn CommandCloseConsumer::not_equal(x : CommandCloseConsumer, y : CommandCloseConsumer) -> Bool

    CommandCloseConsumer::read

    source

    CommandCloseConsumer::read_with_limit

    source

    CommandCloseConsumer::size_of

    source
    fn CommandCloseConsumer::size_of(self : CommandCloseConsumer) -> UInt

    CommandCloseConsumer::to_json

    source

    CommandCloseConsumer::to_repr

    source

    CommandCloseConsumer::write

    source

    CommandCloseProducer

    source
    pub(all) struct CommandCloseProducer {
      producer_id : UInt64
      request_id : UInt64
      assigned_broker_service_url : String?
      assigned_broker_service_url_tls : String?
    } derive(Eq, 
    Debug    )

    CommandCloseProducer::CommandCloseProducer

    source
    #alias(new, deprecated="`new` is deprecated, use `CommandCloseProducer` instead")
    fn CommandCloseProducer::CommandCloseProducer(producer_id : UInt64, request_id : UInt64, assigned_broker_service_url? : String, assigned_broker_service_url_tls? : String) -> CommandCloseProducer

    CommandCloseProducer::default

    source

    CommandCloseProducer::equal

    source
    #deprecated("Use `==` instead")
    fn CommandCloseProducer::equal(CommandCloseProducer, CommandCloseProducer) -> Bool

    CommandCloseProducer::from_json

    source

    CommandCloseProducer::not_equal

    source
    #deprecated("Use `!=` instead")
    fn CommandCloseProducer::not_equal(x : CommandCloseProducer, y : CommandCloseProducer) -> Bool

    CommandCloseProducer::read

    source

    CommandCloseProducer::read_with_limit

    source

    CommandCloseProducer::size_of

    source
    fn CommandCloseProducer::size_of(self : CommandCloseProducer) -> UInt

    CommandCloseProducer::to_json

    source

    CommandCloseProducer::to_repr

    source

    CommandCloseProducer::write

    source

    CommandConnect

    source
    pub(all) struct CommandConnect {
      client_version : String
      auth_method : AuthMethod?
      auth_method_name : String?
      auth_data : Bytes?
      protocol_version : Int?
      proxy_to_broker_url : String?
      original_principal : String?
      original_auth_data : String?
      original_auth_method : String?
      feature_flags : FeatureFlags?
      proxy_version : String?
    } derive(Eq, 
    Debug    )

    CommandConnect::CommandConnect

    source
    #alias(new, deprecated="`new` is deprecated, use `CommandConnect` instead")
    fn CommandConnect::CommandConnect(client_version : String, auth_method? : AuthMethod, auth_method_name? : String, auth_data? : Bytes, protocol_version? : Int, proxy_to_broker_url? : String, original_principal? : String, original_auth_data? : String, original_auth_method? : String, feature_flags? : FeatureFlags, proxy_version? : String) -> CommandConnect

    CommandConnect::default

    source

    CommandConnect::equal

    source
    #deprecated("Use `==` instead")
    fn CommandConnect::equal(CommandConnect, CommandConnect) -> Bool

    CommandConnect::from_json

    source

    CommandConnect::not_equal

    source
    #deprecated("Use `!=` instead")
    fn CommandConnect::not_equal(x : CommandConnect, y : CommandConnect) -> Bool

    CommandConnect::read

    source

    CommandConnect::read_with_limit

    source

    CommandConnect::size_of

    source
    fn CommandConnect::size_of(self : CommandConnect) -> UInt

    CommandConnect::to_json

    source
    fn CommandConnect::to_json(self : CommandConnect) -> Json

    CommandConnect::to_repr

    source

    CommandConnect::write

    source
    fn CommandConnect::write(self : CommandConnect, writer : &
    Writer    ) -> Unit raise

    CommandConnected

    source
    pub(all) struct CommandConnected {
      server_version : String
      protocol_version : Int?
      max_message_size : Int?
      feature_flags : FeatureFlags?
    } derive(Eq, 
    Debug    )

    CommandConnected::CommandConnected

    source
    #alias(new, deprecated="`new` is deprecated, use `CommandConnected` instead")
    fn CommandConnected::CommandConnected(server_version : String, protocol_version? : Int, max_message_size? : Int, feature_flags? : FeatureFlags) -> CommandConnected

    CommandConnected::default

    source

    CommandConnected::equal

    source
    #deprecated("Use `==` instead")
    fn CommandConnected::equal(CommandConnected, CommandConnected) -> Bool

    CommandConnected::from_json

    source

    CommandConnected::not_equal

    source
    #deprecated("Use `!=` instead")
    fn CommandConnected::not_equal(x : CommandConnected, y : CommandConnected) -> Bool

    CommandConnected::read

    source

    CommandConnected::read_with_limit

    source

    CommandConnected::size_of

    source
    fn CommandConnected::size_of(self : CommandConnected) -> UInt

    CommandConnected::to_json

    source
    fn CommandConnected::to_json(self : CommandConnected) -> Json

    CommandConnected::to_repr

    source

    CommandConnected::write

    source
    fn CommandConnected::write(self : CommandConnected, writer : &
    Writer    ) -> Unit raise

    CommandConsumerStats

    source
    pub(all) struct CommandConsumerStats {
      request_id : UInt64
      consumer_id : UInt64
    } derive(Eq, 
    Debug    )

    CommandConsumerStats::CommandConsumerStats

    source
    #alias(new, deprecated="`new` is deprecated, use `CommandConsumerStats` instead")
    fn CommandConsumerStats::CommandConsumerStats(request_id : UInt64, consumer_id : UInt64) -> CommandConsumerStats

    CommandConsumerStats::default

    source

    CommandConsumerStats::equal

    source
    #deprecated("Use `==` instead")
    fn CommandConsumerStats::equal(CommandConsumerStats, CommandConsumerStats) -> Bool

    CommandConsumerStats::from_json

    source

    CommandConsumerStats::not_equal

    source
    #deprecated("Use `!=` instead")
    fn CommandConsumerStats::not_equal(x : CommandConsumerStats, y : CommandConsumerStats) -> Bool

    CommandConsumerStats::read

    source

    CommandConsumerStats::read_with_limit

    source

    CommandConsumerStats::size_of

    source
    fn CommandConsumerStats::size_of(self : CommandConsumerStats) -> UInt

    CommandConsumerStats::to_json

    source

    CommandConsumerStats::to_repr

    source

    CommandConsumerStats::write

    source

    CommandConsumerStatsResponse

    source
    pub(all) struct CommandConsumerStatsResponse {
      request_id : UInt64
      error_code : ServerError?
      error_message : String?
      msg_rate_out : Double?
      msg_throughput_out : Double?
      msg_rate_redeliver : Double?
      consumer_name : String?
      available_permits : UInt64?
      unacked_messages : UInt64?
      blocked_consumer_on_unacked_msgs : Bool?
      address : String?
      connected_since : String?
      type_ : String?
      msg_rate_expired : Double?
      msg_backlog : UInt64?
      message_ack_rate : Double?
    } derive(Eq, 
    Debug    )

    CommandConsumerStatsResponse::CommandConsumerStatsResponse

    source
    #alias(new, deprecated="`new` is deprecated, use `CommandConsumerStatsResponse` instead")
    fn CommandConsumerStatsResponse::CommandConsumerStatsResponse(request_id : UInt64, error_code? : ServerError, error_message? : String, msg_rate_out? : Double, msg_throughput_out? : Double, msg_rate_redeliver? : Double, consumer_name? : String, available_permits? : UInt64, unacked_messages? : UInt64, blocked_consumer_on_unacked_msgs? : Bool, address? : String, connected_since? : String, type_? : String, msg_rate_expired? : Double, msg_backlog? : UInt64, message_ack_rate? : Double) -> CommandConsumerStatsResponse

    CommandConsumerStatsResponse::default

    source

    CommandConsumerStatsResponse::equal

    source

    CommandConsumerStatsResponse::from_json

    source

    CommandConsumerStatsResponse::not_equal

    source
    #deprecated("Use `!=` instead")
    fn CommandConsumerStatsResponse::not_equal(x : CommandConsumerStatsResponse, y : CommandConsumerStatsResponse) -> Bool

    CommandConsumerStatsResponse::read

    source

    CommandConsumerStatsResponse::read_with_limit

    source

    CommandConsumerStatsResponse::size_of

    source

    CommandConsumerStatsResponse::to_json

    source

    CommandConsumerStatsResponse::to_repr

    source

    CommandConsumerStatsResponse::write

    source

    CommandEndTxn

    source
    pub(all) struct CommandEndTxn {
      request_id : UInt64
      txnid_least_bits : UInt64?
      txnid_most_bits : UInt64?
      txn_action : TxnAction?
      scalable : Bool?
    } derive(Eq, 
    Debug    )

    CommandEndTxn::CommandEndTxn

    source
    #alias(new, deprecated="`new` is deprecated, use `CommandEndTxn` instead")
    fn CommandEndTxn::CommandEndTxn(request_id : UInt64, txnid_least_bits? : UInt64, txnid_most_bits? : UInt64, txn_action? : TxnAction, scalable? : Bool) -> CommandEndTxn

    CommandEndTxn::default

    source
    fn CommandEndTxn::default() -> CommandEndTxn

    CommandEndTxn::equal

    source
    #deprecated("Use `==` instead")
    fn CommandEndTxn::equal(CommandEndTxn, CommandEndTxn) -> Bool

    CommandEndTxn::from_json

    source

    CommandEndTxn::not_equal

    source
    #deprecated("Use `!=` instead")
    fn CommandEndTxn::not_equal(x : CommandEndTxn, y : CommandEndTxn) -> Bool

    CommandEndTxn::read

    source

    CommandEndTxn::read_with_limit

    source

    CommandEndTxn::size_of

    source
    fn CommandEndTxn::size_of(self : CommandEndTxn) -> UInt

    CommandEndTxn::to_json

    source
    fn CommandEndTxn::to_json(self : CommandEndTxn) -> Json

    CommandEndTxn::to_repr

    source

    CommandEndTxn::write

    source
    fn CommandEndTxn::write(self : CommandEndTxn, writer : &
    Writer    ) -> Unit raise

    CommandEndTxnOnPartition

    source
    pub(all) struct CommandEndTxnOnPartition {
      request_id : UInt64
      txnid_least_bits : UInt64?
      txnid_most_bits : UInt64?
      topic : String?
      txn_action : TxnAction?
      txnid_least_bits_of_low_watermark : UInt64?
    } derive(Eq, 
    Debug    )

    CommandEndTxnOnPartition::CommandEndTxnOnPartition

    source
    #alias(new, deprecated="`new` is deprecated, use `CommandEndTxnOnPartition` instead")
    fn CommandEndTxnOnPartition::CommandEndTxnOnPartition(request_id : UInt64, txnid_least_bits? : UInt64, txnid_most_bits? : UInt64, topic? : String, txn_action? : TxnAction, txnid_least_bits_of_low_watermark? : UInt64) -> CommandEndTxnOnPartition

    CommandEndTxnOnPartition::default

    source

    CommandEndTxnOnPartition::equal

    source
    #deprecated("Use `==` instead")
    fn CommandEndTxnOnPartition::equal(CommandEndTxnOnPartition, CommandEndTxnOnPartition) -> Bool

    CommandEndTxnOnPartition::from_json

    source

    CommandEndTxnOnPartition::not_equal

    source
    #deprecated("Use `!=` instead")
    fn CommandEndTxnOnPartition::not_equal(x : CommandEndTxnOnPartition, y : CommandEndTxnOnPartition) -> Bool

    CommandEndTxnOnPartition::read

    source

    CommandEndTxnOnPartition::read_with_limit

    source

    CommandEndTxnOnPartition::size_of

    source

    CommandEndTxnOnPartition::to_json

    source

    CommandEndTxnOnPartition::to_repr

    source

    CommandEndTxnOnPartition::write

    source

    CommandEndTxnOnPartitionResponse

    source
    pub(all) struct CommandEndTxnOnPartitionResponse {
      request_id : UInt64
      txnid_least_bits : UInt64?
      txnid_most_bits : UInt64?
      error : ServerError?
      message : String?
    } derive(Eq, 
    Debug    )

    CommandEndTxnOnPartitionResponse::CommandEndTxnOnPartitionResponse

    source
    #alias(new, deprecated="`new` is deprecated, use `CommandEndTxnOnPartitionResponse` instead")
    fn CommandEndTxnOnPartitionResponse::CommandEndTxnOnPartitionResponse(request_id : UInt64, txnid_least_bits? : UInt64, txnid_most_bits? : UInt64, error? : ServerError, message? : String) -> CommandEndTxnOnPartitionResponse

    CommandEndTxnOnPartitionResponse::default

    source

    CommandEndTxnOnPartitionResponse::equal

    source

    CommandEndTxnOnPartitionResponse::from_json

    source

    CommandEndTxnOnPartitionResponse::not_equal

    source
    #deprecated("Use `!=` instead")
    fn CommandEndTxnOnPartitionResponse::not_equal(x : CommandEndTxnOnPartitionResponse, y : CommandEndTxnOnPartitionResponse) -> Bool

    CommandEndTxnOnPartitionResponse::read

    source

    CommandEndTxnOnPartitionResponse::read_with_limit

    source

    CommandEndTxnOnPartitionResponse::size_of

    source

    CommandEndTxnOnPartitionResponse::to_json

    source

    CommandEndTxnOnPartitionResponse::to_repr

    source

    CommandEndTxnOnPartitionResponse::write

    source

    CommandEndTxnOnSubscription

    source
    pub(all) struct CommandEndTxnOnSubscription {
      request_id : UInt64
      txnid_least_bits : UInt64?
      txnid_most_bits : UInt64?
      subscription : Subscription?
      txn_action : TxnAction?
      txnid_least_bits_of_low_watermark : UInt64?
    } derive(Eq, 
    Debug    )

    CommandEndTxnOnSubscription::CommandEndTxnOnSubscription

    source
    #alias(new, deprecated="`new` is deprecated, use `CommandEndTxnOnSubscription` instead")
    fn CommandEndTxnOnSubscription::CommandEndTxnOnSubscription(request_id : UInt64, txnid_least_bits? : UInt64, txnid_most_bits? : UInt64, subscription? : Subscription, txn_action? : TxnAction, txnid_least_bits_of_low_watermark? : UInt64) -> CommandEndTxnOnSubscription

    CommandEndTxnOnSubscription::default

    source

    CommandEndTxnOnSubscription::equal

    source

    CommandEndTxnOnSubscription::from_json

    source

    CommandEndTxnOnSubscription::not_equal

    source
    #deprecated("Use `!=` instead")
    fn CommandEndTxnOnSubscription::not_equal(x : CommandEndTxnOnSubscription, y : CommandEndTxnOnSubscription) -> Bool

    CommandEndTxnOnSubscription::read

    source

    CommandEndTxnOnSubscription::read_with_limit

    source

    CommandEndTxnOnSubscription::size_of

    source

    CommandEndTxnOnSubscription::to_json

    source

    CommandEndTxnOnSubscription::to_repr

    source

    CommandEndTxnOnSubscription::write

    source

    CommandEndTxnOnSubscriptionResponse

    source
    pub(all) struct CommandEndTxnOnSubscriptionResponse {
      request_id : UInt64
      txnid_least_bits : UInt64?
      txnid_most_bits : UInt64?
      error : ServerError?
      message : String?
    } derive(Eq, 
    Debug    )

    CommandEndTxnOnSubscriptionResponse::CommandEndTxnOnSubscriptionResponse

    source
    #alias(new, deprecated="`new` is deprecated, use `CommandEndTxnOnSubscriptionResponse` instead")
    fn CommandEndTxnOnSubscriptionResponse::CommandEndTxnOnSubscriptionResponse(request_id : UInt64, txnid_least_bits? : UInt64, txnid_most_bits? : UInt64, error? : ServerError, message? : String) -> CommandEndTxnOnSubscriptionResponse

    CommandEndTxnOnSubscriptionResponse::default

    source

    CommandEndTxnOnSubscriptionResponse::equal

    source

    CommandEndTxnOnSubscriptionResponse::from_json

    source

    CommandEndTxnOnSubscriptionResponse::not_equal

    source

    CommandEndTxnOnSubscriptionResponse::read

    source

    CommandEndTxnOnSubscriptionResponse::read_with_limit

    source

    CommandEndTxnOnSubscriptionResponse::size_of

    source

    CommandEndTxnOnSubscriptionResponse::to_json

    source

    CommandEndTxnOnSubscriptionResponse::to_repr

    source

    CommandEndTxnOnSubscriptionResponse::write

    source

    CommandEndTxnResponse

    source
    pub(all) struct CommandEndTxnResponse {
      request_id : UInt64
      txnid_least_bits : UInt64?
      txnid_most_bits : UInt64?
      error : ServerError?
      message : String?
    } derive(Eq, 
    Debug    )

    CommandEndTxnResponse::CommandEndTxnResponse

    source
    #alias(new, deprecated="`new` is deprecated, use `CommandEndTxnResponse` instead")
    fn CommandEndTxnResponse::CommandEndTxnResponse(request_id : UInt64, txnid_least_bits? : UInt64, txnid_most_bits? : UInt64, error? : ServerError, message? : String) -> CommandEndTxnResponse

    CommandEndTxnResponse::default

    source

    CommandEndTxnResponse::equal

    source
    #deprecated("Use `==` instead")
    fn CommandEndTxnResponse::equal(CommandEndTxnResponse, CommandEndTxnResponse) -> Bool

    CommandEndTxnResponse::from_json

    source

    CommandEndTxnResponse::not_equal

    source
    #deprecated("Use `!=` instead")
    fn CommandEndTxnResponse::not_equal(x : CommandEndTxnResponse, y : CommandEndTxnResponse) -> Bool

    CommandEndTxnResponse::read

    source

    CommandEndTxnResponse::read_with_limit

    source

    CommandEndTxnResponse::size_of

    source
    fn CommandEndTxnResponse::size_of(self : CommandEndTxnResponse) -> UInt

    CommandEndTxnResponse::to_json

    source

    CommandEndTxnResponse::to_repr

    source

    CommandEndTxnResponse::write

    source

    CommandError

    source
    pub(all) struct CommandError {
      request_id : UInt64
      error : ServerError
      message : String
    } derive(Eq, 
    Debug    )

    CommandError::CommandError

    source
    #alias(new, deprecated="`new` is deprecated, use `CommandError` instead")
    fn CommandError::CommandError(request_id : UInt64, error : ServerError, message : String) -> CommandError

    CommandError::default

    source
    fn CommandError::default() -> CommandError

    CommandError::equal

    source
    #deprecated("Use `==` instead")
    fn CommandError::equal(CommandError, CommandError) -> Bool

    CommandError::from_json

    source

    CommandError::not_equal

    source
    #deprecated("Use `!=` instead")
    fn CommandError::not_equal(x : CommandError, y : CommandError) -> Bool

    CommandError::read

    source

    CommandError::read_with_limit

    source

    CommandError::size_of

    source
    fn CommandError::size_of(self : CommandError) -> UInt

    CommandError::to_json

    source
    fn CommandError::to_json(self : CommandError) -> Json

    CommandError::to_repr

    source

    CommandError::write

    source
    fn CommandError::write(self : CommandError, writer : &
    Writer    ) -> Unit raise

    CommandFlow

    source
    pub(all) struct CommandFlow {
      consumer_id : UInt64
      message_permits : UInt
    } derive(Eq, 
    Debug    )

    impl Read for CommandFlow

    CommandFlow::CommandFlow

    source
    #alias(new, deprecated="`new` is deprecated, use `CommandFlow` instead")
    fn CommandFlow::CommandFlow(consumer_id : UInt64, message_permits : UInt) -> CommandFlow

    CommandFlow::default

    source
    fn CommandFlow::default() -> CommandFlow

    CommandFlow::equal

    source
    #deprecated("Use `==` instead")
    fn CommandFlow::equal(CommandFlow, CommandFlow) -> Bool

    CommandFlow::from_json

    source

    CommandFlow::not_equal

    source
    #deprecated("Use `!=` instead")
    fn CommandFlow::not_equal(x : CommandFlow, y : CommandFlow) -> Bool

    CommandFlow::read

    source

    CommandFlow::read_with_limit

    source

    CommandFlow::size_of

    source
    fn CommandFlow::size_of(self : CommandFlow) -> UInt

    CommandFlow::to_json

    source
    fn CommandFlow::to_json(self : CommandFlow) -> Json

    CommandFlow::to_repr

    source

    CommandFlow::write

    source
    fn CommandFlow::write(self : CommandFlow, writer : &
    Writer    ) -> Unit raise

    CommandGetLastMessageId

    source
    pub(all) struct CommandGetLastMessageId {
      consumer_id : UInt64
      request_id : UInt64
    } derive(Eq, 
    Debug    )

    CommandGetLastMessageId::CommandGetLastMessageId

    source
    #alias(new, deprecated="`new` is deprecated, use `CommandGetLastMessageId` instead")
    fn CommandGetLastMessageId::CommandGetLastMessageId(consumer_id : UInt64, request_id : UInt64) -> CommandGetLastMessageId

    CommandGetLastMessageId::default

    source

    CommandGetLastMessageId::equal

    source
    #deprecated("Use `==` instead")
    fn CommandGetLastMessageId::equal(CommandGetLastMessageId, CommandGetLastMessageId) -> Bool

    CommandGetLastMessageId::from_json

    source

    CommandGetLastMessageId::not_equal

    source
    #deprecated("Use `!=` instead")
    fn CommandGetLastMessageId::not_equal(x : CommandGetLastMessageId, y : CommandGetLastMessageId) -> Bool

    CommandGetLastMessageId::read

    source

    CommandGetLastMessageId::read_with_limit

    source

    CommandGetLastMessageId::size_of

    source

    CommandGetLastMessageId::to_json

    source

    CommandGetLastMessageId::to_repr

    source

    CommandGetLastMessageId::write

    source

    CommandGetLastMessageIdResponse

    source
    pub(all) struct CommandGetLastMessageIdResponse {
      last_message_id : MessageIdData
      request_id : UInt64
      consumer_mark_delete_position : MessageIdData?
    } derive(Eq, 
    Debug    )

    CommandGetLastMessageIdResponse::CommandGetLastMessageIdResponse

    source
    #alias(new, deprecated="`new` is deprecated, use `CommandGetLastMessageIdResponse` instead")
    fn CommandGetLastMessageIdResponse::CommandGetLastMessageIdResponse(last_message_id : MessageIdData, request_id : UInt64, consumer_mark_delete_position? : MessageIdData) -> CommandGetLastMessageIdResponse

    CommandGetLastMessageIdResponse::default

    source

    CommandGetLastMessageIdResponse::equal

    source

    CommandGetLastMessageIdResponse::from_json

    source

    CommandGetLastMessageIdResponse::not_equal

    source
    #deprecated("Use `!=` instead")
    fn CommandGetLastMessageIdResponse::not_equal(x : CommandGetLastMessageIdResponse, y : CommandGetLastMessageIdResponse) -> Bool

    CommandGetLastMessageIdResponse::read

    source

    CommandGetLastMessageIdResponse::read_with_limit

    source

    CommandGetLastMessageIdResponse::size_of

    source

    CommandGetLastMessageIdResponse::to_json

    source

    CommandGetLastMessageIdResponse::to_repr

    source

    CommandGetLastMessageIdResponse::write

    source

    CommandGetOrCreateSchema

    source
    pub(all) struct CommandGetOrCreateSchema {
      request_id : UInt64
      topic : String
      schema : Schema
      producer_name : String?
    } derive(Eq, 
    Debug    )

    CommandGetOrCreateSchema::CommandGetOrCreateSchema

    source
    #alias(new, deprecated="`new` is deprecated, use `CommandGetOrCreateSchema` instead")
    fn CommandGetOrCreateSchema::CommandGetOrCreateSchema(request_id : UInt64, topic : String, schema : Schema, producer_name? : String) -> CommandGetOrCreateSchema

    CommandGetOrCreateSchema::default

    source

    CommandGetOrCreateSchema::equal

    source
    #deprecated("Use `==` instead")
    fn CommandGetOrCreateSchema::equal(CommandGetOrCreateSchema, CommandGetOrCreateSchema) -> Bool

    CommandGetOrCreateSchema::from_json

    source

    CommandGetOrCreateSchema::not_equal

    source
    #deprecated("Use `!=` instead")
    fn CommandGetOrCreateSchema::not_equal(x : CommandGetOrCreateSchema, y : CommandGetOrCreateSchema) -> Bool

    CommandGetOrCreateSchema::read

    source

    CommandGetOrCreateSchema::read_with_limit

    source

    CommandGetOrCreateSchema::size_of

    source

    CommandGetOrCreateSchema::to_json

    source

    CommandGetOrCreateSchema::to_repr

    source

    CommandGetOrCreateSchema::write

    source

    CommandGetOrCreateSchemaResponse

    source
    pub(all) struct CommandGetOrCreateSchemaResponse {
      request_id : UInt64
      error_code : ServerError?
      error_message : String?
      schema_version : Bytes?
    } derive(Eq, 
    Debug    )

    CommandGetOrCreateSchemaResponse::CommandGetOrCreateSchemaResponse

    source
    #alias(new, deprecated="`new` is deprecated, use `CommandGetOrCreateSchemaResponse` instead")
    fn CommandGetOrCreateSchemaResponse::CommandGetOrCreateSchemaResponse(request_id : UInt64, error_code? : ServerError, error_message? : String, schema_version? : Bytes) -> CommandGetOrCreateSchemaResponse

    CommandGetOrCreateSchemaResponse::default

    source

    CommandGetOrCreateSchemaResponse::equal

    source

    CommandGetOrCreateSchemaResponse::from_json

    source

    CommandGetOrCreateSchemaResponse::not_equal

    source
    #deprecated("Use `!=` instead")
    fn CommandGetOrCreateSchemaResponse::not_equal(x : CommandGetOrCreateSchemaResponse, y : CommandGetOrCreateSchemaResponse) -> Bool

    CommandGetOrCreateSchemaResponse::read

    source

    CommandGetOrCreateSchemaResponse::read_with_limit

    source

    CommandGetOrCreateSchemaResponse::size_of

    source

    CommandGetOrCreateSchemaResponse::to_json

    source

    CommandGetOrCreateSchemaResponse::to_repr

    source

    CommandGetOrCreateSchemaResponse::write

    source

    CommandGetSchema

    source
    pub(all) struct CommandGetSchema {
      request_id : UInt64
      topic : String
      schema_version : Bytes?
    } derive(Eq, 
    Debug    )

    CommandGetSchema::CommandGetSchema

    source
    #alias(new, deprecated="`new` is deprecated, use `CommandGetSchema` instead")
    fn CommandGetSchema::CommandGetSchema(request_id : UInt64, topic : String, schema_version? : Bytes) -> CommandGetSchema

    CommandGetSchema::default

    source

    CommandGetSchema::equal

    source
    #deprecated("Use `==` instead")
    fn CommandGetSchema::equal(CommandGetSchema, CommandGetSchema) -> Bool

    CommandGetSchema::from_json

    source

    CommandGetSchema::not_equal

    source
    #deprecated("Use `!=` instead")
    fn CommandGetSchema::not_equal(x : CommandGetSchema, y : CommandGetSchema) -> Bool

    CommandGetSchema::read

    source

    CommandGetSchema::read_with_limit

    source

    CommandGetSchema::size_of

    source
    fn CommandGetSchema::size_of(self : CommandGetSchema) -> UInt

    CommandGetSchema::to_json

    source
    fn CommandGetSchema::to_json(self : CommandGetSchema) -> Json

    CommandGetSchema::to_repr

    source

    CommandGetSchema::write

    source
    fn CommandGetSchema::write(self : CommandGetSchema, writer : &
    Writer    ) -> Unit raise

    CommandGetSchemaResponse

    source
    pub(all) struct CommandGetSchemaResponse {
      request_id : UInt64
      error_code : ServerError?
      error_message : String?
      schema : Schema?
      schema_version : Bytes?
    } derive(Eq, 
    Debug    )

    CommandGetSchemaResponse::CommandGetSchemaResponse

    source
    #alias(new, deprecated="`new` is deprecated, use `CommandGetSchemaResponse` instead")
    fn CommandGetSchemaResponse::CommandGetSchemaResponse(request_id : UInt64, error_code? : ServerError, error_message? : String, schema? : Schema, schema_version? : Bytes) -> CommandGetSchemaResponse

    CommandGetSchemaResponse::default

    source

    CommandGetSchemaResponse::equal

    source
    #deprecated("Use `==` instead")
    fn CommandGetSchemaResponse::equal(CommandGetSchemaResponse, CommandGetSchemaResponse) -> Bool

    CommandGetSchemaResponse::from_json

    source

    CommandGetSchemaResponse::not_equal

    source
    #deprecated("Use `!=` instead")
    fn CommandGetSchemaResponse::not_equal(x : CommandGetSchemaResponse, y : CommandGetSchemaResponse) -> Bool

    CommandGetSchemaResponse::read

    source

    CommandGetSchemaResponse::read_with_limit

    source

    CommandGetSchemaResponse::size_of

    source

    CommandGetSchemaResponse::to_json

    source

    CommandGetSchemaResponse::to_repr

    source

    CommandGetSchemaResponse::write

    source

    CommandGetTopicsOfNamespace

    source
    pub(all) struct CommandGetTopicsOfNamespace {
      request_id : UInt64
      namespace_ : String
      mode : CommandGetTopicsOfNamespace_Mode?
      topics_pattern : String?
      topics_hash : String?
      properties : Array[KeyValue]
    } derive(Eq, 
    Debug    )

    CommandGetTopicsOfNamespace::CommandGetTopicsOfNamespace

    source
    #alias(new, deprecated="`new` is deprecated, use `CommandGetTopicsOfNamespace` instead")
    fn CommandGetTopicsOfNamespace::CommandGetTopicsOfNamespace(request_id : UInt64, namespace_ : String, mode? : CommandGetTopicsOfNamespace_Mode, topics_pattern? : String, topics_hash? : String, properties : Array[KeyValue]) -> CommandGetTopicsOfNamespace

    CommandGetTopicsOfNamespace::default

    source

    CommandGetTopicsOfNamespace::equal

    source

    CommandGetTopicsOfNamespace::from_json

    source

    CommandGetTopicsOfNamespace::not_equal

    source
    #deprecated("Use `!=` instead")
    fn CommandGetTopicsOfNamespace::not_equal(x : CommandGetTopicsOfNamespace, y : CommandGetTopicsOfNamespace) -> Bool

    CommandGetTopicsOfNamespace::read

    source

    CommandGetTopicsOfNamespace::read_with_limit

    source

    CommandGetTopicsOfNamespace::size_of

    source

    CommandGetTopicsOfNamespace::to_json

    source

    CommandGetTopicsOfNamespace::to_repr

    source

    CommandGetTopicsOfNamespace::write

    source

    CommandGetTopicsOfNamespaceResponse

    source
    pub(all) struct CommandGetTopicsOfNamespaceResponse {
      request_id : UInt64
      topics : Array[String]
      filtered : Bool?
      topics_hash : String?
      changed : Bool?
    } derive(Eq, 
    Debug    )

    CommandGetTopicsOfNamespaceResponse::CommandGetTopicsOfNamespaceResponse

    source
    #alias(new, deprecated="`new` is deprecated, use `CommandGetTopicsOfNamespaceResponse` instead")
    fn CommandGetTopicsOfNamespaceResponse::CommandGetTopicsOfNamespaceResponse(request_id : UInt64, topics : Array[String], filtered? : Bool, topics_hash? : String, changed? : Bool) -> CommandGetTopicsOfNamespaceResponse

    CommandGetTopicsOfNamespaceResponse::default

    source

    CommandGetTopicsOfNamespaceResponse::equal

    source

    CommandGetTopicsOfNamespaceResponse::from_json

    source

    CommandGetTopicsOfNamespaceResponse::not_equal

    source

    CommandGetTopicsOfNamespaceResponse::read

    source

    CommandGetTopicsOfNamespaceResponse::read_with_limit

    source

    CommandGetTopicsOfNamespaceResponse::size_of

    source

    CommandGetTopicsOfNamespaceResponse::to_json

    source

    CommandGetTopicsOfNamespaceResponse::to_repr

    source

    CommandGetTopicsOfNamespaceResponse::write

    source

    CommandGetTopicsOfNamespace_Mode

    source
    pub(all) enum CommandGetTopicsOfNamespace_Mode {
      PERSISTENT
      NON_PERSISTENT
      ALL
    } derive(Eq, 
    Debug    )

    CommandGetTopicsOfNamespace_Mode::default

    source

    CommandGetTopicsOfNamespace_Mode::equal

    source

    CommandGetTopicsOfNamespace_Mode::from_enum

    source

    CommandGetTopicsOfNamespace_Mode::from_json

    source

    CommandGetTopicsOfNamespace_Mode::not_equal

    source
    #deprecated("Use `!=` instead")
    fn CommandGetTopicsOfNamespace_Mode::not_equal(x : CommandGetTopicsOfNamespace_Mode, y : CommandGetTopicsOfNamespace_Mode) -> Bool

    CommandGetTopicsOfNamespace_Mode::size_of

    source

    CommandGetTopicsOfNamespace_Mode::to_enum

    source

    CommandGetTopicsOfNamespace_Mode::to_json

    source

    CommandGetTopicsOfNamespace_Mode::to_repr

    source

    CommandLookupTopic

    source
    pub(all) struct CommandLookupTopic {
      topic : String
      request_id : UInt64
      authoritative : Bool?
      original_principal : String?
      original_auth_data : String?
      original_auth_method : String?
      advertised_listener_name : String?
      properties : Array[KeyValue]
    } derive(Eq, 
    Debug    )

    CommandLookupTopic::CommandLookupTopic

    source
    #alias(new, deprecated="`new` is deprecated, use `CommandLookupTopic` instead")
    fn CommandLookupTopic::CommandLookupTopic(topic : String, request_id : UInt64, authoritative? : Bool, original_principal? : String, original_auth_data? : String, original_auth_method? : String, advertised_listener_name? : String, properties : Array[KeyValue]) -> CommandLookupTopic

    CommandLookupTopic::default

    source

    CommandLookupTopic::equal

    source
    #deprecated("Use `==` instead")
    fn CommandLookupTopic::equal(CommandLookupTopic, CommandLookupTopic) -> Bool

    CommandLookupTopic::from_json

    source

    CommandLookupTopic::not_equal

    source
    #deprecated("Use `!=` instead")
    fn CommandLookupTopic::not_equal(x : CommandLookupTopic, y : CommandLookupTopic) -> Bool

    CommandLookupTopic::read

    source

    CommandLookupTopic::read_with_limit

    source

    CommandLookupTopic::size_of

    source
    fn CommandLookupTopic::size_of(self : CommandLookupTopic) -> UInt

    CommandLookupTopic::to_json

    source

    CommandLookupTopic::to_repr

    source

    CommandLookupTopic::write

    source

    CommandLookupTopicResponse

    source
    pub(all) struct CommandLookupTopicResponse {
      broker_service_url : String?
      broker_service_url_tls : String?
      response : CommandLookupTopicResponse_LookupType?
      request_id : UInt64
      authoritative : Bool?
      error : ServerError?
      message : String?
      proxy_through_service_url : Bool?
    } derive(Eq, 
    Debug    )

    CommandLookupTopicResponse::CommandLookupTopicResponse

    source
    #alias(new, deprecated="`new` is deprecated, use `CommandLookupTopicResponse` instead")
    fn CommandLookupTopicResponse::CommandLookupTopicResponse(broker_service_url? : String, broker_service_url_tls? : String, response? : CommandLookupTopicResponse_LookupType, request_id : UInt64, authoritative? : Bool, error? : ServerError, message? : String, proxy_through_service_url? : Bool) -> CommandLookupTopicResponse

    CommandLookupTopicResponse::default

    source

    CommandLookupTopicResponse::equal

    source
    #deprecated("Use `==` instead")
    fn CommandLookupTopicResponse::equal(CommandLookupTopicResponse, CommandLookupTopicResponse) -> Bool

    CommandLookupTopicResponse::from_json

    source

    CommandLookupTopicResponse::not_equal

    source
    #deprecated("Use `!=` instead")
    fn CommandLookupTopicResponse::not_equal(x : CommandLookupTopicResponse, y : CommandLookupTopicResponse) -> Bool

    CommandLookupTopicResponse::read

    source

    CommandLookupTopicResponse::read_with_limit

    source

    CommandLookupTopicResponse::size_of

    source

    CommandLookupTopicResponse::to_json

    source

    CommandLookupTopicResponse::to_repr

    source

    CommandLookupTopicResponse::write

    source

    CommandLookupTopicResponse_LookupType

    source
    pub(all) enum CommandLookupTopicResponse_LookupType {
      Redirect
      Connect
      Failed
    } derive(Eq, 
    Debug    )

    CommandLookupTopicResponse_LookupType::default

    source

    CommandLookupTopicResponse_LookupType::equal

    source

    CommandLookupTopicResponse_LookupType::from_enum

    source

    CommandLookupTopicResponse_LookupType::from_json

    source

    CommandLookupTopicResponse_LookupType::not_equal

    source

    CommandLookupTopicResponse_LookupType::size_of

    source

    CommandLookupTopicResponse_LookupType::to_enum

    source

    CommandLookupTopicResponse_LookupType::to_json

    source

    CommandLookupTopicResponse_LookupType::to_repr

    source

    CommandMessage

    source
    pub(all) struct CommandMessage {
      consumer_id : UInt64
      message_id : MessageIdData
      redelivery_count : UInt?
      ack_set : Array[Int64]
      consumer_epoch : UInt64?
    } derive(Eq, 
    Debug    )

    CommandMessage::CommandMessage

    source
    #alias(new, deprecated="`new` is deprecated, use `CommandMessage` instead")
    fn CommandMessage::CommandMessage(consumer_id : UInt64, message_id : MessageIdData, redelivery_count? : UInt, ack_set : Array[Int64], consumer_epoch? : UInt64) -> CommandMessage

    CommandMessage::default

    source

    CommandMessage::equal

    source
    #deprecated("Use `==` instead")
    fn CommandMessage::equal(CommandMessage, CommandMessage) -> Bool

    CommandMessage::from_json

    source

    CommandMessage::not_equal

    source
    #deprecated("Use `!=` instead")
    fn CommandMessage::not_equal(x : CommandMessage, y : CommandMessage) -> Bool

    CommandMessage::read

    source

    CommandMessage::read_with_limit

    source

    CommandMessage::size_of

    source
    fn CommandMessage::size_of(self : CommandMessage) -> UInt

    CommandMessage::to_json

    source
    fn CommandMessage::to_json(self : CommandMessage) -> Json

    CommandMessage::to_repr

    source

    CommandMessage::write

    source
    fn CommandMessage::write(self : CommandMessage, writer : &
    Writer    ) -> Unit raise

    CommandNewTxn

    source
    pub(all) struct CommandNewTxn {
      request_id : UInt64
      txn_ttl_millis : UInt64?
      tc_id : UInt64?
      scalable : Bool?
    } derive(Eq, 
    Debug    )

    CommandNewTxn::CommandNewTxn

    source
    #alias(new, deprecated="`new` is deprecated, use `CommandNewTxn` instead")
    fn CommandNewTxn::CommandNewTxn(request_id : UInt64, txn_ttl_millis? : UInt64, tc_id? : UInt64, scalable? : Bool) -> CommandNewTxn

    CommandNewTxn::default

    source
    fn CommandNewTxn::default() -> CommandNewTxn

    CommandNewTxn::equal

    source
    #deprecated("Use `==` instead")
    fn CommandNewTxn::equal(CommandNewTxn, CommandNewTxn) -> Bool

    CommandNewTxn::from_json

    source

    CommandNewTxn::not_equal

    source
    #deprecated("Use `!=` instead")
    fn CommandNewTxn::not_equal(x : CommandNewTxn, y : CommandNewTxn) -> Bool

    CommandNewTxn::read

    source

    CommandNewTxn::read_with_limit

    source

    CommandNewTxn::size_of

    source
    fn CommandNewTxn::size_of(self : CommandNewTxn) -> UInt

    CommandNewTxn::to_json

    source
    fn CommandNewTxn::to_json(self : CommandNewTxn) -> Json

    CommandNewTxn::to_repr

    source

    CommandNewTxn::write

    source
    fn CommandNewTxn::write(self : CommandNewTxn, writer : &
    Writer    ) -> Unit raise

    CommandNewTxnResponse

    source
    pub(all) struct CommandNewTxnResponse {
      request_id : UInt64
      txnid_least_bits : UInt64?
      txnid_most_bits : UInt64?
      error : ServerError?
      message : String?
    } derive(Eq, 
    Debug    )

    CommandNewTxnResponse::CommandNewTxnResponse

    source
    #alias(new, deprecated="`new` is deprecated, use `CommandNewTxnResponse` instead")
    fn CommandNewTxnResponse::CommandNewTxnResponse(request_id : UInt64, txnid_least_bits? : UInt64, txnid_most_bits? : UInt64, error? : ServerError, message? : String) -> CommandNewTxnResponse

    CommandNewTxnResponse::default

    source

    CommandNewTxnResponse::equal

    source
    #deprecated("Use `==` instead")
    fn CommandNewTxnResponse::equal(CommandNewTxnResponse, CommandNewTxnResponse) -> Bool

    CommandNewTxnResponse::from_json

    source

    CommandNewTxnResponse::not_equal

    source
    #deprecated("Use `!=` instead")
    fn CommandNewTxnResponse::not_equal(x : CommandNewTxnResponse, y : CommandNewTxnResponse) -> Bool

    CommandNewTxnResponse::read

    source

    CommandNewTxnResponse::read_with_limit

    source

    CommandNewTxnResponse::size_of

    source
    fn CommandNewTxnResponse::size_of(self : CommandNewTxnResponse) -> UInt

    CommandNewTxnResponse::to_json

    source

    CommandNewTxnResponse::to_repr

    source

    CommandNewTxnResponse::write

    source

    CommandPartitionedTopicMetadata

    source
    pub(all) struct CommandPartitionedTopicMetadata {
      topic : String
      request_id : UInt64
      original_principal : String?
      original_auth_data : String?
      original_auth_method : String?
      metadata_auto_creation_enabled : Bool?
    } derive(Eq, 
    Debug    )

    CommandPartitionedTopicMetadata::CommandPartitionedTopicMetadata

    source
    #alias(new, deprecated="`new` is deprecated, use `CommandPartitionedTopicMetadata` instead")
    fn CommandPartitionedTopicMetadata::CommandPartitionedTopicMetadata(topic : String, request_id : UInt64, original_principal? : String, original_auth_data? : String, original_auth_method? : String, metadata_auto_creation_enabled? : Bool) -> CommandPartitionedTopicMetadata

    CommandPartitionedTopicMetadata::default

    source

    CommandPartitionedTopicMetadata::equal

    source

    CommandPartitionedTopicMetadata::from_json

    source

    CommandPartitionedTopicMetadata::not_equal

    source
    #deprecated("Use `!=` instead")
    fn CommandPartitionedTopicMetadata::not_equal(x : CommandPartitionedTopicMetadata, y : CommandPartitionedTopicMetadata) -> Bool

    CommandPartitionedTopicMetadata::read

    source

    CommandPartitionedTopicMetadata::read_with_limit

    source

    CommandPartitionedTopicMetadata::size_of

    source

    CommandPartitionedTopicMetadata::to_json

    source

    CommandPartitionedTopicMetadata::to_repr

    source

    CommandPartitionedTopicMetadata::write

    source

    CommandPartitionedTopicMetadataResponse

    source
    pub(all) struct CommandPartitionedTopicMetadataResponse {
      partitions : UInt?
      request_id : UInt64
      response : CommandPartitionedTopicMetadataResponse_LookupType?
      error : ServerError?
      message : String?
    } derive(Eq, 
    Debug    )

    CommandPartitionedTopicMetadataResponse::CommandPartitionedTopicMetadataResponse

    source
    #alias(new, deprecated="`new` is deprecated, use `CommandPartitionedTopicMetadataResponse` instead")
    fn CommandPartitionedTopicMetadataResponse::CommandPartitionedTopicMetadataResponse(partitions? : UInt, request_id : UInt64, response? : CommandPartitionedTopicMetadataResponse_LookupType, error? : ServerError, message? : String) -> CommandPartitionedTopicMetadataResponse

    CommandPartitionedTopicMetadataResponse::default

    source

    CommandPartitionedTopicMetadataResponse::equal

    source

    CommandPartitionedTopicMetadataResponse::from_json

    source

    CommandPartitionedTopicMetadataResponse::not_equal

    source

    CommandPartitionedTopicMetadataResponse::read

    source

    CommandPartitionedTopicMetadataResponse::read_with_limit

    source

    CommandPartitionedTopicMetadataResponse::size_of

    source

    CommandPartitionedTopicMetadataResponse::to_json

    source

    CommandPartitionedTopicMetadataResponse::to_repr

    source

    CommandPartitionedTopicMetadataResponse::write

    source

    CommandPartitionedTopicMetadataResponse_LookupType

    source
    pub(all) enum CommandPartitionedTopicMetadataResponse_LookupType {
      Success
      Failed
    } derive(Eq, 
    Debug    )

    CommandPartitionedTopicMetadataResponse_LookupType::default

    source

    CommandPartitionedTopicMetadataResponse_LookupType::equal

    source

    CommandPartitionedTopicMetadataResponse_LookupType::from_enum

    source

    CommandPartitionedTopicMetadataResponse_LookupType::from_json

    source

    CommandPartitionedTopicMetadataResponse_LookupType::not_equal

    source

    CommandPartitionedTopicMetadataResponse_LookupType::size_of

    source

    CommandPartitionedTopicMetadataResponse_LookupType::to_enum

    source

    CommandPartitionedTopicMetadataResponse_LookupType::to_json

    source

    CommandPartitionedTopicMetadataResponse_LookupType::to_repr

    source

    CommandPing

    source
    pub(all) struct CommandPing {
    } derive(Eq, 
    Debug    )

    impl Read for CommandPing

    CommandPing::CommandPing

    source
    #alias(new, deprecated="`new` is deprecated, use `CommandPing` instead")
    fn CommandPing::CommandPing() -> CommandPing

    CommandPing::default

    source
    fn CommandPing::default() -> CommandPing

    CommandPing::equal

    source
    #deprecated("Use `==` instead")
    fn CommandPing::equal(CommandPing, CommandPing) -> Bool

    CommandPing::from_json

    source

    CommandPing::not_equal

    source
    #deprecated("Use `!=` instead")
    fn CommandPing::not_equal(x : CommandPing, y : CommandPing) -> Bool

    CommandPing::read

    source

    CommandPing::read_with_limit

    source

    CommandPing::size_of

    source
    fn CommandPing::size_of(_ : CommandPing) -> UInt

    CommandPing::to_json

    source
    fn CommandPing::to_json(_ : CommandPing) -> Json

    CommandPing::to_repr

    source

    CommandPing::write

    source

    CommandPong

    source
    pub(all) struct CommandPong {
    } derive(Eq, 
    Debug    )

    impl Read for CommandPong

    CommandPong::CommandPong

    source
    #alias(new, deprecated="`new` is deprecated, use `CommandPong` instead")
    fn CommandPong::CommandPong() -> CommandPong

    CommandPong::default

    source
    fn CommandPong::default() -> CommandPong

    CommandPong::equal

    source
    #deprecated("Use `==` instead")
    fn CommandPong::equal(CommandPong, CommandPong) -> Bool

    CommandPong::from_json

    source

    CommandPong::not_equal

    source
    #deprecated("Use `!=` instead")
    fn CommandPong::not_equal(x : CommandPong, y : CommandPong) -> Bool

    CommandPong::read

    source

    CommandPong::read_with_limit

    source

    CommandPong::size_of

    source
    fn CommandPong::size_of(_ : CommandPong) -> UInt

    CommandPong::to_json

    source
    fn CommandPong::to_json(_ : CommandPong) -> Json

    CommandPong::to_repr

    source

    CommandPong::write

    source

    CommandProducer

    source
    pub(all) struct CommandProducer {
      topic : String
      producer_id : UInt64
      request_id : UInt64
      producer_name : String?
      encrypted : Bool?
      metadata : Array[KeyValue]
      schema : Schema?
      epoch : UInt64?
      user_provided_producer_name : Bool?
      producer_access_mode : ProducerAccessMode?
      topic_epoch : UInt64?
      txn_enabled : Bool?
      initial_subscription_name : String?
    } derive(Eq, 
    Debug    )

    CommandProducer::CommandProducer

    source
    #alias(new, deprecated="`new` is deprecated, use `CommandProducer` instead")
    fn CommandProducer::CommandProducer(topic : String, producer_id : UInt64, request_id : UInt64, producer_name? : String, encrypted? : Bool, metadata : Array[KeyValue], schema? : Schema, epoch? : UInt64, user_provided_producer_name? : Bool, producer_access_mode? : ProducerAccessMode, topic_epoch? : UInt64, txn_enabled? : Bool, initial_subscription_name? : String) -> CommandProducer

    CommandProducer::default

    source

    CommandProducer::equal

    source
    #deprecated("Use `==` instead")
    fn CommandProducer::equal(CommandProducer, CommandProducer) -> Bool

    CommandProducer::from_json

    source

    CommandProducer::not_equal

    source
    #deprecated("Use `!=` instead")
    fn CommandProducer::not_equal(x : CommandProducer, y : CommandProducer) -> Bool

    CommandProducer::read

    source

    CommandProducer::read_with_limit

    source

    CommandProducer::size_of

    source
    fn CommandProducer::size_of(self : CommandProducer) -> UInt

    CommandProducer::to_json

    source
    fn CommandProducer::to_json(self : CommandProducer) -> Json

    CommandProducer::to_repr

    source

    CommandProducer::write

    source
    fn CommandProducer::write(self : CommandProducer, writer : &
    Writer    ) -> Unit raise

    CommandProducerSuccess

    source
    pub(all) struct CommandProducerSuccess {
      request_id : UInt64
      producer_name : String
      last_sequence_id : Int64?
      schema_version : Bytes?
      topic_epoch : UInt64?
      producer_ready : Bool?
    } derive(Eq, 
    Debug    )

    CommandProducerSuccess::CommandProducerSuccess

    source
    #alias(new, deprecated="`new` is deprecated, use `CommandProducerSuccess` instead")
    fn CommandProducerSuccess::CommandProducerSuccess(request_id : UInt64, producer_name : String, last_sequence_id? : Int64, schema_version? : Bytes, topic_epoch? : UInt64, producer_ready? : Bool) -> CommandProducerSuccess

    CommandProducerSuccess::default

    source

    CommandProducerSuccess::equal

    source
    #deprecated("Use `==` instead")
    fn CommandProducerSuccess::equal(CommandProducerSuccess, CommandProducerSuccess) -> Bool

    CommandProducerSuccess::from_json

    source

    CommandProducerSuccess::not_equal

    source
    #deprecated("Use `!=` instead")
    fn CommandProducerSuccess::not_equal(x : CommandProducerSuccess, y : CommandProducerSuccess) -> Bool

    CommandProducerSuccess::read

    source

    CommandProducerSuccess::read_with_limit

    source

    CommandProducerSuccess::size_of

    source

    CommandProducerSuccess::to_json

    source

    CommandProducerSuccess::to_repr

    source

    CommandProducerSuccess::write

    source

    CommandReachedEndOfTopic

    source
    pub(all) struct CommandReachedEndOfTopic {
      consumer_id : UInt64
    } derive(Eq, 
    Debug    )

    CommandReachedEndOfTopic::CommandReachedEndOfTopic

    source
    #alias(new, deprecated="`new` is deprecated, use `CommandReachedEndOfTopic` instead")
    fn CommandReachedEndOfTopic::CommandReachedEndOfTopic(consumer_id : UInt64) -> CommandReachedEndOfTopic

    CommandReachedEndOfTopic::default

    source

    CommandReachedEndOfTopic::equal

    source
    #deprecated("Use `==` instead")
    fn CommandReachedEndOfTopic::equal(CommandReachedEndOfTopic, CommandReachedEndOfTopic) -> Bool

    CommandReachedEndOfTopic::from_json

    source

    CommandReachedEndOfTopic::not_equal

    source
    #deprecated("Use `!=` instead")
    fn CommandReachedEndOfTopic::not_equal(x : CommandReachedEndOfTopic, y : CommandReachedEndOfTopic) -> Bool

    CommandReachedEndOfTopic::read

    source

    CommandReachedEndOfTopic::read_with_limit

    source

    CommandReachedEndOfTopic::size_of

    source

    CommandReachedEndOfTopic::to_json

    source

    CommandReachedEndOfTopic::to_repr

    source

    CommandReachedEndOfTopic::write

    source

    CommandRedeliverUnacknowledgedMessages

    source
    pub(all) struct CommandRedeliverUnacknowledgedMessages {
      consumer_id : UInt64
      message_ids : Array[MessageIdData]
      consumer_epoch : UInt64?
    } derive(Eq, 
    Debug    )

    CommandRedeliverUnacknowledgedMessages::CommandRedeliverUnacknowledgedMessages

    source
    #alias(new, deprecated="`new` is deprecated, use `CommandRedeliverUnacknowledgedMessages` instead")
    fn CommandRedeliverUnacknowledgedMessages::CommandRedeliverUnacknowledgedMessages(consumer_id : UInt64, message_ids : Array[MessageIdData], consumer_epoch? : UInt64) -> CommandRedeliverUnacknowledgedMessages

    CommandRedeliverUnacknowledgedMessages::default

    source

    CommandRedeliverUnacknowledgedMessages::equal

    source

    CommandRedeliverUnacknowledgedMessages::from_json

    source

    CommandRedeliverUnacknowledgedMessages::not_equal

    source

    CommandRedeliverUnacknowledgedMessages::read

    source

    CommandRedeliverUnacknowledgedMessages::read_with_limit

    source

    CommandRedeliverUnacknowledgedMessages::size_of

    source

    CommandRedeliverUnacknowledgedMessages::to_json

    source

    CommandRedeliverUnacknowledgedMessages::to_repr

    source

    CommandRedeliverUnacknowledgedMessages::write

    source

    CommandScalableTopicAssignmentUpdate

    source
    pub(all) struct CommandScalableTopicAssignmentUpdate {
      consumer_id : UInt64
      assignment : ScalableConsumerAssignment
    } derive(Eq, 
    Debug    )

    CommandScalableTopicAssignmentUpdate::CommandScalableTopicAssignmentUpdate

    source
    #alias(new, deprecated="`new` is deprecated, use `CommandScalableTopicAssignmentUpdate` instead")
    fn CommandScalableTopicAssignmentUpdate::CommandScalableTopicAssignmentUpdate(consumer_id : UInt64, assignment : ScalableConsumerAssignment) -> CommandScalableTopicAssignmentUpdate

    CommandScalableTopicAssignmentUpdate::default

    source

    CommandScalableTopicAssignmentUpdate::equal

    source

    CommandScalableTopicAssignmentUpdate::from_json

    source

    CommandScalableTopicAssignmentUpdate::not_equal

    source

    CommandScalableTopicAssignmentUpdate::read

    source

    CommandScalableTopicAssignmentUpdate::read_with_limit

    source

    CommandScalableTopicAssignmentUpdate::size_of

    source

    CommandScalableTopicAssignmentUpdate::to_json

    source

    CommandScalableTopicAssignmentUpdate::to_repr

    source

    CommandScalableTopicAssignmentUpdate::write

    source

    CommandScalableTopicClose

    source
    pub(all) struct CommandScalableTopicClose {
      session_id : UInt64
    } derive(Eq, 
    Debug    )

    CommandScalableTopicClose::CommandScalableTopicClose

    source
    #alias(new, deprecated="`new` is deprecated, use `CommandScalableTopicClose` instead")
    fn CommandScalableTopicClose::CommandScalableTopicClose(session_id : UInt64) -> CommandScalableTopicClose

    CommandScalableTopicClose::default

    source

    CommandScalableTopicClose::equal

    source
    #deprecated("Use `==` instead")
    fn CommandScalableTopicClose::equal(CommandScalableTopicClose, CommandScalableTopicClose) -> Bool

    CommandScalableTopicClose::from_json

    source

    CommandScalableTopicClose::not_equal

    source
    #deprecated("Use `!=` instead")
    fn CommandScalableTopicClose::not_equal(x : CommandScalableTopicClose, y : CommandScalableTopicClose) -> Bool

    CommandScalableTopicClose::read

    source

    CommandScalableTopicClose::read_with_limit

    source

    CommandScalableTopicClose::size_of

    source

    CommandScalableTopicClose::to_json

    source

    CommandScalableTopicClose::to_repr

    source

    CommandScalableTopicClose::write

    source

    CommandScalableTopicLookup

    source
    pub(all) struct CommandScalableTopicLookup {
      session_id : UInt64
      topic : String
      create_if_missing : Bool?
    } derive(Eq, 
    Debug    )

    CommandScalableTopicLookup::CommandScalableTopicLookup

    source
    #alias(new, deprecated="`new` is deprecated, use `CommandScalableTopicLookup` instead")
    fn CommandScalableTopicLookup::CommandScalableTopicLookup(session_id : UInt64, topic : String, create_if_missing? : Bool) -> CommandScalableTopicLookup

    CommandScalableTopicLookup::default

    source

    CommandScalableTopicLookup::equal

    source
    #deprecated("Use `==` instead")
    fn CommandScalableTopicLookup::equal(CommandScalableTopicLookup, CommandScalableTopicLookup) -> Bool

    CommandScalableTopicLookup::from_json

    source

    CommandScalableTopicLookup::not_equal

    source
    #deprecated("Use `!=` instead")
    fn CommandScalableTopicLookup::not_equal(x : CommandScalableTopicLookup, y : CommandScalableTopicLookup) -> Bool

    CommandScalableTopicLookup::read

    source

    CommandScalableTopicLookup::read_with_limit

    source

    CommandScalableTopicLookup::size_of

    source

    CommandScalableTopicLookup::to_json

    source

    CommandScalableTopicLookup::to_repr

    source

    CommandScalableTopicLookup::write

    source

    CommandScalableTopicSubscribe

    source
    pub(all) struct CommandScalableTopicSubscribe {
      request_id : UInt64
      topic : String
      subscription : String
      consumer_name : String
      consumer_id : UInt64
      consumer_type : ScalableConsumerType
    } derive(Eq, 
    Debug    )

    CommandScalableTopicSubscribe::CommandScalableTopicSubscribe

    source
    #alias(new, deprecated="`new` is deprecated, use `CommandScalableTopicSubscribe` instead")
    fn CommandScalableTopicSubscribe::CommandScalableTopicSubscribe(request_id : UInt64, topic : String, subscription : String, consumer_name : String, consumer_id : UInt64, consumer_type : ScalableConsumerType) -> CommandScalableTopicSubscribe

    CommandScalableTopicSubscribe::default

    source

    CommandScalableTopicSubscribe::equal

    source

    CommandScalableTopicSubscribe::from_json

    source

    CommandScalableTopicSubscribe::not_equal

    source
    #deprecated("Use `!=` instead")
    fn CommandScalableTopicSubscribe::not_equal(x : CommandScalableTopicSubscribe, y : CommandScalableTopicSubscribe) -> Bool

    CommandScalableTopicSubscribe::read

    source

    CommandScalableTopicSubscribe::read_with_limit

    source

    CommandScalableTopicSubscribe::size_of

    source

    CommandScalableTopicSubscribe::to_json

    source

    CommandScalableTopicSubscribe::to_repr

    source

    CommandScalableTopicSubscribe::write

    source

    CommandScalableTopicSubscribeResponse

    source
    pub(all) struct CommandScalableTopicSubscribeResponse {
      request_id : UInt64
      error : ServerError?
      message : String?
      assignment : ScalableConsumerAssignment?
    } derive(Eq, 
    Debug    )

    CommandScalableTopicSubscribeResponse::CommandScalableTopicSubscribeResponse

    source
    #alias(new, deprecated="`new` is deprecated, use `CommandScalableTopicSubscribeResponse` instead")
    fn CommandScalableTopicSubscribeResponse::CommandScalableTopicSubscribeResponse(request_id : UInt64, error? : ServerError, message? : String, assignment? : ScalableConsumerAssignment) -> CommandScalableTopicSubscribeResponse

    CommandScalableTopicSubscribeResponse::default

    source

    CommandScalableTopicSubscribeResponse::equal

    source

    CommandScalableTopicSubscribeResponse::from_json

    source

    CommandScalableTopicSubscribeResponse::not_equal

    source

    CommandScalableTopicSubscribeResponse::read

    source

    CommandScalableTopicSubscribeResponse::read_with_limit

    source

    CommandScalableTopicSubscribeResponse::size_of

    source

    CommandScalableTopicSubscribeResponse::to_json

    source

    CommandScalableTopicSubscribeResponse::to_repr

    source

    CommandScalableTopicSubscribeResponse::write

    source

    CommandScalableTopicUnsubscribe

    source
    pub(all) struct CommandScalableTopicUnsubscribe {
      request_id : UInt64
      consumer_id : UInt64
    } derive(Eq, 
    Debug    )

    CommandScalableTopicUnsubscribe::CommandScalableTopicUnsubscribe

    source
    #alias(new, deprecated="`new` is deprecated, use `CommandScalableTopicUnsubscribe` instead")
    fn CommandScalableTopicUnsubscribe::CommandScalableTopicUnsubscribe(request_id : UInt64, consumer_id : UInt64) -> CommandScalableTopicUnsubscribe

    CommandScalableTopicUnsubscribe::default

    source

    CommandScalableTopicUnsubscribe::equal

    source

    CommandScalableTopicUnsubscribe::from_json

    source

    CommandScalableTopicUnsubscribe::not_equal

    source
    #deprecated("Use `!=` instead")
    fn CommandScalableTopicUnsubscribe::not_equal(x : CommandScalableTopicUnsubscribe, y : CommandScalableTopicUnsubscribe) -> Bool

    CommandScalableTopicUnsubscribe::read

    source

    CommandScalableTopicUnsubscribe::read_with_limit

    source

    CommandScalableTopicUnsubscribe::size_of

    source

    CommandScalableTopicUnsubscribe::to_json

    source

    CommandScalableTopicUnsubscribe::to_repr

    source

    CommandScalableTopicUnsubscribe::write

    source

    CommandScalableTopicUpdate

    source
    pub(all) struct CommandScalableTopicUpdate {
      session_id : UInt64
      dag : ScalableTopicDAG?
      error : ServerError?
      message : String?
      resolved_topic_name : String?
    } derive(Eq, 
    Debug    )

    CommandScalableTopicUpdate::CommandScalableTopicUpdate

    source
    #alias(new, deprecated="`new` is deprecated, use `CommandScalableTopicUpdate` instead")
    fn CommandScalableTopicUpdate::CommandScalableTopicUpdate(session_id : UInt64, dag? : ScalableTopicDAG, error? : ServerError, message? : String, resolved_topic_name? : String) -> CommandScalableTopicUpdate

    CommandScalableTopicUpdate::default

    source

    CommandScalableTopicUpdate::equal

    source
    #deprecated("Use `==` instead")
    fn CommandScalableTopicUpdate::equal(CommandScalableTopicUpdate, CommandScalableTopicUpdate) -> Bool

    CommandScalableTopicUpdate::from_json

    source

    CommandScalableTopicUpdate::not_equal

    source
    #deprecated("Use `!=` instead")
    fn CommandScalableTopicUpdate::not_equal(x : CommandScalableTopicUpdate, y : CommandScalableTopicUpdate) -> Bool

    CommandScalableTopicUpdate::read

    source

    CommandScalableTopicUpdate::read_with_limit

    source

    CommandScalableTopicUpdate::size_of

    source

    CommandScalableTopicUpdate::to_json

    source

    CommandScalableTopicUpdate::to_repr

    source

    CommandScalableTopicUpdate::write

    source

    CommandSeek

    source
    pub(all) struct CommandSeek {
      consumer_id : UInt64
      request_id : UInt64
      message_id : MessageIdData?
      message_publish_time : UInt64?
    } derive(Eq, 
    Debug    )

    impl Read for CommandSeek

    CommandSeek::CommandSeek

    source
    #alias(new, deprecated="`new` is deprecated, use `CommandSeek` instead")
    fn CommandSeek::CommandSeek(consumer_id : UInt64, request_id : UInt64, message_id? : MessageIdData, message_publish_time? : UInt64) -> CommandSeek

    CommandSeek::default

    source
    fn CommandSeek::default() -> CommandSeek

    CommandSeek::equal

    source
    #deprecated("Use `==` instead")
    fn CommandSeek::equal(CommandSeek, CommandSeek) -> Bool

    CommandSeek::from_json

    source

    CommandSeek::not_equal

    source
    #deprecated("Use `!=` instead")
    fn CommandSeek::not_equal(x : CommandSeek, y : CommandSeek) -> Bool

    CommandSeek::read

    source

    CommandSeek::read_with_limit

    source

    CommandSeek::size_of

    source
    fn CommandSeek::size_of(self : CommandSeek) -> UInt

    CommandSeek::to_json

    source
    fn CommandSeek::to_json(self : CommandSeek) -> Json

    CommandSeek::to_repr

    source

    CommandSeek::write

    source
    fn CommandSeek::write(self : CommandSeek, writer : &
    Writer    ) -> Unit raise

    CommandSend

    source
    pub(all) struct CommandSend {
      producer_id : UInt64
      sequence_id : UInt64
      num_messages : Int?
      txnid_least_bits : UInt64?
      txnid_most_bits : UInt64?
      highest_sequence_id : UInt64?
      is_chunk : Bool?
      marker : Bool?
      message_id : MessageIdData?
    } derive(Eq, 
    Debug    )

    impl Read for CommandSend

    CommandSend::CommandSend

    source
    #alias(new, deprecated="`new` is deprecated, use `CommandSend` instead")
    fn CommandSend::CommandSend(producer_id : UInt64, sequence_id : UInt64, num_messages? : Int, txnid_least_bits? : UInt64, txnid_most_bits? : UInt64, highest_sequence_id? : UInt64, is_chunk? : Bool, marker? : Bool, message_id? : MessageIdData) -> CommandSend

    CommandSend::default

    source
    fn CommandSend::default() -> CommandSend

    CommandSend::equal

    source
    #deprecated("Use `==` instead")
    fn CommandSend::equal(CommandSend, CommandSend) -> Bool

    CommandSend::from_json

    source

    CommandSend::not_equal

    source
    #deprecated("Use `!=` instead")
    fn CommandSend::not_equal(x : CommandSend, y : CommandSend) -> Bool

    CommandSend::read

    source

    CommandSend::read_with_limit

    source

    CommandSend::size_of

    source
    fn CommandSend::size_of(self : CommandSend) -> UInt

    CommandSend::to_json

    source
    fn CommandSend::to_json(self : CommandSend) -> Json

    CommandSend::to_repr

    source

    CommandSend::write

    source
    fn CommandSend::write(self : CommandSend, writer : &
    Writer    ) -> Unit raise

    CommandSendError

    source
    pub(all) struct CommandSendError {
      producer_id : UInt64
      sequence_id : UInt64
      error : ServerError
      message : String
    } derive(Eq, 
    Debug    )

    CommandSendError::CommandSendError

    source
    #alias(new, deprecated="`new` is deprecated, use `CommandSendError` instead")
    fn CommandSendError::CommandSendError(producer_id : UInt64, sequence_id : UInt64, error : ServerError, message : String) -> CommandSendError

    CommandSendError::default

    source

    CommandSendError::equal

    source
    #deprecated("Use `==` instead")
    fn CommandSendError::equal(CommandSendError, CommandSendError) -> Bool

    CommandSendError::from_json

    source

    CommandSendError::not_equal

    source
    #deprecated("Use `!=` instead")
    fn CommandSendError::not_equal(x : CommandSendError, y : CommandSendError) -> Bool

    CommandSendError::read

    source

    CommandSendError::read_with_limit

    source

    CommandSendError::size_of

    source
    fn CommandSendError::size_of(self : CommandSendError) -> UInt

    CommandSendError::to_json

    source
    fn CommandSendError::to_json(self : CommandSendError) -> Json

    CommandSendError::to_repr

    source

    CommandSendError::write

    source
    fn CommandSendError::write(self : CommandSendError, writer : &
    Writer    ) -> Unit raise

    CommandSendReceipt

    source
    pub(all) struct CommandSendReceipt {
      producer_id : UInt64
      sequence_id : UInt64
      message_id : MessageIdData?
      highest_sequence_id : UInt64?
    } derive(Eq, 
    Debug    )

    CommandSendReceipt::CommandSendReceipt

    source
    #alias(new, deprecated="`new` is deprecated, use `CommandSendReceipt` instead")
    fn CommandSendReceipt::CommandSendReceipt(producer_id : UInt64, sequence_id : UInt64, message_id? : MessageIdData, highest_sequence_id? : UInt64) -> CommandSendReceipt

    CommandSendReceipt::default

    source

    CommandSendReceipt::equal

    source
    #deprecated("Use `==` instead")
    fn CommandSendReceipt::equal(CommandSendReceipt, CommandSendReceipt) -> Bool

    CommandSendReceipt::from_json

    source

    CommandSendReceipt::not_equal

    source
    #deprecated("Use `!=` instead")
    fn CommandSendReceipt::not_equal(x : CommandSendReceipt, y : CommandSendReceipt) -> Bool

    CommandSendReceipt::read

    source

    CommandSendReceipt::read_with_limit

    source

    CommandSendReceipt::size_of

    source
    fn CommandSendReceipt::size_of(self : CommandSendReceipt) -> UInt

    CommandSendReceipt::to_json

    source

    CommandSendReceipt::to_repr

    source

    CommandSendReceipt::write

    source

    CommandSubscribe

    source
    pub(all) struct CommandSubscribe {
      topic : String
      subscription : String
      sub_type : CommandSubscribe_SubType
      consumer_id : UInt64
      request_id : UInt64
      consumer_name : String?
      priority_level : Int?
      durable : Bool?
      start_message_id : MessageIdData?
      metadata : Array[KeyValue]
      read_compacted : Bool?
      schema : Schema?
      initial_position : CommandSubscribe_InitialPosition?
      replicate_subscription_state : Bool?
      force_topic_creation : Bool?
      start_message_rollback_duration_sec : UInt64?
      key_shared_meta : KeySharedMeta?
      subscription_properties : Array[KeyValue]
      consumer_epoch : UInt64?
    } derive(Eq, 
    Debug    )

    CommandSubscribe::CommandSubscribe

    source
    #alias(new, deprecated="`new` is deprecated, use `CommandSubscribe` instead")
    fn CommandSubscribe::CommandSubscribe(topic : String, subscription : String, sub_type : CommandSubscribe_SubType, consumer_id : UInt64, request_id : UInt64, consumer_name? : String, priority_level? : Int, durable? : Bool, start_message_id? : MessageIdData, metadata : Array[KeyValue], read_compacted? : Bool, schema? : Schema, initial_position? : CommandSubscribe_InitialPosition, replicate_subscription_state? : Bool, force_topic_creation? : Bool, start_message_rollback_duration_sec? : UInt64, key_shared_meta? : KeySharedMeta, subscription_properties : Array[KeyValue], consumer_epoch? : UInt64) -> CommandSubscribe

    CommandSubscribe::default

    source

    CommandSubscribe::equal

    source
    #deprecated("Use `==` instead")
    fn CommandSubscribe::equal(CommandSubscribe, CommandSubscribe) -> Bool

    CommandSubscribe::from_json

    source

    CommandSubscribe::not_equal

    source
    #deprecated("Use `!=` instead")
    fn CommandSubscribe::not_equal(x : CommandSubscribe, y : CommandSubscribe) -> Bool

    CommandSubscribe::read

    source

    CommandSubscribe::read_with_limit

    source

    CommandSubscribe::size_of

    source
    fn CommandSubscribe::size_of(self : CommandSubscribe) -> UInt

    CommandSubscribe::to_json

    source
    fn CommandSubscribe::to_json(self : CommandSubscribe) -> Json

    CommandSubscribe::to_repr

    source

    CommandSubscribe::write

    source
    fn CommandSubscribe::write(self : CommandSubscribe, writer : &
    Writer    ) -> Unit raise

    CommandSubscribe_InitialPosition

    source
    pub(all) enum CommandSubscribe_InitialPosition {
      Latest
      Earliest
    } derive(Eq, 
    Debug    )

    CommandSubscribe_InitialPosition::default

    source

    CommandSubscribe_InitialPosition::equal

    source

    CommandSubscribe_InitialPosition::from_enum

    source

    CommandSubscribe_InitialPosition::from_json

    source

    CommandSubscribe_InitialPosition::not_equal

    source
    #deprecated("Use `!=` instead")
    fn CommandSubscribe_InitialPosition::not_equal(x : CommandSubscribe_InitialPosition, y : CommandSubscribe_InitialPosition) -> Bool

    CommandSubscribe_InitialPosition::size_of

    source

    CommandSubscribe_InitialPosition::to_enum

    source

    CommandSubscribe_InitialPosition::to_json

    source

    CommandSubscribe_InitialPosition::to_repr

    source

    CommandSubscribe_SubType

    source
    pub(all) enum CommandSubscribe_SubType {
      Exclusive
      Shared
      Failover
      Key_Shared
    } derive(Eq, 
    Debug    )

    CommandSubscribe_SubType::default

    source

    CommandSubscribe_SubType::equal

    source
    #deprecated("Use `==` instead")
    fn CommandSubscribe_SubType::equal(CommandSubscribe_SubType, CommandSubscribe_SubType) -> Bool

    CommandSubscribe_SubType::from_enum

    source

    CommandSubscribe_SubType::from_json

    source

    CommandSubscribe_SubType::not_equal

    source
    #deprecated("Use `!=` instead")
    fn CommandSubscribe_SubType::not_equal(x : CommandSubscribe_SubType, y : CommandSubscribe_SubType) -> Bool

    CommandSubscribe_SubType::size_of

    source

    CommandSubscribe_SubType::to_enum

    source

    CommandSubscribe_SubType::to_json

    source

    CommandSubscribe_SubType::to_repr

    source

    CommandSuccess

    source
    pub(all) struct CommandSuccess {
      request_id : UInt64
      schema : Schema?
    } derive(Eq, 
    Debug    )

    CommandSuccess::CommandSuccess

    source
    #alias(new, deprecated="`new` is deprecated, use `CommandSuccess` instead")
    fn CommandSuccess::CommandSuccess(request_id : UInt64, schema? : Schema) -> CommandSuccess

    CommandSuccess::default

    source

    CommandSuccess::equal

    source
    #deprecated("Use `==` instead")
    fn CommandSuccess::equal(CommandSuccess, CommandSuccess) -> Bool

    CommandSuccess::from_json

    source

    CommandSuccess::not_equal

    source
    #deprecated("Use `!=` instead")
    fn CommandSuccess::not_equal(x : CommandSuccess, y : CommandSuccess) -> Bool

    CommandSuccess::read

    source

    CommandSuccess::read_with_limit

    source

    CommandSuccess::size_of

    source
    fn CommandSuccess::size_of(self : CommandSuccess) -> UInt

    CommandSuccess::to_json

    source
    fn CommandSuccess::to_json(self : CommandSuccess) -> Json

    CommandSuccess::to_repr

    source

    CommandSuccess::write

    source
    fn CommandSuccess::write(self : CommandSuccess, writer : &
    Writer    ) -> Unit raise

    CommandTcClientConnectRequest

    source
    pub(all) struct CommandTcClientConnectRequest {
      request_id : UInt64
      tc_id : UInt64
      scalable : Bool?
    } derive(Eq, 
    Debug    )

    CommandTcClientConnectRequest::CommandTcClientConnectRequest

    source
    #alias(new, deprecated="`new` is deprecated, use `CommandTcClientConnectRequest` instead")
    fn CommandTcClientConnectRequest::CommandTcClientConnectRequest(request_id : UInt64, tc_id : UInt64, scalable? : Bool) -> CommandTcClientConnectRequest

    CommandTcClientConnectRequest::default

    source

    CommandTcClientConnectRequest::equal

    source

    CommandTcClientConnectRequest::from_json

    source

    CommandTcClientConnectRequest::not_equal

    source
    #deprecated("Use `!=` instead")
    fn CommandTcClientConnectRequest::not_equal(x : CommandTcClientConnectRequest, y : CommandTcClientConnectRequest) -> Bool

    CommandTcClientConnectRequest::read

    source

    CommandTcClientConnectRequest::read_with_limit

    source

    CommandTcClientConnectRequest::size_of

    source

    CommandTcClientConnectRequest::to_json

    source

    CommandTcClientConnectRequest::to_repr

    source

    CommandTcClientConnectRequest::write

    source

    CommandTcClientConnectResponse

    source
    pub(all) struct CommandTcClientConnectResponse {
      request_id : UInt64
      error : ServerError?
      message : String?
    } derive(Eq, 
    Debug    )

    CommandTcClientConnectResponse::CommandTcClientConnectResponse

    source
    #alias(new, deprecated="`new` is deprecated, use `CommandTcClientConnectResponse` instead")
    fn CommandTcClientConnectResponse::CommandTcClientConnectResponse(request_id : UInt64, error? : ServerError, message? : String) -> CommandTcClientConnectResponse

    CommandTcClientConnectResponse::default

    source

    CommandTcClientConnectResponse::equal

    source

    CommandTcClientConnectResponse::from_json

    source

    CommandTcClientConnectResponse::not_equal

    source
    #deprecated("Use `!=` instead")
    fn CommandTcClientConnectResponse::not_equal(x : CommandTcClientConnectResponse, y : CommandTcClientConnectResponse) -> Bool

    CommandTcClientConnectResponse::read

    source

    CommandTcClientConnectResponse::read_with_limit

    source

    CommandTcClientConnectResponse::size_of

    source

    CommandTcClientConnectResponse::to_json

    source

    CommandTcClientConnectResponse::to_repr

    source

    CommandTcClientConnectResponse::write

    source

    CommandTopicMigrated

    source
    pub(all) struct CommandTopicMigrated {
      resource_id : UInt64
      resource_type : CommandTopicMigrated_ResourceType
      broker_service_url : String?
      broker_service_url_tls : String?
    } derive(Eq, 
    Debug    )

    CommandTopicMigrated::CommandTopicMigrated

    source
    #alias(new, deprecated="`new` is deprecated, use `CommandTopicMigrated` instead")
    fn CommandTopicMigrated::CommandTopicMigrated(resource_id : UInt64, resource_type : CommandTopicMigrated_ResourceType, broker_service_url? : String, broker_service_url_tls? : String) -> CommandTopicMigrated

    CommandTopicMigrated::default

    source

    CommandTopicMigrated::equal

    source
    #deprecated("Use `==` instead")
    fn CommandTopicMigrated::equal(CommandTopicMigrated, CommandTopicMigrated) -> Bool

    CommandTopicMigrated::from_json

    source

    CommandTopicMigrated::not_equal

    source
    #deprecated("Use `!=` instead")
    fn CommandTopicMigrated::not_equal(x : CommandTopicMigrated, y : CommandTopicMigrated) -> Bool

    CommandTopicMigrated::read

    source

    CommandTopicMigrated::read_with_limit

    source

    CommandTopicMigrated::size_of

    source
    fn CommandTopicMigrated::size_of(self : CommandTopicMigrated) -> UInt

    CommandTopicMigrated::to_json

    source

    CommandTopicMigrated::to_repr

    source

    CommandTopicMigrated::write

    source

    CommandTopicMigrated_ResourceType

    source
    pub(all) enum CommandTopicMigrated_ResourceType {
      Producer
      Consumer
    } derive(Eq, 
    Debug    )

    CommandTopicMigrated_ResourceType::default

    source

    CommandTopicMigrated_ResourceType::equal

    source

    CommandTopicMigrated_ResourceType::from_enum

    source

    CommandTopicMigrated_ResourceType::from_json

    source

    CommandTopicMigrated_ResourceType::not_equal

    source

    CommandTopicMigrated_ResourceType::size_of

    source

    CommandTopicMigrated_ResourceType::to_enum

    source

    CommandTopicMigrated_ResourceType::to_json

    source

    CommandTopicMigrated_ResourceType::to_repr

    source

    CommandUnsubscribe

    source
    pub(all) struct CommandUnsubscribe {
      consumer_id : UInt64
      request_id : UInt64
      force : Bool?
    } derive(Eq, 
    Debug    )

    CommandUnsubscribe::CommandUnsubscribe

    source
    #alias(new, deprecated="`new` is deprecated, use `CommandUnsubscribe` instead")
    fn CommandUnsubscribe::CommandUnsubscribe(consumer_id : UInt64, request_id : UInt64, force? : Bool) -> CommandUnsubscribe

    CommandUnsubscribe::default

    source

    CommandUnsubscribe::equal

    source
    #deprecated("Use `==` instead")
    fn CommandUnsubscribe::equal(CommandUnsubscribe, CommandUnsubscribe) -> Bool

    CommandUnsubscribe::from_json

    source

    CommandUnsubscribe::not_equal

    source
    #deprecated("Use `!=` instead")
    fn CommandUnsubscribe::not_equal(x : CommandUnsubscribe, y : CommandUnsubscribe) -> Bool

    CommandUnsubscribe::read

    source

    CommandUnsubscribe::read_with_limit

    source

    CommandUnsubscribe::size_of

    source
    fn CommandUnsubscribe::size_of(self : CommandUnsubscribe) -> UInt

    CommandUnsubscribe::to_json

    source

    CommandUnsubscribe::to_repr

    source

    CommandUnsubscribe::write

    source

    CommandWatchScalableTopics

    source
    pub(all) struct CommandWatchScalableTopics {
      watch_id : UInt64
      namespace_ : String
      property_filters : Array[KeyValue]
      current_hash : String?
    } derive(Eq, 
    Debug    )

    CommandWatchScalableTopics::CommandWatchScalableTopics

    source
    #alias(new, deprecated="`new` is deprecated, use `CommandWatchScalableTopics` instead")
    fn CommandWatchScalableTopics::CommandWatchScalableTopics(watch_id : UInt64, namespace_ : String, property_filters : Array[KeyValue], current_hash? : String) -> CommandWatchScalableTopics

    CommandWatchScalableTopics::default

    source

    CommandWatchScalableTopics::equal

    source
    #deprecated("Use `==` instead")
    fn CommandWatchScalableTopics::equal(CommandWatchScalableTopics, CommandWatchScalableTopics) -> Bool

    CommandWatchScalableTopics::from_json

    source

    CommandWatchScalableTopics::not_equal

    source
    #deprecated("Use `!=` instead")
    fn CommandWatchScalableTopics::not_equal(x : CommandWatchScalableTopics, y : CommandWatchScalableTopics) -> Bool

    CommandWatchScalableTopics::read

    source

    CommandWatchScalableTopics::read_with_limit

    source

    CommandWatchScalableTopics::size_of

    source

    CommandWatchScalableTopics::to_json

    source

    CommandWatchScalableTopics::to_repr

    source

    CommandWatchScalableTopics::write

    source

    CommandWatchScalableTopicsClose

    source
    pub(all) struct CommandWatchScalableTopicsClose {
      watch_id : UInt64
    } derive(Eq, 
    Debug    )

    CommandWatchScalableTopicsClose::CommandWatchScalableTopicsClose

    source
    #alias(new, deprecated="`new` is deprecated, use `CommandWatchScalableTopicsClose` instead")
    fn CommandWatchScalableTopicsClose::CommandWatchScalableTopicsClose(watch_id : UInt64) -> CommandWatchScalableTopicsClose

    CommandWatchScalableTopicsClose::default

    source

    CommandWatchScalableTopicsClose::equal

    source

    CommandWatchScalableTopicsClose::from_json

    source

    CommandWatchScalableTopicsClose::not_equal

    source
    #deprecated("Use `!=` instead")
    fn CommandWatchScalableTopicsClose::not_equal(x : CommandWatchScalableTopicsClose, y : CommandWatchScalableTopicsClose) -> Bool

    CommandWatchScalableTopicsClose::read

    source

    CommandWatchScalableTopicsClose::read_with_limit

    source

    CommandWatchScalableTopicsClose::size_of

    source

    CommandWatchScalableTopicsClose::to_json

    source

    CommandWatchScalableTopicsClose::to_repr

    source

    CommandWatchScalableTopicsClose::write

    source

    CommandWatchScalableTopicsUpdate

    source
    pub(all) struct CommandWatchScalableTopicsUpdate {
      watch_id : UInt64
      error : ServerError?
      message : String?
      event : CommandWatchScalableTopicsUpdate_Event
    } derive(Eq, 
    Debug    )

    CommandWatchScalableTopicsUpdate::CommandWatchScalableTopicsUpdate

    source
    #alias(new, deprecated="`new` is deprecated, use `CommandWatchScalableTopicsUpdate` instead")
    fn CommandWatchScalableTopicsUpdate::CommandWatchScalableTopicsUpdate(watch_id : UInt64, error? : ServerError, message? : String, event? : CommandWatchScalableTopicsUpdate_Event) -> CommandWatchScalableTopicsUpdate

    CommandWatchScalableTopicsUpdate::default

    source

    CommandWatchScalableTopicsUpdate::equal

    source

    CommandWatchScalableTopicsUpdate::from_json

    source

    CommandWatchScalableTopicsUpdate::not_equal

    source
    #deprecated("Use `!=` instead")
    fn CommandWatchScalableTopicsUpdate::not_equal(x : CommandWatchScalableTopicsUpdate, y : CommandWatchScalableTopicsUpdate) -> Bool

    CommandWatchScalableTopicsUpdate::read

    source

    CommandWatchScalableTopicsUpdate::read_with_limit

    source

    CommandWatchScalableTopicsUpdate::size_of

    source

    CommandWatchScalableTopicsUpdate::to_json

    source

    CommandWatchScalableTopicsUpdate::to_repr

    source

    CommandWatchScalableTopicsUpdate::write

    source

    CommandWatchScalableTopicsUpdate_Event

    source
    pub(all) enum CommandWatchScalableTopicsUpdate_Event {
      Snapshot(ScalableTopicsSnapshot)
      Diff(ScalableTopicsDiff)
      NotSet
    } derive(Eq, 
    Debug    )

    CommandWatchScalableTopicsUpdate_Event::default

    source

    CommandWatchScalableTopicsUpdate_Event::equal

    source

    CommandWatchScalableTopicsUpdate_Event::from_json

    source

    CommandWatchScalableTopicsUpdate_Event::not_equal

    source

    CommandWatchScalableTopicsUpdate_Event::to_json

    source

    CommandWatchScalableTopicsUpdate_Event::to_repr

    source

    CommandWatchTcAssignments

    source
    pub(all) struct CommandWatchTcAssignments {
      watch_id : UInt64
    } derive(Eq, 
    Debug    )

    CommandWatchTcAssignments::CommandWatchTcAssignments

    source
    #alias(new, deprecated="`new` is deprecated, use `CommandWatchTcAssignments` instead")
    fn CommandWatchTcAssignments::CommandWatchTcAssignments(watch_id : UInt64) -> CommandWatchTcAssignments

    CommandWatchTcAssignments::default

    source

    CommandWatchTcAssignments::equal

    source
    #deprecated("Use `==` instead")
    fn CommandWatchTcAssignments::equal(CommandWatchTcAssignments, CommandWatchTcAssignments) -> Bool

    CommandWatchTcAssignments::from_json

    source

    CommandWatchTcAssignments::not_equal

    source
    #deprecated("Use `!=` instead")
    fn CommandWatchTcAssignments::not_equal(x : CommandWatchTcAssignments, y : CommandWatchTcAssignments) -> Bool

    CommandWatchTcAssignments::read

    source

    CommandWatchTcAssignments::read_with_limit

    source

    CommandWatchTcAssignments::size_of

    source

    CommandWatchTcAssignments::to_json

    source

    CommandWatchTcAssignments::to_repr

    source

    CommandWatchTcAssignments::write

    source

    CommandWatchTcAssignmentsClose

    source
    pub(all) struct CommandWatchTcAssignmentsClose {
      watch_id : UInt64
    } derive(Eq, 
    Debug    )

    CommandWatchTcAssignmentsClose::CommandWatchTcAssignmentsClose

    source
    #alias(new, deprecated="`new` is deprecated, use `CommandWatchTcAssignmentsClose` instead")
    fn CommandWatchTcAssignmentsClose::CommandWatchTcAssignmentsClose(watch_id : UInt64) -> CommandWatchTcAssignmentsClose

    CommandWatchTcAssignmentsClose::default

    source

    CommandWatchTcAssignmentsClose::equal

    source

    CommandWatchTcAssignmentsClose::from_json

    source

    CommandWatchTcAssignmentsClose::not_equal

    source
    #deprecated("Use `!=` instead")
    fn CommandWatchTcAssignmentsClose::not_equal(x : CommandWatchTcAssignmentsClose, y : CommandWatchTcAssignmentsClose) -> Bool

    CommandWatchTcAssignmentsClose::read

    source

    CommandWatchTcAssignmentsClose::read_with_limit

    source

    CommandWatchTcAssignmentsClose::size_of

    source

    CommandWatchTcAssignmentsClose::to_json

    source

    CommandWatchTcAssignmentsClose::to_repr

    source

    CommandWatchTcAssignmentsClose::write

    source

    CommandWatchTcAssignmentsUpdate

    source
    pub(all) struct CommandWatchTcAssignmentsUpdate {
      watch_id : UInt64
      snapshot : TcAssignmentsSnapshot?
      error : ServerError?
      message : String?
    } derive(Eq, 
    Debug    )

    CommandWatchTcAssignmentsUpdate::CommandWatchTcAssignmentsUpdate

    source
    #alias(new, deprecated="`new` is deprecated, use `CommandWatchTcAssignmentsUpdate` instead")
    fn CommandWatchTcAssignmentsUpdate::CommandWatchTcAssignmentsUpdate(watch_id : UInt64, snapshot? : TcAssignmentsSnapshot, error? : ServerError, message? : String) -> CommandWatchTcAssignmentsUpdate

    CommandWatchTcAssignmentsUpdate::default

    source

    CommandWatchTcAssignmentsUpdate::equal

    source

    CommandWatchTcAssignmentsUpdate::from_json

    source

    CommandWatchTcAssignmentsUpdate::not_equal

    source
    #deprecated("Use `!=` instead")
    fn CommandWatchTcAssignmentsUpdate::not_equal(x : CommandWatchTcAssignmentsUpdate, y : CommandWatchTcAssignmentsUpdate) -> Bool

    CommandWatchTcAssignmentsUpdate::read

    source

    CommandWatchTcAssignmentsUpdate::read_with_limit

    source

    CommandWatchTcAssignmentsUpdate::size_of

    source

    CommandWatchTcAssignmentsUpdate::to_json

    source

    CommandWatchTcAssignmentsUpdate::to_repr

    source

    CommandWatchTcAssignmentsUpdate::write

    source

    CommandWatchTopicList

    source
    pub(all) struct CommandWatchTopicList {
      request_id : UInt64
      watcher_id : UInt64
      namespace_ : String
      topics_pattern : String
      topics_hash : String?
    } derive(Eq, 
    Debug    )

    CommandWatchTopicList::CommandWatchTopicList

    source
    #alias(new, deprecated="`new` is deprecated, use `CommandWatchTopicList` instead")
    fn CommandWatchTopicList::CommandWatchTopicList(request_id : UInt64, watcher_id : UInt64, namespace_ : String, topics_pattern : String, topics_hash? : String) -> CommandWatchTopicList

    CommandWatchTopicList::default

    source

    CommandWatchTopicList::equal

    source
    #deprecated("Use `==` instead")
    fn CommandWatchTopicList::equal(CommandWatchTopicList, CommandWatchTopicList) -> Bool

    CommandWatchTopicList::from_json

    source

    CommandWatchTopicList::not_equal

    source
    #deprecated("Use `!=` instead")
    fn CommandWatchTopicList::not_equal(x : CommandWatchTopicList, y : CommandWatchTopicList) -> Bool

    CommandWatchTopicList::read

    source

    CommandWatchTopicList::read_with_limit

    source

    CommandWatchTopicList::size_of

    source
    fn CommandWatchTopicList::size_of(self : CommandWatchTopicList) -> UInt

    CommandWatchTopicList::to_json

    source

    CommandWatchTopicList::to_repr

    source

    CommandWatchTopicList::write

    source

    CommandWatchTopicListClose

    source
    pub(all) struct CommandWatchTopicListClose {
      request_id : UInt64
      watcher_id : UInt64
    } derive(Eq, 
    Debug    )

    CommandWatchTopicListClose::CommandWatchTopicListClose

    source
    #alias(new, deprecated="`new` is deprecated, use `CommandWatchTopicListClose` instead")
    fn CommandWatchTopicListClose::CommandWatchTopicListClose(request_id : UInt64, watcher_id : UInt64) -> CommandWatchTopicListClose

    CommandWatchTopicListClose::default

    source

    CommandWatchTopicListClose::equal

    source
    #deprecated("Use `==` instead")
    fn CommandWatchTopicListClose::equal(CommandWatchTopicListClose, CommandWatchTopicListClose) -> Bool

    CommandWatchTopicListClose::from_json

    source

    CommandWatchTopicListClose::not_equal

    source
    #deprecated("Use `!=` instead")
    fn CommandWatchTopicListClose::not_equal(x : CommandWatchTopicListClose, y : CommandWatchTopicListClose) -> Bool

    CommandWatchTopicListClose::read

    source

    CommandWatchTopicListClose::read_with_limit

    source

    CommandWatchTopicListClose::size_of

    source

    CommandWatchTopicListClose::to_json

    source

    CommandWatchTopicListClose::to_repr

    source

    CommandWatchTopicListClose::write

    source

    CommandWatchTopicListSuccess

    source
    pub(all) struct CommandWatchTopicListSuccess {
      request_id : UInt64
      watcher_id : UInt64
      topic : Array[String]
      topics_hash : String
    } derive(Eq, 
    Debug    )

    CommandWatchTopicListSuccess::CommandWatchTopicListSuccess

    source
    #alias(new, deprecated="`new` is deprecated, use `CommandWatchTopicListSuccess` instead")
    fn CommandWatchTopicListSuccess::CommandWatchTopicListSuccess(request_id : UInt64, watcher_id : UInt64, topic : Array[String], topics_hash : String) -> CommandWatchTopicListSuccess

    CommandWatchTopicListSuccess::default

    source

    CommandWatchTopicListSuccess::equal

    source

    CommandWatchTopicListSuccess::from_json

    source

    CommandWatchTopicListSuccess::not_equal

    source
    #deprecated("Use `!=` instead")
    fn CommandWatchTopicListSuccess::not_equal(x : CommandWatchTopicListSuccess, y : CommandWatchTopicListSuccess) -> Bool

    CommandWatchTopicListSuccess::read

    source

    CommandWatchTopicListSuccess::read_with_limit

    source

    CommandWatchTopicListSuccess::size_of

    source

    CommandWatchTopicListSuccess::to_json

    source

    CommandWatchTopicListSuccess::to_repr

    source

    CommandWatchTopicListSuccess::write

    source

    CommandWatchTopicUpdate

    source
    pub(all) struct CommandWatchTopicUpdate {
      watcher_id : UInt64
      new_topics : Array[String]
      deleted_topics : Array[String]
      topics_hash : String
    } derive(Eq, 
    Debug    )

    CommandWatchTopicUpdate::CommandWatchTopicUpdate

    source
    #alias(new, deprecated="`new` is deprecated, use `CommandWatchTopicUpdate` instead")
    fn CommandWatchTopicUpdate::CommandWatchTopicUpdate(watcher_id : UInt64, new_topics : Array[String], deleted_topics : Array[String], topics_hash : String) -> CommandWatchTopicUpdate

    CommandWatchTopicUpdate::default

    source

    CommandWatchTopicUpdate::equal

    source
    #deprecated("Use `==` instead")
    fn CommandWatchTopicUpdate::equal(CommandWatchTopicUpdate, CommandWatchTopicUpdate) -> Bool

    CommandWatchTopicUpdate::from_json

    source

    CommandWatchTopicUpdate::not_equal

    source
    #deprecated("Use `!=` instead")
    fn CommandWatchTopicUpdate::not_equal(x : CommandWatchTopicUpdate, y : CommandWatchTopicUpdate) -> Bool

    CommandWatchTopicUpdate::read

    source

    CommandWatchTopicUpdate::read_with_limit

    source

    CommandWatchTopicUpdate::size_of

    source

    CommandWatchTopicUpdate::to_json

    source

    CommandWatchTopicUpdate::to_repr

    source

    CommandWatchTopicUpdate::write

    source

    CompressionType

    source
    pub(all) enum CompressionType {
      NONE
      LZ4
      ZLIB
      ZSTD
      SNAPPY
    } derive(Eq, 
    Debug    )

    CompressionType::default

    source

    CompressionType::equal

    source
    #deprecated("Use `==` instead")
    fn CompressionType::equal(CompressionType, CompressionType) -> Bool

    CompressionType::from_enum

    source

    CompressionType::from_json

    source

    CompressionType::not_equal

    source
    #deprecated("Use `!=` instead")
    fn CompressionType::not_equal(x : CompressionType, y : CompressionType) -> Bool

    CompressionType::size_of

    source
    fn CompressionType::size_of(self : CompressionType) -> UInt

    CompressionType::to_enum

    source

    CompressionType::to_json

    source
    fn CompressionType::to_json(self : CompressionType) -> Json

    CompressionType::to_repr

    source

    EncryptionKeys

    source
    pub(all) struct EncryptionKeys {
      key : String
      value : Bytes
      metadata : Array[KeyValue]
    } derive(Eq, 
    Debug    )

    EncryptionKeys::EncryptionKeys

    source
    #alias(new, deprecated="`new` is deprecated, use `EncryptionKeys` instead")
    fn EncryptionKeys::EncryptionKeys(key : String, value : Bytes, metadata : Array[KeyValue]) -> EncryptionKeys

    EncryptionKeys::default

    source

    EncryptionKeys::equal

    source
    #deprecated("Use `==` instead")
    fn EncryptionKeys::equal(EncryptionKeys, EncryptionKeys) -> Bool

    EncryptionKeys::from_json

    source

    EncryptionKeys::not_equal

    source
    #deprecated("Use `!=` instead")
    fn EncryptionKeys::not_equal(x : EncryptionKeys, y : EncryptionKeys) -> Bool

    EncryptionKeys::read

    source

    EncryptionKeys::read_with_limit

    source

    EncryptionKeys::size_of

    source
    fn EncryptionKeys::size_of(self : EncryptionKeys) -> UInt

    EncryptionKeys::to_json

    source
    fn EncryptionKeys::to_json(self : EncryptionKeys) -> Json

    EncryptionKeys::to_repr

    source

    EncryptionKeys::write

    source
    fn EncryptionKeys::write(self : EncryptionKeys, writer : &
    Writer    ) -> Unit raise

    FeatureFlags

    source
    pub(all) struct FeatureFlags {
      supports_auth_refresh : Bool?
      supports_broker_entry_metadata : Bool?
      supports_partial_producer : Bool?
      supports_topic_watchers : Bool?
      supports_get_partitioned_metadata_without_auto_creation : Bool?
      supports_repl_dedup_by_lid_and_eid : Bool?
      supports_topic_watcher_reconcile : Bool?
      supports_scalable_topics : Bool?
      supports_tc_metadata_discovery : Bool?
    } derive(Eq, 
    Debug    )

    FeatureFlags::FeatureFlags

    source
    #alias(new, deprecated="`new` is deprecated, use `FeatureFlags` instead")
    fn FeatureFlags::FeatureFlags(supports_auth_refresh? : Bool, supports_broker_entry_metadata? : Bool, supports_partial_producer? : Bool, supports_topic_watchers? : Bool, supports_get_partitioned_metadata_without_auto_creation? : Bool, supports_repl_dedup_by_lid_and_eid? : Bool, supports_topic_watcher_reconcile? : Bool, supports_scalable_topics? : Bool, supports_tc_metadata_discovery? : Bool) -> FeatureFlags

    FeatureFlags::default

    source
    fn FeatureFlags::default() -> FeatureFlags

    FeatureFlags::equal

    source
    #deprecated("Use `==` instead")
    fn FeatureFlags::equal(FeatureFlags, FeatureFlags) -> Bool

    FeatureFlags::from_json

    source

    FeatureFlags::not_equal

    source
    #deprecated("Use `!=` instead")
    fn FeatureFlags::not_equal(x : FeatureFlags, y : FeatureFlags) -> Bool

    FeatureFlags::read

    source

    FeatureFlags::read_with_limit

    source

    FeatureFlags::size_of

    source
    fn FeatureFlags::size_of(self : FeatureFlags) -> UInt

    FeatureFlags::to_json

    source
    fn FeatureFlags::to_json(self : FeatureFlags) -> Json

    FeatureFlags::to_repr

    source

    FeatureFlags::write

    source
    fn FeatureFlags::write(self : FeatureFlags, writer : &
    Writer    ) -> Unit raise

    IntRange

    source
    pub(all) struct IntRange {
      start : Int
      end : Int
    } derive(Eq, 
    Debug    )

    impl Default for IntRange
    impl ToJson for IntRange
    impl Read for IntRange
    impl Sized for IntRange
    impl Write for IntRange

    IntRange::IntRange

    source
    #alias(new, deprecated="`new` is deprecated, use `IntRange` instead")
    fn IntRange::IntRange(start : Int, end : Int) -> IntRange

    IntRange::default

    source
    fn IntRange::default() -> IntRange

    IntRange::equal

    source
    #deprecated("Use `==` instead")
    fn IntRange::equal(IntRange, IntRange) -> Bool

    IntRange::from_json

    source

    IntRange::not_equal

    source
    #deprecated("Use `!=` instead")
    fn IntRange::not_equal(x : IntRange, y : IntRange) -> Bool

    IntRange::read

    source

    IntRange::read_with_limit

    source

    IntRange::size_of

    source
    fn IntRange::size_of(self : IntRange) -> UInt

    IntRange::to_json

    source
    fn IntRange::to_json(self : IntRange) -> Json

    IntRange::to_repr

    source

    IntRange::write

    source
    fn IntRange::write(self : IntRange, writer : &
    Writer    ) -> Unit raise

    KeyLongValue

    source
    pub(all) struct KeyLongValue {
      key : String
      value : UInt64
    } derive(Eq, 
    Debug    )

    KeyLongValue::KeyLongValue

    source
    #alias(new, deprecated="`new` is deprecated, use `KeyLongValue` instead")
    fn KeyLongValue::KeyLongValue(key : String, value : UInt64) -> KeyLongValue

    KeyLongValue::default

    source
    fn KeyLongValue::default() -> KeyLongValue

    KeyLongValue::equal

    source
    #deprecated("Use `==` instead")
    fn KeyLongValue::equal(KeyLongValue, KeyLongValue) -> Bool

    KeyLongValue::from_json

    source

    KeyLongValue::not_equal

    source
    #deprecated("Use `!=` instead")
    fn KeyLongValue::not_equal(x : KeyLongValue, y : KeyLongValue) -> Bool

    KeyLongValue::read

    source

    KeyLongValue::read_with_limit

    source

    KeyLongValue::size_of

    source
    fn KeyLongValue::size_of(self : KeyLongValue) -> UInt

    KeyLongValue::to_json

    source
    fn KeyLongValue::to_json(self : KeyLongValue) -> Json

    KeyLongValue::to_repr

    source

    KeyLongValue::write

    source
    fn KeyLongValue::write(self : KeyLongValue, writer : &
    Writer    ) -> Unit raise

    KeySharedMeta

    source
    pub(all) struct KeySharedMeta {
      key_shared_mode : KeySharedMode
      hash_ranges : Array[IntRange]
      allow_out_of_order_delivery : Bool?
      entry_bucket_dispatch : Bool?
    } derive(Eq, 
    Debug    )

    KeySharedMeta::KeySharedMeta

    source
    #alias(new, deprecated="`new` is deprecated, use `KeySharedMeta` instead")
    fn KeySharedMeta::KeySharedMeta(key_shared_mode : KeySharedMode, hash_ranges : Array[IntRange], allow_out_of_order_delivery? : Bool, entry_bucket_dispatch? : Bool) -> KeySharedMeta

    KeySharedMeta::default

    source
    fn KeySharedMeta::default() -> KeySharedMeta

    KeySharedMeta::equal

    source
    #deprecated("Use `==` instead")
    fn KeySharedMeta::equal(KeySharedMeta, KeySharedMeta) -> Bool

    KeySharedMeta::from_json

    source

    KeySharedMeta::not_equal

    source
    #deprecated("Use `!=` instead")
    fn KeySharedMeta::not_equal(x : KeySharedMeta, y : KeySharedMeta) -> Bool

    KeySharedMeta::read

    source

    KeySharedMeta::read_with_limit

    source

    KeySharedMeta::size_of

    source
    fn KeySharedMeta::size_of(self : KeySharedMeta) -> UInt

    KeySharedMeta::to_json

    source
    fn KeySharedMeta::to_json(self : KeySharedMeta) -> Json

    KeySharedMeta::to_repr

    source

    KeySharedMeta::write

    source
    fn KeySharedMeta::write(self : KeySharedMeta, writer : &
    Writer    ) -> Unit raise

    KeySharedMode

    source
    pub(all) enum KeySharedMode {
      AUTO_SPLIT
      STICKY
    } derive(Eq, 
    Debug    )

    KeySharedMode::default

    source
    fn KeySharedMode::default() -> KeySharedMode

    KeySharedMode::equal

    source
    #deprecated("Use `==` instead")
    fn KeySharedMode::equal(KeySharedMode, KeySharedMode) -> Bool

    KeySharedMode::from_enum

    source

    KeySharedMode::from_json

    source

    KeySharedMode::not_equal

    source
    #deprecated("Use `!=` instead")
    fn KeySharedMode::not_equal(x : KeySharedMode, y : KeySharedMode) -> Bool

    KeySharedMode::size_of

    source
    fn KeySharedMode::size_of(self : KeySharedMode) -> UInt

    KeySharedMode::to_enum

    source

    KeySharedMode::to_json

    source
    fn KeySharedMode::to_json(self : KeySharedMode) -> Json

    KeySharedMode::to_repr

    source

    KeyValue

    source
    pub(all) struct KeyValue {
      key : String
      value : String
    } derive(Eq, 
    Debug    )

    impl Default for KeyValue
    impl ToJson for KeyValue
    impl Read for KeyValue
    impl Sized for KeyValue
    impl Write for KeyValue

    KeyValue::KeyValue

    source
    #alias(new, deprecated="`new` is deprecated, use `KeyValue` instead")
    fn KeyValue::KeyValue(key : String, value : String) -> KeyValue

    KeyValue::default

    source
    fn KeyValue::default() -> KeyValue

    KeyValue::equal

    source
    #deprecated("Use `==` instead")
    fn KeyValue::equal(KeyValue, KeyValue) -> Bool

    KeyValue::from_json

    source

    KeyValue::not_equal

    source
    #deprecated("Use `!=` instead")
    fn KeyValue::not_equal(x : KeyValue, y : KeyValue) -> Bool

    KeyValue::read

    source

    KeyValue::read_with_limit

    source

    KeyValue::size_of

    source
    fn KeyValue::size_of(self : KeyValue) -> UInt

    KeyValue::to_json

    source
    fn KeyValue::to_json(self : KeyValue) -> Json

    KeyValue::to_repr

    source

    KeyValue::write

    source
    fn KeyValue::write(self : KeyValue, writer : &
    Writer    ) -> Unit raise

    MessageIdData

    source
    pub(all) struct MessageIdData {
      ledger_id : UInt64
      entry_id : UInt64
      partition : Int?
      batch_index : Int?
      ack_set : Array[Int64]
      batch_size : Int?
      first_chunk_message_id : MessageIdData?
    } derive(Eq, 
    Debug    )

    MessageIdData::MessageIdData

    source
    #alias(new, deprecated="`new` is deprecated, use `MessageIdData` instead")
    fn MessageIdData::MessageIdData(ledger_id : UInt64, entry_id : UInt64, partition? : Int, batch_index? : Int, ack_set : Array[Int64], batch_size? : Int, first_chunk_message_id? : MessageIdData) -> MessageIdData

    MessageIdData::default

    source
    fn MessageIdData::default() -> MessageIdData

    MessageIdData::equal

    source
    #deprecated("Use `==` instead")
    fn MessageIdData::equal(MessageIdData, MessageIdData) -> Bool

    MessageIdData::from_json

    source

    MessageIdData::not_equal

    source
    #deprecated("Use `!=` instead")
    fn MessageIdData::not_equal(x : MessageIdData, y : MessageIdData) -> Bool

    MessageIdData::read

    source

    MessageIdData::read_with_limit

    source

    MessageIdData::size_of

    source
    fn MessageIdData::size_of(self : MessageIdData) -> UInt

    MessageIdData::to_json

    source
    fn MessageIdData::to_json(self : MessageIdData) -> Json

    MessageIdData::to_repr

    source

    MessageIdData::write

    source
    fn MessageIdData::write(self : MessageIdData, writer : &
    Writer    ) -> Unit raise

    MessageMetadata

    source
    pub(all) struct MessageMetadata {
      producer_name : String
      sequence_id : UInt64
      publish_time : UInt64
      properties : Array[KeyValue]
      replicated_from : String?
      partition_key : String?
      replicate_to : Array[String]
      compression : CompressionType?
      uncompressed_size : UInt?
      num_messages_in_batch : Int?
      event_time : UInt64?
      encryption_keys : Array[EncryptionKeys]
      encryption_algo : String?
      encryption_param : Bytes?
      schema_version : Bytes?
      partition_key_b64_encoded : Bool?
      ordering_key : Bytes?
      deliver_at_time : Int64?
      marker_type : Int?
      txnid_least_bits : UInt64?
      txnid_most_bits : UInt64?
      highest_sequence_id : UInt64?
      null_value : Bool?
      uuid : String?
      num_chunks_from_msg : Int?
      total_chunk_msg_size : Int?
      chunk_id : Int?
      null_partition_key : Bool?
      compacted_batch_indexes : Array[Int]
      schema_id : Bytes?
      entry_hash_min : UInt?
      entry_hash_max : UInt?
    } derive(Eq, 
    Debug    )

    MessageMetadata::MessageMetadata

    source
    #alias(new, deprecated="`new` is deprecated, use `MessageMetadata` instead")
    fn MessageMetadata::MessageMetadata(producer_name : String, sequence_id : UInt64, publish_time : UInt64, properties : Array[KeyValue], replicated_from? : String, partition_key? : String, replicate_to : Array[String], compression? : CompressionType, uncompressed_size? : UInt, num_messages_in_batch? : Int, event_time? : UInt64, encryption_keys : Array[EncryptionKeys], encryption_algo? : String, encryption_param? : Bytes, schema_version? : Bytes, partition_key_b64_encoded? : Bool, ordering_key? : Bytes, deliver_at_time? : Int64, marker_type? : Int, txnid_least_bits? : UInt64, txnid_most_bits? : UInt64, highest_sequence_id? : UInt64, null_value? : Bool, uuid? : String, num_chunks_from_msg? : Int, total_chunk_msg_size? : Int, chunk_id? : Int, null_partition_key? : Bool, compacted_batch_indexes : Array[Int], schema_id? : Bytes, entry_hash_min? : UInt, entry_hash_max? : UInt) -> MessageMetadata

    MessageMetadata::default

    source

    MessageMetadata::equal

    source
    #deprecated("Use `==` instead")
    fn MessageMetadata::equal(MessageMetadata, MessageMetadata) -> Bool

    MessageMetadata::from_json

    source

    MessageMetadata::not_equal

    source
    #deprecated("Use `!=` instead")
    fn MessageMetadata::not_equal(x : MessageMetadata, y : MessageMetadata) -> Bool

    MessageMetadata::read

    source

    MessageMetadata::read_with_limit

    source

    MessageMetadata::size_of

    source
    fn MessageMetadata::size_of(self : MessageMetadata) -> UInt

    MessageMetadata::to_json

    source
    fn MessageMetadata::to_json(self : MessageMetadata) -> Json

    MessageMetadata::to_repr

    source

    MessageMetadata::write

    source
    fn MessageMetadata::write(self : MessageMetadata, writer : &
    Writer    ) -> Unit raise

    ProducerAccessMode

    source
    pub(all) enum ProducerAccessMode {
      Shared
      Exclusive
      WaitForExclusive
      ExclusiveWithFencing
    } derive(Eq, 
    Debug    )

    ProducerAccessMode::default

    source

    ProducerAccessMode::equal

    source
    #deprecated("Use `==` instead")
    fn ProducerAccessMode::equal(ProducerAccessMode, ProducerAccessMode) -> Bool

    ProducerAccessMode::from_enum

    source

    ProducerAccessMode::from_json

    source

    ProducerAccessMode::not_equal

    source
    #deprecated("Use `!=` instead")
    fn ProducerAccessMode::not_equal(x : ProducerAccessMode, y : ProducerAccessMode) -> Bool

    ProducerAccessMode::size_of

    source
    fn ProducerAccessMode::size_of(self : ProducerAccessMode) -> UInt

    ProducerAccessMode::to_enum

    source

    ProducerAccessMode::to_json

    source

    ProducerAccessMode::to_repr

    source

    ProtocolVersion

    source
    pub(all) enum ProtocolVersion {
      V0
      V1
      V2
      V3
      V4
      V5
      V6
      V7
      V8
      V9
      V10
      V11
      V12
      V13
      V14
      V15
      V16
      V17
      V18
      V19
      V20
      V21
    } derive(Eq, 
    Debug    )

    ProtocolVersion::default

    source

    ProtocolVersion::equal

    source
    #deprecated("Use `==` instead")
    fn ProtocolVersion::equal(ProtocolVersion, ProtocolVersion) -> Bool

    ProtocolVersion::from_enum

    source

    ProtocolVersion::from_json

    source

    ProtocolVersion::not_equal

    source
    #deprecated("Use `!=` instead")
    fn ProtocolVersion::not_equal(x : ProtocolVersion, y : ProtocolVersion) -> Bool

    ProtocolVersion::size_of

    source
    fn ProtocolVersion::size_of(self : ProtocolVersion) -> UInt

    ProtocolVersion::to_enum

    source

    ProtocolVersion::to_json

    source
    fn ProtocolVersion::to_json(self : ProtocolVersion) -> Json

    ProtocolVersion::to_repr

    source

    ScalableAssignedSegment

    source
    pub(all) struct ScalableAssignedSegment {
      segment_id : UInt64
      hash_start : UInt
      hash_end : UInt
      segment_topic : String
      bucket_ranges : Array[IntRange]
    } derive(Eq, 
    Debug    )

    ScalableAssignedSegment::ScalableAssignedSegment

    source
    #alias(new, deprecated="`new` is deprecated, use `ScalableAssignedSegment` instead")
    fn ScalableAssignedSegment::ScalableAssignedSegment(segment_id : UInt64, hash_start : UInt, hash_end : UInt, segment_topic : String, bucket_ranges : Array[IntRange]) -> ScalableAssignedSegment

    ScalableAssignedSegment::default

    source

    ScalableAssignedSegment::equal

    source
    #deprecated("Use `==` instead")
    fn ScalableAssignedSegment::equal(ScalableAssignedSegment, ScalableAssignedSegment) -> Bool

    ScalableAssignedSegment::from_json

    source

    ScalableAssignedSegment::not_equal

    source
    #deprecated("Use `!=` instead")
    fn ScalableAssignedSegment::not_equal(x : ScalableAssignedSegment, y : ScalableAssignedSegment) -> Bool

    ScalableAssignedSegment::read

    source

    ScalableAssignedSegment::read_with_limit

    source

    ScalableAssignedSegment::size_of

    source

    ScalableAssignedSegment::to_json

    source

    ScalableAssignedSegment::to_repr

    source

    ScalableAssignedSegment::write

    source

    ScalableConsumerAssignment

    source
    pub(all) struct ScalableConsumerAssignment {
      layout_epoch : UInt64
      segments : Array[ScalableAssignedSegment]
    } derive(Eq, 
    Debug    )

    ScalableConsumerAssignment::ScalableConsumerAssignment

    source
    #alias(new, deprecated="`new` is deprecated, use `ScalableConsumerAssignment` instead")
    fn ScalableConsumerAssignment::ScalableConsumerAssignment(layout_epoch : UInt64, segments : Array[ScalableAssignedSegment]) -> ScalableConsumerAssignment

    ScalableConsumerAssignment::default

    source

    ScalableConsumerAssignment::equal

    source
    #deprecated("Use `==` instead")
    fn ScalableConsumerAssignment::equal(ScalableConsumerAssignment, ScalableConsumerAssignment) -> Bool

    ScalableConsumerAssignment::from_json

    source

    ScalableConsumerAssignment::not_equal

    source
    #deprecated("Use `!=` instead")
    fn ScalableConsumerAssignment::not_equal(x : ScalableConsumerAssignment, y : ScalableConsumerAssignment) -> Bool

    ScalableConsumerAssignment::read

    source

    ScalableConsumerAssignment::read_with_limit

    source

    ScalableConsumerAssignment::size_of

    source

    ScalableConsumerAssignment::to_json

    source

    ScalableConsumerAssignment::to_repr

    source

    ScalableConsumerAssignment::write

    source

    ScalableConsumerType

    source
    pub(all) enum ScalableConsumerType {
      STREAM
      CHECKPOINT
    } derive(Eq, 
    Debug    )

    ScalableConsumerType::default

    source

    ScalableConsumerType::equal

    source
    #deprecated("Use `==` instead")
    fn ScalableConsumerType::equal(ScalableConsumerType, ScalableConsumerType) -> Bool

    ScalableConsumerType::from_enum

    source

    ScalableConsumerType::from_json

    source

    ScalableConsumerType::not_equal

    source
    #deprecated("Use `!=` instead")
    fn ScalableConsumerType::not_equal(x : ScalableConsumerType, y : ScalableConsumerType) -> Bool

    ScalableConsumerType::size_of

    source
    fn ScalableConsumerType::size_of(self : ScalableConsumerType) -> UInt

    ScalableConsumerType::to_enum

    source

    ScalableConsumerType::to_json

    source

    ScalableConsumerType::to_repr

    source

    ScalableTopicDAG

    source
    pub(all) struct ScalableTopicDAG {
      epoch : UInt64
      segments : Array[SegmentInfoProto]
      segment_brokers : Array[SegmentBrokerAddress]
      controller_broker_url : String?
      controller_broker_url_tls : String?
    } derive(Eq, 
    Debug    )

    ScalableTopicDAG::ScalableTopicDAG

    source
    #alias(new, deprecated="`new` is deprecated, use `ScalableTopicDAG` instead")
    fn ScalableTopicDAG::ScalableTopicDAG(epoch : UInt64, segments : Array[SegmentInfoProto], segment_brokers : Array[SegmentBrokerAddress], controller_broker_url? : String, controller_broker_url_tls? : String) -> ScalableTopicDAG

    ScalableTopicDAG::default

    source

    ScalableTopicDAG::equal

    source
    #deprecated("Use `==` instead")
    fn ScalableTopicDAG::equal(ScalableTopicDAG, ScalableTopicDAG) -> Bool

    ScalableTopicDAG::from_json

    source

    ScalableTopicDAG::not_equal

    source
    #deprecated("Use `!=` instead")
    fn ScalableTopicDAG::not_equal(x : ScalableTopicDAG, y : ScalableTopicDAG) -> Bool

    ScalableTopicDAG::read

    source

    ScalableTopicDAG::read_with_limit

    source

    ScalableTopicDAG::size_of

    source
    fn ScalableTopicDAG::size_of(self : ScalableTopicDAG) -> UInt

    ScalableTopicDAG::to_json

    source
    fn ScalableTopicDAG::to_json(self : ScalableTopicDAG) -> Json

    ScalableTopicDAG::to_repr

    source

    ScalableTopicDAG::write

    source
    fn ScalableTopicDAG::write(self : ScalableTopicDAG, writer : &
    Writer    ) -> Unit raise

    ScalableTopicsDiff

    source
    pub(all) struct ScalableTopicsDiff {
      added : Array[String]
      removed : Array[String]
    } derive(Eq, 
    Debug    )

    ScalableTopicsDiff::ScalableTopicsDiff

    source
    #alias(new, deprecated="`new` is deprecated, use `ScalableTopicsDiff` instead")
    fn ScalableTopicsDiff::ScalableTopicsDiff(added : Array[String], removed : Array[String]) -> ScalableTopicsDiff

    ScalableTopicsDiff::default

    source

    ScalableTopicsDiff::equal

    source
    #deprecated("Use `==` instead")
    fn ScalableTopicsDiff::equal(ScalableTopicsDiff, ScalableTopicsDiff) -> Bool

    ScalableTopicsDiff::from_json

    source

    ScalableTopicsDiff::not_equal

    source
    #deprecated("Use `!=` instead")
    fn ScalableTopicsDiff::not_equal(x : ScalableTopicsDiff, y : ScalableTopicsDiff) -> Bool

    ScalableTopicsDiff::read

    source

    ScalableTopicsDiff::read_with_limit

    source

    ScalableTopicsDiff::size_of

    source
    fn ScalableTopicsDiff::size_of(self : ScalableTopicsDiff) -> UInt

    ScalableTopicsDiff::to_json

    source

    ScalableTopicsDiff::to_repr

    source

    ScalableTopicsDiff::write

    source

    ScalableTopicsSnapshot

    source
    pub(all) struct ScalableTopicsSnapshot {
      topics : Array[String]
    } derive(Eq, 
    Debug    )

    ScalableTopicsSnapshot::ScalableTopicsSnapshot

    source
    #alias(new, deprecated="`new` is deprecated, use `ScalableTopicsSnapshot` instead")
    fn ScalableTopicsSnapshot::ScalableTopicsSnapshot(topics : Array[String]) -> ScalableTopicsSnapshot

    ScalableTopicsSnapshot::default

    source

    ScalableTopicsSnapshot::equal

    source
    #deprecated("Use `==` instead")
    fn ScalableTopicsSnapshot::equal(ScalableTopicsSnapshot, ScalableTopicsSnapshot) -> Bool

    ScalableTopicsSnapshot::from_json

    source

    ScalableTopicsSnapshot::not_equal

    source
    #deprecated("Use `!=` instead")
    fn ScalableTopicsSnapshot::not_equal(x : ScalableTopicsSnapshot, y : ScalableTopicsSnapshot) -> Bool

    ScalableTopicsSnapshot::read

    source

    ScalableTopicsSnapshot::read_with_limit

    source

    ScalableTopicsSnapshot::size_of

    source

    ScalableTopicsSnapshot::to_json

    source

    ScalableTopicsSnapshot::to_repr

    source

    ScalableTopicsSnapshot::write

    source

    Schema

    source
    pub(all) struct Schema {
      name : String
      schema_data : Bytes
      type_ : Schema_Type
      properties : Array[KeyValue]
    } derive(Eq, 
    Debug    )

    impl Default for Schema
    impl ToJson for Schema
    impl FromJson for Schema
    impl AsyncRead for Schema
    impl Read for Schema
    impl Sized for Schema
    impl Write for Schema

    Schema::Schema

    source
    #alias(new, deprecated="`new` is deprecated, use `Schema` instead")
    fn Schema::Schema(name : String, schema_data : Bytes, type_ : Schema_Type, properties : Array[KeyValue]) -> Schema

    Schema::default

    source
    fn Schema::default() -> Schema

    Schema::equal

    source
    #deprecated("Use `==` instead")
    fn Schema::equal(Schema, Schema) -> Bool

    Schema::from_json

    source

    Schema::not_equal

    source
    #deprecated("Use `!=` instead")
    fn Schema::not_equal(x : Schema, y : Schema) -> Bool

    Schema::read

    source
    fn Schema::read(reader : &
    Reader    ) -> Schema raise

    Schema::read_with_limit

    source

    Schema::size_of

    source
    fn Schema::size_of(self : Schema) -> UInt

    Schema::to_json

    source
    fn Schema::to_json(self : Schema) -> Json

    Schema::to_repr

    source

    Schema::write

    source
    fn Schema::write(self : Schema, writer : &
    Writer    ) -> Unit raise

    Schema_Type

    source
    pub(all) enum Schema_Type {
      None
      String
      Json
      Protobuf
      Avro
      Bool
      Int8
      Int16
      Int32
      Int64
      Float
      Double
      Date
      Time
      Timestamp
      KeyValue
      Instant
      LocalDate
      LocalTime
      LocalDateTime
      ProtobufNative
      AutoConsume
      External
    } derive(Eq, 
    Debug    )

    Schema_Type::default

    source
    fn Schema_Type::default() -> Schema_Type

    Schema_Type::equal

    source
    #deprecated("Use `==` instead")
    fn Schema_Type::equal(Schema_Type, Schema_Type) -> Bool

    Schema_Type::from_enum

    source

    Schema_Type::from_json

    source

    Schema_Type::not_equal

    source
    #deprecated("Use `!=` instead")
    fn Schema_Type::not_equal(x : Schema_Type, y : Schema_Type) -> Bool

    Schema_Type::size_of

    source
    fn Schema_Type::size_of(self : Schema_Type) -> UInt

    Schema_Type::to_enum

    source

    Schema_Type::to_json

    source
    fn Schema_Type::to_json(self : Schema_Type) -> Json

    Schema_Type::to_repr

    source

    SegmentBrokerAddress

    source
    pub(all) struct SegmentBrokerAddress {
      segment_id : UInt64
      broker_url : String
      broker_url_tls : String?
    } derive(Eq, 
    Debug    )

    SegmentBrokerAddress::SegmentBrokerAddress

    source
    #alias(new, deprecated="`new` is deprecated, use `SegmentBrokerAddress` instead")
    fn SegmentBrokerAddress::SegmentBrokerAddress(segment_id : UInt64, broker_url : String, broker_url_tls? : String) -> SegmentBrokerAddress

    SegmentBrokerAddress::default

    source

    SegmentBrokerAddress::equal

    source
    #deprecated("Use `==` instead")
    fn SegmentBrokerAddress::equal(SegmentBrokerAddress, SegmentBrokerAddress) -> Bool

    SegmentBrokerAddress::from_json

    source

    SegmentBrokerAddress::not_equal

    source
    #deprecated("Use `!=` instead")
    fn SegmentBrokerAddress::not_equal(x : SegmentBrokerAddress, y : SegmentBrokerAddress) -> Bool

    SegmentBrokerAddress::read

    source

    SegmentBrokerAddress::read_with_limit

    source

    SegmentBrokerAddress::size_of

    source
    fn SegmentBrokerAddress::size_of(self : SegmentBrokerAddress) -> UInt

    SegmentBrokerAddress::to_json

    source

    SegmentBrokerAddress::to_repr

    source

    SegmentBrokerAddress::write

    source

    SegmentInfoProto

    source
    pub(all) struct SegmentInfoProto {
      segment_id : UInt64
      hash_start : UInt
      hash_end : UInt
      state : SegmentState
      parent_ids : Array[UInt64]
      child_ids : Array[UInt64]
      created_at_epoch : UInt64
      sealed_at_epoch : UInt64?
      created_at_ms : UInt64
      sealed_at_ms : UInt64?
      legacy_topic_name : String?
      entry_bucket_splits : Array[UInt]
    } derive(Eq, 
    Debug    )

    SegmentInfoProto::SegmentInfoProto

    source
    #alias(new, deprecated="`new` is deprecated, use `SegmentInfoProto` instead")
    fn SegmentInfoProto::SegmentInfoProto(segment_id : UInt64, hash_start : UInt, hash_end : UInt, state : SegmentState, parent_ids : Array[UInt64], child_ids : Array[UInt64], created_at_epoch : UInt64, sealed_at_epoch? : UInt64, created_at_ms : UInt64, sealed_at_ms? : UInt64, legacy_topic_name? : String, entry_bucket_splits : Array[UInt]) -> SegmentInfoProto

    SegmentInfoProto::default

    source

    SegmentInfoProto::equal

    source
    #deprecated("Use `==` instead")
    fn SegmentInfoProto::equal(SegmentInfoProto, SegmentInfoProto) -> Bool

    SegmentInfoProto::from_json

    source

    SegmentInfoProto::not_equal

    source
    #deprecated("Use `!=` instead")
    fn SegmentInfoProto::not_equal(x : SegmentInfoProto, y : SegmentInfoProto) -> Bool

    SegmentInfoProto::read

    source

    SegmentInfoProto::read_with_limit

    source

    SegmentInfoProto::size_of

    source
    fn SegmentInfoProto::size_of(self : SegmentInfoProto) -> UInt

    SegmentInfoProto::to_json

    source
    fn SegmentInfoProto::to_json(self : SegmentInfoProto) -> Json

    SegmentInfoProto::to_repr

    source

    SegmentInfoProto::write

    source
    fn SegmentInfoProto::write(self : SegmentInfoProto, writer : &
    Writer    ) -> Unit raise

    SegmentState

    source
    pub(all) enum SegmentState {
      ACTIVE
      SEALED
    } derive(Eq, 
    Debug    )

    SegmentState::default

    source
    fn SegmentState::default() -> SegmentState

    SegmentState::equal

    source
    #deprecated("Use `==` instead")
    fn SegmentState::equal(SegmentState, SegmentState) -> Bool

    SegmentState::from_enum

    source

    SegmentState::from_json

    source

    SegmentState::not_equal

    source
    #deprecated("Use `!=` instead")
    fn SegmentState::not_equal(x : SegmentState, y : SegmentState) -> Bool

    SegmentState::size_of

    source
    fn SegmentState::size_of(self : SegmentState) -> UInt

    SegmentState::to_enum

    source

    SegmentState::to_json

    source
    fn SegmentState::to_json(self : SegmentState) -> Json

    SegmentState::to_repr

    source

    ServerError

    source
    pub(all) enum ServerError {
      UnknownError
      MetadataError
      PersistenceError
      AuthenticationError
      AuthorizationError
      ConsumerBusy
      ServiceNotReady
      ProducerBlockedQuotaExceededError
      ProducerBlockedQuotaExceededException
      ChecksumError
      UnsupportedVersionError
      TopicNotFound
      SubscriptionNotFound
      ConsumerNotFound
      TooManyRequests
      TopicTerminatedError
      ProducerBusy
      InvalidTopicName
      IncompatibleSchema
      ConsumerAssignError
      TransactionCoordinatorNotFound
      InvalidTxnStatus
      NotAllowedError
      TransactionConflict
      TransactionNotFound
      ProducerFenced
    } derive(Eq, 
    Debug    )

    ServerError::default

    source
    fn ServerError::default() -> ServerError

    ServerError::equal

    source
    #deprecated("Use `==` instead")
    fn ServerError::equal(ServerError, ServerError) -> Bool

    ServerError::from_enum

    source

    ServerError::from_json

    source

    ServerError::not_equal

    source
    #deprecated("Use `!=` instead")
    fn ServerError::not_equal(x : ServerError, y : ServerError) -> Bool

    ServerError::size_of

    source
    fn ServerError::size_of(self : ServerError) -> UInt

    ServerError::to_enum

    source

    ServerError::to_json

    source
    fn ServerError::to_json(self : ServerError) -> Json

    ServerError::to_repr

    source

    SingleMessageMetadata

    source
    pub(all) struct SingleMessageMetadata {
      properties : Array[KeyValue]
      partition_key : String?
      payload_size : Int
      compacted_out : Bool?
      event_time : UInt64?
      partition_key_b64_encoded : Bool?
      ordering_key : Bytes?
      sequence_id : UInt64?
      null_value : Bool?
      null_partition_key : Bool?
    } derive(Eq, 
    Debug    )

    SingleMessageMetadata::SingleMessageMetadata

    source
    #alias(new, deprecated="`new` is deprecated, use `SingleMessageMetadata` instead")
    fn SingleMessageMetadata::SingleMessageMetadata(properties : Array[KeyValue], partition_key? : String, payload_size : Int, compacted_out? : Bool, event_time? : UInt64, partition_key_b64_encoded? : Bool, ordering_key? : Bytes, sequence_id? : UInt64, null_value? : Bool, null_partition_key? : Bool) -> SingleMessageMetadata

    SingleMessageMetadata::default

    source

    SingleMessageMetadata::equal

    source
    #deprecated("Use `==` instead")
    fn SingleMessageMetadata::equal(SingleMessageMetadata, SingleMessageMetadata) -> Bool

    SingleMessageMetadata::from_json

    source

    SingleMessageMetadata::not_equal

    source
    #deprecated("Use `!=` instead")
    fn SingleMessageMetadata::not_equal(x : SingleMessageMetadata, y : SingleMessageMetadata) -> Bool

    SingleMessageMetadata::read

    source

    SingleMessageMetadata::read_with_limit

    source

    SingleMessageMetadata::size_of

    source
    fn SingleMessageMetadata::size_of(self : SingleMessageMetadata) -> UInt

    SingleMessageMetadata::to_json

    source

    SingleMessageMetadata::to_repr

    source

    SingleMessageMetadata::write

    source

    Subscription

    source
    pub(all) struct Subscription {
      topic : String
      subscription : String
    } derive(Eq, 
    Debug    )

    Subscription::Subscription

    source
    #alias(new, deprecated="`new` is deprecated, use `Subscription` instead")
    fn Subscription::Subscription(topic : String, subscription : String) -> Subscription

    Subscription::default

    source
    fn Subscription::default() -> Subscription

    Subscription::equal

    source
    #deprecated("Use `==` instead")
    fn Subscription::equal(Subscription, Subscription) -> Bool

    Subscription::from_json

    source

    Subscription::not_equal

    source
    #deprecated("Use `!=` instead")
    fn Subscription::not_equal(x : Subscription, y : Subscription) -> Bool

    Subscription::read

    source

    Subscription::read_with_limit

    source

    Subscription::size_of

    source
    fn Subscription::size_of(self : Subscription) -> UInt

    Subscription::to_json

    source
    fn Subscription::to_json(self : Subscription) -> Json

    Subscription::to_repr

    source

    Subscription::write

    source
    fn Subscription::write(self : Subscription, writer : &
    Writer    ) -> Unit raise

    TcAssignment

    source
    pub(all) struct TcAssignment {
      tc_id : UInt64
      broker_service_url : String?
      broker_service_url_tls : String?
    } derive(Eq, 
    Debug    )

    TcAssignment::TcAssignment

    source
    #alias(new, deprecated="`new` is deprecated, use `TcAssignment` instead")
    fn TcAssignment::TcAssignment(tc_id : UInt64, broker_service_url? : String, broker_service_url_tls? : String) -> TcAssignment

    TcAssignment::default

    source
    fn TcAssignment::default() -> TcAssignment

    TcAssignment::equal

    source
    #deprecated("Use `==` instead")
    fn TcAssignment::equal(TcAssignment, TcAssignment) -> Bool

    TcAssignment::from_json

    source

    TcAssignment::not_equal

    source
    #deprecated("Use `!=` instead")
    fn TcAssignment::not_equal(x : TcAssignment, y : TcAssignment) -> Bool

    TcAssignment::read

    source

    TcAssignment::read_with_limit

    source

    TcAssignment::size_of

    source
    fn TcAssignment::size_of(self : TcAssignment) -> UInt

    TcAssignment::to_json

    source
    fn TcAssignment::to_json(self : TcAssignment) -> Json

    TcAssignment::to_repr

    source

    TcAssignment::write

    source
    fn TcAssignment::write(self : TcAssignment, writer : &
    Writer    ) -> Unit raise

    TcAssignmentsSnapshot

    source
    pub(all) struct TcAssignmentsSnapshot {
      parallelism : UInt
      assignments : Array[TcAssignment]
    } derive(Eq, 
    Debug    )

    TcAssignmentsSnapshot::TcAssignmentsSnapshot

    source
    #alias(new, deprecated="`new` is deprecated, use `TcAssignmentsSnapshot` instead")
    fn TcAssignmentsSnapshot::TcAssignmentsSnapshot(parallelism : UInt, assignments : Array[TcAssignment]) -> TcAssignmentsSnapshot

    TcAssignmentsSnapshot::default

    source

    TcAssignmentsSnapshot::equal

    source
    #deprecated("Use `==` instead")
    fn TcAssignmentsSnapshot::equal(TcAssignmentsSnapshot, TcAssignmentsSnapshot) -> Bool

    TcAssignmentsSnapshot::from_json

    source

    TcAssignmentsSnapshot::not_equal

    source
    #deprecated("Use `!=` instead")
    fn TcAssignmentsSnapshot::not_equal(x : TcAssignmentsSnapshot, y : TcAssignmentsSnapshot) -> Bool

    TcAssignmentsSnapshot::read

    source

    TcAssignmentsSnapshot::read_with_limit

    source

    TcAssignmentsSnapshot::size_of

    source
    fn TcAssignmentsSnapshot::size_of(self : TcAssignmentsSnapshot) -> UInt

    TcAssignmentsSnapshot::to_json

    source

    TcAssignmentsSnapshot::to_repr

    source

    TcAssignmentsSnapshot::write

    source

    TxnAction

    source
    pub(all) enum TxnAction {
      COMMIT
      ABORT
    } derive(Eq, 
    Debug    )

    impl ToJson for TxnAction
    impl Sized for TxnAction

    TxnAction::default

    source
    fn TxnAction::default() -> TxnAction

    TxnAction::equal

    source
    #deprecated("Use `==` instead")
    fn TxnAction::equal(TxnAction, TxnAction) -> Bool

    TxnAction::from_enum

    source

    TxnAction::from_json

    source

    TxnAction::not_equal

    source
    #deprecated("Use `!=` instead")
    fn TxnAction::not_equal(x : TxnAction, y : TxnAction) -> Bool

    TxnAction::size_of

    source
    fn TxnAction::size_of(self : TxnAction) -> UInt

    TxnAction::to_enum

    source

    TxnAction::to_json

    source
    fn TxnAction::to_json(self : TxnAction) -> Json

    TxnAction::to_repr

    source

    Source Files

    Powered by MoonBit

    Site sourceReport issueModulesSkillsCLIBuild queueStatistics

    © 2026 mooncakes.io