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

↓ 4 callersMethodunregisterLifecycleListener

Unregister all lifecycle listener of specific type.

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

↓ 3 callersMethodafterEventDataDeserializerSet

(EventType eventType)

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

↓ 3 callersMethodasHex

(byte b)

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

↓ 3 callersMethodbigEndianLong

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

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

↓ 3 callersMethodbind

()

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

↓ 3 callersMethodclose

()

src/main/java/com/github/shyiko/mysql/binlog/BinaryLogFileReader.java:85

↓ 3 callersMethodcloseQuietly

(Closeable... arrayOfCloseable)

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

↓ 3 callersMethodcommitGtid

()

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

↓ 3 callersMethodcreateSocket

()

src/main/java/com/github/shyiko/mysql/binlog/network/SocketFactory.java:26

↓ 3 callersMethoddeserializeFractionalSeconds

(int meta, ByteArrayInputStream inputStream)

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

↓ 3 callersMethodensureEventDataDeserializerIfPresent

(EventType eventType, Class<? extends EventDataDeserializer<?>> eventDataDeserializerClass)

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

↓ 3 callersMethodgetCode

()

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

↓ 3 callersMethodgetColumnTypes

()

src/main/java/com/github/shyiko/mysql/binlog/event/TableMapEventData.java:57

↓ 3 callersMethodgetCurrentTimeMillis

()

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

↓ 3 callersMethodgetDataLength

()

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

↓ 3 callersMethodgetExternal

()

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

↓ 3 callersMethodgetInternal

()

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

↓ 3 callersMethodgetServerId

()

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

↓ 3 callersMethodgetSql

()

src/main/java/com/github/shyiko/mysql/binlog/event/QueryEventData.java:61

↓ 3 callersMethodgetString

()

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

↓ 3 callersMethodinternal

(EventData eventData)

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

↓ 3 callersMethodisDelete

(EventType eventType)

src/main/java/com/github/shyiko/mysql/binlog/event/EventType.java:215

↓ 3 callersMethodisUpdate

(EventType eventType)

src/main/java/com/github/shyiko/mysql/binlog/event/EventType.java:209

↓ 3 callersMethodisWrite

(EventType eventType)

src/main/java/com/github/shyiko/mysql/binlog/event/EventType.java:203

↓ 3 callersMethodnewNamedThread

(Runnable runnable, String threadName)

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

↓ 3 callersMethodonConnect

Called once client has successfully logged in but before started to receive binlog events.

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

↓ 3 callersMethodonDisconnect

Called upon disconnect (regardless of the reason).

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

↓ 3 callersMethodreadInt16

()

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

↓ 3 callersMethodreadInt32

()

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

↓ 3 callersMethodreadLengthEncodedString

Read variable-length string. Preceding packed integer indicates the length of the string.

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

↓ 3 callersMethodreadLiteral

()

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

↓ 3 callersMethodreadResultSet

(final PacketChannel channel)

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

↓ 3 callersMethodreadValueType

()

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

↓ 3 callersMethodsetCompatibilityMode

@see CompatibilityMode

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

↓ 3 callersMethodsetInvalidDateAndTimeRepresentation

(Long value)

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

↓ 3 callersMethodsetKeepAlive

@param keepAlive true if "keep alive" thread should be automatically started (recommended and true by default), false otherwise. @see #isKeepAlive() @

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

↓ 3 callersMethodsetKeepAliveInterval

@param keepAliveInterval "keep alive" interval in milliseconds. @see #getKeepAliveInterval() @see #setHeartbeatInterval(long)

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

↓ 3 callersMethodsetMayContainExtraInformation

(boolean mayContainExtraInformation)

src/main/java/com/github/shyiko/mysql/binlog/event/deserialization/WriteRowsEventDataDeserializer.java:40

↓ 3 callersMethodsetSocketFactory

@param socketFactory custom socket factory. If not provided, socket will be created with "new Socket()".

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

↓ 3 callersMethodtoString

()

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

↓ 3 callersMethodvalueNull

Receive a null value of an element in a JSON object.

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

↓ 3 callersMethodwriteString

(String value)

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

↓ 2 callersMethodappendDate

(int year, int month, int day)

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

↓ 2 callersMethodappendMap

(StringBuilder sb, Map<?, ?> map)

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

↓ 2 callersMethodappendSixDigitUnsignedInt

(int value, boolean trimTrailingZeros)

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

↓ 2 callersMethodappendString

Append a string by escaping any characters that must be escaped. @param original the string to be written; may not be null

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

↓ 2 callersMethodappendTime

(int hour, int min, int sec, int microSeconds)

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

↓ 2 callersMethodasBigDecimal

see mysql/strings/decimal.c

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

↓ 2 callersMethodbindInSeparateThread

(final TCPReverseProxy tcpReverseProxy)

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

↓ 2 callersMethodconnect

()

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

↓ 2 callersMethodconnectWithTimeout

(final long connectTimeout)

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

↓ 2 callersMethoddeserializeEventData

