Sha256: 4e8afdc923874d7ac206e351dd36a1a43a2b5b26c3c2380a9aa5056374eb618c
Contents?: true
Size: 1.01 KB
Versions: 34
Compression:
Stored size: 1.01 KB
Contents
require 'timecop'
require 'fileutils'
module Fluent
FLYDATA_HOME = Flydata::FLYDATA_HOME
TEST_TAG = "test_tag"
TEST_DB = "test_db"
TEST_TABLE = "test_table"
TEST_SEQUENCE_FILE = File.join(FLYDATA_HOME, "positions/#{TEST_TABLE}.pos")
TEST_SEQUENCE_NUM = 1
TEST_TABLE_BINLOG_POS = File.join(FLYDATA_HOME, "positions/#{TEST_TABLE}.binlog.pos")
TEST_TABLES = "#{TEST_TABLE},test_table_1,test_table_2,test_table_3"
TEST_POSITION_FILE = "test_position.binlog.pos"
TEST_SENT_POSITION_FILE = "test_position.binlog.sent.pos"
TEST_REVISION_FILE = File.join(FLYDATA_HOME, "positions/#{TEST_TABLE}.rev")
TEST_TIMESTAMP = 1389214083
TEST_TABLE_APPEND_ONLY = "test_table_4"
TEST_SEQUENCE_FILE_1 = File.join(FLYDATA_HOME, "positions/#{TEST_TABLE_APPEND_ONLY}.pos")
shared_context 'sync source plugin context' do
def create_file(file_path, content)
File.open(file_path, 'w') {|f| f.write(content)}
end
def delete_file(file_path)
FileUtils.rm(file_path) if File.exists?(file_path)
end
end
end
Version data entries
34 entries across 34 versions & 1 rubygems