Class OpenTelemetryClientTransport

java.lang.Object

org.a2aproject.sdk.extras.opentelemetry.client.OpenTelemetryClientTransport

All Implemented Interfaces:

ClientTransport

public class OpenTelemetryClientTransport
extends Object
implements ClientTransport

Constructor Summary

Constructors

Constructor	Description
OpenTelemetryClientTransport(ClientTransport delegate, io.opentelemetry.api.trace.Tracer tracer)

Method Summary

Modifier and Type	Method	Description
Task	cancelTask(CancelTaskParams request, @Nullable ClientCallContext context)	Request the agent to cancel a specific task.
void	close()	Close the transport and release any associated resources.
TaskPushNotificationConfig	createTaskPushNotificationConfiguration(TaskPushNotificationConfig request, @Nullable ClientCallContext context)	Create or update the push notification configuration for a specific task.
void	deleteTaskPushNotificationConfigurations(DeleteTaskPushNotificationConfigParams request, @Nullable ClientCallContext context)	Delete the list of push notification configurations for a specific task.
AgentCard	getExtendedAgentCard(GetExtendedAgentCardParams params, @Nullable ClientCallContext context)	Retrieve the extended AgentCard.
Task	getTask(TaskQueryParams request, @Nullable ClientCallContext context)	Retrieve the current state and history of a specific task.
TaskPushNotificationConfig	getTaskPushNotificationConfiguration(GetTaskPushNotificationConfigParams request, @Nullable ClientCallContext context)	Retrieve the push notification configuration for a specific task.
ListTaskPushNotificationConfigsResult	listTaskPushNotificationConfigurations(ListTaskPushNotificationConfigsParams request, @Nullable ClientCallContext context)	Retrieve the list of push notification configurations for a specific task with pagination support.
ListTasksResult	listTasks(ListTasksParams request, @Nullable ClientCallContext context)	List tasks with optional filtering and pagination.
EventKind	sendMessage(MessageSendParams request, @Nullable ClientCallContext context)	Send a non-streaming message request to the agent.
void	sendMessageStreaming(MessageSendParams request, Consumer<StreamingEventKind> eventConsumer, Consumer<Throwable> errorConsumer, @Nullable ClientCallContext context)	Send a streaming message request to the agent and receive responses as they arrive.
void	subscribeToTask(TaskIdParams request, Consumer<StreamingEventKind> eventConsumer, Consumer<Throwable> errorConsumer, @Nullable ClientCallContext context)	Reconnect to get task updates for an existing task.

Methods inherited from class Object

clone, equals, finalize, getClass, hashCode, notify, notifyAll, toString, wait, wait, wait

Constructor Details

OpenTelemetryClientTransport

public OpenTelemetryClientTransport(ClientTransport delegate,
 io.opentelemetry.api.trace.Tracer tracer)

Method Details

sendMessage

public EventKind sendMessage(MessageSendParams request,
 @Nullable ClientCallContext context)
                      throws A2AClientException

Description copied from interface: ClientTransport

Send a non-streaming message request to the agent.

Specified by:

sendMessage in interface ClientTransport

Parameters:

request - the message send parameters

context - optional client call context for the request (may be null)

Returns:

the response, either a Task or Message

Throws:

A2AClientException - if sending the message fails for any reason

sendMessageStreaming

public void sendMessageStreaming(MessageSendParams request,
 Consumer<StreamingEventKind> eventConsumer,
 Consumer<Throwable> errorConsumer,
 @Nullable ClientCallContext context)
                          throws A2AClientException

Description copied from interface: ClientTransport

Send a streaming message request to the agent and receive responses as they arrive.

Specified by:

sendMessageStreaming in interface ClientTransport

Parameters:

request - the message send parameters

eventConsumer - consumer that will receive streaming events as they arrive

errorConsumer - consumer that will be called if an error occurs during streaming

context - optional client call context for the request (may be null)

Throws:

A2AClientException - if setting up the streaming connection fails

getTask

public Task getTask(TaskQueryParams request,
 @Nullable ClientCallContext context)
             throws A2AClientException

Description copied from interface: ClientTransport

Retrieve the current state and history of a specific task.

Specified by:

getTask in interface ClientTransport

Parameters:

request - the task query parameters specifying which task to retrieve

context - optional client call context for the request (may be null)

Returns:

the task

Throws:

A2AClientException - if retrieving the task fails for any reason

cancelTask

public Task cancelTask(CancelTaskParams request,
 @Nullable ClientCallContext context)
                throws A2AClientException

Description copied from interface: ClientTransport

