Class: Fluent::MysqlBinlogRecordHandler
- Inherits:
-
Object
- Object
- Fluent::MysqlBinlogRecordHandler
show all
- Defined in:
- lib/flydata/fluent-plugins/in_mysql_binlog_flydata.rb
Instance Method Summary
collapse
Instance Method Details
#dispatch(event) ⇒ Object
60
61
62
63
64
65
66
67
68
69
70
71
|
# File 'lib/flydata/fluent-plugins/in_mysql_binlog_flydata.rb', line 60
def dispatch(event)
method_name = "on_#{event.event_type.downcase}"
if self.respond_to?(method_name)
record = MysqlBinlogInput::BinlogUtil.to_hash(event)
self.send(method_name, record)
else
end
end
|