Index

A B C D E F G H I J N O P Q R S T U V
All Classes and Interfaces|All Packages|Constant Field Values|Serialized Form

A

A2AExtensions - Class in io.a2a.server.extensions

A2AExtensions() - Constructor for class io.a2a.server.extensions.A2AExtensions

activateExtension(String) - Method in class io.a2a.server.ServerCallContext

add(String, EventQueue) - Method in class io.a2a.server.events.InMemoryQueueManager

add(String, EventQueue) - Method in interface io.a2a.server.events.QueueManager

addArtifact(List<Part<?>>, String, String, Map<String, Object>) - Method in class io.a2a.server.tasks.TaskUpdater

addArtifact(List<Part<?>>, String, String, Map<String, Object>, Boolean, Boolean) - Method in class io.a2a.server.tasks.TaskUpdater

addDoneCallback(EnhancedRunnable.DoneCallback) - Method in class io.a2a.server.events.EnhancedRunnable

AgentCardValidator - Class in io.a2a.server

Validates AgentCard transport configuration against available transport endpoints.

AgentCardValidator() - Constructor for class io.a2a.server.AgentCardValidator

AgentExecutor - Interface in io.a2a.server.agentexecution

AsyncExecutorProducer - Class in io.a2a.server.util.async

AsyncExecutorProducer() - Constructor for class io.a2a.server.util.async.AsyncExecutorProducer

AsyncUtils - Class in io.a2a.server.util.async

AsyncUtils() - Constructor for class io.a2a.server.util.async.AsyncUtils

attachRelatedTask(Task) - Method in class io.a2a.server.agentexecution.RequestContext

awaitQueuePollerStart() - Method in class io.a2a.server.events.EventQueue

awaitQueuePollerStart(EventQueue) - Method in class io.a2a.server.events.InMemoryQueueManager

awaitQueuePollerStart(EventQueue) - Method in interface io.a2a.server.events.QueueManager

B

BasePushNotificationSender - Class in io.a2a.server.tasks

BasePushNotificationSender(PushNotificationConfigStore) - Constructor for class io.a2a.server.tasks.BasePushNotificationSender

BasePushNotificationSender(PushNotificationConfigStore, A2AHttpClient) - Constructor for class io.a2a.server.tasks.BasePushNotificationSender

build() - Method in class io.a2a.server.agentexecution.RequestContext.Builder

build() - Method in class io.a2a.server.agentexecution.SimpleRequestContextBuilder

build() - Method in class io.a2a.server.events.EventQueue.EventQueueBuilder

builder(String) - Method in interface io.a2a.server.events.EventQueueFactory

Creates an EventQueueBuilder with the specified taskId context.

Builder() - Constructor for class io.a2a.server.agentexecution.RequestContext.Builder

C

cancel() - Method in class io.a2a.server.tasks.TaskUpdater

cancel(RequestContext, EventQueue) - Method in interface io.a2a.server.agentexecution.AgentExecutor

cancel(Message) - Method in class io.a2a.server.tasks.TaskUpdater

close() - Method in class io.a2a.server.events.EventQueue

close() - Method in class io.a2a.server.util.async.AsyncExecutorProducer

close(boolean) - Method in class io.a2a.server.events.EventQueue

close(String) - Method in class io.a2a.server.events.InMemoryQueueManager

close(String) - Method in interface io.a2a.server.events.QueueManager

complete() - Method in class io.a2a.server.tasks.TaskUpdater

complete(Message) - Method in class io.a2a.server.tasks.TaskUpdater

consumeAll() - Method in class io.a2a.server.events.EventConsumer

consumeAll(EventConsumer) - Method in class io.a2a.server.tasks.ResultAggregator

consumeAndBreakOnInterrupt(EventConsumer, boolean) - Method in class io.a2a.server.tasks.ResultAggregator

consumeAndBreakOnInterrupt(EventConsumer, boolean, Runnable) - Method in class io.a2a.server.tasks.ResultAggregator

consumeAndEmit(EventConsumer) - Method in class io.a2a.server.tasks.ResultAggregator

