Module: Baykit::BayServer::Common::Transporter
- Includes:
- Util::Reusable
- Included in:
- Agent::Multiplexer::PlainTransporter
- Defined in:
- lib/baykit/bayserver/common/transporter.rb
Overview
interface
Instance Method Summary collapse
- #check_timeout(rd, duretion_sec) ⇒ Object
- #get_read_buffer_size ⇒ Object
- #init ⇒ Object
- #on_closed(rd) ⇒ Object
- #on_connected(rd) ⇒ Object
- #on_error(rd, e) ⇒ Object
- #on_read(rd, data, adr) ⇒ Object
- #print_usage(indent) ⇒ Object
- #req_close(rd) ⇒ Object
- #req_connect(rd, adr) ⇒ Object
- #req_read(rd) ⇒ Object
- #req_write(rd, buf, adr, tag, &lis) ⇒ Object
Methods included from Util::Reusable
Instance Method Details
#check_timeout(rd, duretion_sec) ⇒ Object
45 46 47 |
# File 'lib/baykit/bayserver/common/transporter.rb', line 45 def check_timeout(rd, duretion_sec) raise NotImplementedError.new end |
#get_read_buffer_size ⇒ Object
49 50 51 |
# File 'lib/baykit/bayserver/common/transporter.rb', line 49 def get_read_buffer_size raise NotImplementedError.new end |
#init ⇒ Object
9 10 11 |
# File 'lib/baykit/bayserver/common/transporter.rb', line 9 def init() raise NotImplementedError.new end |
#on_closed(rd) ⇒ Object
25 26 27 |
# File 'lib/baykit/bayserver/common/transporter.rb', line 25 def on_closed(rd) raise NotImplementedError.new end |
#on_connected(rd) ⇒ Object
13 14 15 |
# File 'lib/baykit/bayserver/common/transporter.rb', line 13 def on_connected(rd) raise NotImplementedError.new end |
#on_error(rd, e) ⇒ Object
21 22 23 |
# File 'lib/baykit/bayserver/common/transporter.rb', line 21 def on_error(rd, e) raise NotImplementedError.new end |
#on_read(rd, data, adr) ⇒ Object
17 18 19 |
# File 'lib/baykit/bayserver/common/transporter.rb', line 17 def on_read(rd, data, adr) raise NotImplementedError.new end |
#print_usage(indent) ⇒ Object
53 54 55 |
# File 'lib/baykit/bayserver/common/transporter.rb', line 53 def print_usage(indent) raise NotImplementedError.new end |
#req_close(rd) ⇒ Object
41 42 43 |
# File 'lib/baykit/bayserver/common/transporter.rb', line 41 def req_close(rd) raise NotImplementedError.new end |
#req_connect(rd, adr) ⇒ Object
29 30 31 |
# File 'lib/baykit/bayserver/common/transporter.rb', line 29 def req_connect(rd, adr) raise NotImplementedError.new end |
#req_read(rd) ⇒ Object
33 34 35 |
# File 'lib/baykit/bayserver/common/transporter.rb', line 33 def req_read(rd) raise NotImplementedError.new end |
#req_write(rd, buf, adr, tag, &lis) ⇒ Object
37 38 39 |
# File 'lib/baykit/bayserver/common/transporter.rb', line 37 def req_write(rd, buf, adr, tag, &lis) raise NotImplementedError.new end |