Class: GrpcKit::Call

Inherits:

Object

• Object
• GrpcKit::Call

Defined in:

lib/grpc_kit/call.rb

Direct Known Subclasses

GrpcKit::Calls::Client::BidiStreamer, GrpcKit::Calls::Client::ClientStreamer, GrpcKit::Calls::Client::RequestResponse, GrpcKit::Calls::Client::ServerStreamer, GrpcKit::Calls::Server::BidiStreamer, GrpcKit::Calls::Server::ClientStreamer, GrpcKit::Calls::Server::RequestResponse, GrpcKit::Calls::Server::ServerStreamer

Defined Under Namespace

Classes: Klass, Name, Reciver

Instance Attribute Summary

• #metadata ⇒ Hash<String, String> readonly

  GRPC metadata.

• #method ⇒ GrpcKit::Call::Name readonly

  GRPC method object.

• #method_name ⇒ Symbol readonly

  GRPC method name.

• #service_name ⇒ String readonly

  GRPC service name.

Instance Method Summary

• #deadline ⇒ Time

  Deadline of this rpc call.

• #initialize(stream:, config:, metadata:, timeout: nil) ⇒ Call constructor

  A new instance of Call.

Constructor Details

#initialize(stream:, config:, metadata:, timeout: nil) ⇒ Call

# File 'lib/grpc_kit/call.rb', line 24

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

Instance Attribute Details

#metadata ⇒ Hash<String, String> (readonly)

# File 'lib/grpc_kit/call.rb', line 19

def metadata
  @metadata
end

#method ⇒ GrpcKit::Call::Name (readonly)

# File 'lib/grpc_kit/call.rb', line 10

def method
  @method
end

#method_name ⇒ Symbol (readonly)

# File 'lib/grpc_kit/call.rb', line 13

def method_name
  @method_name
end

#service_name ⇒ String (readonly)

# File 'lib/grpc_kit/call.rb', line 16

def service_name
  @service_name
end

Instance Method Details

#deadline ⇒ Time

# File 'lib/grpc_kit/call.rb', line 39

def deadline
  return @deadline if instance_variable_defined?(:@deadline)

  @deadline = @timeout && @timeout.to_absolute_time
end