(ByteArrayInputStream inputStream, EventHeader eventHeader, EventDataDeserializer eventDataDeseria

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

↓ 2 callersMethodensureCompatibility

(EventDataDeserializer eventDataDeserializer)

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

↓ 2 callersMethodfill

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

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

↓ 2 callersMethodflush

()

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

↓ 2 callersMethodgetHeaderLength

()

src/main/java/com/github/shyiko/mysql/binlog/event/EventHeaderV4.java:88

↓ 2 callersMethodgetIncludedColumns

()

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

↓ 2 callersMethodgetLength

()

src/main/java/com/github/shyiko/mysql/binlog/event/deserialization/ChecksumType.java:35

↓ 2 callersMethodgetOutputStream

()

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

↓ 2 callersMethodgetOutputStream

()

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

↓ 2 callersMethodgetPort

()

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

↓ 2 callersMethodgetTableId

()

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

↓ 2 callersMethodgetTimestamp

()

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

↓ 2 callersMethodgetUUIDSets

Get an immutable collection of the {@link UUIDSet range of GTIDs for a single server}. @return the {@link UUIDSet GTID ranges for each server}; never

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

↓ 2 callersMethodgetValue

(int index)

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

↓ 2 callersMethodhostname

()

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

↓ 2 callersMethodincrementCounter

(AtomicInteger counter)

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

↓ 2 callersMethodisContainedWithin

Determine if the GTIDs represented by this object are contained completely within the supplied set of GTIDs. Note that if two {@link GtidSet}s are equ

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

↓ 2 callersMethodisOpen

()

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

↓ 2 callersMethodjoin

(CharSequence delimiter, CharSequence... elements)

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

↓ 2 callersMethodjoin

(String[] values, String separator)

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

↓ 2 callersMethodjoinAdjacentIntervals

Collapses intervals like a-(b-1):b-c into a-c (only in index+-1 range).

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

↓ 2 callersMethodleapYearsBefore

(int year)

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

↓ 2 callersMethodname

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

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

↓ 2 callersMethodnextEntry

Called after an entry signaling that another entry will be signaled.

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

↓ 2 callersMethodnextEvent

@return deserialized event or null in case of end-of-stream

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

↓ 2 callersMethodonCommunicationFailure

It's guarantied to be called before {@link #onDisconnect(BinaryLogClient)}) in case of communication failure.

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

↓ 2 callersMethodonDisconnect

(BinaryLogClient client)

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

↓ 2 callersMethodonEventDeserializationFailure

Called in case of failed event deserialization. Note this type of error does NOT cause client to disconnect. If you wish to stop receiving events you'

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

↓ 2 callersMethodonEventDeserializationFailure

(BinaryLogClient client, Exception ex)

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

↓ 2 callersMethodparseArray

(boolean small, JsonFormatter formatter)

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

↓ 2 callersMethodparseAsString

Parse the MySQL binary representation of a {@code JSON} value and return the JSON string representation. <p> This method is equivalent to {@link #pars

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

↓ 2 callersMethodparseObject

Parse a JSON object. <p> The grammar of the binary representation of JSON objects are defined in the MySQL code base in the <a href="https://github.co

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

↓ 2 callersMethodpassword

()

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

↓ 2 callersMethodpasswordCompatibleWithMySQL411

see mysql/sql/password.c scramble(...)

src/main/java/com/github/shyiko/mysql/binlog/network/protocol/command/AuthenticateCommand.java:82

↓ 2 callersMethodport

()

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

↓ 2 callersMethodquery

(String sql, Callback<ResultSet> callback)

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

↓ 2 callersMethodreadDefaultCharset

(ByteArrayInputStream inputStream)

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

↓ 2 callersMethodreadEvent

@return deserialized event or null in case of end-of-stream

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

↓ 2 callersMethodreadIntegerPairs

(ByteArrayInputStream inputStream)

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

↓ 2 callersMethodreadTypeValues

(ByteArrayInputStream inputStream)

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

↓ 2 callersMethodreadVariableInt

Read a variable-length integer value. <p> If the high bit of a byte is 1, the length field is continued in the next byte, otherwise it is the last byt

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

↓ 2 callersMethodreadWithinBlockBoundaries

()

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

↓ 2 callersMethodreconnect

()

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

↓ 2 callersMethodresetInternalState

()

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

↓ 2 callersMethodsetEventType

(EventType eventType)

src/main/java/com/github/shyiko/mysql/binlog/event/EventHeaderV4.java:47

↓ 2 callersMethodsetKeepAliveConnectTimeout

@param connectTimeout "keep alive" connect timeout in milliseconds. @see #getKeepAliveConnectTimeout() @deprecated in favour of {@link #setConnectTim

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

↓ 2 callersMethodsetNextPosition

(long nextPosition)

src/main/java/com/github/shyiko/mysql/binlog/event/EventHeaderV4.java:76

↓ 2 callersMethodsetServerId

@param serverId server id (in the range from 1 to 2^32 - 1). This value MUST be unique across whole replication group (that is, different from any oth

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

↓ 2 callersMethodsetServerId

(long serverId)

src/main/java/com/github/shyiko/mysql/binlog/event/EventHeaderV4.java:56

← previous next →101–200 of 787, ranked by callers