Module: EsHttpClient

Defined in:

lib/es_http_client.rb,
lib/es_http_client/ref.rb,
lib/es_http_client/page.rb,
lib/es_http_client/event.rb,
lib/es_http_client/client.rb,
lib/es_http_client/connection.rb,
lib/es_http_client/error_handler.rb,
lib/es_http_client/stream_events.rb,
lib/es_http_client/readonly_stream.rb,
lib/es_http_client/caught_up_stream.rb,
lib/es_http_client/writeable_stream.rb,
lib/es_http_client/es_http_client_error.rb

Defined Under Namespace

Modules: ExpectedVersion Classes: CaughtUpStream, Client, Connection, ErrorHandler, EsHttpClientError, Event, Page, ReadonlyStream, Ref, StreamEvents, WriteableStream

Class Method Summary

• .connect(endpoint, username, password) ⇒ Object
• .create_event(type, data) ⇒ Object

Class Method Details

.connect(endpoint, username, password) ⇒ Object

# File 'lib/es_http_client.rb', line 14

def self.connect(endpoint, username, password)
  Client.new(Connection.new(endpoint, username, password))
end

.create_event(type, data) ⇒ Object

# File 'lib/es_http_client.rb', line 18

def self.create_event(type, data)
  id = UUIDTools::UUID.random_create.to_s
  timestamp = Time.now.strftime('%FT%T.%3N%:z')
  data = data.merge({
    occurredAt: timestamp
  })
  Event.new(id, type, data, timestamp, 0)
end