@@ -4,28 +4,28 @@ |
||
4 | 4 | |
5 | 5 | class Partition |
6 | 6 | { |
7 | - /** |
|
8 | - * @return int |
|
9 | - */ |
|
10 | - public function getId() {} |
|
7 | + /** |
|
8 | + * @return int |
|
9 | + */ |
|
10 | + public function getId() {} |
|
11 | 11 | |
12 | - /** |
|
13 | - * @return mixed |
|
14 | - */ |
|
15 | - public function getErr() {} |
|
12 | + /** |
|
13 | + * @return mixed |
|
14 | + */ |
|
15 | + public function getErr() {} |
|
16 | 16 | |
17 | - /** |
|
18 | - * @return mixed |
|
19 | - */ |
|
20 | - public function getLeader() {} |
|
17 | + /** |
|
18 | + * @return mixed |
|
19 | + */ |
|
20 | + public function getLeader() {} |
|
21 | 21 | |
22 | - /** |
|
23 | - * @return mixed |
|
24 | - */ |
|
25 | - public function getReplicas() {} |
|
22 | + /** |
|
23 | + * @return mixed |
|
24 | + */ |
|
25 | + public function getReplicas() {} |
|
26 | 26 | |
27 | - /** |
|
28 | - * @return mixed |
|
29 | - */ |
|
30 | - public function getIsrs() {} |
|
27 | + /** |
|
28 | + * @return mixed |
|
29 | + */ |
|
30 | + public function getIsrs() {} |
|
31 | 31 | } |
@@ -2,8 +2,7 @@ |
||
2 | 2 | |
3 | 3 | namespace RdKafka\Metadata; |
4 | 4 | |
5 | -class Partition |
|
6 | -{ |
|
5 | +class Partition { |
|
7 | 6 | /** |
8 | 7 | * @return int |
9 | 8 | */ |
@@ -4,9 +4,9 @@ |
||
4 | 4 | |
5 | 5 | class Broker |
6 | 6 | { |
7 | - public function getId() {} |
|
7 | + public function getId() {} |
|
8 | 8 | |
9 | - public function getHost() {} |
|
9 | + public function getHost() {} |
|
10 | 10 | |
11 | - public function getPort() {} |
|
11 | + public function getPort() {} |
|
12 | 12 | } |
@@ -2,8 +2,7 @@ |
||
2 | 2 | |
3 | 3 | namespace RdKafka\Metadata; |
4 | 4 | |
5 | -class Broker |
|
6 | -{ |
|
5 | +class Broker { |
|
7 | 6 | public function getId() {} |
8 | 7 | |
9 | 8 | public function getHost() {} |
@@ -4,18 +4,18 @@ |
||
4 | 4 | |
5 | 5 | class Topic |
6 | 6 | { |
7 | - /** |
|
8 | - * @return string |
|
9 | - */ |
|
10 | - public function getTopic() {} |
|
7 | + /** |
|
8 | + * @return string |
|
9 | + */ |
|
10 | + public function getTopic() {} |
|
11 | 11 | |
12 | - /** |
|
13 | - * @return Partition[] |
|
14 | - */ |
|
15 | - public function getPartitions() {} |
|
12 | + /** |
|
13 | + * @return Partition[] |
|
14 | + */ |
|
15 | + public function getPartitions() {} |
|
16 | 16 | |
17 | - /** |
|
18 | - * @return mixed |
|
19 | - */ |
|
20 | - public function getErr() {} |
|
17 | + /** |
|
18 | + * @return mixed |
|
19 | + */ |
|
20 | + public function getErr() {} |
|
21 | 21 | } |
@@ -2,8 +2,7 @@ |
||
2 | 2 | |
3 | 3 | namespace RdKafka\Metadata; |
4 | 4 | |
5 | -class Topic |
|
6 | -{ |
|
5 | +class Topic { |
|
7 | 6 | /** |
8 | 7 | * @return string |
9 | 8 | */ |
@@ -7,74 +7,74 @@ |
||
7 | 7 | */ |
8 | 8 | class Conf |
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 TopicConf $topic_conf |
|
27 | - * |
|
28 | - * @return void |
|
29 | - */ |
|
30 | - public function setDefaultTopicConf($topic_conf) {} |
|
25 | + /** |
|
26 | + * @param TopicConf $topic_conf |
|
27 | + * |
|
28 | + * @return void |
|
29 | + */ |
|
30 | + public function setDefaultTopicConf($topic_conf) {} |
|
31 | 31 | |
32 | - /** |
|
33 | - * @param callable $callback |
|
34 | - * |
|
35 | - * @return void |
|
36 | - */ |
|
37 | - public function setDrMsgCb($callback) {} |
|
32 | + /** |
|
33 | + * @param callable $callback |
|
34 | + * |
|
35 | + * @return void |
|
36 | + */ |
|
37 | + public function setDrMsgCb($callback) {} |
|
38 | 38 | |
39 | - /** |
|
40 | - * @param callable $callback |
|
41 | - * |
|
42 | - * @return void |
|
43 | - */ |
|
44 | - public function setErrorCb($callback) {} |
|
39 | + /** |
|
40 | + * @param callable $callback |
|
41 | + * |
|
42 | + * @return void |
|
43 | + */ |
|
44 | + public function setErrorCb($callback) {} |
|
45 | 45 | |
46 | - /** |
|
47 | - * @param callable $callback |
|
48 | - * |
|
49 | - * @return void |
|
50 | - */ |
|
51 | - public function setRebalanceCb($callback) {} |
|
46 | + /** |
|
47 | + * @param callable $callback |
|
48 | + * |
|
49 | + * @return void |
|
50 | + */ |
|
51 | + public function setRebalanceCb($callback) {} |
|
52 | 52 | |
53 | - /** |
|
54 | - * @param callable $callback |
|
55 | - * |
|
56 | - * @return void |
|
57 | - */ |
|
58 | - public function setStatsCb($callback) {} |
|
53 | + /** |
|
54 | + * @param callable $callback |
|
55 | + * |
|
56 | + * @return void |
|
57 | + */ |
|
58 | + public function setStatsCb($callback) {} |
|
59 | 59 | |
60 | - /** |
|
61 | - * @param callable $callback |
|
62 | - * |
|
63 | - * @return void |
|
64 | - */ |
|
65 | - public function setOffsetCommitCb($callback) {} |
|
60 | + /** |
|
61 | + * @param callable $callback |
|
62 | + * |
|
63 | + * @return void |
|
64 | + */ |
|
65 | + public function setOffsetCommitCb($callback) {} |
|
66 | 66 | |
67 | - /** |
|
68 | - * @param callable $callback |
|
69 | - * |
|
70 | - * @return void |
|
71 | - */ |
|
72 | - public function setConsumeCb($callback) {} |
|
67 | + /** |
|
68 | + * @param callable $callback |
|
69 | + * |
|
70 | + * @return void |
|
71 | + */ |
|
72 | + public function setConsumeCb($callback) {} |
|
73 | 73 | |
74 | - /** |
|
75 | - * @param callable $callback |
|
76 | - * |
|
77 | - * @return void |
|
78 | - */ |
|
79 | - public function setLogCb($callback) {} |
|
74 | + /** |
|
75 | + * @param callable $callback |
|
76 | + * |
|
77 | + * @return void |
|
78 | + */ |
|
79 | + public function setLogCb($callback) {} |
|
80 | 80 | } |
@@ -5,8 +5,7 @@ |
||
5 | 5 | /** |
6 | 6 | * Configuration reference: https://github.com/edenhill/librdkafka/blob/master/CONFIGURATION.md |
7 | 7 | */ |
8 | -class Conf |
|
9 | -{ |
|
8 | +class Conf { |
|
10 | 9 | public function __construct() {} |
11 | 10 | |
12 | 11 | /** |
@@ -4,33 +4,33 @@ |
||
4 | 4 | |
5 | 5 | class KafkaErrorException extends Exception |
6 | 6 | { |
7 | - /** |
|
8 | - * @param string $message |
|
9 | - * @param int $code |
|
10 | - * @param string $error_string |
|
11 | - * @param bool $isFatal |
|
12 | - * @param bool $isRetriable |
|
13 | - * @param bool $transactionRequiresAbort |
|
14 | - */ |
|
15 | - public function __construct($message, $code, $error_string, $isFatal, $isRetriable, $transactionRequiresAbort) {} |
|
7 | + /** |
|
8 | + * @param string $message |
|
9 | + * @param int $code |
|
10 | + * @param string $error_string |
|
11 | + * @param bool $isFatal |
|
12 | + * @param bool $isRetriable |
|
13 | + * @param bool $transactionRequiresAbort |
|
14 | + */ |
|
15 | + public function __construct($message, $code, $error_string, $isFatal, $isRetriable, $transactionRequiresAbort) {} |
|
16 | 16 | |
17 | - /** |
|
18 | - * @return string |
|
19 | - */ |
|
20 | - public function getErrorString() {} |
|
17 | + /** |
|
18 | + * @return string |
|
19 | + */ |
|
20 | + public function getErrorString() {} |
|
21 | 21 | |
22 | - /** |
|
23 | - * @return bool |
|
24 | - */ |
|
25 | - public function isFatal() {} |
|
22 | + /** |
|
23 | + * @return bool |
|
24 | + */ |
|
25 | + public function isFatal() {} |
|
26 | 26 | |
27 | - /** |
|
28 | - * @return bool |
|
29 | - */ |
|
30 | - public function isRetriable() {} |
|
27 | + /** |
|
28 | + * @return bool |
|
29 | + */ |
|
30 | + public function isRetriable() {} |
|
31 | 31 | |
32 | - /** |
|
33 | - * @return bool |
|
34 | - */ |
|
35 | - public function transactionRequiresAbort() {} |
|
32 | + /** |
|
33 | + * @return bool |
|
34 | + */ |
|
35 | + public function transactionRequiresAbort() {} |
|
36 | 36 | } |
@@ -2,8 +2,7 @@ |
||
2 | 2 | |
3 | 3 | namespace RdKafka; |
4 | 4 | |
5 | -class KafkaErrorException extends Exception |
|
6 | -{ |
|
5 | +class KafkaErrorException extends Exception { |
|
7 | 6 | /** |
8 | 7 | * @param string $message |
9 | 8 | * @param int $code |
@@ -4,42 +4,42 @@ |
||
4 | 4 | |
5 | 5 | class Producer 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 ProducerTopic |
|
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 ProducerTopic |
|
17 | + */ |
|
18 | + public function newTopic($topic_name, ?TopicConf $topic_conf = null) {} |
|
19 | 19 | |
20 | - /** |
|
21 | - * @param int $timeout_ms |
|
22 | - * |
|
23 | - * @return void |
|
24 | - */ |
|
25 | - public function initTransactions($timeout_ms) {} |
|
20 | + /** |
|
21 | + * @param int $timeout_ms |
|
22 | + * |
|
23 | + * @return void |
|
24 | + */ |
|
25 | + public function initTransactions($timeout_ms) {} |
|
26 | 26 | |
27 | - /** |
|
28 | - * @return void |
|
29 | - */ |
|
30 | - public function beginTransaction() {} |
|
27 | + /** |
|
28 | + * @return void |
|
29 | + */ |
|
30 | + public function beginTransaction() {} |
|
31 | 31 | |
32 | - /** |
|
33 | - * @param int $timeout_ms |
|
34 | - * |
|
35 | - * @return void |
|
36 | - */ |
|
37 | - public function commitTransaction($timeout_ms) {} |
|
32 | + /** |
|
33 | + * @param int $timeout_ms |
|
34 | + * |
|
35 | + * @return void |
|
36 | + */ |
|
37 | + public function commitTransaction($timeout_ms) {} |
|
38 | 38 | |
39 | - /** |
|
40 | - * @param int $timeout_ms |
|
41 | - * |
|
42 | - * @return void |
|
43 | - */ |
|
44 | - public function abortTransaction($timeout_ms) {} |
|
39 | + /** |
|
40 | + * @param int $timeout_ms |
|
41 | + * |
|
42 | + * @return void |
|
43 | + */ |
|
44 | + public function abortTransaction($timeout_ms) {} |
|
45 | 45 | } |
@@ -7,23 +7,23 @@ |
||
7 | 7 | |
8 | 8 | class Metadata |
9 | 9 | { |
10 | - /** |
|
11 | - * @return Collection |
|
12 | - */ |
|
13 | - public function getBrokers() {} |
|
10 | + /** |
|
11 | + * @return Collection |
|
12 | + */ |
|
13 | + public function getBrokers() {} |
|
14 | 14 | |
15 | - /** |
|
16 | - * @return Collection|Topic[] |
|
17 | - */ |
|
18 | - public function getTopics() {} |
|
15 | + /** |
|
16 | + * @return Collection|Topic[] |
|
17 | + */ |
|
18 | + public function getTopics() {} |
|
19 | 19 | |
20 | - /** |
|
21 | - * @return int |
|
22 | - */ |
|
23 | - public function getOrigBrokerId() {} |
|
20 | + /** |
|
21 | + * @return int |
|
22 | + */ |
|
23 | + public function getOrigBrokerId() {} |
|
24 | 24 | |
25 | - /** |
|
26 | - * @return string |
|
27 | - */ |
|
28 | - public function getOrigBrokerName() {} |
|
25 | + /** |
|
26 | + * @return string |
|
27 | + */ |
|
28 | + public function getOrigBrokerName() {} |
|
29 | 29 | } |
@@ -5,8 +5,7 @@ |
||
5 | 5 | use RdKafka\Metadata\Collection; |
6 | 6 | use RdKafka\Metadata\Topic; |
7 | 7 | |
8 | -class Metadata |
|
9 | -{ |
|
8 | +class Metadata { |
|
10 | 9 | /** |
11 | 10 | * @return Collection |
12 | 11 | */ |
@@ -4,55 +4,55 @@ |
||
4 | 4 | |
5 | 5 | class Message |
6 | 6 | { |
7 | - /** |
|
8 | - * @var int |
|
9 | - */ |
|
10 | - public $err; |
|
11 | - |
|
12 | - /** |
|
13 | - * @var string |
|
14 | - */ |
|
15 | - public $topic_name; |
|
16 | - |
|
17 | - /** |
|
18 | - * @var int |
|
19 | - */ |
|
20 | - public $timestamp; |
|
21 | - |
|
22 | - /** |
|
23 | - * @var int |
|
24 | - */ |
|
25 | - public $partition; |
|
26 | - |
|
27 | - /** |
|
28 | - * @var string |
|
29 | - */ |
|
30 | - public $payload; |
|
31 | - |
|
32 | - /** |
|
33 | - * @var int |
|
34 | - */ |
|
35 | - public $len; |
|
36 | - |
|
37 | - /** |
|
38 | - * @var string |
|
39 | - */ |
|
40 | - public $key; |
|
41 | - |
|
42 | - /** |
|
43 | - * @var int |
|
44 | - */ |
|
45 | - public $offset; |
|
46 | - |
|
47 | - /** |
|
48 | - * @var array |
|
49 | - */ |
|
50 | - public $headers; |
|
51 | - |
|
52 | - public $opaque; |
|
53 | - |
|
54 | - /** |
|
55 | - * @return string |
|
56 | - */ |
|
57 | - public function errstr() {} |
|
7 | + /** |
|
8 | + * @var int |
|
9 | + */ |
|
10 | + public $err; |
|
11 | + |
|
12 | + /** |
|
13 | + * @var string |
|
14 | + */ |
|
15 | + public $topic_name; |
|
16 | + |
|
17 | + /** |
|
18 | + * @var int |
|
19 | + */ |
|
20 | + public $timestamp; |
|
21 | + |
|
22 | + /** |
|
23 | + * @var int |
|
24 | + */ |
|
25 | + public $partition; |
|
26 | + |
|
27 | + /** |
|
28 | + * @var string |
|
29 | + */ |
|
30 | + public $payload; |
|
31 | + |
|
32 | + /** |
|
33 | + * @var int |
|
34 | + */ |
|
35 | + public $len; |
|
36 | + |
|
37 | + /** |
|
38 | + * @var string |
|
39 | + */ |
|
40 | + public $key; |
|
41 | + |
|
42 | + /** |
|
43 | + * @var int |
|
44 | + */ |
|
45 | + public $offset; |
|
46 | + |
|
47 | + /** |
|
48 | + * @var array |
|
49 | + */ |
|
50 | + public $headers; |
|
51 | + |
|
52 | + public $opaque; |
|
53 | + |
|
54 | + /** |
|
55 | + * @return string |
|
56 | + */ |
|
57 | + public function errstr() {} |
|
58 | 58 | } |
@@ -2,8 +2,7 @@ |
||
2 | 2 | |
3 | 3 | namespace RdKafka; |
4 | 4 | |
5 | -class Message |
|
6 | -{ |
|
5 | +class Message { |
|
7 | 6 | /** |
8 | 7 | * @var int |
9 | 8 | */ |
@@ -4,8 +4,8 @@ |
||
4 | 4 | |
5 | 5 | abstract class Topic |
6 | 6 | { |
7 | - /** |
|
8 | - * @return string |
|
9 | - */ |
|
10 | - public function getName() {} |
|
7 | + /** |
|
8 | + * @return string |
|
9 | + */ |
|
10 | + public function getName() {} |
|
11 | 11 | } |
@@ -2,8 +2,7 @@ |
||
2 | 2 | |
3 | 3 | namespace RdKafka; |
4 | 4 | |
5 | -abstract class Topic |
|
6 | -{ |
|
5 | +abstract class Topic { |
|
7 | 6 | /** |
8 | 7 | * @return string |
9 | 8 | */ |