consumeOne() - Method in class io.a2a.server.events.EventConsumer

consumer(TubeConfiguration, Flow.Publisher<T>, Function<T, Boolean>, Consumer<Throwable>) - Static method in class io.a2a.server.util.async.AsyncUtils

convertingProcessor(Flow.Publisher<T>, Function<T, N>) - Static method in class io.a2a.server.util.async.AsyncUtils

createAgentRunnableDoneCallback() - Method in class io.a2a.server.events.EventConsumer

createOrTap(String) - Method in class io.a2a.server.events.InMemoryQueueManager

createOrTap(String) - Method in interface io.a2a.server.events.QueueManager

createTubeConfig() - Static method in class io.a2a.server.util.async.AsyncUtils

createTubeConfig(int) - Static method in class io.a2a.server.util.async.AsyncUtils

D

deactivateExtension(String) - Method in class io.a2a.server.ServerCallContext

DEFAULT_QUEUE_SIZE - Static variable in class io.a2a.server.events.EventQueue

DefaultRequestHandler - Class in io.a2a.server.requesthandlers

DefaultRequestHandler(AgentExecutor, TaskStore, QueueManager, PushNotificationConfigStore, PushNotificationSender, Executor) - Constructor for class io.a2a.server.requesthandlers.DefaultRequestHandler

delete(String) - Method in class io.a2a.server.tasks.InMemoryTaskStore

delete(String) - Method in interface io.a2a.server.tasks.TaskStore

deleteInfo(String, String) - Method in class io.a2a.server.tasks.InMemoryPushNotificationConfigStore

deleteInfo(String, String) - Method in interface io.a2a.server.tasks.PushNotificationConfigStore

Deletes the push notification configuration for a task.

dequeueEvent(int) - Method in class io.a2a.server.events.EventQueue

doClose() - Method in class io.a2a.server.events.EventQueue

doClose(boolean) - Method in class io.a2a.server.events.EventQueue

done(EnhancedRunnable) - Method in interface io.a2a.server.events.EnhancedRunnable.DoneCallback

E

EnhancedRunnable - Class in io.a2a.server.events

EnhancedRunnable() - Constructor for class io.a2a.server.events.EnhancedRunnable

EnhancedRunnable.DoneCallback - Interface in io.a2a.server.events

enqueueEvent(Event) - Method in class io.a2a.server.events.EventQueue

equals(Object) - Method in record class io.a2a.server.tasks.ResultAggregator.EventTypeAndInterrupt

Indicates whether some other object is "equal to" this one.

EventConsumer - Class in io.a2a.server.events

EventConsumer(EventQueue) - Constructor for class io.a2a.server.events.EventConsumer

EventEnqueueHook - Interface in io.a2a.server.events

EventQueue - Class in io.a2a.server.events

EventQueue() - Constructor for class io.a2a.server.events.EventQueue

EventQueue(int) - Constructor for class io.a2a.server.events.EventQueue

EventQueue(EventQueue) - Constructor for class io.a2a.server.events.EventQueue

EventQueue.EventQueueBuilder - Class in io.a2a.server.events

EventQueueBuilder() - Constructor for class io.a2a.server.events.EventQueue.EventQueueBuilder

EventQueueClosedException - Exception in io.a2a.server.events

EventQueueClosedException() - Constructor for exception io.a2a.server.events.EventQueueClosedException

EventQueueFactory - Interface in io.a2a.server.events

eventType() - Method in record class io.a2a.server.tasks.ResultAggregator.EventTypeAndInterrupt

Returns the value of the eventType record component.

EventTypeAndInterrupt(EventKind, boolean) - Constructor for record class io.a2a.server.tasks.ResultAggregator.EventTypeAndInterrupt

Creates an instance of a EventTypeAndInterrupt record class.

execute(RequestContext, EventQueue) - Method in interface io.a2a.server.agentexecution.AgentExecutor

ExtendedAgentCard - Annotation Interface in io.a2a.server

F

