Ydb.Topic.DescribeConsumerResult.PartitionConsumerStats */ class PartitionConsumerStats extends \Google\Protobuf\Internal\Message { /** * Last read offset from this partition. * * Generated from protobuf field int64 last_read_offset = 1; */ protected $last_read_offset = 0; /** * Committed offset for this partition. * * Generated from protobuf field int64 committed_offset = 2; */ protected $committed_offset = 0; /** * Reading this partition read session identifier. * * Generated from protobuf field string read_session_id = 3; */ protected $read_session_id = ''; /** * Timestamp of providing this partition to this session by server. * * Generated from protobuf field .google.protobuf.Timestamp partition_read_session_create_time = 4; */ protected $partition_read_session_create_time = null; /** * Timestamp of last read from this partition. * * Generated from protobuf field .google.protobuf.Timestamp last_read_time = 5; */ protected $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 = 6; */ 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 = 7; */ protected $max_write_time_lag = null; /** * How much bytes were read during several windows statistics from this partiton. * * Generated from protobuf field .Ydb.Topic.MultipleWindowsStat bytes_read = 8; */ protected $bytes_read = null; /** * Read session name, provided by client. * * Generated from protobuf field string reader_name = 11; */ protected $reader_name = ''; /** * Host where read session connected. * * Generated from protobuf field int32 connection_node_id = 12; */ protected $connection_node_id = 0; /** * Constructor. * * @param array $data { * Optional. Data for populating the Message object. * * @type int|string $last_read_offset * Last read offset from this partition. * @type int|string $committed_offset * Committed offset for this partition. * @type string $read_session_id * Reading this partition read session identifier. * @type \Google\Protobuf\Timestamp $partition_read_session_create_time * Timestamp of providing this partition to this session by server. * @type \Google\Protobuf\Timestamp $last_read_time * Timestamp of last read from this partition. * @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 * How much bytes were read during several windows statistics from this partiton. * @type string $reader_name * Read session name, provided by client. * @type int $connection_node_id * Host where read session connected. * } */ public function __construct($data = NULL) { \GPBMetadata\Protos\YdbTopic::initOnce(); parent::__construct($data); } /** * Last read offset from this partition. * * Generated from protobuf field int64 last_read_offset = 1; * @return int|string */ public function getLastReadOffset() { return $this->last_read_offset; } /** * Last read offset from this partition. * * Generated from protobuf field int64 last_read_offset = 1; * @param int|string $var * @return $this */ public function setLastReadOffset($var) { GPBUtil::checkInt64($var); $this->last_read_offset = $var; return $this; } /** * Committed offset for this partition. * * Generated from protobuf field int64 committed_offset = 2; * @return int|string */ public function getCommittedOffset() { return $this->committed_offset; } /** * Committed offset for this partition. * * Generated from protobuf field int64 committed_offset = 2; * @param int|string $var * @return $this */ public function setCommittedOffset($var) { GPBUtil::checkInt64($var); $this->committed_offset = $var; return $this; } /** * Reading this partition read session identifier. * * Generated from protobuf field string read_session_id = 3; * @return string */ public function getReadSessionId() { return $this->read_session_id; } /** * Reading this partition read session identifier. * * Generated from protobuf field string read_session_id = 3; * @param string $var * @return $this */ public function setReadSessionId($var) { GPBUtil::checkString($var, True); $this->read_session_id = $var; return $this; } /** * Timestamp of providing this partition to this session by server. * * Generated from protobuf field .google.protobuf.Timestamp partition_read_session_create_time = 4; * @return \Google\Protobuf\Timestamp|null */ public function getPartitionReadSessionCreateTime() { return $this->partition_read_session_create_time; } public function hasPartitionReadSessionCreateTime() { return isset($this->partition_read_session_create_time); } public function clearPartitionReadSessionCreateTime() { unset($this->partition_read_session_create_time); } /** * Timestamp of providing this partition to this session by server. * * Generated from protobuf field .google.protobuf.Timestamp partition_read_session_create_time = 4; * @param \Google\Protobuf\Timestamp $var * @return $this */ public function setPartitionReadSessionCreateTime($var) { GPBUtil::checkMessage($var, \Google\Protobuf\Timestamp::class); $this->partition_read_session_create_time = $var; return $this; } /** * Timestamp of last read from this partition. * * Generated from protobuf field .google.protobuf.Timestamp last_read_time = 5; * @return \Google\Protobuf\Timestamp|null */ public function getLastReadTime() { return $this->last_read_time; } public function hasLastReadTime() { return isset($this->last_read_time); } public function clearLastReadTime() { unset($this->last_read_time); } /** * Timestamp of last read from this partition. * * Generated from protobuf field .google.protobuf.Timestamp last_read_time = 5; * @param \Google\Protobuf\Timestamp $var * @return $this */ public function setLastReadTime($var) { GPBUtil::checkMessage($var, \Google\Protobuf\Timestamp::class); $this->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 = 6; * @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 = 6; * @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 = 7; * @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 = 7; * @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; } /** * How much bytes were read during several windows statistics from this partiton. * * Generated from protobuf field .Ydb.Topic.MultipleWindowsStat bytes_read = 8; * @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); } /** * How much bytes were read during several windows statistics from this partiton. * * Generated from protobuf field .Ydb.Topic.MultipleWindowsStat bytes_read = 8; * @param \Ydb\Topic\MultipleWindowsStat $var * @return $this */ public function setBytesRead($var) { GPBUtil::checkMessage($var, \Ydb\Topic\MultipleWindowsStat::class); $this->bytes_read = $var; return $this; } /** * Read session name, provided by client. * * Generated from protobuf field string reader_name = 11; * @return string */ public function getReaderName() { return $this->reader_name; } /** * Read session name, provided by client. * * Generated from protobuf field string reader_name = 11; * @param string $var * @return $this */ public function setReaderName($var) { GPBUtil::checkString($var, True); $this->reader_name = $var; return $this; } /** * Host where read session connected. * * Generated from protobuf field int32 connection_node_id = 12; * @return int */ public function getConnectionNodeId() { return $this->connection_node_id; } /** * Host where read session connected. * * Generated from protobuf field int32 connection_node_id = 12; * @param int $var * @return $this */ public function setConnectionNodeId($var) { GPBUtil::checkInt32($var); $this->connection_node_id = $var; return $this; } } // Adding a class alias for backwards compatibility with the previous class name. class_alias(PartitionConsumerStats::class, \Ydb\Topic\DescribeConsumerResult_PartitionConsumerStats::class);