Sha256: bb1c8d7aa9bb23a698dd82894cf10818912e6d25f8c09dd5689ac6f1ec6abfa9
Contents?: true
Size: 1.64 KB
Versions: 19
Compression:
Stored size: 1.64 KB
Contents
require 'timeout' require 'protobuf/logger' require 'protobuf/rpc/rpc.pb' require 'protobuf/rpc/buffer' require 'protobuf/rpc/error' require 'protobuf/rpc/stat' require 'protobuf/rpc/connectors/common' module Protobuf module Rpc module Connectors DEFAULT_OPTIONS = { :service => nil, # Fully-qualified Service class :method => nil, # Service method to invoke :host => '127.0.0.1', # The hostname or address of the service (usually overridden or pre-configured) :port => '9399', # The port of the service (usually overridden or pre-configured) :request => nil, # The request object sent by the client :request_type => nil, # The request type expected by the client :response_type => nil, # The response type expected by the client :timeout => 300, # The default timeout for the request, also handled by client.rb :client_host => nil # The hostname or address of this client } class Base include Protobuf::Logger::LogMethods attr_reader :options attr_accessor :success_cb, :failure_cb, :complete_cb def initialize(options) @options = DEFAULT_OPTIONS.merge(options) end def send_request raise 'If you inherit a Connector from Base you must implement send_request' end def ping_port @ping_port ||= ENV["PB_RPC_PING_PORT"] end def ping_port_enabled? ENV.has_key?("PB_RPC_PING_PORT") end end end end end
Version data entries
19 entries across 19 versions & 1 rubygems