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