Contents

module Momento
  # Encapsulates gRPC configuration tunables
  class GrpcConfiguration
    # Number of milliseconds the client is willing to wait for an RPC to
    # complete before it is terminated with a DeadlineExceeded error
    attr_reader :deadline

    def self.with_deadline(deadline)
      return GrpcConfiguration.new(deadline)
    end

    def initialize(deadline)
      unless deadline.is_a? Integer
        raise Momento::Error::InvalidArgumentError,
          'Client timeout must be an integer'
      end
      if (deadline.is_a? Integer) && (deadline < 1)
        raise Momento::Error::InvalidArgumentError,
          'Client timeout must be positive'
      end

      @deadline = deadline
    end
  end
end

Version data entries

1 entries across 1 versions & 1 rubygems

Version	Path
momento-0.4.9	lib/momento/config/transport/grpc_configuration.rb