Class: Riak::TimeSeries::Submission

Inherits:
Object
  • Object
show all
Defined in:
lib/riak/time_series/submission.rb

Instance Attribute Summary collapse

Instance Method Summary collapse

Constructor Details

#initialize(client, table_name) ⇒ Submission

Initializes the submission object with a client and table name

Parameters:

  • client (Riak::Client) —

    the client connected to the Riak TS cluster

  • table_name (String) —

    the table name in the cluster



34
35
36
37
 
# File 'lib/riak/time_series/submission.rb', line 34

def initialize(client, table_name)
  @client = client
  @table_name = table_name
end

Instance Attribute Details

#client ⇒ Riak::Client (readonly)

Returns the client to write submissions to.

Returns:



24
25
26
 
# File 'lib/riak/time_series/submission.rb', line 24

def client
  @client
end

#measurements ⇒ Array<Array<Object>>

Returns measurements to write to Riak TS.

Returns:



20
21
22
 
# File 'lib/riak/time_series/submission.rb', line 20

def measurements
  @measurements
end

#table_name ⇒ String (readonly)

Returns the table name to write submissions to.

Returns:

  • (String) —

    the table name to write submissions to



28
29
30
 
# File 'lib/riak/time_series/submission.rb', line 28

def table_name
  @table_name
end

Instance Method Details

#write! ⇒ Object

Write the submitted data to Riak.



40
41
42
43
44
 
# File 'lib/riak/time_series/submission.rb', line 40

def write!
  client.backend do |be|
    be.time_series_put_operator.put(table_name, measurements)
  end
end