MCPcopy Create free account
hub / github.com/actiontech/dtle / NewDataEvent

Function NewDataEvent

driver/common/binlog.go:111–120  ·  view source on GitHub ↗
(databaseName, tableName string, dml int8, columnCount uint64, timestamp uint32)

Source from the content-addressed store, hash-verified

109}
110
111func NewDataEvent(databaseName, tableName string, dml int8, columnCount uint64, timestamp uint32) *DataEvent {
112 event := &DataEvent{
113 DatabaseName: databaseName,
114 TableName: tableName,
115 DML: dml,
116 ColumnCount: columnCount,
117 Timestamp: timestamp,
118 }
119 return event
120}
121
122func NewQueryEvent(currentSchema, query string, dml int8, timestamp uint32, flags []byte) DataEvent {
123 event := DataEvent{

Callers 1

handleRowsEventMethod · 0.92

Calls

no outgoing calls

Tested by

no test coverage detected