fail() - Method in class io.a2a.server.tasks.TaskUpdater

fail(Message) - Method in class io.a2a.server.tasks.TaskUpdater

findExtensionByUri(AgentCard, String) - Static method in class io.a2a.server.extensions.A2AExtensions

G

get(String) - Method in class io.a2a.server.events.InMemoryQueueManager

get(String) - Method in interface io.a2a.server.events.QueueManager

get(String) - Method in class io.a2a.server.tasks.InMemoryTaskStore

get(String) - Method in interface io.a2a.server.tasks.TaskStore

getActivatedExtensions() - Method in class io.a2a.server.ServerCallContext

getCallContext() - Method in class io.a2a.server.agentexecution.RequestContext

getConfiguration() - Method in class io.a2a.server.agentexecution.RequestContext

getContextId() - Method in class io.a2a.server.agentexecution.RequestContext.Builder

getContextId() - Method in class io.a2a.server.agentexecution.RequestContext

getCurrentResult() - Method in class io.a2a.server.tasks.ResultAggregator

getError() - Method in class io.a2a.server.events.EnhancedRunnable

getError() - Method in exception io.a2a.server.JSONRPCException

getEventQueueBuilder(String) - Method in interface io.a2a.server.events.QueueManager

getInfo(String) - Method in class io.a2a.server.tasks.InMemoryPushNotificationConfigStore

getInfo(String) - Method in interface io.a2a.server.tasks.PushNotificationConfigStore

Retrieves the push notification configuration for a task.

getMessage() - Method in class io.a2a.server.agentexecution.RequestContext

getParams() - Method in class io.a2a.server.agentexecution.RequestContext.Builder

getParams() - Method in class io.a2a.server.agentexecution.RequestContext

getQueueSize() - Method in class io.a2a.server.events.EventQueue

getRelatedTasks() - Method in class io.a2a.server.agentexecution.RequestContext.Builder

getRelatedTasks() - Method in class io.a2a.server.agentexecution.RequestContext

getRequestedExtensions() - Method in class io.a2a.server.ServerCallContext

getRequestedExtensions(List<String>) - Static method in class io.a2a.server.extensions.A2AExtensions

getServerCallContext() - Method in class io.a2a.server.agentexecution.RequestContext.Builder

getState() - Method in class io.a2a.server.ServerCallContext

getTask() - Method in class io.a2a.server.agentexecution.RequestContext.Builder

getTask() - Method in class io.a2a.server.agentexecution.RequestContext

getTask() - Method in class io.a2a.server.tasks.TaskManager

getTaskId() - Method in class io.a2a.server.agentexecution.RequestContext.Builder

getTaskId() - Method in class io.a2a.server.agentexecution.RequestContext

getTransportProtocol() - Method in interface io.a2a.server.TransportMetadata

Returns the transport protocol this endpoint supports.

getUser() - Method in class io.a2a.server.ServerCallContext

getUserInput(String) - Method in class io.a2a.server.agentexecution.RequestContext

getUsername() - Method in class io.a2a.server.auth.UnauthenticatedUser

getUsername() - Method in interface io.a2a.server.auth.User

H

hashCode() - Method in record class io.a2a.server.tasks.ResultAggregator.EventTypeAndInterrupt

Returns a hash code value for this object.

hook(EventEnqueueHook) - Method in class io.a2a.server.events.EventQueue.EventQueueBuilder

I

init() - Method in class io.a2a.server.util.async.AsyncExecutorProducer

InMemoryPushNotificationConfigStore - Class in io.a2a.server.tasks

In-memory implementation of the PushNotificationConfigStore interface.

InMemoryPushNotificationConfigStore() - Constructor for class io.a2a.server.tasks.InMemoryPushNotificationConfigStore

InMemoryQueueManager - Class in io.a2a.server.events

InMemoryQueueManager() - Constructor for class io.a2a.server.events.InMemoryQueueManager

InMemoryQueueManager(EventQueueFactory) - Constructor for class io.a2a.server.events.InMemoryQueueManager

