jgaskins

# Experiment with macros to allow for project-local requires
# https://forum.crystal-lang.org/t/project-relative-require/4617

{% begin %}
  ROOT = "{{system("pwd").strip.id}}"
{% end %}
macro spec(file)
  macro load_spec
    \{% path = __DIR__.gsub(%r{\A{{ROOT.id}}}, "").gsub(%r{[^/]+}, "..").id %}
    require "\{{path[1..]}}/spec/{{file.id}}"

jgaskins

require "http"
require "json"
require "uuid/json"
require "db"
require "interro" # github: jgaskins/interro
require "faker"   # github: askn/faker

ES = ElasticSearch::Client.new
pg = DB.open("postgres:///")
Interro.config { |c| c.db = pg }

jgaskins

class ImmutableEachArray(T)
  include Enumerable(T)

  @iterating = Atomic(Int32).new(0)
  @array = Array(T).new

  def <<(value : T) : self
    raise CannotMutateWhileIterating.new("you iteratin bruh") if @iterating.get > 0

    @array << value

jgaskins

Drivers

Name	Description
ruby	The redis gem with the plain-Ruby driver
hiredis	The redis gem with the hiredis driver (compiled as a C extension)
myredis	Pure-Ruby, optimized for the specific operation

Benchmarks

jgaskins

require 'bundler/inline'

require 'socket'
class MyRedis
  CRLF = "\r\n"

  def initialize
    @connection = TCPSocket.new('localhost', 6379)
    @connection.sync = false
  end

jgaskins

require "http"

require "./route"

class App
  include HTTP::Handler
  include Route

  def call(context)
    route context do |r, response|

jgaskins

require "benchmark"

value = nil
Benchmark.ips do |x|
  x.report "1 ivar" { value = OneIVar.new }
  x.report "2 ivars" { value = TwoIVars.new }
  x.report "4 ivars" { value = FourIVars.new }
  x.report "8 ivars" { value = EightIVars.new }
  x.report "16 ivars" { value = SixteenIVars.new }
end

jgaskins

require "benchmark"

int = 0
[1, 12, 1234, 12345678, 1234567812345678].each do |number|
  puts "Parsing #{number}..."
  io = IO::Memory.new
  io << ":#{number}\r\n" # Redis integer format
  io.rewind

  Benchmark.ips do |x|

jgaskins

require "socket"

module Redis
  alias Type = String | Int64 | Nil | Array(Type)

  class Future
    property! value : Type
  end

  module Commands

jgaskins

class Redis
  module Commands
    def xadd(stream, id, params : Hash)
      params = params.each_with_object(Array(String).new(params.size * 2)) do |(key, value), array|
        array << key << value.to_s
      end
      string_command(["XADD", stream, id] + params)
    end

    def xrange(stream, start, finish)