Sha256: 9fd2d568b71d2ebca3e33279d09b6a413932299bf699a6c812fc231c1448de7a
Contents?: true
Size: 1.22 KB
Versions: 14
Compression:
Stored size: 1.22 KB
Contents
# frozen_string_literal: true
module GrpcKit
class Call
Name = Struct.new(:name, :receiver)
Reciver = Struct.new(:class)
Klass = Struct.new(:service_name)
# @return [GrpcKit::Call::Name] gRPC method object
attr_reader :method
# @return [Symbol] gRPC method name
attr_reader :method_name
# @return [String] gRPC service name
attr_reader :service_name
# @return [Hash<String, String>] gRPC metadata
attr_reader :metadata
# @param stream [GrpcKit::Stream::ServerStream|GrpcKit::Stream::ClientStream]
# @param config [GrpcKit::MethodConfig]
# @param metadata [Hash<String,String>]
def initialize(stream:, config:, metadata:, timeout: nil)
@config = config
@metadata = metadata
@method_name = @config.method_name
@service_name = @config.service_name
@codec = @config.codec
@timeout = timeout
@stream = stream
# for compatible
klass = Klass.new(@service_name)
@method ||= Name.new(@method_name, Reciver.new(klass))
end
# @return [Time] deadline of this rpc call
def deadline
return @deadline if instance_variable_defined?(:@deadline)
@deadline = @timeout && @timeout.to_absolute_time
end
end
end
Version data entries
14 entries across 14 versions & 1 rubygems