gem.sh

lib/protobuf/zmq.rb

##
## ZMQ Mode
##
#
# Require this file if you wish to run your server and/or client RPC
# with the ZeroMQ handlers.
#
# To run with rpc_server specify the switch `zmq`:
#
#   rpc_server --zmq myapp.rb
#
# To run for client-side only override the require in your Gemfile:
#
#   gem 'protobuf', :require => 'protobuf/zmq'
#
require 'protobuf'
Protobuf.connector_type = :zmq

require 'ffi-rzmq'
require 'protobuf/rpc/servers/zmq/server'
require 'protobuf/rpc/connectors/zmq'

Source Files

lib/protobuf.rb
lib/protobuf/cli.rb
lib/protobuf/code_generator.rb
lib/protobuf/decoder.rb
lib/protobuf/deprecation.rb
lib/protobuf/descriptors.rb
lib/protobuf/descriptors/google/protobuf/compiler/plugin.pb.rb
lib/protobuf/descriptors/google/protobuf/descriptor.pb.rb
lib/protobuf/encoder.rb
lib/protobuf/enum.rb
lib/protobuf/exceptions.rb
lib/protobuf/field.rb
lib/protobuf/field/base_field.rb
lib/protobuf/field/bool_field.rb
lib/protobuf/field/bytes_field.rb
lib/protobuf/field/double_field.rb
lib/protobuf/field/enum_field.rb
lib/protobuf/field/field_array.rb
lib/protobuf/field/fixed32_field.rb
lib/protobuf/field/fixed64_field.rb
lib/protobuf/field/float_field.rb
lib/protobuf/field/int32_field.rb
lib/protobuf/field/int64_field.rb
lib/protobuf/field/integer_field.rb
lib/protobuf/field/message_field.rb
lib/protobuf/field/sfixed32_field.rb
lib/protobuf/field/sfixed64_field.rb
lib/protobuf/field/signed_integer_field.rb
lib/protobuf/field/sint32_field.rb
lib/protobuf/field/sint64_field.rb
lib/protobuf/field/string_field.rb
lib/protobuf/field/uint32_field.rb
lib/protobuf/field/uint64_field.rb
lib/protobuf/field/varint_field.rb
lib/protobuf/generators/base.rb
lib/protobuf/generators/enum_generator.rb
lib/protobuf/generators/extension_generator.rb
lib/protobuf/generators/field_generator.rb
lib/protobuf/generators/file_generator.rb
lib/protobuf/generators/group_generator.rb
lib/protobuf/generators/message_generator.rb
lib/protobuf/generators/printable.rb
lib/protobuf/generators/service_generator.rb
lib/protobuf/lifecycle.rb
lib/protobuf/logging.rb
lib/protobuf/message.rb
lib/protobuf/message/fields.rb
lib/protobuf/message/serialization.rb
lib/protobuf/optionable.rb
lib/protobuf/rpc/buffer.rb
lib/protobuf/rpc/client.rb
lib/protobuf/rpc/connector.rb
lib/protobuf/rpc/connectors/base.rb
lib/protobuf/rpc/connectors/common.rb
lib/protobuf/rpc/connectors/ping.rb
lib/protobuf/rpc/connectors/socket.rb
lib/protobuf/rpc/connectors/zmq.rb
lib/protobuf/rpc/dynamic_discovery.pb.rb
lib/protobuf/rpc/env.rb
lib/protobuf/rpc/error.rb
lib/protobuf/rpc/error/client_error.rb
lib/protobuf/rpc/error/server_error.rb
lib/protobuf/rpc/middleware.rb
lib/protobuf/rpc/middleware/exception_handler.rb
lib/protobuf/rpc/middleware/logger.rb
lib/protobuf/rpc/middleware/request_decoder.rb
lib/protobuf/rpc/middleware/response_encoder.rb
lib/protobuf/rpc/middleware/runner.rb
lib/protobuf/rpc/rpc.pb.rb
lib/protobuf/rpc/server.rb
lib/protobuf/rpc/servers/socket/server.rb
lib/protobuf/rpc/servers/socket/worker.rb
lib/protobuf/rpc/servers/socket_runner.rb
lib/protobuf/rpc/servers/zmq/broker.rb
lib/protobuf/rpc/servers/zmq/server.rb
lib/protobuf/rpc/servers/zmq/util.rb
lib/protobuf/rpc/servers/zmq/worker.rb
lib/protobuf/rpc/servers/zmq_runner.rb
lib/protobuf/rpc/service.rb
lib/protobuf/rpc/service_directory.rb
lib/protobuf/rpc/service_dispatcher.rb
lib/protobuf/rpc/service_filters.rb
lib/protobuf/rpc/stat.rb
lib/protobuf/socket.rb
lib/protobuf/tasks.rb
lib/protobuf/varint.rb
lib/protobuf/varint_pure.rb
lib/protobuf/version.rb
lib/protobuf/wire_type.rb
lib/protobuf/zmq.rb

Modules

Classes

lib/protobuf/zmq.rb

Source Files