lib/grpc_kit/calls.rb in grpc_kit-0.1.8 vs lib/grpc_kit/calls.rb in grpc_kit-0.1.9
- old
+ new
@@ -4,15 +4,26 @@
module Calls
class Call
Name = Struct.new(:name, :receiver)
Reciver = Struct.new(:class)
Klass = Struct.new(:service_name)
+
+ # @return [GrpcKit::Calls::Call::Name] gRPC method object
attr_reader :method
- # @params stream [GrpcKit::Stream::ServerStream|GrpcKit::Stream::ClientStream]
- # @params config [GrpcKit::MethodConfig]
- # @params metadata [Hash]
+ # @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
@@ -24,17 +35,20 @@
klass = Klass.new(@service_name)
@method ||= Name.new(@method_name, Reciver.new(klass))
@restrict = false
end
+ # @return [void]
def restrict_mode
@restrict = true
end
+ # @return [void]
def normal_mode
@restrict = false
end
+ # @return [Time] deadline of this rpc call
def deadline
@deadline ||= @timeout.to_absolute_time
end
end
end