class Reckoner::Cdp::Client

Public Class Methods

new(token, endpoint: nil, client_id: nil, connection: nil) click to toggle source
# File lib/reckoner/cdp/client.rb, line 6
def initialize(token, endpoint: nil, client_id: nil, connection: nil)
  @token = token
  @endpoint = endpoint
  @client_id = client_id
  @connection = connection
end

Public Instance Methods

streaming_insert(workflow_id, data) click to toggle source
# File lib/reckoner/cdp/client.rb, line 13
def streaming_insert(workflow_id, data)
  streaming_api.insert(workflow_id, data)
end

Private Instance Methods

streaming_api() click to toggle source
# File lib/reckoner/cdp/client.rb, line 19
def streaming_api
  @streaming_api ||= Reckoner::Cdp::API::StreamingCore.new(
    @token,
    @endpoint,
    @client_id,
    @connection
  )
end