diff options
Diffstat (limited to 'REFLECTION')
-rw-r--r-- | REFLECTION | 179 |
1 files changed, 165 insertions, 14 deletions
@@ -1,6 +1,6 @@ -Extension [ <persistent> extension #124 rdkafka version 6.0.3 ] { +Extension [ <persistent> extension #94 rdkafka version 6.0.4 ] { - - Constants [185] { + - Constants [193] { 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 #124 rdkafka version 6.0.3 ] { 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 ] { 33685759 } - Constant [ int RD_KAFKA_BUILD_VERSION ] { 33554687 } + Constant [ int RD_KAFKA_VERSION ] { 33947903 } + Constant [ int RD_KAFKA_BUILD_VERSION ] { 33947903 } 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 } @@ -75,6 +75,7 @@ Extension [ <persistent> extension #124 rdkafka version 6.0.3 ] { Constant [ int RD_KAFKA_RESP_ERR__NOOP ] { -141 } Constant [ int RD_KAFKA_RESP_ERR__AUTO_OFFSET_RESET ] { -140 } Constant [ int RD_KAFKA_RESP_ERR__LOG_TRUNCATION ] { -139 } + Constant [ int RD_KAFKA_RESP_ERR__INVALID_DIFFERENT_RECORD ] { -138 } Constant [ int RD_KAFKA_RESP_ERR__END ] { -100 } Constant [ int RD_KAFKA_RESP_ERR_UNKNOWN ] { -1 } Constant [ int RD_KAFKA_RESP_ERR_NO_ERROR ] { 0 } @@ -175,6 +176,13 @@ Extension [ <persistent> extension #124 rdkafka version 6.0.3 ] { Constant [ int RD_KAFKA_RESP_ERR_INVALID_UPDATE_VERSION ] { 95 } Constant [ int RD_KAFKA_RESP_ERR_FEATURE_UPDATE_FAILED ] { 96 } Constant [ int RD_KAFKA_RESP_ERR_PRINCIPAL_DESERIALIZATION_FAILURE ] { 97 } + Constant [ int RD_KAFKA_RESP_ERR_UNKNOWN_TOPIC_ID ] { 100 } + Constant [ int RD_KAFKA_RESP_ERR_FENCED_MEMBER_EPOCH ] { 110 } + Constant [ int RD_KAFKA_RESP_ERR_UNRELEASED_INSTANCE_ID ] { 111 } + Constant [ int RD_KAFKA_RESP_ERR_UNSUPPORTED_ASSIGNOR ] { 112 } + Constant [ int RD_KAFKA_RESP_ERR_STALE_MEMBER_EPOCH ] { 113 } + Constant [ int RD_KAFKA_RESP_ERR_UNKNOWN_SUBSCRIPTION_ID ] { 117 } + Constant [ int RD_KAFKA_RESP_ERR_TELEMETRY_TOO_LARGE ] { 118 } Constant [ int RD_KAFKA_CONF_UNKNOWN ] { -2 } Constant [ int RD_KAFKA_CONF_INVALID ] { -1 } Constant [ int RD_KAFKA_CONF_OK ] { 0 } @@ -254,7 +262,7 @@ Extension [ <persistent> extension #124 rdkafka version 6.0.3 ] { Property [ private ?callable $dr_cb ] } - - Methods [16] { + - Methods [19] { Method [ <internal:rdkafka, ctor> private method __construct ] { - Parameters [0] { @@ -279,6 +287,14 @@ Extension [ <persistent> extension #124 rdkafka version 6.0.3 ] { - Tentative return [ RdKafka\Metadata ] } + Method [ <internal:rdkafka> public method getControllerId ] { + + - Parameters [1] { + Parameter #0 [ <required> int $timeout_ms ] + } + - Tentative return [ int ] + } + Method [ <internal:rdkafka> public method getOutQLen ] { - Parameters [0] { @@ -388,6 +404,25 @@ Extension [ <persistent> extension #124 rdkafka version 6.0.3 ] { } - Tentative return [ array ] } + + Method [ <internal:rdkafka> public method oauthbearerSetToken ] { + + - Parameters [4] { + Parameter #0 [ <required> string $token_value ] + Parameter #1 [ <required> int $lifetime_ms ] + Parameter #2 [ <required> string $principal_name ] + Parameter #3 [ <optional> array $extensions = [] ] + } + - Tentative return [ void ] + } + + Method [ <internal:rdkafka> public method oauthbearerSetTokenFailure ] { + + - Parameters [1] { + Parameter #0 [ <required> string $error ] + } + - Tentative return [ void ] + } } } @@ -405,7 +440,7 @@ Extension [ <persistent> extension #124 rdkafka version 6.0.3 ] { - Properties [0] { } - - Methods [17] { + - Methods [20] { Method [ <internal:rdkafka, ctor> public method __construct ] { - Parameters [1] { @@ -438,6 +473,14 @@ Extension [ <persistent> extension #124 rdkafka version 6.0.3 ] { - Tentative return [ RdKafka\Metadata ] } + Method [ <internal:rdkafka, inherits RdKafka> public method getControllerId ] { + + - Parameters [1] { + Parameter #0 [ <required> int $timeout_ms ] + } + - Tentative return [ int ] + } + Method [ <internal:rdkafka, inherits RdKafka> public method getOutQLen ] { - Parameters [0] { @@ -547,6 +590,25 @@ Extension [ <persistent> extension #124 rdkafka version 6.0.3 ] { } - Tentative return [ array ] } + + Method [ <internal:rdkafka, inherits RdKafka> public method oauthbearerSetToken ] { + + - Parameters [4] { + Parameter #0 [ <required> string $token_value ] + Parameter #1 [ <required> int $lifetime_ms ] + Parameter #2 [ <required> string $principal_name ] + Parameter #3 [ <optional> array $extensions = [] ] + } + - Tentative return [ void ] + } + + Method [ <internal:rdkafka, inherits RdKafka> public method oauthbearerSetTokenFailure ] { + + - Parameters [1] { + Parameter #0 [ <required> string $error ] + } + - Tentative return [ void ] + } } } @@ -564,7 +626,7 @@ Extension [ <persistent> extension #124 rdkafka version 6.0.3 ] { - Properties [0] { } - - Methods [20] { + - Methods [23] { Method [ <internal:rdkafka, ctor> public method __construct ] { - Parameters [1] { @@ -621,6 +683,14 @@ Extension [ <persistent> extension #124 rdkafka version 6.0.3 ] { - Tentative return [ RdKafka\Metadata ] } + Method [ <internal:rdkafka, inherits RdKafka> public method getControllerId ] { + + - Parameters [1] { + Parameter #0 [ <required> int $timeout_ms ] + } + - Tentative return [ int ] + } + Method [ <internal:rdkafka, inherits RdKafka> public method getOutQLen ] { - Parameters [0] { @@ -730,6 +800,25 @@ Extension [ <persistent> extension #124 rdkafka version 6.0.3 ] { } - Tentative return [ array ] } + + Method [ <internal:rdkafka, inherits RdKafka> public method oauthbearerSetToken ] { + + - Parameters [4] { + Parameter #0 [ <required> string $token_value ] + Parameter #1 [ <required> int $lifetime_ms ] + Parameter #2 [ <required> string $principal_name ] + Parameter #3 [ <optional> array $extensions = [] ] + } + - Tentative return [ void ] + } + + Method [ <internal:rdkafka, inherits RdKafka> public method oauthbearerSetTokenFailure ] { + + - Parameters [1] { + Parameter #0 [ <required> string $error ] + } + - Tentative return [ void ] + } } } @@ -839,7 +928,7 @@ Extension [ <persistent> extension #124 rdkafka version 6.0.3 ] { - Properties [0] { } - - Methods [11] { + - Methods [12] { Method [ <internal:rdkafka, ctor> public method __construct ] { - Parameters [0] { @@ -925,6 +1014,14 @@ Extension [ <persistent> extension #124 rdkafka version 6.0.3 ] { } - Tentative return [ void ] } + + Method [ <internal:rdkafka> public method setOauthbearerTokenRefreshCb ] { + + - Parameters [1] { + Parameter #0 [ <required> callable $callback ] + } + - Tentative return [ void ] + } } } @@ -1119,7 +1216,7 @@ Extension [ <persistent> extension #124 rdkafka version 6.0.3 ] { Property [ private ?callable $dr_msg_cb ] } - - Methods [18] { + - Methods [21] { Method [ <internal:rdkafka, ctor> public method __construct ] { - Parameters [1] { @@ -1135,6 +1232,22 @@ Extension [ <persistent> extension #124 rdkafka version 6.0.3 ] { - Tentative return [ void ] } + Method [ <internal:rdkafka> public method incrementalAssign ] { + + - Parameters [1] { + Parameter #0 [ <required> array $topic_partitions ] + } + - Tentative return [ void ] + } + + Method [ <internal:rdkafka> public method incrementalUnassign ] { + + - Parameters [1] { + Parameter #0 [ <required> array $topic_partitions ] + } + - Tentative return [ void ] + } + Method [ <internal:rdkafka> public method getAssignment ] { - Parameters [0] { @@ -1205,6 +1318,14 @@ Extension [ <persistent> extension #124 rdkafka version 6.0.3 ] { - Tentative return [ RdKafka\Metadata ] } + Method [ <internal:rdkafka> public method getControllerId ] { + + - Parameters [1] { + Parameter #0 [ <required> int $timeout_ms ] + } + - Tentative return [ int ] + } + Method [ <internal:rdkafka> public method newTopic ] { - Parameters [2] { @@ -1318,7 +1439,13 @@ Extension [ <persistent> extension #124 rdkafka version 6.0.3 ] { - Properties [0] { } - - Methods [4] { + - Methods [5] { + Method [ <internal:rdkafka, ctor> private method __construct ] { + + - Parameters [0] { + } + } + Method [ <internal:rdkafka> public method getOrigBrokerId ] { - Parameters [0] { @@ -1363,7 +1490,13 @@ Extension [ <persistent> extension #124 rdkafka version 6.0.3 ] { - Properties [0] { } - - Methods [3] { + - Methods [4] { + Method [ <internal:rdkafka, ctor> private method __construct ] { + + - Parameters [0] { + } + } + Method [ <internal:rdkafka> public method getTopic ] { - Parameters [0] { @@ -1401,7 +1534,13 @@ Extension [ <persistent> extension #124 rdkafka version 6.0.3 ] { - Properties [0] { } - - Methods [3] { + - Methods [4] { + Method [ <internal:rdkafka, ctor> private method __construct ] { + + - Parameters [0] { + } + } + Method [ <internal:rdkafka> public method getId ] { - Parameters [0] { @@ -1439,7 +1578,13 @@ Extension [ <persistent> extension #124 rdkafka version 6.0.3 ] { - Properties [0] { } - - Methods [5] { + - Methods [6] { + Method [ <internal:rdkafka, ctor> private method __construct ] { + + - Parameters [0] { + } + } + Method [ <internal:rdkafka> public method getId ] { - Parameters [0] { @@ -1491,7 +1636,13 @@ Extension [ <persistent> extension #124 rdkafka version 6.0.3 ] { - Properties [0] { } - - Methods [6] { + - Methods [7] { + Method [ <internal:rdkafka, ctor> private method __construct ] { + + - Parameters [0] { + } + } + Method [ <internal:rdkafka, prototype Countable> public method count ] { - Parameters [0] { |