Class: A2A::Transport::A2AServiceStub
- Inherits:
-
Object
- Object
- A2A::Transport::A2AServiceStub
- 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
- #cancel_task(_request, _options = {}) ⇒ Object
- #get_agent_card(_request, _options = {}) ⇒ Object
- #get_task(_request, _options = {}) ⇒ Object
-
#initialize(endpoint, credentials, channel_args: {}) ⇒ A2AServiceStub
constructor
A new instance of A2AServiceStub.
-
#send_message(_request, _options = {}) ⇒ Object
Placeholder methods - would be generated from protobuf definitions.
- #send_message_stream(_request, _options = {}) ⇒ Object
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, = {}) 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, = {}) 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, = {}) 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 (_request, = {}) 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 (_request, = {}) raise A2A::Errors::CapabilityNotSupported, "gRPC service implementation not available" end |