ConsumerStats.php 6.4 KB

123456789101112131415161718192021222324252627282930313233343536373839404142434445464748495051525354555657585960616263646566676869707172737475767778798081828384858687888990919293949596979899100101102103104105106107108109110111112113114115116117118119120121122123124125126127128129130131132133134135136137138139140141142143144145146147148149150151152153154155156157158159160161162163164165166167168169170171172173174175176177178179180181182183184185186187188189190191192193194195196197198199200201202203204205206207208209210
  1. <?php
  2. # Generated by the protocol buffer compiler. DO NOT EDIT!
  3. # source: protos/ydb_topic.proto
  4. namespace Ydb\Topic\Consumer;
  5. use Google\Protobuf\Internal\GPBType;
  6. use Google\Protobuf\Internal\RepeatedField;
  7. use Google\Protobuf\Internal\GPBUtil;
  8. /**
  9. * Generated from protobuf message <code>Ydb.Topic.Consumer.ConsumerStats</code>
  10. */
  11. class ConsumerStats extends \Google\Protobuf\Internal\Message
  12. {
  13. /**
  14. * Minimal timestamp of last read from partitions.
  15. *
  16. * Generated from protobuf field <code>.google.protobuf.Timestamp min_partitions_last_read_time = 1;</code>
  17. */
  18. protected $min_partitions_last_read_time = null;
  19. /**
  20. * Maximum of differences between timestamp of read and write timestamp for all messages, read during last minute.
  21. *
  22. * Generated from protobuf field <code>.google.protobuf.Duration max_read_time_lag = 2;</code>
  23. */
  24. protected $max_read_time_lag = null;
  25. /**
  26. * Maximum of differences between write timestamp and create timestamp for all messages, read during last minute.
  27. *
  28. * Generated from protobuf field <code>.google.protobuf.Duration max_write_time_lag = 3;</code>
  29. */
  30. protected $max_write_time_lag = null;
  31. /**
  32. * Bytes read stastics.
  33. *
  34. * Generated from protobuf field <code>.Ydb.Topic.MultipleWindowsStat bytes_read = 4;</code>
  35. */
  36. protected $bytes_read = null;
  37. /**
  38. * Constructor.
  39. *
  40. * @param array $data {
  41. * Optional. Data for populating the Message object.
  42. *
  43. * @type \Google\Protobuf\Timestamp $min_partitions_last_read_time
  44. * Minimal timestamp of last read from partitions.
  45. * @type \Google\Protobuf\Duration $max_read_time_lag
  46. * Maximum of differences between timestamp of read and write timestamp for all messages, read during last minute.
  47. * @type \Google\Protobuf\Duration $max_write_time_lag
  48. * Maximum of differences between write timestamp and create timestamp for all messages, read during last minute.
  49. * @type \Ydb\Topic\MultipleWindowsStat $bytes_read
  50. * Bytes read stastics.
  51. * }
  52. */
  53. public function __construct($data = NULL) {
  54. \GPBMetadata\Protos\YdbTopic::initOnce();
  55. parent::__construct($data);
  56. }
  57. /**
  58. * Minimal timestamp of last read from partitions.
  59. *
  60. * Generated from protobuf field <code>.google.protobuf.Timestamp min_partitions_last_read_time = 1;</code>
  61. * @return \Google\Protobuf\Timestamp|null
  62. */
  63. public function getMinPartitionsLastReadTime()
  64. {
  65. return $this->min_partitions_last_read_time;
  66. }
  67. public function hasMinPartitionsLastReadTime()
  68. {
  69. return isset($this->min_partitions_last_read_time);
  70. }
  71. public function clearMinPartitionsLastReadTime()
  72. {
  73. unset($this->min_partitions_last_read_time);
  74. }
  75. /**
  76. * Minimal timestamp of last read from partitions.
  77. *
  78. * Generated from protobuf field <code>.google.protobuf.Timestamp min_partitions_last_read_time = 1;</code>
  79. * @param \Google\Protobuf\Timestamp $var
  80. * @return $this
  81. */
  82. public function setMinPartitionsLastReadTime($var)
  83. {
  84. GPBUtil::checkMessage($var, \Google\Protobuf\Timestamp::class);
  85. $this->min_partitions_last_read_time = $var;
  86. return $this;
  87. }
  88. /**
  89. * Maximum of differences between timestamp of read and write timestamp for all messages, read during last minute.
  90. *
  91. * Generated from protobuf field <code>.google.protobuf.Duration max_read_time_lag = 2;</code>
  92. * @return \Google\Protobuf\Duration|null
  93. */
  94. public function getMaxReadTimeLag()
  95. {
  96. return $this->max_read_time_lag;
  97. }
  98. public function hasMaxReadTimeLag()
  99. {
  100. return isset($this->max_read_time_lag);
  101. }
  102. public function clearMaxReadTimeLag()
  103. {
  104. unset($this->max_read_time_lag);
  105. }
  106. /**
  107. * Maximum of differences between timestamp of read and write timestamp for all messages, read during last minute.
  108. *
  109. * Generated from protobuf field <code>.google.protobuf.Duration max_read_time_lag = 2;</code>
  110. * @param \Google\Protobuf\Duration $var
  111. * @return $this
  112. */
  113. public function setMaxReadTimeLag($var)
  114. {
  115. GPBUtil::checkMessage($var, \Google\Protobuf\Duration::class);
  116. $this->max_read_time_lag = $var;
  117. return $this;
  118. }
  119. /**
  120. * Maximum of differences between write timestamp and create timestamp for all messages, read during last minute.
  121. *
  122. * Generated from protobuf field <code>.google.protobuf.Duration max_write_time_lag = 3;</code>
  123. * @return \Google\Protobuf\Duration|null
  124. */
  125. public function getMaxWriteTimeLag()
  126. {
  127. return $this->max_write_time_lag;
  128. }
  129. public function hasMaxWriteTimeLag()
  130. {
  131. return isset($this->max_write_time_lag);
  132. }
  133. public function clearMaxWriteTimeLag()
  134. {
  135. unset($this->max_write_time_lag);
  136. }
  137. /**
  138. * Maximum of differences between write timestamp and create timestamp for all messages, read during last minute.
  139. *
  140. * Generated from protobuf field <code>.google.protobuf.Duration max_write_time_lag = 3;</code>
  141. * @param \Google\Protobuf\Duration $var
  142. * @return $this
  143. */
  144. public function setMaxWriteTimeLag($var)
  145. {
  146. GPBUtil::checkMessage($var, \Google\Protobuf\Duration::class);
  147. $this->max_write_time_lag = $var;
  148. return $this;
  149. }
  150. /**
  151. * Bytes read stastics.
  152. *
  153. * Generated from protobuf field <code>.Ydb.Topic.MultipleWindowsStat bytes_read = 4;</code>
  154. * @return \Ydb\Topic\MultipleWindowsStat|null
  155. */
  156. public function getBytesRead()
  157. {
  158. return $this->bytes_read;
  159. }
  160. public function hasBytesRead()
  161. {
  162. return isset($this->bytes_read);
  163. }
  164. public function clearBytesRead()
  165. {
  166. unset($this->bytes_read);
  167. }
  168. /**
  169. * Bytes read stastics.
  170. *
  171. * Generated from protobuf field <code>.Ydb.Topic.MultipleWindowsStat bytes_read = 4;</code>
  172. * @param \Ydb\Topic\MultipleWindowsStat $var
  173. * @return $this
  174. */
  175. public function setBytesRead($var)
  176. {
  177. GPBUtil::checkMessage($var, \Ydb\Topic\MultipleWindowsStat::class);
  178. $this->bytes_read = $var;
  179. return $this;
  180. }
  181. }
  182. // Adding a class alias for backwards compatibility with the previous class name.
  183. class_alias(ConsumerStats::class, \Ydb\Topic\Consumer_ConsumerStats::class);