Class: Thrift::MultiplexedProtocol
- Inherits:
-
BaseProtocol
- Object
- BaseProtocol
- Thrift::MultiplexedProtocol
- Defined in:
- lib/thrift_client/thrift/protocol.rb
Instance Method Summary collapse
-
#initialize(protocol, service_name) ⇒ MultiplexedProtocol
constructor
A new instance of MultiplexedProtocol.
- #read_binary ⇒ Object
- #read_bool ⇒ Object
- #read_byte ⇒ Object
- #read_double ⇒ Object
- #read_field_begin ⇒ Object
- #read_field_end ⇒ Object
- #read_i16 ⇒ Object
- #read_i32 ⇒ Object
- #read_i64 ⇒ Object
- #read_list_begin ⇒ Object
- #read_list_end ⇒ Object
- #read_map_begin ⇒ Object
- #read_map_end ⇒ Object
- #read_message_begin ⇒ Object
- #read_message_end ⇒ Object
- #read_set_begin ⇒ Object
- #read_set_end ⇒ Object
- #read_string ⇒ Object
- #read_struct_begin ⇒ Object
- #read_struct_end ⇒ Object
- #trans ⇒ Object
- #write_binary(buf) ⇒ Object
- #write_bool(bool) ⇒ Object
- #write_byte(byte) ⇒ Object
- #write_double(dub) ⇒ Object
- #write_field_begin(name, type, id) ⇒ Object
- #write_field_end ⇒ Object
- #write_field_stop ⇒ Object
- #write_i16(i16) ⇒ Object
- #write_i32(i32) ⇒ Object
- #write_i64(i64) ⇒ Object
- #write_list_begin(etype, size) ⇒ Object
- #write_list_end ⇒ Object
- #write_map_begin(ktype, vtype, size) ⇒ Object
- #write_map_end ⇒ Object
- #write_message_begin(name, type, seqid) ⇒ Object
- #write_message_end ⇒ Object
- #write_set_begin(etype, size) ⇒ Object
- #write_set_end ⇒ Object
- #write_string(str) ⇒ Object
- #write_struct_begin(name) ⇒ Object
- #write_struct_end ⇒ Object
Constructor Details
permalink #initialize(protocol, service_name) ⇒ MultiplexedProtocol
Returns a new instance of MultiplexedProtocol.
4 5 6 7 |
# File 'lib/thrift_client/thrift/protocol.rb', line 4 def initialize(protocol,service_name) @protocol = protocol @service_name = service_name end |
Instance Method Details
permalink #read_binary ⇒ Object
[View source]
178 179 180 |
# File 'lib/thrift_client/thrift/protocol.rb', line 178 def read_binary @protocol.read_binary end |
permalink #read_bool ⇒ Object
[View source]
150 151 152 |
# File 'lib/thrift_client/thrift/protocol.rb', line 150 def read_bool @protocol.read_bool end |
permalink #read_byte ⇒ Object
[View source]
154 155 156 |
# File 'lib/thrift_client/thrift/protocol.rb', line 154 def read_byte @protocol.read_byte end |
permalink #read_double ⇒ Object
[View source]
170 171 172 |
# File 'lib/thrift_client/thrift/protocol.rb', line 170 def read_double @protocol.read_double end |
permalink #read_field_begin ⇒ Object
[View source]
118 119 120 |
# File 'lib/thrift_client/thrift/protocol.rb', line 118 def read_field_begin @protocol.read_field_begin end |
permalink #read_field_end ⇒ Object
[View source]
122 123 124 |
# File 'lib/thrift_client/thrift/protocol.rb', line 122 def read_field_end @protocol.read_field_end end |
permalink #read_i16 ⇒ Object
[View source]
158 159 160 |
# File 'lib/thrift_client/thrift/protocol.rb', line 158 def read_i16 @protocol.read_i16 end |
permalink #read_i32 ⇒ Object
[View source]
162 163 164 |
# File 'lib/thrift_client/thrift/protocol.rb', line 162 def read_i32 @protocol.read_i32 end |
permalink #read_i64 ⇒ Object
[View source]
166 167 168 |
# File 'lib/thrift_client/thrift/protocol.rb', line 166 def read_i64 @protocol.read_i64 end |
permalink #read_list_begin ⇒ Object
[View source]
134 135 136 |
# File 'lib/thrift_client/thrift/protocol.rb', line 134 def read_list_begin @protocol.read_list_begin end |
permalink #read_list_end ⇒ Object
[View source]
138 139 140 |
# File 'lib/thrift_client/thrift/protocol.rb', line 138 def read_list_end @protocol.read_list_end end |
permalink #read_map_begin ⇒ Object
[View source]
126 127 128 |
# File 'lib/thrift_client/thrift/protocol.rb', line 126 def read_map_begin @protocol.read_map_begin end |
permalink #read_map_end ⇒ Object
[View source]
130 131 132 |
# File 'lib/thrift_client/thrift/protocol.rb', line 130 def read_map_end @protocol.read_map_end end |
permalink #read_message_begin ⇒ Object
[View source]
102 103 104 |
# File 'lib/thrift_client/thrift/protocol.rb', line 102 def @protocol. end |
permalink #read_message_end ⇒ Object
[View source]
106 107 108 |
# File 'lib/thrift_client/thrift/protocol.rb', line 106 def @protocol. end |
permalink #read_set_begin ⇒ Object
[View source]
142 143 144 |
# File 'lib/thrift_client/thrift/protocol.rb', line 142 def read_set_begin @protocol.read_set_begin end |
permalink #read_set_end ⇒ Object
[View source]
146 147 148 |
# File 'lib/thrift_client/thrift/protocol.rb', line 146 def read_set_end @protocol.read_set_end end |
permalink #read_string ⇒ Object
[View source]
174 175 176 |
# File 'lib/thrift_client/thrift/protocol.rb', line 174 def read_string @protocol.read_string end |
permalink #read_struct_begin ⇒ Object
[View source]
110 111 112 |
# File 'lib/thrift_client/thrift/protocol.rb', line 110 def read_struct_begin @protocol.read_struct_begin end |
permalink #read_struct_end ⇒ Object
[View source]
114 115 116 |
# File 'lib/thrift_client/thrift/protocol.rb', line 114 def read_struct_end @protocol.read_struct_end end |
permalink #trans ⇒ Object
[View source]
9 10 11 |
# File 'lib/thrift_client/thrift/protocol.rb', line 9 def trans @protocol.trans end |
permalink #write_binary(buf) ⇒ Object
[View source]
98 99 100 |
# File 'lib/thrift_client/thrift/protocol.rb', line 98 def write_binary(buf) @protocol.write_binary(buf) end |
permalink #write_bool(bool) ⇒ Object
[View source]
70 71 72 |
# File 'lib/thrift_client/thrift/protocol.rb', line 70 def write_bool(bool) @protocol.write_bool(bool) end |
permalink #write_byte(byte) ⇒ Object
[View source]
74 75 76 |
# File 'lib/thrift_client/thrift/protocol.rb', line 74 def write_byte(byte) @protocol.write_byte(byte) end |
permalink #write_double(dub) ⇒ Object
[View source]
90 91 92 |
# File 'lib/thrift_client/thrift/protocol.rb', line 90 def write_double(dub) @protocol.write_double(dub) end |
permalink #write_field_begin(name, type, id) ⇒ Object
[View source]
34 35 36 |
# File 'lib/thrift_client/thrift/protocol.rb', line 34 def write_field_begin(name, type, id) @protocol.write_field_begin(name, type, id) end |
permalink #write_field_end ⇒ Object
[View source]
38 39 40 |
# File 'lib/thrift_client/thrift/protocol.rb', line 38 def write_field_end @protocol.write_field_end end |
permalink #write_field_stop ⇒ Object
[View source]
42 43 44 |
# File 'lib/thrift_client/thrift/protocol.rb', line 42 def write_field_stop @protocol.write_field_stop end |
permalink #write_i16(i16) ⇒ Object
[View source]
78 79 80 |
# File 'lib/thrift_client/thrift/protocol.rb', line 78 def write_i16(i16) @protocol.write_i16(i16) end |
permalink #write_i32(i32) ⇒ Object
[View source]
82 83 84 |
# File 'lib/thrift_client/thrift/protocol.rb', line 82 def write_i32(i32) @protocol.write_i32(i32) end |
permalink #write_i64(i64) ⇒ Object
[View source]
86 87 88 |
# File 'lib/thrift_client/thrift/protocol.rb', line 86 def write_i64(i64) @protocol.write_i64(i64) end |
permalink #write_list_begin(etype, size) ⇒ Object
[View source]
54 55 56 |
# File 'lib/thrift_client/thrift/protocol.rb', line 54 def write_list_begin(etype, size) @protocol.write_list_begin(etype, size) end |
permalink #write_list_end ⇒ Object
[View source]
58 59 60 |
# File 'lib/thrift_client/thrift/protocol.rb', line 58 def write_list_end @protocol.write_list_end end |
permalink #write_map_begin(ktype, vtype, size) ⇒ Object
[View source]
46 47 48 |
# File 'lib/thrift_client/thrift/protocol.rb', line 46 def write_map_begin(ktype, vtype, size) @protocol.write_map_begin(ktype, vtype, size) end |
permalink #write_map_end ⇒ Object
[View source]
50 51 52 |
# File 'lib/thrift_client/thrift/protocol.rb', line 50 def write_map_end @protocol.write_map_end end |
permalink #write_message_begin(name, type, seqid) ⇒ Object
[View source]
13 14 15 16 17 18 19 20 |
# File 'lib/thrift_client/thrift/protocol.rb', line 13 def (name, type, seqid) case type when MessageTypes::CALL, MessageTypes::ONEWAY @protocol.(@service_name + ":" + name, type, seqid) else @protocol.(name, type, seqid) end end |
permalink #write_message_end ⇒ Object
[View source]
22 23 24 |
# File 'lib/thrift_client/thrift/protocol.rb', line 22 def @protocol. end |
permalink #write_set_begin(etype, size) ⇒ Object
[View source]
62 63 64 |
# File 'lib/thrift_client/thrift/protocol.rb', line 62 def write_set_begin(etype, size) @protocol.write_set_begin(etype, size) end |
permalink #write_set_end ⇒ Object
[View source]
66 67 68 |
# File 'lib/thrift_client/thrift/protocol.rb', line 66 def write_set_end @protocol.write_set_end end |
permalink #write_string(str) ⇒ Object
[View source]
94 95 96 |
# File 'lib/thrift_client/thrift/protocol.rb', line 94 def write_string(str) @protocol.write_string(str) end |
permalink #write_struct_begin(name) ⇒ Object
[View source]
26 27 28 |
# File 'lib/thrift_client/thrift/protocol.rb', line 26 def write_struct_begin(name) @protocol.write_struct_begin(name) end |
permalink #write_struct_end ⇒ Object
[View source]
30 31 32 |
# File 'lib/thrift_client/thrift/protocol.rb', line 30 def write_struct_end @protocol.write_struct_end end |