Class: ThriftFlumeClientServer::Client

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

Instance Method Summary collapse

Instance Method Details

#acknowledge(ackid) ⇒ Object 



74
75
76
77
 
# File 'lib/thrift/thrift_flume_client_server.rb', line 74

def acknowledge(ackid)
  send_acknowledge(ackid)
  recv_acknowledge()
end

#checkAck(ackid) ⇒ Object 



88
89
90
91
 
# File 'lib/thrift/thrift_flume_client_server.rb', line 88

def checkAck(ackid)
  send_checkAck(ackid)
  return recv_checkAck()
end

#getChokeMap(physNode) ⇒ Object 



59
60
61
62
 
# File 'lib/thrift/thrift_flume_client_server.rb', line 59

def getChokeMap(physNode)
  send_getChokeMap(physNode)
  return recv_getChokeMap()
end

#getConfig(sourceId) ⇒ Object 



29
30
31
32
 
# File 'lib/thrift/thrift_flume_client_server.rb', line 29

def getConfig(sourceId)
  send_getConfig(sourceId)
  return recv_getConfig()
end

#getLogicalNodes(physNode) ⇒ Object 



44
45
46
47
 
# File 'lib/thrift/thrift_flume_client_server.rb', line 44

def getLogicalNodes(physNode)
  send_getLogicalNodes(physNode)
  return recv_getLogicalNodes()
end

#heartbeat(logicalNode, physicalNode, host, s, timestamp) ⇒ Object 



14
15
16
17
 
# File 'lib/thrift/thrift_flume_client_server.rb', line 14

def heartbeat(logicalNode, physicalNode, host, s, timestamp)
  send_heartbeat(logicalNode, physicalNode, host, s, timestamp)
  return recv_heartbeat()
end

#putReports(reports) ⇒ Object 



103
104
105
106
 
# File 'lib/thrift/thrift_flume_client_server.rb', line 103

def putReports(reports)
  send_putReports(reports)
  recv_putReports()
end

#recv_acknowledge ⇒ Object 



83
84
85
86
 
# File 'lib/thrift/thrift_flume_client_server.rb', line 83

def recv_acknowledge()
  result = receive_message(Acknowledge_result)
  return
end

#recv_checkAck ⇒ Object

Raises:

  • (::Thrift::ApplicationException) 


97
98
99
100
101
 
# File 'lib/thrift/thrift_flume_client_server.rb', line 97

def recv_checkAck()
  result = receive_message(CheckAck_result)
  return result.success unless result.success.nil?
  raise ::Thrift::ApplicationException.new(::Thrift::ApplicationException::MISSING_RESULT, 'checkAck failed: unknown result')
end

#recv_getChokeMap ⇒ Object

Raises:

  • (::Thrift::ApplicationException) 


68
69
70
71
72
 
# File 'lib/thrift/thrift_flume_client_server.rb', line 68

def recv_getChokeMap()
  result = receive_message(GetChokeMap_result)
  return result.success unless result.success.nil?
  raise ::Thrift::ApplicationException.new(::Thrift::ApplicationException::MISSING_RESULT, 'getChokeMap failed: unknown result')
end

#recv_getConfig ⇒ Object

Raises:

  • (::Thrift::ApplicationException) 


38
39
40
41
42
 
# File 'lib/thrift/thrift_flume_client_server.rb', line 38

def recv_getConfig()
  result = receive_message(GetConfig_result)
  return result.success unless result.success.nil?
  raise ::Thrift::ApplicationException.new(::Thrift::ApplicationException::MISSING_RESULT, 'getConfig failed: unknown result')
end

#recv_getLogicalNodes ⇒ Object

Raises:

  • (::Thrift::ApplicationException) 


53
54
55
56
57
 
# File 'lib/thrift/thrift_flume_client_server.rb', line 53

def recv_getLogicalNodes()
  result = receive_message(GetLogicalNodes_result)
  return result.success unless result.success.nil?
  raise ::Thrift::ApplicationException.new(::Thrift::ApplicationException::MISSING_RESULT, 'getLogicalNodes failed: unknown result')
end

#recv_heartbeat ⇒ Object

Raises:

  • (::Thrift::ApplicationException) 


23
24
25
26
27
 
# File 'lib/thrift/thrift_flume_client_server.rb', line 23

def recv_heartbeat()
  result = receive_message(Heartbeat_result)
  return result.success unless result.success.nil?
  raise ::Thrift::ApplicationException.new(::Thrift::ApplicationException::MISSING_RESULT, 'heartbeat failed: unknown result')
end

#recv_putReports ⇒ Object 



112
113
114
115
 
# File 'lib/thrift/thrift_flume_client_server.rb', line 112

def recv_putReports()
  result = receive_message(PutReports_result)
  return
end

#send_acknowledge(ackid) ⇒ Object 



79
80
81
 
# File 'lib/thrift/thrift_flume_client_server.rb', line 79

def send_acknowledge(ackid)
  send_message('acknowledge', Acknowledge_args, :ackid => ackid)
end

#send_checkAck(ackid) ⇒ Object 



93
94
95
 
# File 'lib/thrift/thrift_flume_client_server.rb', line 93

def send_checkAck(ackid)
  send_message('checkAck', CheckAck_args, :ackid => ackid)
end

#send_getChokeMap(physNode) ⇒ Object 



64
65
66
 
# File 'lib/thrift/thrift_flume_client_server.rb', line 64

def send_getChokeMap(physNode)
  send_message('getChokeMap', GetChokeMap_args, :physNode => physNode)
end

#send_getConfig(sourceId) ⇒ Object 



34
35
36
 
# File 'lib/thrift/thrift_flume_client_server.rb', line 34

def send_getConfig(sourceId)
  send_message('getConfig', GetConfig_args, :sourceId => sourceId)
end

#send_getLogicalNodes(physNode) ⇒ Object 



49
50
51
 
# File 'lib/thrift/thrift_flume_client_server.rb', line 49

def send_getLogicalNodes(physNode)
  send_message('getLogicalNodes', GetLogicalNodes_args, :physNode => physNode)
end

#send_heartbeat(logicalNode, physicalNode, host, s, timestamp) ⇒ Object 



19
20
21
 
# File 'lib/thrift/thrift_flume_client_server.rb', line 19

def send_heartbeat(logicalNode, physicalNode, host, s, timestamp)
  send_message('heartbeat', Heartbeat_args, :logicalNode => logicalNode, :physicalNode => physicalNode, :host => host, :s => s, :timestamp => timestamp)
end

#send_putReports(reports) ⇒ Object 



108
109
110
 
# File 'lib/thrift/thrift_flume_client_server.rb', line 108

def send_putReports(reports)
  send_message('putReports', PutReports_args, :reports => reports)
end