Ydb.Topic.Consumer.ConsumerStats */ class ConsumerStats extends \Google\Protobuf\Internal\Message { /** * Minimal timestamp of last read from partitions. * * Generated from protobuf field .google.protobuf.Timestamp min_partitions_last_read_time = 1; */ protected $min_partitions_last_read_time = null; /** * Maximum of differences between timestamp of read and write timestamp for all messages, read during last minute. * * Generated from protobuf field .google.protobuf.Duration max_read_time_lag = 2; */ protected $max_read_time_lag = null; /** * Maximum of differences between write timestamp and create timestamp for all messages, read during last minute. * * Generated from protobuf field .google.protobuf.Duration max_write_time_lag = 3; */ protected $max_write_time_lag = null; /** * Bytes read stastics. * * Generated from protobuf field .Ydb.Topic.MultipleWindowsStat bytes_read = 4; */ protected $bytes_read = null; /** * Constructor. * * @param array $data { * Optional. Data for populating the Message object. * * @type \Google\Protobuf\Timestamp $min_partitions_last_read_time * Minimal timestamp of last read from partitions. * @type \Google\Protobuf\Duration $max_read_time_lag * Maximum of differences between timestamp of read and write timestamp for all messages, read during last minute. * @type \Google\Protobuf\Duration $max_write_time_lag * Maximum of differences between write timestamp and create timestamp for all messages, read during last minute. * @type \Ydb\Topic\MultipleWindowsStat $bytes_read * Bytes read stastics. * } */ public function __construct($data = NULL) { \GPBMetadata\Protos\YdbTopic::initOnce(); parent::__construct($data); } /** * Minimal timestamp of last read from partitions. * * Generated from protobuf field .google.protobuf.Timestamp min_partitions_last_read_time = 1; * @return \Google\Protobuf\Timestamp|null */ public function getMinPartitionsLastReadTime() { return $this->min_partitions_last_read_time; } public function hasMinPartitionsLastReadTime() { return isset($this->min_partitions_last_read_time); } public function clearMinPartitionsLastReadTime() { unset($this->min_partitions_last_read_time); } /** * Minimal timestamp of last read from partitions. * * Generated from protobuf field .google.protobuf.Timestamp min_partitions_last_read_time = 1; * @param \Google\Protobuf\Timestamp $var * @return $this */ public function setMinPartitionsLastReadTime($var) { GPBUtil::checkMessage($var, \Google\Protobuf\Timestamp::class); $this->min_partitions_last_read_time = $var; return $this; } /** * Maximum of differences between timestamp of read and write timestamp for all messages, read during last minute. * * Generated from protobuf field .google.protobuf.Duration max_read_time_lag = 2; * @return \Google\Protobuf\Duration|null */ public function getMaxReadTimeLag() { return $this->max_read_time_lag; } public function hasMaxReadTimeLag() { return isset($this->max_read_time_lag); } public function clearMaxReadTimeLag() { unset($this->max_read_time_lag); } /** * Maximum of differences between timestamp of read and write timestamp for all messages, read during last minute. * * Generated from protobuf field .google.protobuf.Duration max_read_time_lag = 2; * @param \Google\Protobuf\Duration $var * @return $this */ public function setMaxReadTimeLag($var) { GPBUtil::checkMessage($var, \Google\Protobuf\Duration::class); $this->max_read_time_lag = $var; return $this; } /** * Maximum of differences between write timestamp and create timestamp for all messages, read during last minute. * * Generated from protobuf field .google.protobuf.Duration max_write_time_lag = 3; * @return \Google\Protobuf\Duration|null */ public function getMaxWriteTimeLag() { return $this->max_write_time_lag; } public function hasMaxWriteTimeLag() { return isset($this->max_write_time_lag); } public function clearMaxWriteTimeLag() { unset($this->max_write_time_lag); } /** * Maximum of differences between write timestamp and create timestamp for all messages, read during last minute. * * Generated from protobuf field .google.protobuf.Duration max_write_time_lag = 3; * @param \Google\Protobuf\Duration $var * @return $this */ public function setMaxWriteTimeLag($var) { GPBUtil::checkMessage($var, \Google\Protobuf\Duration::class); $this->max_write_time_lag = $var; return $this; } /** * Bytes read stastics. * * Generated from protobuf field .Ydb.Topic.MultipleWindowsStat bytes_read = 4; * @return \Ydb\Topic\MultipleWindowsStat|null */ public function getBytesRead() { return $this->bytes_read; } public function hasBytesRead() { return isset($this->bytes_read); } public function clearBytesRead() { unset($this->bytes_read); } /** * Bytes read stastics. * * Generated from protobuf field .Ydb.Topic.MultipleWindowsStat bytes_read = 4; * @param \Ydb\Topic\MultipleWindowsStat $var * @return $this */ public function setBytesRead($var) { GPBUtil::checkMessage($var, \Ydb\Topic\MultipleWindowsStat::class); $this->bytes_read = $var; return $this; } } // Adding a class alias for backwards compatibility with the previous class name. class_alias(ConsumerStats::class, \Ydb\Topic\Consumer_ConsumerStats::class);