Sha256: 2ebce64d1eef4fa7d586f03a68b2e3376a9fec4ea42a3bdf6c6834398cd67384
Contents?: true
Size: 1.61 KB
Versions: 34
Compression:
Stored size: 1.61 KB
Contents
require 'fluent_plugins_spec_helper'
require 'flydata/source_mysql/plugin_support/source_position_file'
require 'tempfile'
module Flydata::SourceMysql::PluginSupport
describe SourcePositionFile do
let(:binlog_file) { "mysqlbin-00001" }
let(:binlog_pos) { "4" }
let(:source_pos_content) { "#{binlog_file}\t#{binlog_pos}" }
let(:pos_file) { Tempfile.new('source_pos') }
let(:file_path) { pos_file.path }
let(:subject_object) { described_class.new(file_path) }
before { File.write(file_path, source_pos_content) }
after { FileUtils.rm(file_path) if File.exists?(file_path) }
describe '#exists?' do
subject { subject_object.exists? }
context 'when the file exists' do
it { is_expected.to eq(true) }
end
context 'when the file does not exist' do
before { FileUtils.rm(file_path) }
it { is_expected.to eq(false) }
end
end
describe '#read' do
subject { subject_object.read }
it { is_expected.to eq(source_pos_content) }
end
describe '#pos' do
subject { subject_object.pos }
it { is_expected.to be_kind_of(FlydataCore::Mysql::BinlogPos) }
it { expect(subject.to_s).to eq(source_pos_content) }
context 'when the file is missing' do
before { FileUtils.rm(file_path) }
it { is_expected.to be_nil }
end
end
describe '#save' do
subject { subject_object.save("mysql-bin.000002", 120)}
it { is_expected.to be_kind_of(FlydataCore::Mysql::BinlogPos) }
it do
subject
expect(subject_object.read).to eq("mysql-bin.000002\t120")
end
end
end
end
Version data entries
34 entries across 34 versions & 1 rubygems