InMemoryTaskStore - Class in io.a2a.server.tasks

InMemoryTaskStore() - Constructor for class io.a2a.server.tasks.InMemoryTaskStore

INSTANCE - Static variable in class io.a2a.server.auth.UnauthenticatedUser

Internal - Annotation Interface in io.a2a.server.util.async

interrupted() - Method in record class io.a2a.server.tasks.ResultAggregator.EventTypeAndInterrupt

Returns the value of the interrupted record component.

invokeDoneCallbacks() - Method in class io.a2a.server.events.EnhancedRunnable

io.a2a.server - package io.a2a.server

io.a2a.server.agentexecution - package io.a2a.server.agentexecution

io.a2a.server.auth - package io.a2a.server.auth

io.a2a.server.events - package io.a2a.server.events

io.a2a.server.extensions - package io.a2a.server.extensions

io.a2a.server.requesthandlers - package io.a2a.server.requesthandlers

io.a2a.server.tasks - package io.a2a.server.tasks

io.a2a.server.util.async - package io.a2a.server.util.async

isAuthenticated() - Method in class io.a2a.server.auth.UnauthenticatedUser

isAuthenticated() - Method in interface io.a2a.server.auth.User

isAvailable() - Method in interface io.a2a.server.TransportMetadata

Checks if this transport endpoint is currently available/functional.

isClosed() - Method in class io.a2a.server.events.EventQueue

isExtensionActivated(String) - Method in class io.a2a.server.ServerCallContext

isExtensionRequested(String) - Method in class io.a2a.server.ServerCallContext

J

JSONRPCException - Exception in io.a2a.server

JSONRPCException(JSONRPCError) - Constructor for exception io.a2a.server.JSONRPCException

N

newAgentMessage(List<Part<?>>, Map<String, Object>) - Method in class io.a2a.server.tasks.TaskUpdater

NoTaskQueueException - Exception in io.a2a.server.events

NoTaskQueueException() - Constructor for exception io.a2a.server.events.NoTaskQueueException

NoTaskQueueException(String) - Constructor for exception io.a2a.server.events.NoTaskQueueException

NoTaskQueueException(String, Throwable) - Constructor for exception io.a2a.server.events.NoTaskQueueException

NoTaskQueueException(String, Throwable, boolean, boolean) - Constructor for exception io.a2a.server.events.NoTaskQueueException

NoTaskQueueException(Throwable) - Constructor for exception io.a2a.server.events.NoTaskQueueException

O

onCancelTask(TaskIdParams, ServerCallContext) - Method in class io.a2a.server.requesthandlers.DefaultRequestHandler

onCancelTask(TaskIdParams, ServerCallContext) - Method in interface io.a2a.server.requesthandlers.RequestHandler

onDeleteTaskPushNotificationConfig(DeleteTaskPushNotificationConfigParams, ServerCallContext) - Method in class io.a2a.server.requesthandlers.DefaultRequestHandler

onDeleteTaskPushNotificationConfig(DeleteTaskPushNotificationConfigParams, ServerCallContext) - Method in interface io.a2a.server.requesthandlers.RequestHandler

onEnqueue(Event) - Method in interface io.a2a.server.events.EventEnqueueHook

onGetTask(TaskQueryParams, ServerCallContext) - Method in class io.a2a.server.requesthandlers.DefaultRequestHandler

onGetTask(TaskQueryParams, ServerCallContext) - Method in interface io.a2a.server.requesthandlers.RequestHandler

onGetTaskPushNotificationConfig(GetTaskPushNotificationConfigParams, ServerCallContext) - Method in class io.a2a.server.requesthandlers.DefaultRequestHandler

onGetTaskPushNotificationConfig(GetTaskPushNotificationConfigParams, ServerCallContext) - Method in interface io.a2a.server.requesthandlers.RequestHandler

onListTaskPushNotificationConfig(ListTaskPushNotificationConfigParams, ServerCallContext) - Method in class io.a2a.server.requesthandlers.DefaultRequestHandler

