Class: RealtimeIndexing

Inherits:
Object
  • Object
show all
Defined in:
backend/app/lib/realtime_indexing.rb

Class Method Summary (collapse)

Class Method Details

+ (Object) blocking_updates_since(seq) 



39
40
41
 
# File 'backend/app/lib/realtime_indexing.rb', line 39

def self.blocking_updates_since(seq)
  longpolling.blocking_updates_since(seq)
end

+ (Object) longpolling 



5
6
7
8
9
10
11
 
# File 'backend/app/lib/realtime_indexing.rb', line 5

def self.longpolling
  if !@longpolling
    @longpolling = LongPolling.new(AppConfig[:realtime_index_backlog_ms].to_i)
  end

  @longpolling
end

+ (Object) record_delete(uri) 



29
30
31
 
# File 'backend/app/lib/realtime_indexing.rb', line 29

def self.record_delete(uri)
  longpolling.record_update(:record => :deleted, :uri => uri)
end

+ (Object) record_update(target, uri) 



24
25
26
 
# File 'backend/app/lib/realtime_indexing.rb', line 24

def self.record_update(target, uri)
  longpolling.record_update(:record => target, :uri => uri)
end

+ (Object) reset! 



19
20
21
 
# File 'backend/app/lib/realtime_indexing.rb', line 19

def self.reset!
  longpolling.reset!
end

+ (Object) shutdown 



14
15
16
 
# File 'backend/app/lib/realtime_indexing.rb', line 14

def self.shutdown
  @longpolling.shutdown if @longpolling
end

+ (Object) updates_since(seq) 



34
35
36
 
# File 'backend/app/lib/realtime_indexing.rb', line 34

def self.updates_since(seq)
  longpolling.updates_since(seq)
end