Class: Cellect::Client::Connection

Inherits:
Object
  • Object
show all
Includes:
Celluloid, Celluloid::IO
Defined in:
lib/cellect/client/connection.rb

Instance Method Summary collapse

Instance Method Details

#add_seen(id, user_id: user_id, host: host, workflow_id: workflow_id) ⇒ Object 



29
30
31
 
# File 'lib/cellect/client/connection.rb', line 29

def add_seen(id, user_id: user_id, host: host, workflow_id: workflow_id)
  send_http host, :put, "/workflows/#{ workflow_id }/users/#{ user_id }/add_seen", querystring(subject_id: id)
end

#add_subject(id, workflow_id: workflow_id, group_id: nil, priority: nil) ⇒ Object 



17
18
19
 
# File 'lib/cellect/client/connection.rb', line 17

def add_subject(id, workflow_id: workflow_id, group_id: nil, priority: nil)
  broadcast :put, "/workflows/#{ workflow_id }/add", querystring(subject_id: id, group_id: group_id, priority: priority)
end

#delete_workflow(id) ⇒ Object 



13
14
15
 
# File 'lib/cellect/client/connection.rb', line 13

def delete_workflow(id)
  broadcast :delete, "/workflows/#{ id }"
end

#get_subjects(user_id: user_id, host: host, workflow_id: workflow_id, limit: limit, group_id: group_id) ⇒ Object 



33
34
35
 
# File 'lib/cellect/client/connection.rb', line 33

def get_subjects(user_id: user_id, host: host, workflow_id: workflow_id, limit: limit, group_id: group_id)
  send_http host, :get, "/workflows/#{ workflow_id }", querystring(user_id: user_id, group_id: group_id, limit: limit)
end

#load_user(id, host: host, workflow_id: workflow_id) ⇒ Object 



25
26
27
 
# File 'lib/cellect/client/connection.rb', line 25

def load_user(id, host: host, workflow_id: workflow_id)
  send_http host, :post, "/workflows/#{ workflow_id }/users/#{ id }/load"
end

#reload_workflow(id) ⇒ Object 



9
10
11
 
# File 'lib/cellect/client/connection.rb', line 9

def reload_workflow(id)
  broadcast :post, "/workflows/#{ id }/reload"
end

#remove_subject(id, workflow_id: workflow_id, group_id: nil) ⇒ Object 



21
22
23
 
# File 'lib/cellect/client/connection.rb', line 21

def remove_subject(id, workflow_id: workflow_id, group_id: nil)
  broadcast :put, "/workflows/#{ workflow_id }/remove", querystring(subject_id: id, group_id: group_id)
end