Sha256: 34e9eeed312f5818b14e188eed64c4e0bc896fa875380bf407319ecaee37bd1a
Contents?: true
Size: 395 Bytes
Versions: 42
Compression:
Stored size: 395 Bytes
Contents
# encoding: utf-8
module LogStash module PluginMixins module JdbcStreaming
class CachePayload
attr_reader :payload
def initialize
@failure = false
@payload = []
end
def push(data)
@payload << data
end
def failed!
@failure = true
end
def failed?
@failure
end
def empty?
@payload.empty?
end
end
end end end
Version data entries
42 entries across 42 versions & 2 rubygems