🥮 mooncakes.io
    Sign in

    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

    AuthMethod

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

    impl Sized for AuthMethod

    AuthMethod::from_enum

    source

    AuthMethod::to_enum

    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_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    )

    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

    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

    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

    CommandAck_AckType

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

    CommandAck_ValidationError

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

    CommandAck_ValidationError::from_enum

    source

    CommandAck_ValidationError::to_enum

    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

    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

    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

    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

    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

    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

    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

    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

    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

    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

    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

    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

    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

    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

    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

    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

    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

    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

    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

    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

    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

    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

    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

    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

    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

    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

    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

    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

    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

    CommandGetTopicsOfNamespace_Mode

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

    CommandGetTopicsOfNamespace_Mode::from_enum

    source

    CommandGetTopicsOfNamespace_Mode::to_enum

    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

    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_LookupType

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

    CommandLookupTopicResponse_LookupType::from_enum

    source

    CommandLookupTopicResponse_LookupType::to_enum

    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

    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

    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

    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

    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_LookupType

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

    CommandPartitionedTopicMetadataResponse_LookupType::from_enum

    source

    CommandPartitionedTopicMetadataResponse_LookupType::to_enum

    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

    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

    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

    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

    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

    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

    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

    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

    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

    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

    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

    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

    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

    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

    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

    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

    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

    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_InitialPosition

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

    CommandSubscribe_InitialPosition::from_enum

    source

    CommandSubscribe_InitialPosition::to_enum

    source

    CommandSubscribe_SubType

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

    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

    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

    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

    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_ResourceType

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

    CommandTopicMigrated_ResourceType::from_enum

    source

    CommandTopicMigrated_ResourceType::to_enum

    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

    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

    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

    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_Event

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

    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

    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

    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

    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

    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

    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

    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

    CompressionType

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

    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

    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

    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

    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

    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

    KeySharedMode

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

    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

    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

    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

    ProducerAccessMode

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

    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    )

    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

    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

    ScalableConsumerType

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

    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

    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

    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

    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_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::from_enum

    source

    Schema_Type::to_enum

    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

    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

    SegmentState

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

    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::from_enum

    source

    ServerError::to_enum

    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

    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

    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

    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

    TxnAction

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

    impl ToJson for TxnAction
    impl Sized for TxnAction

    TxnAction::from_enum

    source

    TxnAction::to_enum

    source

    Source Files

    Powered by MoonBit

    Site sourceReport issuePackagesBuild queueSkillsStatistics

    © 2026 mooncakes.io