diff options
Diffstat (limited to 'REFLECTION')
| -rw-r--r-- | REFLECTION | 133 |
1 files changed, 127 insertions, 6 deletions
@@ -1,6 +1,6 @@ -Extension [ <persistent> extension #97 rdkafka version 4.0.4 ] { +Extension [ <persistent> extension #97 rdkafka version 4.1.0 ] { - - Constants [166] { + - Constants [172] { Constant [ int RD_KAFKA_CONSUMER ] { 1 } Constant [ int RD_KAFKA_OFFSET_BEGINNING ] { -2 } Constant [ int RD_KAFKA_OFFSET_END ] { -1 } @@ -11,8 +11,8 @@ Extension [ <persistent> extension #97 rdkafka version 4.0.4 ] { Constant [ int RD_KAFKA_PURGE_F_QUEUE ] { 1 } Constant [ int RD_KAFKA_PURGE_F_INFLIGHT ] { 2 } Constant [ int RD_KAFKA_PURGE_F_NON_BLOCKING ] { 4 } - Constant [ int RD_KAFKA_VERSION ] { 17105151 } - Constant [ int RD_KAFKA_BUILD_VERSION ] { 17105151 } + Constant [ int RD_KAFKA_VERSION ] { 17105663 } + Constant [ int RD_KAFKA_BUILD_VERSION ] { 17105663 } Constant [ int RD_KAFKA_RESP_ERR__BEGIN ] { -200 } Constant [ int RD_KAFKA_RESP_ERR__BAD_MSG ] { -199 } Constant [ int RD_KAFKA_RESP_ERR__BAD_COMPRESSION ] { -198 } @@ -156,6 +156,12 @@ Extension [ <persistent> extension #97 rdkafka version 4.0.4 ] { Constant [ int RD_KAFKA_RESP_ERR_PREFERRED_LEADER_NOT_AVAILABLE ] { 80 } Constant [ int RD_KAFKA_RESP_ERR_GROUP_MAX_SIZE_REACHED ] { 81 } Constant [ int RD_KAFKA_RESP_ERR_FENCED_INSTANCE_ID ] { 82 } + Constant [ int RD_KAFKA_RESP_ERR_ELIGIBLE_LEADERS_NOT_AVAILABLE ] { 83 } + Constant [ int RD_KAFKA_RESP_ERR_ELECTION_NOT_NEEDED ] { 84 } + Constant [ int RD_KAFKA_RESP_ERR_NO_REASSIGNMENT_IN_PROGRESS ] { 85 } + Constant [ int RD_KAFKA_RESP_ERR_GROUP_SUBSCRIBED_TO_TOPIC ] { 86 } + Constant [ int RD_KAFKA_RESP_ERR_INVALID_RECORD ] { 87 } + Constant [ int RD_KAFKA_RESP_ERR_UNSTABLE_OFFSET_COMMIT ] { 88 } Constant [ int RD_KAFKA_CONF_UNKNOWN ] { -2 } Constant [ int RD_KAFKA_CONF_INVALID ] { -1 } Constant [ int RD_KAFKA_CONF_OK ] { 0 } @@ -205,7 +211,7 @@ Extension [ <persistent> extension #97 rdkafka version 4.0.4 ] { } } - - Classes [19] { + - Classes [20] { Class [ <internal:rdkafka> abstract class RdKafka ] { - Constants [0] { @@ -467,7 +473,7 @@ Extension [ <persistent> extension #97 rdkafka version 4.0.4 ] { - Properties [0] { } - - Methods [14] { + - Methods [18] { Method [ <internal:rdkafka, ctor> public method __construct ] { - Parameters [1] { @@ -475,6 +481,33 @@ Extension [ <persistent> extension #97 rdkafka version 4.0.4 ] { } } + Method [ <internal:rdkafka> public method initTransactions ] { + + - Parameters [1] { + Parameter #0 [ <required> $timeout_ms ] + } + } + + Method [ <internal:rdkafka> public method beginTransaction ] { + + - Parameters [0] { + } + } + + Method [ <internal:rdkafka> public method commitTransaction ] { + + - Parameters [1] { + Parameter #0 [ <required> $timeout_ms ] + } + } + + Method [ <internal:rdkafka> public method abortTransaction ] { + + - Parameters [1] { + Parameter #0 [ <required> $timeout_ms ] + } + } + Method [ <internal:rdkafka, inherits RdKafka> public method addBrokers ] { - Parameters [1] { @@ -770,6 +803,94 @@ Extension [ <persistent> extension #97 rdkafka version 4.0.4 ] { } } + Class [ <internal:rdkafka> class RdKafka\KafkaErrorException extends RdKafka\Exception implements Throwable ] { + + - Constants [0] { + } + + - Static properties [0] { + } + + - Static methods [0] { + } + + - Properties [8] { + Property [ <default> protected $message ] + Property [ <default> protected $code ] + Property [ <default> protected $file ] + Property [ <default> protected $line ] + Property [ <default> private $error_string ] + Property [ <default> private $isFatal ] + Property [ <default> private $isRetriable ] + Property [ <default> private $transactionRequiresAbort ] + } + + - Methods [14] { + Method [ <internal:rdkafka, overwrites Exception, ctor> public method __construct ] { + + - Parameters [6] { + Parameter #0 [ <required> $message ] + Parameter #1 [ <required> $code ] + Parameter #2 [ <required> $error_string ] + Parameter #3 [ <required> $isFatal ] + Parameter #4 [ <required> $isRetriable ] + Parameter #5 [ <required> $transactionRequiresAbort ] + } + } + + Method [ <internal:rdkafka> public method getErrorString ] { + + - Parameters [0] { + } + } + + Method [ <internal:rdkafka> public method isFatal ] { + + - Parameters [0] { + } + } + + Method [ <internal:rdkafka> public method isRetriable ] { + + - Parameters [0] { + } + } + + Method [ <internal:rdkafka> public method transactionRequiresAbort ] { + + - Parameters [0] { + } + } + + Method [ <internal:Core, inherits Exception> public method __wakeup ] { + } + + Method [ <internal:Core, inherits Exception, prototype Throwable> final public method getMessage ] { + } + + Method [ <internal:Core, inherits Exception, prototype Throwable> final public method getCode ] { + } + + Method [ <internal:Core, inherits Exception, prototype Throwable> final public method getFile ] { + } + + Method [ <internal:Core, inherits Exception, prototype Throwable> final public method getLine ] { + } + + Method [ <internal:Core, inherits Exception, prototype Throwable> final public method getTrace ] { + } + + Method [ <internal:Core, inherits Exception, prototype Throwable> final public method getPrevious ] { + } + + Method [ <internal:Core, inherits Exception, prototype Throwable> final public method getTraceAsString ] { + } + + Method [ <internal:Core, inherits Exception, prototype Throwable> public method __toString ] { + } + } + } + Class [ <internal:rdkafka> class RdKafka\KafkaConsumer ] { - Constants [0] { |