Sha256: 65859856da3671fccdb44e33414a82941390233407fc4b75cf61f670d06cdd6c
Contents?: true
Size: 1.8 KB
Versions: 7
Compression:
Stored size: 1.8 KB
Contents
require 'spec_helper'
require 'riak'
describe "Yokozuna", test_client: true, integration: true do
before(:all) do
@client = test_client
@index = 'yz_spec-' + random_key
@schema = 'yz_spec-' + random_key
end
context "without any indexes" do
it "allows index creation" do
expect(@client.create_search_index(@index, "_yz_default", 3)).to eq(true)
end
end
context "with an index" do
before :all do
expect(@client.create_search_index(@index)).to eq(true)
wait_until{ !@client.get_search_index(@index).nil? }
end
it "allows index inspection" do
expect(@client.get_search_index(@index).name).to eq(@index)
expect{ @client.get_search_index("herp_derp") }.to raise_error(Riak::ProtobuffsFailedRequest)
end
it "has an index list" do
expect(@client.list_search_indexes.size).to be >= 1
end
it "associates a bucket with an index" do
@bucket = Riak::Bucket.new(@client, @index)
@bucket.props = {'search_index' => @index}
@bucket = @client.bucket(@index)
expect(@bucket.props).to include('search_index' => @index)
end
context "associated with a bucket" do
before :all do
@bucket = Riak::Bucket.new(@client, @index)
@bucket.props = {'search_index' => @index}
@bucket = @client.bucket(@index)
expect(@bucket.props).to include('search_index' => @index)
end
it "indexes on object writes" do
object = @bucket.get_or_new("cat")
object.raw_data = {"cat_s"=>"Lela"}.to_json
object.content_type = 'application/json'
object.store
sleep 1.1 # pause for index commit to trigger
resp = @client.search(@index, "cat_s:Lela")
expect(resp).to include('docs')
expect(resp['docs'].size).to eq(1)
end
end
end
end
Version data entries
7 entries across 7 versions & 2 rubygems