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.ExponentialBackoffH C
customized_backoff (2%.apache.rocketmq.v2.CustomizedBackoffH B
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;
}
}