google-adk-kotlin-a2a/com.google.adk.kt.a2a.agent/BaseRemoteA2AAgent

BaseRemoteA2AAgent

abstract class BaseRemoteA2AAgent(name: String, val description: String = "", subAgents: List<BaseAgent> = emptyList(), beforeAgentCallbacks: List<BeforeAgentCallback> = emptyList(), afterAgentCallbacks: List<AfterAgentCallback> = emptyList()) : BaseAgent

Abstract base class for Remote A2A Agents. Marker base class for remote agent implementations.

Constructors

BaseRemoteA2AAgent

constructor(name: String, description: String = "", subAgents: List<BaseAgent> = emptyList(), beforeAgentCallbacks: List<BeforeAgentCallback> = emptyList(), afterAgentCallbacks: List<AfterAgentCallback> = emptyList())

Types

AgentCardResolutionError

class AgentCardResolutionError(message: String, cause: Throwable? = null) : RuntimeException

Exception thrown when the agent card cannot be resolved.

Properties

afterAgentCallbacks

val afterAgentCallbacks: List<AfterAgentCallback>

beforeAgentCallbacks

val beforeAgentCallbacks: List<BeforeAgentCallback>

open override val config: NodeConfig

open override val description: String

disallowTransferToParent

val disallowTransferToParent: Boolean

disallowTransferToPeers

val disallowTransferToPeers: Boolean

open override val inputSchema: Schema?

isStreamingEnabled

abstract val isStreamingEnabled: Boolean

Returns true if this agent supports streaming responses.

override val name: String

open override val outputSchema: Schema?

requiresAllPredecessors

open override val requiresAllPredecessors: Boolean

open override val rerunOnResume: Boolean

open override val stateSchema: Schema?

val subAgents: List<BaseAgent>

open override val waitForOutput: Boolean

Functions

fun run(context: Context, nodeInput: Any?): Flow<Event>

fun runAsync(parentContext: InvocationContext): Flow<Event>

open override fun runNode(context: Context, nodeInput: Any?): Flow<Any?>