diff --git a/src/MySQLReplication/Definitions/ConstEventType.php b/src/MySQLReplication/Definitions/ConstEventType.php index 2c06f02..0f99cc3 100644 --- a/src/MySQLReplication/Definitions/ConstEventType.php +++ b/src/MySQLReplication/Definitions/ConstEventType.php @@ -5,7 +5,7 @@ namespace MySQLReplication\Definitions; /** - * @see https://dev.mysql.com/doc/internals/en/event-classes-and-types.html + * @see https://github.com/mysql/mysql-server/blob/824e2b4064053f7daf17d7f3f84b7a3ed92e5fb4/libs/mysql/binlog/event/binlog_event.h#L285 (MySQL binlog_event.h) */ enum ConstEventType: int { diff --git a/src/MySQLReplication/Event/Event.php b/src/MySQLReplication/Event/Event.php index 4af0caf..75ff41e 100644 --- a/src/MySQLReplication/Event/Event.php +++ b/src/MySQLReplication/Event/Event.php @@ -37,7 +37,7 @@ public function consume(): void { $binaryDataReader = new BinaryDataReader($this->binLogSocketConnect->getResponse()); - // check EOF_Packet -> https://dev.mysql.com/doc/internals/en/packet-EOF_Packet.html + // check EOF_Packet -> https://dev.mysql.com/doc/dev/mysql-server/latest/page_protocol_basic_eof_packet.html if ($binaryDataReader->readUInt8() === self::EOF_HEADER_VALUE) { return; } @@ -127,6 +127,9 @@ private function makeEvent(BinaryDataReader $binaryDataReader): ?EventDTO return null; } + /** + * @see https://dev.mysql.com/doc/dev/mysql-server/latest/page_protocol_replication_binlog_event.html#sect_protocol_replication_binlog_event_header + */ private function createEventInfo(BinaryDataReader $binaryDataReader): EventInfo { return new EventInfo( diff --git a/src/MySQLReplication/Event/QueryEvent.php b/src/MySQLReplication/Event/QueryEvent.php index e20675f..b4e8a94 100644 --- a/src/MySQLReplication/Event/QueryEvent.php +++ b/src/MySQLReplication/Event/QueryEvent.php @@ -7,7 +7,7 @@ use MySQLReplication\Event\DTO\QueryDTO; /** - * @see https://dev.mysql.com/doc/internals/en/query-event.html + * @see https://dev.mysql.com/doc/dev/mysql-server/latest/page_protocol_replication_binlog_event.html#sect_protocol_replication_event_query */ class QueryEvent extends EventCommon { diff --git a/src/MySQLReplication/Event/RotateEvent.php b/src/MySQLReplication/Event/RotateEvent.php index 8beac31..0e0d2b9 100644 --- a/src/MySQLReplication/Event/RotateEvent.php +++ b/src/MySQLReplication/Event/RotateEvent.php @@ -7,7 +7,7 @@ use MySQLReplication\Event\DTO\RotateDTO; /** - * @see https://dev.mysql.com/doc/internals/en/rotate-event.html + * @see https://dev.mysql.com/doc/dev/mysql-server/latest/page_protocol_replication_binlog_event.html#sect_protocol_replication_event_rotate */ class RotateEvent extends EventCommon { diff --git a/src/MySQLReplication/Event/XidEvent.php b/src/MySQLReplication/Event/XidEvent.php index 41a4a8b..39611fa 100644 --- a/src/MySQLReplication/Event/XidEvent.php +++ b/src/MySQLReplication/Event/XidEvent.php @@ -6,6 +6,9 @@ use MySQLReplication\Event\DTO\XidDTO; +/** + * @see https://dev.mysql.com/doc/dev/mysql-server/latest/page_protocol_replication_binlog_event.html#sect_protocol_replication_event_xid + */ class XidEvent extends EventCommon { public function makeXidDTO(): XidDTO