subagent

type AgentRegistration[M adk.MessageType] struct {
	Agent             adk.TypedResumableAgent[M]
	RunOptionsFactory RunOptionsFactory
}

type Executor[M adk.MessageType] struct {
	// contains filtered or unexported fields
}

type ExecutorConfig[M adk.MessageType] struct {
	// SessionStore persists child events without attempt-specific construction.
	// It is retained for providers whose store performs fencing by another
	// mechanism. Persistent child sessions may be used by multiple task IDs, so
	// production providers must serialize concurrent turns for one session
	// across workers. Configure exactly one of SessionStore and
	// SessionStoreFactory.
	SessionStore adk.SessionEventStore[M]
	// SessionStoreFactory constructs a task-bound child event store.
	// Stores returned for tasks sharing a ChildSessionID must coordinate the
	// same durable session and serialize concurrent turns across workers.
	SessionStoreFactory SessionStoreFactory[M]
	// CheckPointStore persists ADK Runner checkpoints for interruption and recovery.
	CheckPointStore adk.CheckPointStore
	// SessionConfig optionally customizes child-session persistence.
	SessionConfig *adk.SessionConfig[M]
}

type RunOptionsFactory func() ([]adk.AgentRunOption, error)

type SessionStoreFactory[M adk.MessageType] func(
	context.Context,
	*backgroundtask.Task,
) (adk.SessionEventStore[M], error)

type SubmitRequest[M adk.MessageType] struct {
	TaskID                        string
	SubAgentName                  string
	Input                         *adk.TypedAgentInput[M]
	Description                   string
	SessionID                     string
	ChildSessionID                string
	DisableLifecycleNotifications bool
	InitialCheckpoint             []byte
}

type TaskContext struct {
	TaskID          string
	ParentSessionID string
	SubAgentName    string
	ChildSessionID  string
	Attempt         int64
}