Sha256: 9696d62780b83f7ab15a8f1cbb9d5476b26ff0409b486fad56eade86778bae13
Contents?: true
Size: 1.29 KB
Versions: 48
Compression:
Stored size: 1.29 KB
Contents
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, # Service to invoke
:method => nil, # Service method to call
:host => '127.0.0.1', # A default host (usually overridden)
:port => '9399', # A default port (usually overridden)
: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 => 30 # The default timeout for the request, also handled by client.rb
}
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
48 entries across 48 versions & 1 rubygems