Sha256: f3689e4a3046cd29def7b4636e86d5749a8da8418527420b5451a28e6df7497a
Contents?: true
Size: 1.47 KB
Versions: 6
Compression:
Stored size: 1.47 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 => 15, # 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
end
end
end
end
Version data entries
6 entries across 6 versions & 1 rubygems