Contents

require 'timeout'
require 'protobuf/logging'
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)
        :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
        :first_alive_load_balance => false,       # Do we want to use check_avail frames before request
      }

      class Base
        include Protobuf::Logging

        attr_reader :options
        attr_accessor :success_cb, :failure_cb, :complete_cb

        def initialize(options)
          @options = DEFAULT_OPTIONS.merge(options)
        end

        def first_alive_load_balance?
          ENV.has_key?("PB_FIRST_ALIVE_LOAD_BALANCE") ||
            options[:first_alive_load_balance]
        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

5 entries across 5 versions & 1 rubygems

Version	Path
protobuf-3.3.4	lib/protobuf/rpc/connectors/base.rb
protobuf-3.3.3	lib/protobuf/rpc/connectors/base.rb
protobuf-3.3.2	lib/protobuf/rpc/connectors/base.rb
protobuf-3.3.1	lib/protobuf/rpc/connectors/base.rb
protobuf-3.3.0	lib/protobuf/rpc/connectors/base.rb