@@ -4,21 +4,21 @@ |
||
4 | 4 | |
5 | 5 | class Consumer extends \RdKafka |
6 | 6 | { |
7 | - /** |
|
8 | - * @param null|Conf $conf |
|
9 | - */ |
|
10 | - public function __construct($conf = null) {} |
|
7 | + /** |
|
8 | + * @param null|Conf $conf |
|
9 | + */ |
|
10 | + public function __construct($conf = null) {} |
|
11 | 11 | |
12 | - /** |
|
13 | - * @param string $topic_name |
|
14 | - * @param null|TopicConf $topic_conf |
|
15 | - * |
|
16 | - * @return ConsumerTopic |
|
17 | - */ |
|
18 | - public function newTopic($topic_name, ?TopicConf $topic_conf = null) {} |
|
12 | + /** |
|
13 | + * @param string $topic_name |
|
14 | + * @param null|TopicConf $topic_conf |
|
15 | + * |
|
16 | + * @return ConsumerTopic |
|
17 | + */ |
|
18 | + public function newTopic($topic_name, ?TopicConf $topic_conf = null) {} |
|
19 | 19 | |
20 | - /** |
|
21 | - * @return Queue |
|
22 | - */ |
|
23 | - public function newQueue() {} |
|
20 | + /** |
|
21 | + * @return Queue |
|
22 | + */ |
|
23 | + public function newQueue() {} |
|
24 | 24 | } |
@@ -4,46 +4,46 @@ |
||
4 | 4 | |
5 | 5 | class TopicPartition |
6 | 6 | { |
7 | - /** |
|
8 | - * @param string $topic |
|
9 | - * @param int $partition |
|
10 | - * @param int $offset |
|
11 | - */ |
|
12 | - public function __construct($topic, $partition, $offset = null) {} |
|
13 | - |
|
14 | - /** |
|
15 | - * @return int |
|
16 | - */ |
|
17 | - public function getOffset() {} |
|
18 | - |
|
19 | - /** |
|
20 | - * @return int |
|
21 | - */ |
|
22 | - public function getPartition() {} |
|
23 | - |
|
24 | - /** |
|
25 | - * @return string |
|
26 | - */ |
|
27 | - public function getTopic() {} |
|
28 | - |
|
29 | - /** |
|
30 | - * @param int $offset |
|
31 | - * |
|
32 | - * @return void |
|
33 | - */ |
|
34 | - public function setOffset($offset) {} |
|
35 | - |
|
36 | - /** |
|
37 | - * @param int $partition |
|
38 | - * |
|
39 | - * @return void |
|
40 | - */ |
|
41 | - public function setPartition($partition) {} |
|
42 | - |
|
43 | - /** |
|
44 | - * @param string $topic_name |
|
45 | - * |
|
46 | - * @return void |
|
47 | - */ |
|
48 | - public function setTopic($topic_name) {} |
|
7 | + /** |
|
8 | + * @param string $topic |
|
9 | + * @param int $partition |
|
10 | + * @param int $offset |
|
11 | + */ |
|
12 | + public function __construct($topic, $partition, $offset = null) {} |
|
13 | + |
|
14 | + /** |
|
15 | + * @return int |
|
16 | + */ |
|
17 | + public function getOffset() {} |
|
18 | + |
|
19 | + /** |
|
20 | + * @return int |
|
21 | + */ |
|
22 | + public function getPartition() {} |
|
23 | + |
|
24 | + /** |
|
25 | + * @return string |
|
26 | + */ |
|
27 | + public function getTopic() {} |
|
28 | + |
|
29 | + /** |
|
30 | + * @param int $offset |
|
31 | + * |
|
32 | + * @return void |
|
33 | + */ |
|
34 | + public function setOffset($offset) {} |
|
35 | + |
|
36 | + /** |
|
37 | + * @param int $partition |
|
38 | + * |
|
39 | + * @return void |
|
40 | + */ |
|
41 | + public function setPartition($partition) {} |
|
42 | + |
|
43 | + /** |
|
44 | + * @param string $topic_name |
|
45 | + * |
|
46 | + * @return void |
|
47 | + */ |
|
48 | + public function setTopic($topic_name) {} |
|
49 | 49 | } |
@@ -2,8 +2,7 @@ |
||
2 | 2 | |
3 | 3 | namespace RdKafka; |
4 | 4 | |
5 | -class TopicPartition |
|
6 | -{ |
|
5 | +class TopicPartition { |
|
7 | 6 | /** |
8 | 7 | * @param string $topic |
9 | 8 | * @param int $partition |
@@ -7,25 +7,25 @@ |
||
7 | 7 | */ |
8 | 8 | class TopicConf |
9 | 9 | { |
10 | - public function __construct() {} |
|
10 | + public function __construct() {} |
|
11 | 11 | |
12 | - /** |
|
13 | - * @return array |
|
14 | - */ |
|
15 | - public function dump() {} |
|
12 | + /** |
|
13 | + * @return array |
|
14 | + */ |
|
15 | + public function dump() {} |
|
16 | 16 | |
17 | - /** |
|
18 | - * @param string $name |
|
19 | - * @param string $value |
|
20 | - * |
|
21 | - * @return void |
|
22 | - */ |
|
23 | - public function set($name, $value) {} |
|
17 | + /** |
|
18 | + * @param string $name |
|
19 | + * @param string $value |
|
20 | + * |
|
21 | + * @return void |
|
22 | + */ |
|
23 | + public function set($name, $value) {} |
|
24 | 24 | |
25 | - /** |
|
26 | - * @param int $partitioner |
|
27 | - * |
|
28 | - * @return void |
|
29 | - */ |
|
30 | - public function setPartitioner($partitioner) {} |
|
25 | + /** |
|
26 | + * @param int $partitioner |
|
27 | + * |
|
28 | + * @return void |
|
29 | + */ |
|
30 | + public function setPartitioner($partitioner) {} |
|
31 | 31 | } |
@@ -5,8 +5,7 @@ |
||
5 | 5 | /** |
6 | 6 | * Configuration reference: https://github.com/edenhill/librdkafka/blob/master/CONFIGURATION.md |
7 | 7 | */ |
8 | -class TopicConf |
|
9 | -{ |
|
8 | +class TopicConf { |
|
10 | 9 | public function __construct() {} |
11 | 10 | |
12 | 11 | /** |
@@ -4,13 +4,13 @@ |
||
4 | 4 | |
5 | 5 | class KafkaConsumerTopic extends Topic |
6 | 6 | { |
7 | - private function __construct() {} |
|
7 | + private function __construct() {} |
|
8 | 8 | |
9 | - /** |
|
10 | - * @param int $partition |
|
11 | - * @param int $offset |
|
12 | - * |
|
13 | - * @return void |
|
14 | - */ |
|
15 | - public function offsetStore($partition, $offset) {} |
|
9 | + /** |
|
10 | + * @param int $partition |
|
11 | + * @param int $offset |
|
12 | + * |
|
13 | + * @return void |
|
14 | + */ |
|
15 | + public function offsetStore($partition, $offset) {} |
|
16 | 16 | } |
@@ -2,8 +2,7 @@ |
||
2 | 2 | |
3 | 3 | namespace RdKafka; |
4 | 4 | |
5 | -class KafkaConsumerTopic extends Topic |
|
6 | -{ |
|
5 | +class KafkaConsumerTopic extends Topic { |
|
7 | 6 | private function __construct() {} |
8 | 7 | |
9 | 8 | /** |
@@ -4,121 +4,121 @@ |
||
4 | 4 | |
5 | 5 | class KafkaConsumer |
6 | 6 | { |
7 | - /** |
|
8 | - * @param Conf $conf |
|
9 | - */ |
|
10 | - public function __construct($conf) {} |
|
11 | - |
|
12 | - /** |
|
13 | - * @param TopicPartition[] $topic_partitions |
|
14 | - * |
|
15 | - * @throws Exception |
|
16 | - * @return void |
|
17 | - */ |
|
18 | - public function assign($topic_partitions = null) {} |
|
19 | - |
|
20 | - /** |
|
21 | - * @param null|Message|TopicPartition[] $message_or_offsets |
|
22 | - * |
|
23 | - * @throws Exception |
|
24 | - * @return void |
|
25 | - */ |
|
26 | - public function commit($message_or_offsets = null) {} |
|
27 | - |
|
28 | - /** |
|
29 | - * @param null|Message|TopicPartition[] $message_or_offsets |
|
30 | - * |
|
31 | - * @throws Exception |
|
32 | - * @return void |
|
33 | - */ |
|
34 | - public function commitAsync($message_or_offsets = null) {} |
|
35 | - |
|
36 | - /** |
|
37 | - * @param int $timeout_ms |
|
38 | - * |
|
39 | - * @throws Exception |
|
40 | - * @throws \InvalidArgumentException |
|
41 | - * @return Message |
|
42 | - */ |
|
43 | - public function consume($timeout_ms) {} |
|
44 | - |
|
45 | - /** |
|
46 | - * @throws Exception |
|
47 | - * @return TopicPartition[] |
|
48 | - */ |
|
49 | - public function getAssignment() {} |
|
50 | - |
|
51 | - /** |
|
52 | - * @param bool $all_topics |
|
53 | - * @param KafkaConsumerTopic $only_topic |
|
54 | - * @param int $timeout_ms |
|
55 | - * |
|
56 | - * @throws Exception |
|
57 | - * @return Metadata |
|
58 | - */ |
|
59 | - public function getMetadata($all_topics, $only_topic = null, $timeout_ms) {} |
|
60 | - |
|
61 | - /** |
|
62 | - * @return array |
|
63 | - */ |
|
64 | - public function getSubscription() {} |
|
65 | - |
|
66 | - /** |
|
67 | - * @param array $topics |
|
68 | - * |
|
69 | - * @throws Exception |
|
70 | - * @return void |
|
71 | - */ |
|
72 | - public function subscribe($topics) {} |
|
73 | - |
|
74 | - /** |
|
75 | - * @throws Exception |
|
76 | - * @return void |
|
77 | - */ |
|
78 | - public function unsubscribe() {} |
|
79 | - |
|
80 | - /** |
|
81 | - * @param array $topic_partitions |
|
82 | - * @param int $timeout_ms |
|
83 | - * |
|
84 | - * @return array |
|
85 | - */ |
|
86 | - public function getCommittedOffsets($topic_partitions, $timeout_ms) {} |
|
87 | - |
|
88 | - /** |
|
89 | - * @param TopicPartition[] $topic_partitions |
|
90 | - * @param int $timeout_ms |
|
91 | - * |
|
92 | - * @return TopicPartition[] |
|
93 | - */ |
|
94 | - public function offsetsForTimes($topic_partitions, $timeout_ms) {} |
|
95 | - |
|
96 | - /** |
|
97 | - * @param string $topic |
|
98 | - * @param int $partition |
|
99 | - * @param int &$low |
|
100 | - * @param int &$high |
|
101 | - * @param int $timeout_ms |
|
102 | - * |
|
103 | - * @return void |
|
104 | - */ |
|
105 | - public function queryWatermarkOffsets($topic, $partition = 0, &$low = 0, &$high = 0, $timeout_ms = 0) {} |
|
106 | - |
|
107 | - /** |
|
108 | - * @param TopicPartition[] $topic_partitions |
|
109 | - */ |
|
110 | - public function getOffsetPositions($topic_partitions) {} |
|
111 | - |
|
112 | - /** |
|
113 | - * @param string $topic_name |
|
114 | - * @param null|TopicConf $topic_conf |
|
115 | - * |
|
116 | - * @return Topic |
|
117 | - */ |
|
118 | - public function newTopic($topic_name, $topic_conf = null) {} |
|
119 | - |
|
120 | - /** |
|
121 | - * @return void |
|
122 | - */ |
|
123 | - public function close() {} |
|
7 | + /** |
|
8 | + * @param Conf $conf |
|
9 | + */ |
|
10 | + public function __construct($conf) {} |
|
11 | + |
|
12 | + /** |
|
13 | + * @param TopicPartition[] $topic_partitions |
|
14 | + * |
|
15 | + * @throws Exception |
|
16 | + * @return void |
|
17 | + */ |
|
18 | + public function assign($topic_partitions = null) {} |
|
19 | + |
|
20 | + /** |
|
21 | + * @param null|Message|TopicPartition[] $message_or_offsets |
|
22 | + * |
|
23 | + * @throws Exception |
|
24 | + * @return void |
|
25 | + */ |
|
26 | + public function commit($message_or_offsets = null) {} |
|
27 | + |
|
28 | + /** |
|
29 | + * @param null|Message|TopicPartition[] $message_or_offsets |
|
30 | + * |
|
31 | + * @throws Exception |
|
32 | + * @return void |
|
33 | + */ |
|
34 | + public function commitAsync($message_or_offsets = null) {} |
|
35 | + |
|
36 | + /** |
|
37 | + * @param int $timeout_ms |
|
38 | + * |
|
39 | + * @throws Exception |
|
40 | + * @throws \InvalidArgumentException |
|
41 | + * @return Message |
|
42 | + */ |
|
43 | + public function consume($timeout_ms) {} |
|
44 | + |
|
45 | + /** |
|
46 | + * @throws Exception |
|
47 | + * @return TopicPartition[] |
|
48 | + */ |
|
49 | + public function getAssignment() {} |
|
50 | + |
|
51 | + /** |
|
52 | + * @param bool $all_topics |
|
53 | + * @param KafkaConsumerTopic $only_topic |
|
54 | + * @param int $timeout_ms |
|
55 | + * |
|
56 | + * @throws Exception |
|
57 | + * @return Metadata |
|
58 | + */ |
|
59 | + public function getMetadata($all_topics, $only_topic = null, $timeout_ms) {} |
|
60 | + |
|
61 | + /** |
|
62 | + * @return array |
|
63 | + */ |
|
64 | + public function getSubscription() {} |
|
65 | + |
|
66 | + /** |
|
67 | + * @param array $topics |
|
68 | + * |
|
69 | + * @throws Exception |
|
70 | + * @return void |
|
71 | + */ |
|
72 | + public function subscribe($topics) {} |
|
73 | + |
|
74 | + /** |
|
75 | + * @throws Exception |
|
76 | + * @return void |
|
77 | + */ |
|
78 | + public function unsubscribe() {} |
|
79 | + |
|
80 | + /** |
|
81 | + * @param array $topic_partitions |
|
82 | + * @param int $timeout_ms |
|
83 | + * |
|
84 | + * @return array |
|
85 | + */ |
|
86 | + public function getCommittedOffsets($topic_partitions, $timeout_ms) {} |
|
87 | + |
|
88 | + /** |
|
89 | + * @param TopicPartition[] $topic_partitions |
|
90 | + * @param int $timeout_ms |
|
91 | + * |
|
92 | + * @return TopicPartition[] |
|
93 | + */ |
|
94 | + public function offsetsForTimes($topic_partitions, $timeout_ms) {} |
|
95 | + |
|
96 | + /** |
|
97 | + * @param string $topic |
|
98 | + * @param int $partition |
|
99 | + * @param int &$low |
|
100 | + * @param int &$high |
|
101 | + * @param int $timeout_ms |
|
102 | + * |
|
103 | + * @return void |
|
104 | + */ |
|
105 | + public function queryWatermarkOffsets($topic, $partition = 0, &$low = 0, &$high = 0, $timeout_ms = 0) {} |
|
106 | + |
|
107 | + /** |
|
108 | + * @param TopicPartition[] $topic_partitions |
|
109 | + */ |
|
110 | + public function getOffsetPositions($topic_partitions) {} |
|
111 | + |
|
112 | + /** |
|
113 | + * @param string $topic_name |
|
114 | + * @param null|TopicConf $topic_conf |
|
115 | + * |
|
116 | + * @return Topic |
|
117 | + */ |
|
118 | + public function newTopic($topic_name, $topic_conf = null) {} |
|
119 | + |
|
120 | + /** |
|
121 | + * @return void |
|
122 | + */ |
|
123 | + public function close() {} |
|
124 | 124 | } |
@@ -2,8 +2,7 @@ |
||
2 | 2 | |
3 | 3 | namespace RdKafka; |
4 | 4 | |
5 | -class KafkaConsumer |
|
6 | -{ |
|
5 | +class KafkaConsumer { |
|
7 | 6 | /** |
8 | 7 | * @param Conf $conf |
9 | 8 | */ |
@@ -4,29 +4,29 @@ |
||
4 | 4 | |
5 | 5 | class ProducerTopic extends Topic |
6 | 6 | { |
7 | - private function __construct() {} |
|
7 | + private function __construct() {} |
|
8 | 8 | |
9 | - /** |
|
10 | - * @param int $partition |
|
11 | - * @param int $msgflags |
|
12 | - * @param string|null $payload |
|
13 | - * @param string|null $key |
|
14 | - * @param string|null $msg_opaque |
|
15 | - * |
|
16 | - * @return void |
|
17 | - */ |
|
18 | - public function produce($partition, $msgflags, $payload = null, $key = null, $msg_opaque = null) {} |
|
9 | + /** |
|
10 | + * @param int $partition |
|
11 | + * @param int $msgflags |
|
12 | + * @param string|null $payload |
|
13 | + * @param string|null $key |
|
14 | + * @param string|null $msg_opaque |
|
15 | + * |
|
16 | + * @return void |
|
17 | + */ |
|
18 | + public function produce($partition, $msgflags, $payload = null, $key = null, $msg_opaque = null) {} |
|
19 | 19 | |
20 | - /** |
|
21 | - * @param int $partition |
|
22 | - * @param int $msgflags |
|
23 | - * @param string|null $payload |
|
24 | - * @param string|null $key |
|
25 | - * @param array|null $headers |
|
26 | - * @param int $timestamp_ms |
|
27 | - * @param string|null $msg_opaque |
|
28 | - * |
|
29 | - * @return void |
|
30 | - */ |
|
31 | - public function producev($partition, $msgflags, $payload = null, $key = null, $headers = null, $timestamp_ms = 0, $msg_opaque = null) {} |
|
20 | + /** |
|
21 | + * @param int $partition |
|
22 | + * @param int $msgflags |
|
23 | + * @param string|null $payload |
|
24 | + * @param string|null $key |
|
25 | + * @param array|null $headers |
|
26 | + * @param int $timestamp_ms |
|
27 | + * @param string|null $msg_opaque |
|
28 | + * |
|
29 | + * @return void |
|
30 | + */ |
|
31 | + public function producev($partition, $msgflags, $payload = null, $key = null, $headers = null, $timestamp_ms = 0, $msg_opaque = null) {} |
|
32 | 32 | } |
@@ -2,8 +2,7 @@ |
||
2 | 2 | |
3 | 3 | namespace RdKafka; |
4 | 4 | |
5 | -class ProducerTopic extends Topic |
|
6 | -{ |
|
5 | +class ProducerTopic extends Topic { |
|
7 | 6 | private function __construct() {} |
8 | 7 | |
9 | 8 | /** |
@@ -4,49 +4,49 @@ |
||
4 | 4 | |
5 | 5 | class ConsumerTopic extends Topic |
6 | 6 | { |
7 | - private function __construct() {} |
|
8 | - |
|
9 | - /** |
|
10 | - * @param int $partition |
|
11 | - * @param int $timeout_ms |
|
12 | - * |
|
13 | - * @return Message |
|
14 | - */ |
|
15 | - public function consume($partition, $timeout_ms) {} |
|
16 | - |
|
17 | - /** |
|
18 | - * @param int $partition |
|
19 | - * @param int $offset |
|
20 | - * @param Queue $queue |
|
21 | - * |
|
22 | - * @return void |
|
23 | - */ |
|
24 | - public function consumeQueueStart($partition, $offset, $queue) {} |
|
25 | - |
|
26 | - /** |
|
27 | - * @param int $partition |
|
28 | - * @param int $offset |
|
29 | - * |
|
30 | - * @return void |
|
31 | - */ |
|
32 | - public function consumeStart($partition, $offset) {} |
|
33 | - |
|
34 | - /** |
|
35 | - * @param int $partition |
|
36 | - * |
|
37 | - * @return void |
|
38 | - */ |
|
39 | - public function consumeStop($partition) {} |
|
40 | - |
|
41 | - /** |
|
42 | - * @param int $partition |
|
43 | - * @param int $offset |
|
44 | - * |
|
45 | - * @return void |
|
46 | - */ |
|
47 | - public function offsetStore($partition, $offset) {} |
|
48 | - |
|
49 | - public function consumeCallback($partition, $timeout_ms, $callback) {} |
|
50 | - |
|
51 | - public function consumeBatch($partition, $timeout_ms, $batch_size) {} |
|
7 | + private function __construct() {} |
|
8 | + |
|
9 | + /** |
|
10 | + * @param int $partition |
|
11 | + * @param int $timeout_ms |
|
12 | + * |
|
13 | + * @return Message |
|
14 | + */ |
|
15 | + public function consume($partition, $timeout_ms) {} |
|
16 | + |
|
17 | + /** |
|
18 | + * @param int $partition |
|
19 | + * @param int $offset |
|
20 | + * @param Queue $queue |
|
21 | + * |
|
22 | + * @return void |
|
23 | + */ |
|
24 | + public function consumeQueueStart($partition, $offset, $queue) {} |
|
25 | + |
|
26 | + /** |
|
27 | + * @param int $partition |
|
28 | + * @param int $offset |
|
29 | + * |
|
30 | + * @return void |
|
31 | + */ |
|
32 | + public function consumeStart($partition, $offset) {} |
|
33 | + |
|
34 | + /** |
|
35 | + * @param int $partition |
|
36 | + * |
|
37 | + * @return void |
|
38 | + */ |
|
39 | + public function consumeStop($partition) {} |
|
40 | + |
|
41 | + /** |
|
42 | + * @param int $partition |
|
43 | + * @param int $offset |
|
44 | + * |
|
45 | + * @return void |
|
46 | + */ |
|
47 | + public function offsetStore($partition, $offset) {} |
|
48 | + |
|
49 | + public function consumeCallback($partition, $timeout_ms, $callback) {} |
|
50 | + |
|
51 | + public function consumeBatch($partition, $timeout_ms, $batch_size) {} |
|
52 | 52 | } |
@@ -2,8 +2,7 @@ |
||
2 | 2 | |
3 | 3 | namespace RdKafka; |
4 | 4 | |
5 | -class ConsumerTopic extends Topic |
|
6 | -{ |
|
5 | +class ConsumerTopic extends Topic { |
|
7 | 6 | private function __construct() {} |
8 | 7 | |
9 | 8 | /** |
@@ -8,86 +8,86 @@ |
||
8 | 8 | |
9 | 9 | abstract class RdKafka |
10 | 10 | { |
11 | - /** |
|
12 | - * @param string $broker_list |
|
13 | - * |
|
14 | - * @return int |
|
15 | - */ |
|
16 | - public function addBrokers($broker_list) {} |
|
11 | + /** |
|
12 | + * @param string $broker_list |
|
13 | + * |
|
14 | + * @return int |
|
15 | + */ |
|
16 | + public function addBrokers($broker_list) {} |
|
17 | 17 | |
18 | - /** |
|
19 | - * @param bool $all_topics |
|
20 | - * @param Topic $only_topic |
|
21 | - * @param int $timeout_ms |
|
22 | - * |
|
23 | - * @throws Exception |
|
24 | - * @return Metadata |
|
25 | - */ |
|
26 | - public function getMetadata($all_topics, $only_topic = null, $timeout_ms = 0) {} |
|
18 | + /** |
|
19 | + * @param bool $all_topics |
|
20 | + * @param Topic $only_topic |
|
21 | + * @param int $timeout_ms |
|
22 | + * |
|
23 | + * @throws Exception |
|
24 | + * @return Metadata |
|
25 | + */ |
|
26 | + public function getMetadata($all_topics, $only_topic = null, $timeout_ms = 0) {} |
|
27 | 27 | |
28 | - /** |
|
29 | - * @return int |
|
30 | - */ |
|
31 | - public function getOutQLen() {} |
|
28 | + /** |
|
29 | + * @return int |
|
30 | + */ |
|
31 | + public function getOutQLen() {} |
|
32 | 32 | |
33 | - /** |
|
34 | - * @param string $topic_name |
|
35 | - * @param null|TopicConf $topic_conf |
|
36 | - * |
|
37 | - * @return Topic |
|
38 | - */ |
|
39 | - public function newTopic($topic_name, $topic_conf = null) {} |
|
33 | + /** |
|
34 | + * @param string $topic_name |
|
35 | + * @param null|TopicConf $topic_conf |
|
36 | + * |
|
37 | + * @return Topic |
|
38 | + */ |
|
39 | + public function newTopic($topic_name, $topic_conf = null) {} |
|
40 | 40 | |
41 | - /** |
|
42 | - * @param int $timeout_ms |
|
43 | - * |
|
44 | - * @return void |
|
45 | - */ |
|
46 | - public function poll($timeout_ms) {} |
|
41 | + /** |
|
42 | + * @param int $timeout_ms |
|
43 | + * |
|
44 | + * @return void |
|
45 | + */ |
|
46 | + public function poll($timeout_ms) {} |
|
47 | 47 | |
48 | - /** |
|
49 | - * @param int $level |
|
50 | - * |
|
51 | - * @return void |
|
52 | - */ |
|
53 | - public function setLogLevel($level) {} |
|
48 | + /** |
|
49 | + * @param int $level |
|
50 | + * |
|
51 | + * @return void |
|
52 | + */ |
|
53 | + public function setLogLevel($level) {} |
|
54 | 54 | |
55 | - /** |
|
56 | - * @param TopicPartition[] $topic_partitions |
|
57 | - * @param int $timeout_ms |
|
58 | - * |
|
59 | - * @return TopicPartition[] |
|
60 | - */ |
|
61 | - public function offsetsForTimes($topic_partitions, $timeout_ms) {} |
|
55 | + /** |
|
56 | + * @param TopicPartition[] $topic_partitions |
|
57 | + * @param int $timeout_ms |
|
58 | + * |
|
59 | + * @return TopicPartition[] |
|
60 | + */ |
|
61 | + public function offsetsForTimes($topic_partitions, $timeout_ms) {} |
|
62 | 62 | |
63 | - /** |
|
64 | - * @param string $topic |
|
65 | - * @param int $partition |
|
66 | - * @param int $low |
|
67 | - * @param int $high |
|
68 | - * @param int $timeout_ms |
|
69 | - * |
|
70 | - * @return void |
|
71 | - */ |
|
72 | - public function queryWatermarkOffsets($topic, $partition = 0, &$low = 0, &$high = 0, $timeout_ms = 0) {} |
|
63 | + /** |
|
64 | + * @param string $topic |
|
65 | + * @param int $partition |
|
66 | + * @param int $low |
|
67 | + * @param int $high |
|
68 | + * @param int $timeout_ms |
|
69 | + * |
|
70 | + * @return void |
|
71 | + */ |
|
72 | + public function queryWatermarkOffsets($topic, $partition = 0, &$low = 0, &$high = 0, $timeout_ms = 0) {} |
|
73 | 73 | |
74 | - /** |
|
75 | - * @param int $purge_flags |
|
76 | - * |
|
77 | - * @return int |
|
78 | - */ |
|
79 | - public function purge($purge_flags) {} |
|
74 | + /** |
|
75 | + * @param int $purge_flags |
|
76 | + * |
|
77 | + * @return int |
|
78 | + */ |
|
79 | + public function purge($purge_flags) {} |
|
80 | 80 | |
81 | - /** |
|
82 | - * @param int $timeout_ms |
|
83 | - * |
|
84 | - * @return int |
|
85 | - */ |
|
86 | - public function flush($timeout_ms) {} |
|
81 | + /** |
|
82 | + * @param int $timeout_ms |
|
83 | + * |
|
84 | + * @return int |
|
85 | + */ |
|
86 | + public function flush($timeout_ms) {} |
|
87 | 87 | |
88 | - public function metadata($all_topics, $only_topic = false, $timeout_ms = 0) {} |
|
88 | + public function metadata($all_topics, $only_topic = false, $timeout_ms = 0) {} |
|
89 | 89 | |
90 | - public function setLogger($logger) {} |
|
90 | + public function setLogger($logger) {} |
|
91 | 91 | |
92 | - public function outqLen() {} |
|
92 | + public function outqLen() {} |
|
93 | 93 | } |
@@ -6,8 +6,7 @@ |
||
6 | 6 | use RdKafka\TopicConf; |
7 | 7 | use RdKafka\TopicPartition; |
8 | 8 | |
9 | -abstract class RdKafka |
|
10 | -{ |
|
9 | +abstract class RdKafka { |
|
11 | 10 | /** |
12 | 11 | * @param string $broker_list |
13 | 12 | * |
@@ -4,44 +4,44 @@ |
||
4 | 4 | /** Metadata entry for a single AST kind, as returned by ast\get_metadata(). */ |
5 | 5 | class Metadata |
6 | 6 | { |
7 | - /** @var string[] List of supported flags. The flags are given as names of constants, such as "ast\flags\TYPE_STRING". */ |
|
8 | - public $flags; |
|
9 | - /** @var bool Whether the flags are exclusive or combinable. Exclusive flags should be checked using ===, while combinable flags should be checked using &. */ |
|
10 | - public $flagsCombinable; |
|
11 | - /** @var int AST node kind (one of the `ast\AST_*` constants). */ |
|
12 | - public $kind; |
|
13 | - /** @var string Name of the node kind (e.g. "AST_NAME"). */ |
|
14 | - public $name; |
|
7 | + /** @var string[] List of supported flags. The flags are given as names of constants, such as "ast\flags\TYPE_STRING". */ |
|
8 | + public $flags; |
|
9 | + /** @var bool Whether the flags are exclusive or combinable. Exclusive flags should be checked using ===, while combinable flags should be checked using &. */ |
|
10 | + public $flagsCombinable; |
|
11 | + /** @var int AST node kind (one of the `ast\AST_*` constants). */ |
|
12 | + public $kind; |
|
13 | + /** @var string Name of the node kind (e.g. "AST_NAME"). */ |
|
14 | + public $name; |
|
15 | 15 | } |
16 | 16 | |
17 | 17 | /** This class describes a single node in a PHP AST. */ |
18 | 18 | class Node |
19 | 19 | { |
20 | - /** @var array Child nodes (may be empty) */ |
|
21 | - public $children; |
|
20 | + /** @var array Child nodes (may be empty) */ |
|
21 | + public $children; |
|
22 | 22 | |
23 | - /** @var int Line the node ends on. */ |
|
24 | - public $endLineno; |
|
23 | + /** @var int Line the node ends on. */ |
|
24 | + public $endLineno; |
|
25 | 25 | |
26 | - /** @var int Certain node kinds have flags that can be set. These will be a bitfield of `ast\flags\*` constants. */ |
|
27 | - public $flags; |
|
26 | + /** @var int Certain node kinds have flags that can be set. These will be a bitfield of `ast\flags\*` constants. */ |
|
27 | + public $flags; |
|
28 | 28 | |
29 | - /** @var int AST Node Kind. Values are one of `ast\AST_*` constants. */ |
|
30 | - public $kind; |
|
29 | + /** @var int AST Node Kind. Values are one of `ast\AST_*` constants. */ |
|
30 | + public $kind; |
|
31 | 31 | |
32 | - /** @var int Line the node starts on. */ |
|
33 | - public $lineno; |
|
32 | + /** @var int Line the node starts on. */ |
|
33 | + public $lineno; |
|
34 | 34 | |
35 | - /** |
|
36 | - * A constructor which accepts any types for the properties. |
|
37 | - * For backwards compatibility reasons, all values are optional and can be any type, and properties default to null. |
|
38 | - * |
|
39 | - * @param int|null $kind |
|
40 | - * @param int|null $flags |
|
41 | - * @param array|null $children |
|
42 | - * @param int|null $lineno |
|
43 | - */ |
|
44 | - public function __construct(?int $kind = null, ?int $flags = null, ?array $children = null, ?int $lineno = null) {} |
|
35 | + /** |
|
36 | + * A constructor which accepts any types for the properties. |
|
37 | + * For backwards compatibility reasons, all values are optional and can be any type, and properties default to null. |
|
38 | + * |
|
39 | + * @param int|null $kind |
|
40 | + * @param int|null $flags |
|
41 | + * @param array|null $children |
|
42 | + * @param int|null $lineno |
|
43 | + */ |
|
44 | + public function __construct(?int $kind = null, ?int $flags = null, ?array $children = null, ?int $lineno = null) {} |
|
45 | 45 | } |
46 | 46 | |
47 | 47 | /** |
@@ -2,8 +2,7 @@ discard block |
||
2 | 2 | |
3 | 3 | namespace ast { |
4 | 4 | /** Metadata entry for a single AST kind, as returned by ast\get_metadata(). */ |
5 | -class Metadata |
|
6 | -{ |
|
5 | +class Metadata { |
|
7 | 6 | /** @var string[] List of supported flags. The flags are given as names of constants, such as "ast\flags\TYPE_STRING". */ |
8 | 7 | public $flags; |
9 | 8 | /** @var bool Whether the flags are exclusive or combinable. Exclusive flags should be checked using ===, while combinable flags should be checked using &. */ |
@@ -15,8 +14,7 @@ discard block |
||
15 | 14 | } |
16 | 15 | |
17 | 16 | /** This class describes a single node in a PHP AST. */ |
18 | -class Node |
|
19 | -{ |
|
17 | +class Node { |
|
20 | 18 | /** @var array Child nodes (may be empty) */ |
21 | 19 | public $children; |
22 | 20 |