Code
Hub
Workspaces
Following
Trending
Connect
MCP
copy
Create free account
hub
/
github.com/shyiko/mysql-binlog-connector-java
/ functions
Functions
787 in github.com/shyiko/mysql-binlog-connector-java
⨍
Functions
787
◇
Types & classes
116
Method
onCommunicationFailure
(BinaryLogClient client, Exception ex)
src/main/java/com/github/shyiko/mysql/binlog/jmx/BinaryLogClientStatistics.java:127
Method
onConnect
(BinaryLogClient client)
src/test/java/com/github/shyiko/mysql/binlog/BinaryLogClientIntegrationTest.java:968
Method
onConnect
(BinaryLogClient client)
src/test/java/com/github/shyiko/mysql/binlog/TraceLifecycleListener.java:28
Method
onConnect
(BinaryLogClient client)
src/main/java/com/github/shyiko/mysql/binlog/BinaryLogClient.java:869
Method
onConnect
(BinaryLogClient client)
src/main/java/com/github/shyiko/mysql/binlog/BinaryLogClient.java:1309
Method
onConnect
(BinaryLogClient client)
src/main/java/com/github/shyiko/mysql/binlog/jmx/BinaryLogClientStatistics.java:123
Method
onDisconnect
(BinaryLogClient client)
src/test/java/com/github/shyiko/mysql/binlog/TraceLifecycleListener.java:49
Method
onDisconnect
(BinaryLogClient client)
src/main/java/com/github/shyiko/mysql/binlog/BinaryLogClient.java:1315
Method
onEvent
(Event event)
src/test/java/com/github/shyiko/mysql/binlog/CountDownEventListener.java:36
Method
onEvent
(Event event)
src/test/java/com/github/shyiko/mysql/binlog/TraceEventListener.java:30
Method
onEvent
(Event event)
src/test/java/com/github/shyiko/mysql/binlog/CapturingEventListener.java:32
Method
onEvent
(Event event)
src/test/java/com/github/shyiko/mysql/binlog/BinaryLogClientIntegrationTest.java:494
Method
onEvent
(Event event)
src/test/java/com/github/shyiko/mysql/binlog/event/deserialization/json/JsonBinaryValueIntegrationTest.java:432
Method
onEventDeserializationFailure
(BinaryLogClient client, Exception ex)
src/test/java/com/github/shyiko/mysql/binlog/TraceLifecycleListener.java:42
Method
onEventDeserializationFailure
(BinaryLogClient client, Exception ex)
src/main/java/com/github/shyiko/mysql/binlog/BinaryLogClient.java:1313
Method
read
(byte[] b, int off, int len)
src/test/java/com/github/shyiko/mysql/binlog/BinaryLogClientIntegrationTest.java:915
Method
readFractionalSecondsInMicroseconds
()
src/main/java/com/github/shyiko/mysql/binlog/event/deserialization/json/JsonBinary.java:859
Method
readInt24
()
src/main/java/com/github/shyiko/mysql/binlog/event/deserialization/json/JsonBinary.java:897
Method
reset
()
src/test/java/com/github/shyiko/mysql/binlog/CountDownEventListener.java:89
Method
run
()
src/test/java/com/github/shyiko/mysql/binlog/BinaryLogClientIntegrationTest.java:845
Method
run
()
src/test/java/com/github/shyiko/mysql/binlog/BinaryLogClientTest.java:83
Method
run
()
src/main/java/com/github/shyiko/mysql/binlog/BinaryLogClient.java:629
Method
setBlocking
@param blocking blocking mode. If set to false - BinaryLogClient will disconnect after the last event.
src/main/java/com/github/shyiko/mysql/binlog/BinaryLogClient.java:213
Method
setClientCapabilities
(int clientCapabilities)
src/main/java/com/github/shyiko/mysql/binlog/network/protocol/command/AuthenticateCommand.java:44
Method
setClientCapabilities
(int clientCapabilities)
src/main/java/com/github/shyiko/mysql/binlog/network/protocol/command/SSLRequestCommand.java:31
Method
setGtidSetFallbackToPurged
@param gtidSetFallbackToPurged true if gtid_purged should be used as a fallback when gtidSet is set to "" and MySQL server has purged some of the bina
src/main/java/com/github/shyiko/mysql/binlog/BinaryLogClient.java:334
Method
setHeartbeatInterval
@param heartbeatInterval heartbeat period in milliseconds. <p> If set (recommended) <ul> <li> HEARTBEAT event will be emitted every "heartbeatInterval
src/main/java/com/github/shyiko/mysql/binlog/BinaryLogClient.java:432
Method
setMayContainExtraInformation
(boolean mayContainExtraInformation)
src/main/java/com/github/shyiko/mysql/binlog/event/deserialization/UpdateRowsEventDataDeserializer.java:41
Method
setMayContainExtraInformation
(boolean mayContainExtraInformation)
src/main/java/com/github/shyiko/mysql/binlog/event/deserialization/DeleteRowsEventDataDeserializer.java:40
Method
setSSLMode
(SSLMode sslMode)
src/main/java/com/github/shyiko/mysql/binlog/BinaryLogClient.java:221
Method
setSslSocketFactory
@param sslSocketFactory custom ssl socket factory
src/main/java/com/github/shyiko/mysql/binlog/BinaryLogClient.java:472
Method
setThreadFactory
@param threadFactory custom thread factory. If not provided, threads will be created using simple "new Thread()".
src/main/java/com/github/shyiko/mysql/binlog/BinaryLogClient.java:479
Method
setUp
()
src/test/java/com/github/shyiko/mysql/binlog/BinaryLogClientIntegrationTest.java:114
Method
setUp
()
src/test/java/com/github/shyiko/mysql/binlog/event/deserialization/json/JsonBinaryValueIntegrationTest.java:69
Method
setUseBinlogFilenamePositionInGtidMode
@param useBinlogFilenamePositionInGtidMode true if MySQL server should start streaming events from a given {@link #getBinlogFilename()} and {@link #ge
src/main/java/com/github/shyiko/mysql/binlog/BinaryLogClient.java:350
Method
tearDown
()
src/test/java/com/github/shyiko/mysql/binlog/BinaryLogClientIntegrationTest.java:1032
Method
tearDown
()
src/test/java/com/github/shyiko/mysql/binlog/event/deserialization/json/JsonBinaryValueIntegrationTest.java:454
Method
testAbilityToBeRewind
()
src/test/java/com/github/shyiko/mysql/binlog/BinaryLogClientIntegrationTest.java:633
Method
testAbilityToBeSuspendedAndResumed
()
src/test/java/com/github/shyiko/mysql/binlog/BinaryLogClientIntegrationTest.java:603
Method
testAdd
()
src/test/java/com/github/shyiko/mysql/binlog/GtidSetTest.java:35
Method
testAuthenticationFailsWhenNonExistingSchemaProvided
()
src/test/java/com/github/shyiko/mysql/binlog/BinaryLogClientIntegrationTest.java:857
Method
testAutomaticFailover
()
src/test/java/com/github/shyiko/mysql/binlog/BinaryLogClientIntegrationTest.java:651
Method
testBinlogPositionPointsToTableMapEventUntilTheEndOfLogicalGroup
()
src/test/java/com/github/shyiko/mysql/binlog/BinaryLogClientIntegrationTest.java:487
Method
testChecksumCRC32
()
src/test/java/com/github/shyiko/mysql/binlog/BinaryLogFileReaderIntegrationTest.java:56
Method
testChecksumCRC32WithCustomEventDataDeserializer
()
src/test/java/com/github/shyiko/mysql/binlog/BinaryLogFileReaderIntegrationTest.java:64
Method
testChecksumNONE
()
src/test/java/com/github/shyiko/mysql/binlog/BinaryLogFileReaderIntegrationTest.java:48
Method
testCollapseAdjacentIntervals
()
src/test/java/com/github/shyiko/mysql/binlog/GtidSetTest.java:113
Method
testConnectionTimeout
()
src/test/java/com/github/shyiko/mysql/binlog/BinaryLogClientTest.java:77
Method
testCorrectness
()
src/test/java/com/github/shyiko/mysql/binlog/io/BufferedSocketInputStreamTest.java:30
Method
testCustomEventDataDeserializers
()
src/test/java/com/github/shyiko/mysql/binlog/BinaryLogClientIntegrationTest.java:773
Method
testDeserializationOfBIT
()
src/test/java/com/github/shyiko/mysql/binlog/BinaryLogClientIntegrationTest.java:207
Method
testDeserializationOfBLOB
()
src/test/java/com/github/shyiko/mysql/binlog/BinaryLogClientIntegrationTest.java:334
Method
testDeserializationOfDATE
()
src/test/java/com/github/shyiko/mysql/binlog/BinaryLogClientIntegrationTest.java:273
Method
testDeserializationOfDATETIME
()
src/test/java/com/github/shyiko/mysql/binlog/BinaryLogClientIntegrationTest.java:307
Method
testDeserializationOfDOUBLE
()
src/test/java/com/github/shyiko/mysql/binlog/BinaryLogClientIntegrationTest.java:260
Method
testDeserializationOfDateAndTimeAsLong
()
src/test/java/com/github/shyiko/mysql/binlog/BinaryLogClientIntegrationTest.java:393
Method
testDeserializationOfDateAndTimeAsLongMicrosecondsPrecision
()
src/test/java/com/github/shyiko/mysql/binlog/BinaryLogClientIntegrationTest.java:409
Method
testDeserializationOfENUM
()
src/test/java/com/github/shyiko/mysql/binlog/BinaryLogClientIntegrationTest.java:346
Method
testDeserializationOfFLOAT
()
src/test/java/com/github/shyiko/mysql/binlog/BinaryLogClientIntegrationTest.java:254
Method
testDeserializationOfGEOMETRY
()
src/test/java/com/github/shyiko/mysql/binlog/BinaryLogClientIntegrationTest.java:356
Method
testDeserializationOfINT24
()
src/test/java/com/github/shyiko/mysql/binlog/BinaryLogClientIntegrationTest.java:230
Method
testDeserializationOfLONG
()
src/test/java/com/github/shyiko/mysql/binlog/BinaryLogClientIntegrationTest.java:238
Method
testDeserializationOfLONGLONG
()
src/test/java/com/github/shyiko/mysql/binlog/BinaryLogClientIntegrationTest.java:246
Method
testDeserializationOfNEWDECIMAL
()
src/test/java/com/github/shyiko/mysql/binlog/BinaryLogClientIntegrationTest.java:266
Method
testDeserializationOfSET
()
src/test/java/com/github/shyiko/mysql/binlog/BinaryLogClientIntegrationTest.java:351
Method
testDeserializationOfSHORT
()
src/test/java/com/github/shyiko/mysql/binlog/BinaryLogClientIntegrationTest.java:222
Method
testDeserializationOfSTRING
()
src/test/java/com/github/shyiko/mysql/binlog/BinaryLogClientIntegrationTest.java:318
Method
testDeserializationOfTIME
()
src/test/java/com/github/shyiko/mysql/binlog/BinaryLogClientIntegrationTest.java:295
Method
testDeserializationOfTIMESTAMP
()
src/test/java/com/github/shyiko/mysql/binlog/BinaryLogClientIntegrationTest.java:301
Method
testDeserializationOfTINY
()
src/test/java/com/github/shyiko/mysql/binlog/BinaryLogClientIntegrationTest.java:213
Method
testDeserializationOfVARSTRING
()
src/test/java/com/github/shyiko/mysql/binlog/BinaryLogClientIntegrationTest.java:328
Method
testDeserializationOfYEAR
()
src/test/java/com/github/shyiko/mysql/binlog/BinaryLogClientIntegrationTest.java:313
Method
testDeserializationSuppressionByEventType
()
src/test/java/com/github/shyiko/mysql/binlog/BinaryLogFileReaderIntegrationTest.java:95
Method
testDisconnectWhileBlockedByFBRead
()
src/test/java/com/github/shyiko/mysql/binlog/BinaryLogClientTest.java:116
Method
testEOFExceptionTriggersReconnectIfKeepAliveIsOn
()
src/test/java/com/github/shyiko/mysql/binlog/BinaryLogClientIntegrationTest.java:697
Method
testEmptyArray
()
src/test/java/com/github/shyiko/mysql/binlog/event/deserialization/json/JsonBinaryValueIntegrationTest.java:337
Method
testEmptyObject
()
src/test/java/com/github/shyiko/mysql/binlog/event/deserialization/json/JsonBinaryValueIntegrationTest.java:332
Method
testEmptySet
()
src/test/java/com/github/shyiko/mysql/binlog/GtidSetTest.java:56
Method
testEquals
()
src/test/java/com/github/shyiko/mysql/binlog/GtidSetTest.java:61
Method
testEventListenersManagement
()
src/test/java/com/github/shyiko/mysql/binlog/BinaryLogClientTest.java:41
Method
testExceptionIsThrownWhenInsufficientPermissionsToDetectPosition
()
src/test/java/com/github/shyiko/mysql/binlog/BinaryLogClientIntegrationTest.java:833
Method
testExceptionIsThrownWhenProvidedWithWrongCredentials
()
src/test/java/com/github/shyiko/mysql/binlog/BinaryLogClientIntegrationTest.java:821
Method
testExceptionIsThrownWhenTryingToConnectAlreadyConnectedClient
()
src/test/java/com/github/shyiko/mysql/binlog/BinaryLogClientIntegrationTest.java:815
Method
testFSP
()
src/test/java/com/github/shyiko/mysql/binlog/BinaryLogClientIntegrationTest.java:363
Method
testFrom
()
src/test/java/com/github/shyiko/mysql/binlog/event/deserialization/AbstractRowsEventDataDeserializerTest.java:31
Method
testGTIDAdvancesStatementBased
()
src/test/java/com/github/shyiko/mysql/binlog/BinaryLogClientGTIDIntegrationTest.java:76
Method
testInitialState
()
src/test/java/com/github/shyiko/mysql/binlog/jmx/BinaryLogClientStatisticsTest.java:35
Method
testIsDelete
()
src/test/java/com/github/shyiko/mysql/binlog/event/EventTypeTest.java:60
Method
testIsUpdate
()
src/test/java/com/github/shyiko/mysql/binlog/event/EventTypeTest.java:46
Method
testIsWrite
()
src/test/java/com/github/shyiko/mysql/binlog/event/EventTypeTest.java:32
Method
testJoin
()
src/test/java/com/github/shyiko/mysql/binlog/GtidSetTest.java:48
Method
testJsonArray
()
src/test/java/com/github/shyiko/mysql/binlog/event/deserialization/json/JsonBinaryValueIntegrationTest.java:213
Method
testJsonArrayNested
()
src/test/java/com/github/shyiko/mysql/binlog/event/deserialization/json/JsonBinaryValueIntegrationTest.java:241
Method
testJsonObject
()
src/test/java/com/github/shyiko/mysql/binlog/event/deserialization/json/JsonBinaryValueIntegrationTest.java:133
Method
testJsonObjectLargerThan64k
()
src/test/java/com/github/shyiko/mysql/binlog/event/deserialization/json/JsonBinaryValueIntegrationTest.java:162
Method
testJsonObjectNested
()
src/test/java/com/github/shyiko/mysql/binlog/event/deserialization/json/JsonBinaryValueIntegrationTest.java:203
Method
testJsonWithEmptyKey
()
src/test/java/com/github/shyiko/mysql/binlog/event/deserialization/json/JsonBinaryValueIntegrationTest.java:208
Method
testLifecycleListenersManagement
()
src/test/java/com/github/shyiko/mysql/binlog/BinaryLogClientTest.java:56
Method
testMagicHeaderCheck
()
src/test/java/com/github/shyiko/mysql/binlog/BinaryLogFileReaderIntegrationTest.java:85
Method
testMultipleIntervals
()
src/test/java/com/github/shyiko/mysql/binlog/GtidSetTest.java:134
← previous
next →
601–700 of 787, ranked by callers