Functions — github.com/shyiko/mysql-binlog-connector-java

hub / github.com/shyiko/mysql-binlog-connector-java / functions

Functions787 in github.com/shyiko/mysql-binlog-connector-java

⨍ Functions 787◇ Types & classes 116

↓ 118 callersMethodexecute

(T obj)

src/test/java/com/github/shyiko/mysql/binlog/BinaryLogClientIntegrationTest.java:1170

↓ 65 callersMethodread

()

src/main/java/com/github/shyiko/mysql/binlog/network/protocol/PacketChannel.java:58

↓ 52 callersMethodwriteAndCaptureRow

(final String columnDefinition, final String... values)

src/test/java/com/github/shyiko/mysql/binlog/BinaryLogClientIntegrationTest.java:446

↓ 49 callersMethodreadInteger

Read int written in little-endian format.

src/main/java/com/github/shyiko/mysql/binlog/io/ByteArrayInputStream.java:43

↓ 41 callersMethodwaitFor

(EventType eventType, int numberOfEvents, long timeoutInMilliseconds)

src/test/java/com/github/shyiko/mysql/binlog/CountDownEventListener.java:63

↓ 31 callersMethodadd

@param gtid GTID ("source_id:transaction_id") @return whether or not gtid was added to the set (false if it was already there)

src/main/java/com/github/shyiko/mysql/binlog/GtidSet.java:100

↓ 29 callersMethodsize

()

src/main/java/com/github/shyiko/mysql/binlog/network/protocol/ResultSetRowPacket.java:48

↓ 27 callersMethodassertJSONMatchOriginal

(String value)

src/test/java/com/github/shyiko/mysql/binlog/event/deserialization/json/JsonBinaryValueIntegrationTest.java:395

↓ 26 callersMethodregisterEventListener

src/main/java/com/github/shyiko/mysql/binlog/BinaryLogClient.java:1130

↓ 25 callersMethodgetIntervals

Get the intervals of transaction numbers. @return the immutable transaction intervals; never null

src/main/java/com/github/shyiko/mysql/binlog/GtidSet.java:265

↓ 23 callersMethodreadLong

Read long written in little-endian format.

src/main/java/com/github/shyiko/mysql/binlog/io/ByteArrayInputStream.java:54

↓ 20 callersMethodavailable

()

src/main/java/com/github/shyiko/mysql/binlog/io/ByteArrayInputStream.java:165

↓ 18 callersMethodwriteInteger

Write int in little-endian format.

src/main/java/com/github/shyiko/mysql/binlog/io/ByteArrayOutputStream.java:39

↓ 17 callersMethodgetString

()

src/main/java/com/github/shyiko/mysql/binlog/event/deserialization/json/JsonBinary.java:194

↓ 15 callersMethodwriteAndCaptureJSON

(final String value)

src/test/java/com/github/shyiko/mysql/binlog/event/deserialization/json/JsonBinaryValueIntegrationTest.java:407

↓ 14 callersMethodconnect

(long timeoutInMilliseconds)

src/main/java/com/github/shyiko/mysql/binlog/jmx/BinaryLogClientMXBean.java:30

↓ 14 callersMethodgenerateTime

(int year, int month, int day, int hour, int minute, int second, int millisecond)

src/test/java/com/github/shyiko/mysql/binlog/BinaryLogClientIntegrationTest.java:434

↓ 14 callersMethodvalue

Receive the string value of an element in a JSON object. @param value the element's value; never null

src/main/java/com/github/shyiko/mysql/binlog/event/deserialization/json/JsonFormatter.java:67

↓ 13 callersMethodconnect

Connect to the replication stream. Note that this method blocks until disconnected. @throws AuthenticationException if authentication fails @throws Se

src/main/java/com/github/shyiko/mysql/binlog/BinaryLogClient.java:489

↓ 13 callersMethodequals

(Object obj)

src/main/java/com/github/shyiko/mysql/binlog/GtidSet.java:142

↓ 12 callersMethodclose

()

src/test/java/com/github/shyiko/mysql/binlog/BinaryLogClientIntegrationTest.java:1148

↓ 12 callersMethodgetData

()

src/main/java/com/github/shyiko/mysql/binlog/event/Event.java:38

↓ 12 callersMethodreadPackedInteger

@see #readPackedNumber()

src/main/java/com/github/shyiko/mysql/binlog/io/ByteArrayInputStream.java:130

↓ 12 callersMethodregisterLifecycleListener

src/main/java/com/github/shyiko/mysql/binlog/BinaryLogClient.java:1178

↓ 11 callersMethodawait

(long timeout, TimeUnit unit)

