Sha256: af078c015e9eb942eee01e6b7f1f28513db3ea3849bb61f04f52deadb3b4b1e1

Contents?: true

Size: 253 Bytes

Versions: 10

Compression:

Stored size: 253 Bytes

Contents

module Tako
  module MultiShardExecution
    def with_all_shards
      shard_names.each do |shard_name|
        shard(shard_name) do
          yield
        end
      end
    end

    def shard_names
      Tako::Repository.shard_names
    end
  end
end

Version data entries

10 entries across 10 versions & 1 rubygems

Version Path
tako-0.6.0 lib/tako/multi_shard_execution.rb
tako-0.5.0 lib/tako/multi_shard_execution.rb
tako-0.4.1 lib/tako/multi_shard_execution.rb
tako-0.4.0 lib/tako/multi_shard_execution.rb
tako-0.3.2 lib/tako/multi_shard_execution.rb
tako-0.3.1 lib/tako/multi_shard_execution.rb
tako-0.3.0 lib/tako/multi_shard_execution.rb
tako-0.2.2 lib/tako/multi_shard_execution.rb
tako-0.2.1 lib/tako/multi_shard_execution.rb
tako-0.2.0 lib/tako/multi_shard_execution.rb