http4k-ai-a2a-sdk/org.http4k.protocol/A2A

A2A

class A2A(val cards: AgentCardProvider, tasks: TaskStorage = TaskStorage.InMemory(), pushNotifications: PushNotificationConfigStorage = PushNotificationConfigStorage.InMemory(), subscriptions: TaskSubscriptions = TaskSubscriptions.InMemory(), pushNotificationUrlPolicy: PushNotificationUrlPolicy = AllowAll, handler: MessageHandler)(source)

Constructors

constructor(cards: AgentCardProvider, tasks: TaskStorage = TaskStorage.InMemory(), pushNotifications: PushNotificationConfigStorage = PushNotificationConfigStorage.InMemory(), subscriptions: TaskSubscriptions = TaskSubscriptions.InMemory(), pushNotificationUrlPolicy: PushNotificationUrlPolicy = AllowAll, handler: MessageHandler)

constructor(agentCard: AgentCard, tasks: TaskStorage = TaskStorage.InMemory(), pushNotifications: PushNotificationConfigStorage = PushNotificationConfigStorage.InMemory(), subscriptions: TaskSubscriptions = TaskSubscriptions.NoOp(), pushNotificationUrlPolicy: PushNotificationUrlPolicy = PushNotificationUrlPolicy.AllowAll, handler: MessageHandler)

Properties

val cards: AgentCardProvider

Functions

fun cancelTask(params: A2ATask.Cancel.Request.Params): Task?

deletePushConfig

fun deletePushConfig(params: A2APushNotificationConfig.Delete.Request.Params): PushNotificationConfigId?

fun getPushConfig(params: A2APushNotificationConfig.Get.Request.Params): TaskPushNotificationConfig?

fun getTask(params: A2ATask.Get.Request.Params): Task?

listPushConfigs

fun listPushConfigs(params: A2APushNotificationConfig.List.Request.Params): PushNotificationConfigPage

fun listTasks(params: A2ATask.ListTasks.Request.Params): TaskPage

fun send(params: A2AMessage.Send.Request.Params, http: Request): MessageResponse

fun setPushConfig(params: A2APushNotificationConfig.Set.Request.Params): TaskPushNotificationConfig

fun stream(params: A2AMessage.Stream.Request.Params, http: Request): Sequence<StreamItem>

fun subscribe(taskId: TaskId, sse: Sse, tenant: Tenant? = null): Task?