Module: Ksql

Defined in:

lib/ksql.rb,
lib/ksql/error.rb,
lib/ksql/client.rb,
lib/ksql/stream.rb,
lib/ksql/version.rb,
lib/ksql/api/info.rb,
lib/ksql/api/ksql.rb,
lib/ksql/api/query.rb,
lib/ksql/api/stream.rb,
lib/ksql/collection.rb,
lib/ksql/handlers/raw.rb,
lib/ksql/api/terminate.rb,
lib/ksql/configuration.rb,
lib/ksql/api/close_query.rb,
lib/ksql/handlers/stream.rb,
lib/ksql/api/health_check.rb,
lib/ksql/connection/client.rb,
lib/ksql/api/cluster_status.rb,
lib/ksql/connection/request.rb,
lib/ksql/connection/response.rb,
lib/ksql/handlers/collection.rb,
lib/ksql/handlers/typed_list.rb

Defined Under Namespace

Modules: Api, Connection, Handlers Classes: Client, Collection, Configuration, ConfigurationError, Error, Stream, StreamError

Constant Summary

VERSION =

'0.1.2'

Class Attribute Summary

• .config ⇒ Object

  Returns the value of attribute config.

Class Method Summary

• .configure {|config| ... } ⇒ Boolean

  Configure Ksql.

Class Attribute Details

.config ⇒ Object

Returns the value of attribute config.

# File 'lib/ksql.rb', line 36

def config
  @config
end

Class Method Details

.configure {|config| ... } ⇒ Boolean

Configure Ksql

Yields:

• (config)

Returns:

• (Boolean) —

  true

# File 'lib/ksql.rb', line 43

def configure
  self.config = Ksql::Configuration.new
  yield(config)
  config.validate
end