Module: Arf

Defined in:

lib/arf.rb,
lib/arf/types.rb,
lib/arf/errors.rb,
lib/arf/server.rb,
lib/arf/status.rb,
lib/arf/context.rb,
lib/arf/reactor.rb,
lib/arf/version.rb,
lib/arf/observer.rb,
lib/arf/rpc/enum.rb,
lib/arf/io/buffer.rb,
lib/arf/proto/map.rb,
lib/arf/rpc/struct.rb,
lib/arf/wire/frame.rb,
lib/arf/proto/array.rb,
lib/arf/proto/bytes.rb,
lib/arf/proto/float.rb,
lib/arf/proto/types.rb,
lib/arf/proto/union.rb,
lib/arf/rpc/request.rb,
lib/arf/types/mixin.rb,
lib/arf/wire/client.rb,
lib/arf/wire/errors.rb,
lib/arf/wire/server.rb,
lib/arf/wire/stream.rb,
lib/arf/proto/scalar.rb,
lib/arf/proto/string.rb,
lib/arf/proto/struct.rb,
lib/arf/rpc/metadata.rb,
lib/arf/rpc/response.rb,
lib/arf/configuration.rb,
lib/arf/proto/boolean.rb,
lib/arf/proto/decoder.rb,
lib/arf/proto/encoder.rb,
lib/arf/rpc/responder.rb,
lib/arf/wire/encoding.rb,
lib/arf/io/compression.rb,
lib/arf/proto/registry.rb,
lib/arf/rpc/end_stream.rb,
lib/arf/types/coercion.rb,
lib/arf/types/map_type.rb,
lib/arf/types/streamer.rb,
lib/arf/io/limit_reader.rb,
lib/arf/rpc/client_base.rb,
lib/arf/rpc/method_meta.rb,
lib/arf/rpc/stream_item.rb,
lib/arf/types/base_type.rb,
lib/arf/wire/error_code.rb,
lib/arf/wire/frame_kind.rb,
lib/arf/rpc/base_message.rb,
lib/arf/rpc/message_kind.rb,
lib/arf/rpc/service_base.rb,
lib/arf/rpc/start_stream.rb,
lib/arf/rpc/stream_error.rb,
lib/arf/types/array_type.rb,
lib/arf/wire/server/peer.rb,
lib/arf/wire/wait_signal.rb,
lib/arf/wire/frame_reader.rb,
lib/arf/wire/stream/state.rb,
lib/arf/types/input_stream.rb,
lib/arf/rpc/stream_metadata.rb,
lib/arf/types/in_out_stream.rb,
lib/arf/types/output_stream.rb,
lib/arf/wire/base_connection.rb,
lib/arf/wire/frames/base_frame.rb,
lib/arf/wire/frames/data_frame.rb,
lib/arf/wire/frames/ping_frame.rb,
lib/arf/wire/frames/go_away_frame.rb,
lib/arf/wire/frames/make_stream_frame.rb,
lib/arf/wire/frames/reset_stream_frame.rb,
lib/arf/wire/frames/configuration_frame.rb

Defined Under Namespace

Modules: IO, Proto, RPC, Status, Types, Wire Classes: Configuration, Context, DecodeFailedError, Error, InvalidEncodingTypeError, Observer, Reactor, Server, UnknownMeessageError, UnknownTypeError, UnsupportedNestedUnionError

Constant Summary

VERSION =

"0.1.0"

Class Method Summary

• .config ⇒ Object
• .configuration ⇒ Object
• .configure {|inst| ... } ⇒ Object
• .connect(host, port) ⇒ Object
• .logger ⇒ Object

Class Method Details

.config ⇒ Object

# File 'lib/arf.rb', line 40

def self.config = configuration

.configuration ⇒ Object

# File 'lib/arf.rb', line 39

def self.configuration = Configuration.instance

.configure {|inst| ... } ⇒ Object

Yields:

• (inst)

# File 'lib/arf.rb', line 33

def self.configure
  inst = Configuration.instance
  yield inst if block_given?
  nil
end

.connect(host, port) ⇒ Object

# File 'lib/arf.rb', line 43

def self.connect(host, port)
  Reactor.connect(host, port, Wire::Client)
end

.logger ⇒ Object

# File 'lib/arf.rb', line 41

def self.logger = configuration.logger