onListTaskPushNotificationConfig(ListTaskPushNotificationConfigParams, ServerCallContext) - Method in interface io.a2a.server.requesthandlers.RequestHandler

onMessageSend(MessageSendParams, ServerCallContext) - Method in class io.a2a.server.requesthandlers.DefaultRequestHandler

onMessageSend(MessageSendParams, ServerCallContext) - Method in interface io.a2a.server.requesthandlers.RequestHandler

onMessageSendStream(MessageSendParams, ServerCallContext) - Method in class io.a2a.server.requesthandlers.DefaultRequestHandler

onMessageSendStream(MessageSendParams, ServerCallContext) - Method in interface io.a2a.server.requesthandlers.RequestHandler

onResubscribeToTask(TaskIdParams, ServerCallContext) - Method in class io.a2a.server.requesthandlers.DefaultRequestHandler

onResubscribeToTask(TaskIdParams, ServerCallContext) - Method in interface io.a2a.server.requesthandlers.RequestHandler

onSetTaskPushNotificationConfig(TaskPushNotificationConfig, ServerCallContext) - Method in class io.a2a.server.requesthandlers.DefaultRequestHandler

onSetTaskPushNotificationConfig(TaskPushNotificationConfig, ServerCallContext) - Method in interface io.a2a.server.requesthandlers.RequestHandler

P

process(Event) - Method in class io.a2a.server.tasks.TaskManager

processor(TubeConfiguration, Flow.Publisher<T>, BiFunction<Consumer<Throwable>, T, Boolean>) - Static method in class io.a2a.server.util.async.AsyncUtils

produce() - Method in class io.a2a.server.util.async.AsyncExecutorProducer

PublicAgentCard - Annotation Interface in io.a2a.server

PushNotificationConfigStore - Interface in io.a2a.server.tasks

Interface for storing and retrieving push notification configurations for tasks.

PushNotificationSender - Interface in io.a2a.server.tasks

Interface for sending push notifications for tasks.

Q

QueueManager - Interface in io.a2a.server.events

queueSize(int) - Method in class io.a2a.server.events.EventQueue.EventQueueBuilder

R

reject() - Method in class io.a2a.server.tasks.TaskUpdater

reject(Message) - Method in class io.a2a.server.tasks.TaskUpdater

RequestContext - Class in io.a2a.server.agentexecution

RequestContext(MessageSendParams, String, String, Task, List<Task>, ServerCallContext) - Constructor for class io.a2a.server.agentexecution.RequestContext

RequestContext.Builder - Class in io.a2a.server.agentexecution

RequestHandler - Interface in io.a2a.server.requesthandlers

requiresAuth() - Method in class io.a2a.server.tasks.TaskUpdater

requiresAuth(boolean) - Method in class io.a2a.server.tasks.TaskUpdater

requiresAuth(Message) - Method in class io.a2a.server.tasks.TaskUpdater

requiresAuth(Message, boolean) - Method in class io.a2a.server.tasks.TaskUpdater

requiresInput() - Method in class io.a2a.server.tasks.TaskUpdater

requiresInput(boolean) - Method in class io.a2a.server.tasks.TaskUpdater

requiresInput(Message) - Method in class io.a2a.server.tasks.TaskUpdater

requiresInput(Message, boolean) - Method in class io.a2a.server.tasks.TaskUpdater

ResultAggregator - Class in io.a2a.server.tasks

ResultAggregator(TaskManager, Message) - Constructor for class io.a2a.server.tasks.ResultAggregator

ResultAggregator.EventTypeAndInterrupt - Record Class in io.a2a.server.tasks

S

save(Task) - Method in class io.a2a.server.tasks.InMemoryTaskStore

save(Task) - Method in interface io.a2a.server.tasks.TaskStore

sendNotification(Task) - Method in class io.a2a.server.tasks.BasePushNotificationSender

sendNotification(Task) - Method in interface io.a2a.server.tasks.PushNotificationSender

Sends a push notification containing the latest task state.

ServerCallContext - Class in io.a2a.server

