Copyright | (c) Winterland 2016 |
---|---|
License | BSD |
Maintainer | [email protected] |
Stability | experimental |
Portability | PORTABLE |
Safe Haskell | None |
Language | Haskell2010 |
Database.MySQL.BinLogProtocol.BinLogEvent
Description
Binlog event type
Synopsis
- data BinLogEventType
- = BINLOG_UNKNOWN_EVENT
- | BINLOG_START_EVENT_V3
- | BINLOG_QUERY_EVENT
- | BINLOG_STOP_EVENT
- | BINLOG_ROTATE_EVENT
- | BINLOG_INTVAR_EVENT
- | BINLOG_LOAD_EVENT
- | BINLOG_SLAVE_EVENT
- | BINLOG_CREATE_FILE_EVENT
- | BINLOG_APPEND_BLOCK_EVENT
- | BINLOG_EXEC_LOAD_EVENT
- | BINLOG_DELETE_FILE_EVENT
- | BINLOG_NEW_LOAD_EVENT
- | BINLOG_RAND_EVENT
- | BINLOG_USER_VAR_EVENT
- | BINLOG_FORMAT_DESCRIPTION_EVENT
- | BINLOG_XID_EVENT
- | BINLOG_BEGIN_LOAD_QUERY_EVENT
- | BINLOG_EXECUTE_LOAD_QUERY_EVENT
- | BINLOG_TABLE_MAP_EVENT
- | BINLOG_WRITE_ROWS_EVENTv0
- | BINLOG_UPDATE_ROWS_EVENTv0
- | BINLOG_DELETE_ROWS_EVENTv0
- | BINLOG_WRITE_ROWS_EVENTv1
- | BINLOG_UPDATE_ROWS_EVENTv1
- | BINLOG_DELETE_ROWS_EVENTv1
- | BINLOG_INCIDENT_EVENT
- | BINLOG_HEARTBEAT_EVENT
- | BINLOG_IGNORABLE_EVENT
- | BINLOG_ROWS_QUERY_EVENT
- | BINLOG_WRITE_ROWS_EVENTv2
- | BINLOG_UPDATE_ROWS_EVENTv2
- | BINLOG_DELETE_ROWS_EVENTv2
- | BINLOG_GTID_EVENT
- | BINLOG_ANONYMOUS_GTID_EVENT
- | BINLOG_PREVIOUS_GTIDS_EVENT
- data BinLogPacket = BinLogPacket {
- blTimestamp :: !Word32
- blEventType :: !BinLogEventType
- blServerId :: !Word32
- blEventSize :: !Word32
- blLogPos :: !Word64
- blFlags :: !Word16
- blBody :: !ByteString
- blSemiAck :: !Bool
- putSemiAckResp :: Word32 -> ByteString -> Put
- getBinLogPacket :: Bool -> Bool -> Get BinLogPacket
- getFromBinLogPacket :: Get a -> BinLogPacket -> IO a
- getFromBinLogPacket' :: (BinLogEventType -> Get a) -> BinLogPacket -> IO a
- data FormatDescription = FormatDescription {}
- getFormatDescription :: Get FormatDescription
- eventHeaderLen :: FormatDescription -> BinLogEventType -> Word8
- data RotateEvent = RotateEvent {
- rPos :: !Word64
- rFileName :: !ByteString
- getRotateEvent :: Get RotateEvent
- data QueryEvent = QueryEvent {
- qSlaveProxyId :: !Word32
- qExecTime :: !Word32
- qErrCode :: !Word16
- qStatusVars :: !ByteString
- qSchemaName :: !ByteString
- qQuery :: !Query
- getQueryEvent :: Get QueryEvent
- data QueryEvent' = QueryEvent' {}
- getQueryEvent' :: Get QueryEvent'
- data TableMapEvent = TableMapEvent {
- tmTableId :: !Word64
- tmFlags :: !Word16
- tmSchemaName :: !ByteString
- tmTableName :: !ByteString
- tmColumnCnt :: !Int
- tmColumnType :: ![FieldType]
- tmColumnMeta :: ![BinLogMeta]
- tmNullMap :: !ByteString
- getTableMapEvent :: FormatDescription -> Get TableMapEvent
- data DeleteRowsEvent = DeleteRowsEvent {
- deleteTableId :: !Word64
- deleteFlags :: !Word16
- deleteColumnCnt :: !Int
- deletePresentMap :: !BitMap
- deleteRowData :: ![[BinLogValue]]
- getDeleteRowEvent :: FormatDescription -> TableMapEvent -> BinLogEventType -> Get DeleteRowsEvent
- data WriteRowsEvent = WriteRowsEvent {
- writeTableId :: !Word64
- writeFlags :: !Word16
- writeColumnCnt :: !Int
- writePresentMap :: !BitMap
- writeRowData :: ![[BinLogValue]]
- getWriteRowEvent :: FormatDescription -> TableMapEvent -> BinLogEventType -> Get WriteRowsEvent
- data UpdateRowsEvent = UpdateRowsEvent {
- updateTableId :: !Word64
- updateFlags :: !Word16
- updateColumnCnt :: !Int
- updatePresentMap :: !(BitMap, BitMap)
- updateRowData :: ![([BinLogValue], [BinLogValue])]
- getUpdateRowEvent :: FormatDescription -> TableMapEvent -> BinLogEventType -> Get UpdateRowsEvent
- getPresentMap :: Int -> Int -> Get BitMap
Documentation
data BinLogEventType Source #
binlog tyoe
Constructors
Instances
Enum BinLogEventType Source # | |
Defined in Database.MySQL.BinLogProtocol.BinLogEvent Methods succ :: BinLogEventType -> BinLogEventType # pred :: BinLogEventType -> BinLogEventType # toEnum :: Int -> BinLogEventType # fromEnum :: BinLogEventType -> Int # enumFrom :: BinLogEventType -> [BinLogEventType] # enumFromThen :: BinLogEventType -> BinLogEventType -> [BinLogEventType] # enumFromTo :: BinLogEventType -> BinLogEventType -> [BinLogEventType] # enumFromThenTo :: BinLogEventType -> BinLogEventType -> BinLogEventType -> [BinLogEventType] # | |
Show BinLogEventType Source # | |
Defined in Database.MySQL.BinLogProtocol.BinLogEvent Methods showsPrec :: Int -> BinLogEventType -> ShowS # show :: BinLogEventType -> String # showList :: [BinLogEventType] -> ShowS # | |
Eq BinLogEventType Source # | |
Defined in Database.MySQL.BinLogProtocol.BinLogEvent Methods (==) :: BinLogEventType -> BinLogEventType -> Bool # (/=) :: BinLogEventType -> BinLogEventType -> Bool # |
data BinLogPacket Source #
Constructors
BinLogPacket | |
Fields
|
Instances
Show BinLogPacket Source # | |
Defined in Database.MySQL.BinLogProtocol.BinLogEvent Methods showsPrec :: Int -> BinLogPacket -> ShowS # show :: BinLogPacket -> String # showList :: [BinLogPacket] -> ShowS # | |
Eq BinLogPacket Source # | |
Defined in Database.MySQL.BinLogProtocol.BinLogEvent |
putSemiAckResp :: Word32 -> ByteString -> Put Source #
getBinLogPacket :: Bool -> Bool -> Get BinLogPacket Source #
getFromBinLogPacket :: Get a -> BinLogPacket -> IO a Source #
getFromBinLogPacket' :: (BinLogEventType -> Get a) -> BinLogPacket -> IO a Source #
data FormatDescription Source #
Constructors
FormatDescription | |
Fields
|
Instances
data RotateEvent Source #
Constructors
RotateEvent | |
Fields
|
Instances
Show RotateEvent Source # | |
Defined in Database.MySQL.BinLogProtocol.BinLogEvent Methods showsPrec :: Int -> RotateEvent -> ShowS # show :: RotateEvent -> String # showList :: [RotateEvent] -> ShowS # | |
Eq RotateEvent Source # | |
Defined in Database.MySQL.BinLogProtocol.BinLogEvent |
data QueryEvent Source #
This's query parser for statement based binlog's query event, it's actually not used in row based binlog.
Constructors
QueryEvent | |
Fields
|
Instances
Generic QueryEvent Source # | |||||
Defined in Database.MySQL.BinLogProtocol.BinLogEvent Associated Types
| |||||
Show QueryEvent Source # | |||||
Defined in Database.MySQL.BinLogProtocol.BinLogEvent Methods showsPrec :: Int -> QueryEvent -> ShowS # show :: QueryEvent -> String # showList :: [QueryEvent] -> ShowS # | |||||
Eq QueryEvent Source # | |||||
Defined in Database.MySQL.BinLogProtocol.BinLogEvent | |||||
type Rep QueryEvent Source # | |||||
Defined in Database.MySQL.BinLogProtocol.BinLogEvent type Rep QueryEvent = D1 ('MetaData "QueryEvent" "Database.MySQL.BinLogProtocol.BinLogEvent" "mysql-haskell-1.1.6-JOqhFfZi3Mj7eJFUFAhvZg" 'False) (C1 ('MetaCons "QueryEvent" 'PrefixI 'True) ((S1 ('MetaSel ('Just "qSlaveProxyId") 'NoSourceUnpackedness 'SourceStrict 'DecidedStrict) (Rec0 Word32) :*: (S1 ('MetaSel ('Just "qExecTime") 'NoSourceUnpackedness 'SourceStrict 'DecidedStrict) (Rec0 Word32) :*: S1 ('MetaSel ('Just "qErrCode") 'NoSourceUnpackedness 'SourceStrict 'DecidedStrict) (Rec0 Word16))) :*: (S1 ('MetaSel ('Just "qStatusVars") 'NoSourceUnpackedness 'SourceStrict 'DecidedStrict) (Rec0 ByteString) :*: (S1 ('MetaSel ('Just "qSchemaName") 'NoSourceUnpackedness 'SourceStrict 'DecidedStrict) (Rec0 ByteString) :*: S1 ('MetaSel ('Just "qQuery") 'NoSourceUnpackedness 'SourceStrict 'DecidedStrict) (Rec0 Query))))) |
data QueryEvent' Source #
This's the query event in row based binlog.
Constructors
QueryEvent' | |
Instances
Show QueryEvent' Source # | |
Defined in Database.MySQL.BinLogProtocol.BinLogEvent Methods showsPrec :: Int -> QueryEvent' -> ShowS # show :: QueryEvent' -> String # showList :: [QueryEvent'] -> ShowS # | |
Eq QueryEvent' Source # | |
Defined in Database.MySQL.BinLogProtocol.BinLogEvent |
data TableMapEvent Source #
Constructors
TableMapEvent | |
Fields
|
Instances
Generic TableMapEvent Source # | |||||
Defined in Database.MySQL.BinLogProtocol.BinLogEvent Associated Types
| |||||
Show TableMapEvent Source # | |||||
Defined in Database.MySQL.BinLogProtocol.BinLogEvent Methods showsPrec :: Int -> TableMapEvent -> ShowS # show :: TableMapEvent -> String # showList :: [TableMapEvent] -> ShowS # | |||||
Eq TableMapEvent Source # | |||||
Defined in Database.MySQL.BinLogProtocol.BinLogEvent Methods (==) :: TableMapEvent -> TableMapEvent -> Bool # (/=) :: TableMapEvent -> TableMapEvent -> Bool # | |||||
type Rep TableMapEvent Source # | |||||
Defined in Database.MySQL.BinLogProtocol.BinLogEvent type Rep TableMapEvent = D1 ('MetaData "TableMapEvent" "Database.MySQL.BinLogProtocol.BinLogEvent" "mysql-haskell-1.1.6-JOqhFfZi3Mj7eJFUFAhvZg" 'False) (C1 ('MetaCons "TableMapEvent" 'PrefixI 'True) (((S1 ('MetaSel ('Just "tmTableId") 'NoSourceUnpackedness 'SourceStrict 'DecidedStrict) (Rec0 Word64) :*: S1 ('MetaSel ('Just "tmFlags") 'NoSourceUnpackedness 'SourceStrict 'DecidedStrict) (Rec0 Word16)) :*: (S1 ('MetaSel ('Just "tmSchemaName") 'NoSourceUnpackedness 'SourceStrict 'DecidedStrict) (Rec0 ByteString) :*: S1 ('MetaSel ('Just "tmTableName") 'NoSourceUnpackedness 'SourceStrict 'DecidedStrict) (Rec0 ByteString))) :*: ((S1 ('MetaSel ('Just "tmColumnCnt") 'NoSourceUnpackedness 'SourceStrict 'DecidedStrict) (Rec0 Int) :*: S1 ('MetaSel ('Just "tmColumnType") 'NoSourceUnpackedness 'SourceStrict 'DecidedStrict) (Rec0 [FieldType])) :*: (S1 ('MetaSel ('Just "tmColumnMeta") 'NoSourceUnpackedness 'SourceStrict 'DecidedStrict) (Rec0 [BinLogMeta]) :*: S1 ('MetaSel ('Just "tmNullMap") 'NoSourceUnpackedness 'SourceStrict 'DecidedStrict) (Rec0 ByteString))))) |
data DeleteRowsEvent Source #
Constructors
DeleteRowsEvent | |
Fields
|
Instances
Generic DeleteRowsEvent Source # | |||||
Defined in Database.MySQL.BinLogProtocol.BinLogEvent Associated Types
Methods from :: DeleteRowsEvent -> Rep DeleteRowsEvent x # to :: Rep DeleteRowsEvent x -> DeleteRowsEvent # | |||||
Show DeleteRowsEvent Source # | |||||
Defined in Database.MySQL.BinLogProtocol.BinLogEvent Methods showsPrec :: Int -> DeleteRowsEvent -> ShowS # show :: DeleteRowsEvent -> String # showList :: [DeleteRowsEvent] -> ShowS # | |||||
Eq DeleteRowsEvent Source # | |||||
Defined in Database.MySQL.BinLogProtocol.BinLogEvent Methods (==) :: DeleteRowsEvent -> DeleteRowsEvent -> Bool # (/=) :: DeleteRowsEvent -> DeleteRowsEvent -> Bool # | |||||
type Rep DeleteRowsEvent Source # | |||||
Defined in Database.MySQL.BinLogProtocol.BinLogEvent type Rep DeleteRowsEvent = D1 ('MetaData "DeleteRowsEvent" "Database.MySQL.BinLogProtocol.BinLogEvent" "mysql-haskell-1.1.6-JOqhFfZi3Mj7eJFUFAhvZg" 'False) (C1 ('MetaCons "DeleteRowsEvent" 'PrefixI 'True) ((S1 ('MetaSel ('Just "deleteTableId") 'NoSourceUnpackedness 'SourceStrict 'DecidedStrict) (Rec0 Word64) :*: S1 ('MetaSel ('Just "deleteFlags") 'NoSourceUnpackedness 'SourceStrict 'DecidedStrict) (Rec0 Word16)) :*: (S1 ('MetaSel ('Just "deleteColumnCnt") 'NoSourceUnpackedness 'SourceStrict 'DecidedStrict) (Rec0 Int) :*: (S1 ('MetaSel ('Just "deletePresentMap") 'NoSourceUnpackedness 'SourceStrict 'DecidedStrict) (Rec0 BitMap) :*: S1 ('MetaSel ('Just "deleteRowData") 'NoSourceUnpackedness 'SourceStrict 'DecidedStrict) (Rec0 [[BinLogValue]]))))) |
getDeleteRowEvent :: FormatDescription -> TableMapEvent -> BinLogEventType -> Get DeleteRowsEvent Source #
data WriteRowsEvent Source #
Constructors
WriteRowsEvent | |
Fields
|
Instances
Generic WriteRowsEvent Source # | |||||
Defined in Database.MySQL.BinLogProtocol.BinLogEvent Associated Types
Methods from :: WriteRowsEvent -> Rep WriteRowsEvent x # to :: Rep WriteRowsEvent x -> WriteRowsEvent # | |||||
Show WriteRowsEvent Source # | |||||
Defined in Database.MySQL.BinLogProtocol.BinLogEvent Methods showsPrec :: Int -> WriteRowsEvent -> ShowS # show :: WriteRowsEvent -> String # showList :: [WriteRowsEvent] -> ShowS # | |||||
Eq WriteRowsEvent Source # | |||||
Defined in Database.MySQL.BinLogProtocol.BinLogEvent Methods (==) :: WriteRowsEvent -> WriteRowsEvent -> Bool # (/=) :: WriteRowsEvent -> WriteRowsEvent -> Bool # | |||||
type Rep WriteRowsEvent Source # | |||||
Defined in Database.MySQL.BinLogProtocol.BinLogEvent type Rep WriteRowsEvent = D1 ('MetaData "WriteRowsEvent" "Database.MySQL.BinLogProtocol.BinLogEvent" "mysql-haskell-1.1.6-JOqhFfZi3Mj7eJFUFAhvZg" 'False) (C1 ('MetaCons "WriteRowsEvent" 'PrefixI 'True) ((S1 ('MetaSel ('Just "writeTableId") 'NoSourceUnpackedness 'SourceStrict 'DecidedStrict) (Rec0 Word64) :*: S1 ('MetaSel ('Just "writeFlags") 'NoSourceUnpackedness 'SourceStrict 'DecidedStrict) (Rec0 Word16)) :*: (S1 ('MetaSel ('Just "writeColumnCnt") 'NoSourceUnpackedness 'SourceStrict 'DecidedStrict) (Rec0 Int) :*: (S1 ('MetaSel ('Just "writePresentMap") 'NoSourceUnpackedness 'SourceStrict 'DecidedStrict) (Rec0 BitMap) :*: S1 ('MetaSel ('Just "writeRowData") 'NoSourceUnpackedness 'SourceStrict 'DecidedStrict) (Rec0 [[BinLogValue]]))))) |
getWriteRowEvent :: FormatDescription -> TableMapEvent -> BinLogEventType -> Get WriteRowsEvent Source #
data UpdateRowsEvent Source #
Constructors
UpdateRowsEvent | |
Fields
|
Instances
Generic UpdateRowsEvent Source # | |||||
Defined in Database.MySQL.BinLogProtocol.BinLogEvent Associated Types
Methods from :: UpdateRowsEvent -> Rep UpdateRowsEvent x # to :: Rep UpdateRowsEvent x -> UpdateRowsEvent # | |||||
Show UpdateRowsEvent Source # | |||||
Defined in Database.MySQL.BinLogProtocol.BinLogEvent Methods showsPrec :: Int -> UpdateRowsEvent -> ShowS # show :: UpdateRowsEvent -> String # showList :: [UpdateRowsEvent] -> ShowS # | |||||
Eq UpdateRowsEvent Source # | |||||
Defined in Database.MySQL.BinLogProtocol.BinLogEvent Methods (==) :: UpdateRowsEvent -> UpdateRowsEvent -> Bool # (/=) :: UpdateRowsEvent -> UpdateRowsEvent -> Bool # | |||||
type Rep UpdateRowsEvent Source # | |||||
Defined in Database.MySQL.BinLogProtocol.BinLogEvent type Rep UpdateRowsEvent = D1 ('MetaData "UpdateRowsEvent" "Database.MySQL.BinLogProtocol.BinLogEvent" "mysql-haskell-1.1.6-JOqhFfZi3Mj7eJFUFAhvZg" 'False) (C1 ('MetaCons "UpdateRowsEvent" 'PrefixI 'True) ((S1 ('MetaSel ('Just "updateTableId") 'NoSourceUnpackedness 'SourceStrict 'DecidedStrict) (Rec0 Word64) :*: S1 ('MetaSel ('Just "updateFlags") 'NoSourceUnpackedness 'SourceStrict 'DecidedStrict) (Rec0 Word16)) :*: (S1 ('MetaSel ('Just "updateColumnCnt") 'NoSourceUnpackedness 'SourceStrict 'DecidedStrict) (Rec0 Int) :*: (S1 ('MetaSel ('Just "updatePresentMap") 'NoSourceUnpackedness 'SourceStrict 'DecidedStrict) (Rec0 (BitMap, BitMap)) :*: S1 ('MetaSel ('Just "updateRowData") 'NoSourceUnpackedness 'SourceStrict 'DecidedStrict) (Rec0 [([BinLogValue], [BinLogValue])]))))) |