src/test/java/com/github/shyiko/mysql/binlog/TCPReverseProxy.java:133

↓ 11 callersMethodread

(int length)

src/main/java/com/github/shyiko/mysql/binlog/io/ByteArrayInputStream.java:87

↓ 11 callersMethodtoString

()

src/main/java/com/github/shyiko/mysql/binlog/GtidSet.java:154

↓ 11 callersMethodwrite

(Command command, int packetNumber)

src/main/java/com/github/shyiko/mysql/binlog/network/protocol/PacketChannel.java:64

↓ 10 callersMethoddisconnect

Disconnect from the replication stream. Note that this does not reset binlogFilename/binlogPosition. Calling {@link #connect()} or {@link #connect(lon

src/main/java/com/github/shyiko/mysql/binlog/BinaryLogClient.java:1205

↓ 10 callersMethoddisconnect

()

src/main/java/com/github/shyiko/mysql/binlog/jmx/BinaryLogClientMXBean.java:32

↓ 10 callersMethodgetEventType

()

src/main/java/com/github/shyiko/mysql/binlog/event/EventHeader.java:26

↓ 10 callersMethodreadString

Read fixed length string.

src/main/java/com/github/shyiko/mysql/binlog/io/ByteArrayInputStream.java:65

↓ 10 callersMethodreset

()

src/main/java/com/github/shyiko/mysql/binlog/jmx/BinaryLogClientStatisticsMXBean.java:30

↓ 10 callersMethodsetValue

(Object value)

src/main/java/com/github/shyiko/mysql/binlog/event/deserialization/json/JsonBinary.java:1011

↓ 10 callersMethodunregisterEventListener

Unregister all event listener of specific type.

src/main/java/com/github/shyiko/mysql/binlog/BinaryLogClient.java:1137

↓ 10 callersMethodwrite

(int b)

src/main/java/com/github/shyiko/mysql/binlog/io/ByteArrayOutputStream.java:66

↓ 9 callersMethodgetHeader

()

src/main/java/com/github/shyiko/mysql/binlog/event/Event.java:33

↓ 9 callersMethodreadZeroTerminatedString

Read variable-length string. End is indicated by 0x00 byte.

src/main/java/com/github/shyiko/mysql/binlog/io/ByteArrayInputStream.java:79

↓ 8 callersMethodbitSlice

(long value, int bitOffset, int numberOfBits, int payloadSize)

src/main/java/com/github/shyiko/mysql/binlog/event/deserialization/AbstractRowsEventDataDeserializer.java:432

↓ 8 callersMethoddeserialize

(ByteArrayInputStream inputStream)

src/main/java/com/github/shyiko/mysql/binlog/event/deserialization/EventDataDeserializer.java:29

↓ 8 callersMethodfrom

(int year, int month, int day, int hour, int minute, int second, int millis)

src/main/java/com/github/shyiko/mysql/binlog/event/deserialization/AbstractRowsEventDataDeserializer.java:536

↓ 8 callersMethodgetUUID

Get the UUID for the server that generated the GTIDs. @return the server's UUID; never null

src/main/java/com/github/shyiko/mysql/binlog/GtidSet.java:257

↓ 8 callersMethodgetUUIDSet

Find the {@link UUIDSet} for the server with the specified UUID. @param uuid the UUID of the server @return the {@link UUIDSet} for the identified ser

src/main/java/com/github/shyiko/mysql/binlog/GtidSet.java:82

↓ 8 callersMethodread

()

src/main/java/com/github/shyiko/mysql/binlog/io/BufferedSocketInputStream.java:45

↓ 8 callersMethodsetEventDataDeserializer

(EventType eventType, EventDataDeserializer eventDataDeserializer)

src/main/java/com/github/shyiko/mysql/binlog/event/deserialization/EventDeserializer.java:124

↓ 8 callersMethodtoByteArray

()

src/main/java/com/github/shyiko/mysql/binlog/io/ByteArrayOutputStream.java:71

↓ 8 callersMethodtoString

()

src/main/java/com/github/shyiko/mysql/binlog/event/deserialization/json/JsonStringFormatter.java:72

↓ 8 callersMethodwriteLong

Write long in little-endian format.

src/main/java/com/github/shyiko/mysql/binlog/io/ByteArrayOutputStream.java:48

↓ 7 callersMethodassetTimeEquals

(long actual, long expected)

src/test/java/com/github/shyiko/mysql/binlog/event/deserialization/AbstractRowsEventDataDeserializerTest.java:48

↓ 7 callersMethodcastTimestamp

(Long timestamp, int fsp)

src/main/java/com/github/shyiko/mysql/binlog/event/deserialization/AbstractRowsEventDataDeserializer.java:241

↓ 7 callersMethodgetErrorCode

()

src/main/java/com/github/shyiko/mysql/binlog/network/protocol/ErrorPacket.java:41

↓ 7 callersMethodgetErrorMessage

()

src/main/java/com/github/shyiko/mysql/binlog/network/protocol/ErrorPacket.java:49

↓ 7 callersMethodgetSqlState

()

src/main/java/com/github/shyiko/mysql/binlog/network/protocol/ErrorPacket.java:45

↓ 7 callersMethodreadBitSet

(int length, boolean bigEndian)

src/main/java/com/github/shyiko/mysql/binlog/io/ByteArrayInputStream.java:104

↓ 7 callersMethodreadUnsignedIndex

(int maxValue, boolean isSmall, String desc)

src/main/java/com/github/shyiko/mysql/binlog/event/deserialization/json/JsonBinary.java:873

↓ 7 callersMethodsetEventDeserializer

@param eventDeserializer custom event deserializer

src/main/java/com/github/shyiko/mysql/binlog/BinaryLogClient.java:455

↓ 7 callersMethodverify

(String hostname, SSLSession session)

src/main/java/com/github/shyiko/mysql/binlog/network/TLSHostnameVerifier.java:32

↓ 6 callersMethodgetEnd

Get the ending transaction number in this interval. @return this interval's last transaction number

src/main/java/com/github/shyiko/mysql/binlog/GtidSet.java:369

↓ 6 callersMethodgetEventDataDeserializer

(EventType eventType)

src/main/java/com/github/shyiko/mysql/binlog/event/deserialization/EventDeserializer.java:305

↓ 6 callersMethodgetEvents

(Class<E> eventDataType)

src/test/java/com/github/shyiko/mysql/binlog/CapturingEventListener.java:39

↓ 6 callersMethodgetRows

()

src/main/java/com/github/shyiko/mysql/binlog/event/WriteRowsEventData.java:51

↓ 6 callersMethodgetStart

Get the starting transaction number in this interval. @return this interval's first transaction number

src/main/java/com/github/shyiko/mysql/binlog/GtidSet.java:361

↓ 6 callersMethodgetValue

()

src/main/java/com/github/shyiko/mysql/binlog/event/IntVarEventData.java:38

↓ 6 callersMethodsplit

(long value, int divider, int length)

src/main/java/com/github/shyiko/mysql/binlog/event/deserialization/AbstractRowsEventDataDeserializer.java:445

↓ 5 callersMethodappendList

(StringBuilder sb, List<?> elements)

src/main/java/com/github/shyiko/mysql/binlog/event/TableMapEventMetadata.java:184

↓ 5 callersMethodappendTwoDigitUnsignedInt

(int value)

src/main/java/com/github/shyiko/mysql/binlog/event/deserialization/json/JsonStringFormatter.java:254

↓ 5 callersMethodasUnixTime

(int year, int month, int day, int hour, int minute, int second, int millis)

src/main/java/com/github/shyiko/mysql/binlog/event/deserialization/AbstractRowsEventDataDeserializer.java:415

↓ 5 callersMethodbigEndianInteger

(byte[] bytes, int offset, int length)

src/main/java/com/github/shyiko/mysql/binlog/event/deserialization/AbstractRowsEventDataDeserializer.java:490

↓ 5 callersMethodbyteArrayToHex

(byte[] a, int offset, int len)

src/main/java/com/github/shyiko/mysql/binlog/event/deserialization/GtidEventDataDeserializer.java:44

↓ 5 callersMethodbyteArrayToHex

(byte[] a, int offset, int len)

src/main/java/com/github/shyiko/mysql/binlog/event/deserialization/PreviousGtidSetDeserializer.java:60

↓ 5 callersMethodcloseChannel

(final PacketChannel channel)

src/main/java/com/github/shyiko/mysql/binlog/BinaryLogClient.java:1261

↓ 5 callersMethodenterBlock

(int length)

src/main/java/com/github/shyiko/mysql/binlog/io/ByteArrayInputStream.java:210

↓ 5 callersMethodgetBinlogFilename

()

src/main/java/com/github/shyiko/mysql/binlog/jmx/BinaryLogClientMXBean.java:26

↓ 5 callersMethodgetBinlogPosition

()

src/main/java/com/github/shyiko/mysql/binlog/jmx/BinaryLogClientMXBean.java:28

↓ 5 callersMethodgetLastEvent

()

src/main/java/com/github/shyiko/mysql/binlog/jmx/BinaryLogClientStatistics.java:46

↓ 5 callersMethodgetNumberOfSkippedEvents

()

src/main/java/com/github/shyiko/mysql/binlog/jmx/BinaryLogClientStatistics.java:81

↓ 5 callersMethodgetTotalNumberOfEventsSeen

()

src/main/java/com/github/shyiko/mysql/binlog/jmx/BinaryLogClientStatistics.java:71

↓ 5 callersMethodreadInt64

()

src/main/java/com/github/shyiko/mysql/binlog/event/deserialization/json/JsonBinary.java:920

↓ 5 callersMethodreadUInt16

()

src/main/java/com/github/shyiko/mysql/binlog/event/deserialization/json/JsonBinary.java:891

↓ 5 callersMethodtimestamp

(int year, int month, int dayOfMonth, int hourOfDay, int minute, int second, int millis)

src/test/java/com/github/shyiko/mysql/binlog/event/deserialization/AbstractRowsEventDataDeserializerTest.java:54

↓ 4 callersMethodbitSet

(int... bitsToSetTrue)

src/test/java/com/github/shyiko/mysql/binlog/BinaryLogClientIntegrationTest.java:425

↓ 4 callersMethodbyCode

(int code)

src/main/java/com/github/shyiko/mysql/binlog/event/deserialization/ColumnType.java:79

↓ 4 callersMethoddeserializeRow

(long tableId, BitSet includedColumns, ByteArrayInputStream inputStream)

src/main/java/com/github/shyiko/mysql/binlog/event/deserialization/AbstractRowsEventDataDeserializer.java:100

↓ 4 callersMethodgenerateEvent

(long timestamp, EventType type, long serverId, long nextPosition)

src/test/java/com/github/shyiko/mysql/binlog/jmx/BinaryLogClientStatisticsTest.java:104

↓ 4 callersMethodgetCounter

(Map<K, AtomicInteger> counterMap, K key)

src/test/java/com/github/shyiko/mysql/binlog/CountDownEventListener.java:45

↓ 4 callersMethodgetEventListeners

@return registered event listeners

src/main/java/com/github/shyiko/mysql/binlog/BinaryLogClient.java:1122

↓ 4 callersMethodgetGtidSet

@return GTID set. Note that this value changes with each received GTID event (provided client is in GTID mode). @see #setGtidSet(String)

src/main/java/com/github/shyiko/mysql/binlog/BinaryLogClient.java:298

↓ 4 callersMethodgetInputStream

()

src/main/java/com/github/shyiko/mysql/binlog/network/protocol/PacketChannel.java:50

↓ 4 callersMethodgetLifecycleListeners

@return registered lifecycle listeners

src/main/java/com/github/shyiko/mysql/binlog/BinaryLogClient.java:1170

↓ 4 callersMethodgetNumberOfDisconnects

()

src/main/java/com/github/shyiko/mysql/binlog/jmx/BinaryLogClientStatistics.java:86

↓ 4 callersMethodgetSecondsBehindMaster

()

src/main/java/com/github/shyiko/mysql/binlog/jmx/BinaryLogClientStatistics.java:59

↓ 4 callersMethodgetSecondsSinceLastEvent

()

src/main/java/com/github/shyiko/mysql/binlog/jmx/BinaryLogClientStatistics.java:53

↓ 4 callersMethodisKeepAliveThreadRunning

()

src/main/java/com/github/shyiko/mysql/binlog/BinaryLogClient.java:854

↓ 4 callersMethodjoin

(Collection<?> o, String delimiter)

src/main/java/com/github/shyiko/mysql/binlog/GtidSet.java:163

↓ 4 callersMethodonEvent

(Event event)

src/main/java/com/github/shyiko/mysql/binlog/jmx/BinaryLogClientStatistics.java:101

↓ 4 callersMethodparse

Parse the MySQL binary representation of a {@code JSON} value and call the supplied {@link JsonFormatter} for the various components of the value. @p

src/main/java/com/github/shyiko/mysql/binlog/event/deserialization/json/JsonBinary.java:180

↓ 4 callersMethodpeek

()

src/main/java/com/github/shyiko/mysql/binlog/io/ByteArrayInputStream.java:173

↓ 4 callersMethodreadAll

(BinaryLogFileReader reader, int expect)

src/test/java/com/github/shyiko/mysql/binlog/BinaryLogFileReaderIntegrationTest.java:73

↓ 4 callersMethodreadIntegers

(ByteArrayInputStream inputStream)

src/main/java/com/github/shyiko/mysql/binlog/event/deserialization/TableMapEventMetadataDeserializer.java:115

↓ 4 callersMethodreadUInt32

()

src/main/java/com/github/shyiko/mysql/binlog/event/deserialization/json/JsonBinary.java:912

next →1–100 of 787, ranked by callers