Class: ThriftFlumeEventServer::Client

Inherits:
Object
  • Object
show all
Includes:
Thrift::Client
Defined in:
lib/fluent/plugin/thrift/thrift_flume_event_server.rb

Instance Method Summary collapse

Instance Method Details

#ackedAppend(evt) ⇒ Object 



28
29
30
31
 
# File 'lib/fluent/plugin/thrift/thrift_flume_event_server.rb', line 28

def ackedAppend(evt)
  send_ackedAppend(evt)
  return recv_ackedAppend()
end

#append(evt) ⇒ Object 



14
15
16
 
# File 'lib/fluent/plugin/thrift/thrift_flume_event_server.rb', line 14

def append(evt)
  send_append(evt)
end

#close ⇒ Object 



43
44
45
46
 
# File 'lib/fluent/plugin/thrift/thrift_flume_event_server.rb', line 43

def close()
  send_close()
  recv_close()
end

#rawAppend(evt) ⇒ Object 



21
22
23
 
# File 'lib/fluent/plugin/thrift/thrift_flume_event_server.rb', line 21

def rawAppend(evt)
  send_rawAppend(evt)
end

#recv_ackedAppend ⇒ Object

Raises:

  • (::Thrift::ApplicationException) 


37
38
39
40
41
 
# File 'lib/fluent/plugin/thrift/thrift_flume_event_server.rb', line 37

def recv_ackedAppend()
  result = receive_message(AckedAppend_result)
  return result.success unless result.success.nil?
  raise ::Thrift::ApplicationException.new(::Thrift::ApplicationException::MISSING_RESULT, 'ackedAppend failed: unknown result')
end

#recv_close ⇒ Object 



52
53
54
55
 
# File 'lib/fluent/plugin/thrift/thrift_flume_event_server.rb', line 52

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

#send_ackedAppend(evt) ⇒ Object 



33
34
35
 
# File 'lib/fluent/plugin/thrift/thrift_flume_event_server.rb', line 33

def send_ackedAppend(evt)
  send_message('ackedAppend', AckedAppend_args, :evt => evt)
end

#send_append(evt) ⇒ Object 



18
19
20
 
# File 'lib/fluent/plugin/thrift/thrift_flume_event_server.rb', line 18

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

#send_close ⇒ Object 



48
49
50
 
# File 'lib/fluent/plugin/thrift/thrift_flume_event_server.rb', line 48

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

#send_rawAppend(evt) ⇒ Object 



25
26
27
 
# File 'lib/fluent/plugin/thrift/thrift_flume_event_server.rb', line 25

def send_rawAppend(evt)
  send_message('rawAppend', RawAppend_args, :evt => evt)
end