Class: ThriftFlumeEventServer::Client

Inherits:
Object
  • Object
show all
Includes:
Thrift::Client
Defined in:
lib/flume-logger/flume-og/thrift_flume_event_server.rb

Instance Method Summary collapse

Instance Method Details

#append(evt) ⇒ Object 



14
15
16
 
# File 'lib/flume-logger/flume-og/thrift_flume_event_server.rb', line 14

def append(evt)
  send_append(evt)
end

#close ⇒ Object 



21
22
23
24
 
# File 'lib/flume-logger/flume-og/thrift_flume_event_server.rb', line 21

def close()
  send_close()
  recv_close()
end

#recv_close ⇒ Object 



30
31
32
33
 
# File 'lib/flume-logger/flume-og/thrift_flume_event_server.rb', line 30

def recv_close()
  result = receive_message(Close_result)
  return
end

#send_append(evt) ⇒ Object 



18
19
20
 
# File 'lib/flume-logger/flume-og/thrift_flume_event_server.rb', line 18

def send_append(evt)
  send_message('append', Append_args, :evt => evt)
end

#send_close ⇒ Object 



26
27
28
 
# File 'lib/flume-logger/flume-og/thrift_flume_event_server.rb', line 26

def send_close()
  send_message('close', Close_args)
end