module Reckoner::Cdp::API::Streaming
Public Instance Methods
insert(workflow_id, data)
click to toggle source
# File lib/reckoner/cdp/api/streaming.rb, line 11 def insert(workflow_id, data) unless data.class == Array raise Reckoner::Cdp::InvalidArgumentError, "'data' must be an Array" end params = { data: data.to_msgpack, time: Time.now.to_i, workflow_id: workflow_id, record_id: SecureRandom.uuid } get('/api/v1/streaming', params) end