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