Class: A2A::Transport::A2AServiceStub

Inherits:
Object
  • Object
show all
Defined in:
lib/a2a/transport/grpc.rb

Overview

Stub implementation for A2A gRPC service This would be replaced with generated protobuf stubs

Instance Method Summary collapse

Constructor Details

#initialize(endpoint, credentials, channel_args: {}) ⇒ A2AServiceStub

Returns a new instance of A2AServiceStub.



453
454
455
456
457
# File 'lib/a2a/transport/grpc.rb', line 453

def initialize(endpoint, credentials, channel_args: {})
  @endpoint = endpoint
  @credentials = credentials
  @channel_args = channel_args
end

Instance Method Details

#cancel_task(_request, _options = {}) ⇒ Object



472
473
474
# File 'lib/a2a/transport/grpc.rb', line 472

def cancel_task(_request, _options = {})
  raise A2A::Errors::CapabilityNotSupported, "gRPC service implementation not available"
end

#get_agent_card(_request, _options = {}) ⇒ Object



476
477
478
# File 'lib/a2a/transport/grpc.rb', line 476

def get_agent_card(_request, _options = {})
  raise A2A::Errors::CapabilityNotSupported, "gRPC service implementation not available"
end

#get_task(_request, _options = {}) ⇒ Object



468
469
470
# File 'lib/a2a/transport/grpc.rb', line 468

def get_task(_request, _options = {})
  raise A2A::Errors::CapabilityNotSupported, "gRPC service implementation not available"
end

#send_message(_request, _options = {}) ⇒ Object

Placeholder methods - would be generated from protobuf definitions



460
461
462
# File 'lib/a2a/transport/grpc.rb', line 460

def send_message(_request, _options = {})
  raise A2A::Errors::CapabilityNotSupported, "gRPC service implementation not available"
end

#send_message_stream(_request, _options = {}) ⇒ Object



464
465
466
# File 'lib/a2a/transport/grpc.rb', line 464

def send_message_stream(_request, _options = {})
  raise A2A::Errors::CapabilityNotSupported, "gRPC service implementation not available"
end