module Thrift

Licensed to the Apache Software Foundation (ASF) under one or more contributor license agreements. See the NOTICE file distributed with this work for additional information regarding copyright ownership. The ASF licenses this file to you under the Apache License, Version 2.0 (the “License”); you may not use this file except in compliance with the License. You may obtain a copy of the License at

http://www.apache.org/licenses/LICENSE-2.0

Unless required by applicable law or agreed to in writing, software distributed under the License is distributed on an “AS IS” BASIS, WITHOUT WARRANTIES OR CONDITIONS OF ANY KIND, either express or implied. See the License for the specific language governing permissions and limitations under the License.

http://www.apache.org/licenses/LICENSE-2.0

http://www.apache.org/licenses/LICENSE-2.0

http://www.apache.org/licenses/LICENSE-2.0

The only change required for a transport to support BinaryProtocolAccelerated is to implement 2 methods:

* borrow(size), which takes an optional argument and returns atleast _size_ bytes from the transport,
                or the default buffer size if no argument is given
* consume!(size), which removes size bytes from the front of the buffer

See MemoryBuffer and BufferedTransport for examples.

http://www.apache.org/licenses/LICENSE-2.0

http://www.apache.org/licenses/LICENSE-2.0

http://www.apache.org/licenses/LICENSE-2.0

http://www.apache.org/licenses/LICENSE-2.0

http://www.apache.org/licenses/LICENSE-2.0

http://www.apache.org/licenses/LICENSE-2.0

http://www.apache.org/licenses/LICENSE-2.0

Wraps the Thin web server to provide a Thrift server over HTTP. DEPRECATED: Use Thrift::RackApplication with a maintained Rack server instead.

http://www.apache.org/licenses/LICENSE-2.0

http://www.apache.org/licenses/LICENSE-2.0

http://www.apache.org/licenses/LICENSE-2.0

http://www.apache.org/licenses/LICENSE-2.0

Very very simple implementation of wrapping two objects, one with a read method and one with a write method, into a transport for thrift.

Assumes both objects are open, remain open, don’t require flushing, etc.

http://www.apache.org/licenses/LICENSE-2.0

Constants

DEFAULT_RECURSION_DEPTH

Attributes

type_checking [RW]

Public Class Methods

check_type (value, field, name, skip_nil = true)

Source

   # File lib/thrift/types.rb
48 def self.check_type(value, field, name, skip_nil = true)
49   return if value.nil? and skip_nil
50   klasses = case field[:type]
51   when Types::VOID
52     NilClass
53   when Types::BOOL
54     [TrueClass, FalseClass]
55   when Types::BYTE, Types::I16, Types::I32, Types::I64
56     Integer
57   when Types::DOUBLE
58     Float
59   when Types::STRING
60     String
61   when Types::UUID
62     String
63   when Types::STRUCT
64     [Struct, Union]
65   when Types::MAP
66     Hash
67   when Types::SET
68     Set
69   when Types::LIST
70     Array
71   end
72   valid = klasses && [*klasses].any? { |klass| klass === value }
73   raise TypeError, "Expected #{type_name(field[:type])}, received #{value.class} for field #{name}" unless valid
74   # check elements now
75   case field[:type]
76   when Types::MAP
77     value.each_pair do |k, v|
78       check_type(k, field[:key], "#{name}.key", false)
79       check_type(v, field[:value], "#{name}.value", false)
80     end
81   when Types::SET, Types::LIST
82     value.each do |el|
83       check_type(el, field[:element], "#{name}.element", false)
84     end
85   when Types::STRUCT
86     raise TypeError, "Expected #{field[:class]}, received #{value.class} for field #{name}" unless field[:class] == value.class
87   end
88 end

type_name (type)

Source

   # File lib/thrift/types.rb
90 def self.type_name(type)
91   Types.constants.each do |const|
92     return "Types::#{const}" if Types.const_get(const) == type
93   end
94   nil
95 end