ServerCallContext(User, Map<String, Object>, Set<String>) - Constructor for class io.a2a.server.ServerCallContext

setContextId(String) - Method in class io.a2a.server.agentexecution.RequestContext.Builder

setError(Throwable) - Method in class io.a2a.server.events.EnhancedRunnable

setInfo(String, PushNotificationConfig) - Method in class io.a2a.server.tasks.InMemoryPushNotificationConfigStore

setInfo(String, PushNotificationConfig) - Method in interface io.a2a.server.tasks.PushNotificationConfigStore

Sets or updates the push notification configuration for a task.

setParams(MessageSendParams) - Method in class io.a2a.server.agentexecution.RequestContext.Builder

setRelatedTasks(List<Task>) - Method in class io.a2a.server.agentexecution.RequestContext.Builder

setServerCallContext(ServerCallContext) - Method in class io.a2a.server.agentexecution.RequestContext.Builder

setTask(Task) - Method in class io.a2a.server.agentexecution.RequestContext.Builder

setTaskId(String) - Method in class io.a2a.server.agentexecution.RequestContext.Builder

SimpleRequestContextBuilder - Class in io.a2a.server.agentexecution

SimpleRequestContextBuilder(TaskStore, boolean) - Constructor for class io.a2a.server.agentexecution.SimpleRequestContextBuilder

SKIP_GRPC_PROPERTY - Static variable in class io.a2a.server.AgentCardValidator

SKIP_JSONRPC_PROPERTY - Static variable in class io.a2a.server.AgentCardValidator

SKIP_PROPERTY - Static variable in class io.a2a.server.AgentCardValidator

SKIP_REST_PROPERTY - Static variable in class io.a2a.server.AgentCardValidator

startWork() - Method in class io.a2a.server.tasks.TaskUpdater

startWork(Message) - Method in class io.a2a.server.tasks.TaskUpdater

submit() - Method in class io.a2a.server.tasks.TaskUpdater

submit(Message) - Method in class io.a2a.server.tasks.TaskUpdater

T

tap(String) - Method in class io.a2a.server.events.InMemoryQueueManager

tap(String) - Method in interface io.a2a.server.events.QueueManager

taskDone() - Method in class io.a2a.server.events.EventQueue

TaskManager - Class in io.a2a.server.tasks

TaskManager(String, String, TaskStore, Message) - Constructor for class io.a2a.server.tasks.TaskManager

TaskQueueExistsException - Exception in io.a2a.server.events

TaskQueueExistsException() - Constructor for exception io.a2a.server.events.TaskQueueExistsException

TaskQueueExistsException(String) - Constructor for exception io.a2a.server.events.TaskQueueExistsException

TaskQueueExistsException(String, Throwable) - Constructor for exception io.a2a.server.events.TaskQueueExistsException

TaskQueueExistsException(String, Throwable, boolean, boolean) - Constructor for exception io.a2a.server.events.TaskQueueExistsException

TaskQueueExistsException(Throwable) - Constructor for exception io.a2a.server.events.TaskQueueExistsException

TaskStore - Interface in io.a2a.server.tasks

TaskUpdater - Class in io.a2a.server.tasks

TaskUpdater(RequestContext, EventQueue) - Constructor for class io.a2a.server.tasks.TaskUpdater

toString() - Method in record class io.a2a.server.tasks.ResultAggregator.EventTypeAndInterrupt

Returns a string representation of this record class.

TransportMetadata - Interface in io.a2a.server

Interface for transport endpoint implementations to provide metadata about their transport.

U

UnauthenticatedUser - Class in io.a2a.server.auth

updateWithMessage(Message, Task) - Method in class io.a2a.server.tasks.TaskManager

User - Interface in io.a2a.server.auth

V

validateTransportConfiguration(AgentCard) - Static method in class io.a2a.server.AgentCardValidator

Validates the transport configuration of an AgentCard against available transports found on the classpath.

A B C D E F G H I J N O P Q R S T U V
All Classes and Interfaces|All Packages|Constant Field Values|Serialized Form