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