Request the agent to cancel a specific task.

Specified by:

cancelTask in interface ClientTransport

Parameters:

request - the task ID parameters specifying which task to cancel

context - optional client call context for the request (may be null)

Returns:

the cancelled task

Throws:

A2AClientException - if cancelling the task fails for any reason

listTasks

public ListTasksResult listTasks(ListTasksParams request,
 @Nullable ClientCallContext context)
                          throws A2AClientException

Description copied from interface: ClientTransport

List tasks with optional filtering and pagination.

Specified by:

listTasks in interface ClientTransport

Parameters:

request - the list tasks parameters including filters and pagination

context - optional client call context for the request (may be null)

Returns:

the list tasks result containing tasks and pagination information

Throws:

A2AClientException - if listing tasks fails for any reason

createTaskPushNotificationConfiguration

public TaskPushNotificationConfig createTaskPushNotificationConfiguration(TaskPushNotificationConfig request,
 @Nullable ClientCallContext context)
                                                                   throws A2AClientException

Description copied from interface: ClientTransport

Create or update the push notification configuration for a specific task.

Specified by:

createTaskPushNotificationConfiguration in interface ClientTransport

Parameters:

request - the push notification configuration to set for the task

context - optional client call context for the request (may be null)

Returns:

the configured TaskPushNotificationConfig

Throws:

A2AClientException - if creating or updating the task push notification configuration fails for any reason

getTaskPushNotificationConfiguration

public TaskPushNotificationConfig getTaskPushNotificationConfiguration(GetTaskPushNotificationConfigParams request,
 @Nullable ClientCallContext context)
                                                                throws A2AClientException

Description copied from interface: ClientTransport

Retrieve the push notification configuration for a specific task.

Specified by:

getTaskPushNotificationConfiguration in interface ClientTransport

Parameters:

request - the parameters specifying which task's notification config to retrieve

context - optional client call context for the request (may be null)

Returns:

the task push notification config

Throws:

A2AClientException - if getting the task push notification config fails for any reason

listTaskPushNotificationConfigurations

public ListTaskPushNotificationConfigsResult listTaskPushNotificationConfigurations(ListTaskPushNotificationConfigsParams request,
 @Nullable ClientCallContext context)
                                                                             throws A2AClientException

Description copied from interface: ClientTransport

Retrieve the list of push notification configurations for a specific task with pagination support.

Specified by:

listTaskPushNotificationConfigurations in interface ClientTransport

Parameters:

request - the parameters specifying which task's notification configs to retrieve

context - optional client call context for the request (may be null)

Returns:

the result containing the list of task push notification configs and pagination information

Throws:

A2AClientException - if getting the task push notification configs fails for any reason

deleteTaskPushNotificationConfigurations

public void deleteTaskPushNotificationConfigurations(DeleteTaskPushNotificationConfigParams request,
 @Nullable ClientCallContext context)
                                              throws A2AClientException

Description copied from interface: ClientTransport

Delete the list of push notification configurations for a specific task.

Specified by:

deleteTaskPushNotificationConfigurations in interface ClientTransport

Parameters:

request - the parameters specifying which task's notification configs to delete

context - optional client call context for the request (may be null)

Throws:

A2AClientException - if deleting the task push notification configs fails for any reason

subscribeToTask

public void subscribeToTask(TaskIdParams request,
 Consumer<StreamingEventKind> eventConsumer,
 Consumer<Throwable> errorConsumer,
 @Nullable ClientCallContext context)
                     throws A2AClientException

Description copied from interface: ClientTransport

Reconnect to get task updates for an existing task.

Specified by:

subscribeToTask in interface ClientTransport

Parameters:

request - the task ID parameters specifying which task to subscribe to

eventConsumer - consumer that will receive streaming events as they arrive

errorConsumer - consumer that will be called if an error occurs during streaming

context - optional client call context for the request (may be null)

Throws:

A2AClientException - if subscribing to the task fails for any reason

getExtendedAgentCard

public AgentCard getExtendedAgentCard(GetExtendedAgentCardParams params,
 @Nullable ClientCallContext context)
                               throws A2AClientException

Description copied from interface: ClientTransport

Retrieve the extended AgentCard.

Specified by:

getExtendedAgentCard in interface ClientTransport

Parameters:

params - the parameters to get the extended agent card.

context - optional client call context for the request (may be null)

Returns:

the extended agent card

Throws:

A2AClientException - if retrieving the agent card fails for any reason

close

public void close()

Description copied from interface: ClientTransport

Close the transport and release any associated resources.

Specified by:

close in interface ClientTransport