module GlassOctopus

Build a middleware stack. Basically a shortcut to +Builder.new { }.to_app+

@example

require "glass_octopus"

app = GlassOctopus.build do
  use GlassOctopus::Middleware::CommonLogger

  run Proc.new { |context|
    puts "Hello, #{context.message.value}"
  }
end

GlassOctopus.run(app) do |config|
  # set config here
end

@see Builder @yield use the builder DSL to build your middleware stack @return [#call] an application that can be fed into the {.run}

# File lib/glass_octopus.rb, line 47
def self.build(&block)
  Builder.new(&block).to_app
end

Run an application. The application can be anything that responds to #call. It is invoked with with a context that has the message and other goodies.

@param app [#call] application to process messages @param runner [#run] a runner that takes care of running and shutting down

the application. See {Runner} for more details.

@yield [config] configure your application in this block, this is called

before connecting to Kafka

@yieldparam config [Configuration] the configuration object @raise [ArgumentError] when no block for configuration is passed

# File lib/glass_octopus.rb, line 19
def self.run(app, runner: Runner, &block)
  raise ArgumentError, "A block must be given to set up the #{name}." unless block_given?
  go_app = Application.new(app, &block)
  runner.run(go_app)
end