Class: Ag::Client

Inherits:
Object
  • Object
show all
Defined in:
lib/ag/client.rb

Instance Method Summary collapse

Constructor Details

#initialize(adapter) ⇒ Client

Returns a new instance of Client.



3
4
5
 
# File 'lib/ag/client.rb', line 3

def initialize(adapter)
  @adapter = adapter
end

Instance Method Details

#connect(consumer, producer) ⇒ Object 



7
8
9
 
# File 'lib/ag/client.rb', line 7

def connect(consumer, producer)
  @adapter.connect(consumer, producer)
end

#connected?(consumer, producer) ⇒ Boolean

Returns:

  • (Boolean) 


15
16
17
 
# File 'lib/ag/client.rb', line 15

def connected?(consumer, producer)
  @adapter.connected?(consumer, producer)
end

#consumers(producer, options = {}) ⇒ Object 



19
20
21
 
# File 'lib/ag/client.rb', line 19

def consumers(producer, options = {})
  @adapter.consumers(producer, options)
end

#produce(event) ⇒ Object 



11
12
13
 
# File 'lib/ag/client.rb', line 11

def produce(event)
  @adapter.produce(event)
end

#producers(consumer, options = {}) ⇒ Object 



23
24
25
 
# File 'lib/ag/client.rb', line 23

def producers(consumer, options = {})
  @adapter.producers(consumer, options)
end

#timeline(consumer, options = {}) ⇒ Object 



27
28
29
 
# File 'lib/ag/client.rb', line 27

def timeline(consumer, options = {})
  @adapter.timeline(consumer, options)
end