Class: LogStash::Filters::JdbcStreaming
- Inherits:
-
Base
- Object
- Base
- LogStash::Filters::JdbcStreaming
- Includes:
- PluginMixins::JdbcStreaming
- Defined in:
- lib/logstash/filters/jdbc_streaming.rb
Defined Under Namespace
Classes: CachePayload, NoCache, RowCache
Instance Method Summary collapse
Methods included from PluginMixins::JdbcStreaming
included, #prepare_jdbc_connection, #setup_jdbc_config
Instance Method Details
#filter(event) ⇒ Object
119 120 121 122 123 124 125 126 127 128 129 130 131 132 |
# File 'lib/logstash/filters/jdbc_streaming.rb', line 119 def filter(event) result = cache_lookup(event) # should return a JdbcCachePayload if result.failed? tag_failure(event) end if result.empty? tag_default(event) process_event(event, @default_array) else process_event(event, result.payload) end end |
#register ⇒ Object
114 115 116 117 |
# File 'lib/logstash/filters/jdbc_streaming.rb', line 114 def register prepare_connected_jdbc_cache end |