class LogStash::PluginMixins::JdbcStreaming::CachePayload
Attributes
payload[R]
Public Class Methods
new()
click to toggle source
# File lib/logstash/plugin_mixins/jdbc_streaming/cache_payload.rb, line 7 def initialize @failure = false @payload = [] end
Public Instance Methods
empty?()
click to toggle source
# File lib/logstash/plugin_mixins/jdbc_streaming/cache_payload.rb, line 24 def empty? @payload.empty? end
failed!()
click to toggle source
# File lib/logstash/plugin_mixins/jdbc_streaming/cache_payload.rb, line 16 def failed! @failure = true end
failed?()
click to toggle source
# File lib/logstash/plugin_mixins/jdbc_streaming/cache_payload.rb, line 20 def failed? @failure end
push(data)
click to toggle source
# File lib/logstash/plugin_mixins/jdbc_streaming/cache_payload.rb, line 12 def push(data) @payload << data end