php/grpc/GPBMetadata/Apache/Rocketmq/V2/Definition.php (207 lines of code) (raw):

<?php # Generated by the protocol buffer compiler. DO NOT EDIT! # source: apache/rocketmq/v2/definition.proto namespace GPBMetadata\Apache\Rocketmq\V2; class Definition { public static $is_initialized = false; public static function initOnce() { $pool = \Google\Protobuf\Internal\DescriptorPool::getGeneratedPool(); if (static::$is_initialized == true) { return; } \GPBMetadata\Google\Protobuf\Timestamp::initOnce(); \GPBMetadata\Google\Protobuf\Duration::initOnce(); $pool->internalAddGeneratedFile( ' �& #apache/rocketmq/v2/definition.protoapache.rocketmq.v2google/protobuf/duration.proto"T FilterExpression, type (2.apache.rocketmq.v2.FilterType expression ( "� RetryPolicy max_attempts (E exponential_backoff ( 2&.apache.rocketmq.v2.ExponentialBackoffHC customized_backoff ( 2%.apache.rocketmq.v2.CustomizedBackoffHB strategy"| ExponentialBackoff* initial ( 2.google.protobuf.Duration& max ( 2.google.protobuf.Duration multiplier ("< CustomizedBackoff\' next ( 2.google.protobuf.Duration"4 Resource resource_namespace (  name ( "z SubscriptionEntry+ topic ( 2.apache.rocketmq.v2.Resource8 expression ( 2$.apache.rocketmq.v2.FilterExpression"% Address host (  port ("n Endpoints1 scheme (2!.apache.rocketmq.v2.AddressScheme. addresses ( 2.apache.rocketmq.v2.Address"T Broker name (  id (0 endpoints ( 2.apache.rocketmq.v2.Endpoints"� MessageQueue+ topic ( 2.apache.rocketmq.v2.Resource id (2 permission (2.apache.rocketmq.v2.Permission* broker ( 2.apache.rocketmq.v2.Broker= accept_message_types (2.apache.rocketmq.v2.MessageType"H Digest, type (2.apache.rocketmq.v2.DigestType checksum ( "� SystemProperties tag ( H� keys (  message_id ( / body_digest ( 2.apache.rocketmq.v2.Digest3 body_encoding (2.apache.rocketmq.v2.Encoding5 message_type (2.apache.rocketmq.v2.MessageType2 born_timestamp ( 2.google.protobuf.Timestamp born_host ( 8 store_timestamp ( 2.google.protobuf.TimestampH� store_host ( ; delivery_timestamp ( 2.google.protobuf.TimestampH� receipt_handle ( H� queue_id ( queue_offset (H�: invisible_duration ( 2.google.protobuf.DurationH� delivery_attempt (H� message_group ( H� trace_context ( H�N &orphaned_transaction_recovery_duration ( 2.google.protobuf.DurationH �B _tagB _store_timestampB _delivery_timestampB _receipt_handleB _queue_offsetB _invisible_durationB _delivery_attemptB _message_groupB _trace_contextB) \'_orphaned_transaction_recovery_duration"� Message+ topic ( 2.apache.rocketmq.v2.ResourceH user_properties ( 2/.apache.rocketmq.v2.Message.UserPropertiesEntry? system_properties ( 2$.apache.rocketmq.v2.SystemProperties body ( 5 UserPropertiesEntry key (  value ( :8"E Assignment7 message_queue ( 2 .apache.rocketmq.v2.MessageQueue"A Status& code (2.apache.rocketmq.v2.Code message ( "i UA. language (2.apache.rocketmq.v2.Language version (  platform (  hostname ( *Y TransactionResolution& "TRANSACTION_RESOLUTION_UNSPECIFIED COMMIT ROLLBACK*W TransactionSource SOURCE_UNSPECIFIED SOURCE_CLIENT SOURCE_SERVER_CHECK*W Permission PERMISSION_UNSPECIFIED NONE READ WRITE READ_WRITE*; FilterType FILTER_TYPE_UNSPECIFIED TAG SQL*T AddressScheme ADDRESS_SCHEME_UNSPECIFIED IPv4 IPv6 DOMAIN_NAME*] MessageType MESSAGE_TYPE_UNSPECIFIED NORMAL FIFO DELAY TRANSACTION*G DigestType DIGEST_TYPE_UNSPECIFIED CRC32 MD5 SHA1*_ ClientType CLIENT_TYPE_UNSPECIFIED PRODUCER PUSH_CONSUMER SIMPLE_CONSUMER*< Encoding ENCODING_UNSPECIFIED IDENTITY GZIP*� Code CODE_UNSPECIFIED OK�� MULTIPLE_RESULTS�� BAD_REQUEST�� ILLEGAL_ACCESS_POINT�� ILLEGAL_TOPIC¸ ILLEGAL_CONSUMER_GROUPø ILLEGAL_MESSAGE_TAGĸ ILLEGAL_MESSAGE_KEYŸ ILLEGAL_MESSAGE_GROUPƸ" ILLEGAL_MESSAGE_PROPERTY_KEYǸ INVALID_TRANSACTION_IDȸ ILLEGAL_MESSAGE_IDɸ ILLEGAL_FILTER_EXPRESSIONʸ ILLEGAL_INVISIBLE_TIME˸ ILLEGAL_DELIVERY_TIME̸ INVALID_RECEIPT_HANDLE͸) #MESSAGE_PROPERTY_CONFLICT_WITH_TYPEθ UNRECOGNIZED_CLIENT_TYPEϸ MESSAGE_CORRUPTEDи CLIENT_ID_REQUIREDѸ UNAUTHORIZED�� PAYMENT_REQUIRED�� FORBIDDEN� NOT_FOUNDл MESSAGE_NOT_FOUNDѻ TOPIC_NOT_FOUNDһ CONSUMER_GROUP_NOT_FOUNDӻ REQUEST_TIMEOUT� PAYLOAD_TOO_LARGE�� MESSAGE_BODY_TOO_LARGE�� PRECONDITION_FAILED�� TOO_MANY_REQUESTS��% REQUEST_HEADER_FIELDS_TOO_LARGE��" MESSAGE_PROPERTIES_TOO_LARGE�� INTERNAL_ERRORІ INTERNAL_SERVER_ERRORц HA_NOT_AVAILABLE҆ NOT_IMPLEMENTED�� PROXY_TIMEOUT�� MASTER_PERSISTENCE_TIMEOUT� SLAVE_PERSISTENCE_TIMEOUT� UNSUPPORTEDĊ VERSION_UNSUPPORTEDŊ% VERIFY_FIFO_MESSAGE_UNSUPPORTEDƊ FAILED_TO_CONSUME_MESSAGE��*Z Language LANGUAGE_UNSPECIFIED JAVA CPP DOT_NET GOLANG RUSTB; apache.rocketmq.v2BMQDomainP���Apache.Rocketmq.V2bproto3' , true); static::$is_initialized = true; } }