engine

type AppCallbackEventSink struct {
	// contains filtered or unexported fields
}

type AppCallbackRoute struct {
	AppID      string
	URL        string
	Token      string
	EventTypes []string
}

type CallbackEventSink struct {
	// contains filtered or unexported fields
}

type CallbackEventSinkConfig struct {
	URL     string
	Token   string
	Timeout time.Duration
}

type Config struct {
	// ManualLightweightExecution lets an embedded caller own execution and cancellation.
	// The caller must invoke ExecuteRunOnce after StartRun or ResumeRun.
	ManualLightweightExecution bool

	// RequireRunModelCredentials is trusted deployment policy, never run input.
	RequireRunModelCredentials func(appID string) bool
	ValidateRunModelEndpoint   func(appID string, model *sdk.RunModel) error
	ModelCredentials           *modelauth.Manager
	DefaultExecutionMode       string
	Store                      agentcore.Store
	Runtimes                   *runtime.Registry
	Tools                      *tools.Registry
	Targets                    host.TargetContextProvider
	Skills                     *skills.Registry
	SkillPackages              *skills.PackageStoreRegistry
	Workspaces                 *workspace.Registry
	Durable                    DurableExecutor
	EventSink                  EventSink
	RunMCP                     mcp.RunConfig
	CodingWorker               bool
	CheckCodingAdmission       func(context.Context) error
}

type DurableExecutionDescriber interface {
	DescribeRun(ctx context.Context, run *agentcore.AgentRun) (*RunExecutionInfo, error)
}

type DurableExecutionInspector interface {
	InspectRun(ctx context.Context, run *agentcore.AgentRun) (string, error)
}

type DurableExecutor interface {
	StartRun(ctx context.Context, run *agentcore.AgentRun) error
	CancelRun(ctx context.Context, run *agentcore.AgentRun) error
	ResumeRun(ctx context.Context, run *agentcore.AgentRun, payload ResumePayload) error
}

type Engine struct {
	// contains filtered or unexported fields
}

type Event = sdk.Event

type EventBroker struct {
	// contains filtered or unexported fields
}

type EventSink interface {
	Emit(ctx context.Context, event Event)
}

type MultiEventSink []EventSink

type NATSEventSink struct {
	// contains filtered or unexported fields
}

type NATSEventSinkConfig struct {
	URL             string
	ClientName      string
	StreamName      string
	StreamSubjects  []string
	SubjectTemplate string
	EnsureStream    bool
}

type NATSRuntimeEvent = sdk.EventEnvelope

type NoopEventSink struct{}

type PersistedEventSink struct {
	Store       agentcore.Store
	V2Enabled   func(appID string) bool
	V2Publisher V2EventPublisher
}

type ResumePayload struct {
	MessageProvenance string                `json:"message_provenance,omitempty"`
	Intent            string                `json:"intent"`
	Content           string                `json:"content,omitempty"`
	ResponsePayload   json.RawMessage       `json:"response_payload,omitempty"`
	ExternalActorID   string                `json:"external_actor_id,omitempty"`
	ResumeID          string                `json:"resume_id,omitempty"`
	InteractionID     string                `json:"interaction_id,omitempty"`
	TurnPolicy        *agentcore.TurnPolicy `json:"turn_policy,omitempty"`
}

type RunExecutionInfo struct {
	ExecutionMode        string     `json:"execution_mode"`
	State                string     `json:"state"`
	WorkflowID           string     `json:"workflow_id,omitempty"`
	TemporalRunID        string     `json:"temporal_run_id,omitempty"`
	TaskQueue            string     `json:"task_queue,omitempty"`
	HistoryLength        int64      `json:"history_length,omitempty"`
	HistorySizeBytes     int64      `json:"history_size_bytes,omitempty"`
	StateTransitionCount int64      `json:"state_transition_count,omitempty"`
	StartedAt            *time.Time `json:"started_at,omitempty"`
	ClosedAt             *time.Time `json:"closed_at,omitempty"`
}

type RunMCPCredentialUpdate struct {
	RunID     string     `json:"run_id"`
	ServerID  string     `json:"server_id"`
	ExpiresAt *time.Time `json:"expires_at,omitempty"`
	UpdatedAt time.Time  `json:"updated_at"`
}

type SlogEventSink struct{}

type StartRunRequest struct {
	Model           *sdk.RunModel          `json:"model,omitempty"`
	ModelCredential *sdk.ModelCredential   `json:"model_credential,omitempty"`
	AppID           string                 `json:"app_id"`
	HostRunID       string                 `json:"host_run_id,omitempty"`
	AgentID         string                 `json:"agent_id"`
	Target          agentcore.TargetRef    `json:"target"`
	Instructions    string                 `json:"instructions,omitempty"`
	AllowedTools    []string               `json:"allowed_tools,omitempty"`
	ExternalActorID string                 `json:"external_actor_id,omitempty"`
	Mode            string                 `json:"mode,omitempty"`
	ExecutionMode   string                 `json:"execution_mode,omitempty"`
	Trigger         map[string]interface{} `json:"trigger,omitempty"`
	Metadata        map[string]interface{} `json:"metadata,omitempty"`
	TurnPolicy      agentcore.TurnPolicy   `json:"turn_policy,omitempty"`
	MCPServers      []mcp.RunServerRequest `json:"mcp_servers,omitempty"`
}

type V2EventEnvelope struct {
	EventID       string                 `json:"event_id"`
	SentAt        time.Time              `json:"sent_at"`
	SequenceNo    int64                  `json:"sequence_no"`
	AppID         string                 `json:"app_id"`
	RunID         string                 `json:"run_id"`
	HostRunID     string                 `json:"host_run_id,omitempty"`
	SchemaVersion string                 `json:"schema_version"`
	TurnID        string                 `json:"turn_id,omitempty"`
	SegmentID     string                 `json:"segment_id,omitempty"`
	Revision      int64                  `json:"revision"`
	BaseRevision  int64                  `json:"base_revision,omitempty"`
	Type          string                 `json:"type"`
	Data          map[string]interface{} `json:"data,omitempty"`
}

type V2EventPublisher interface {
	PublishV2(ctx context.Context, event agentcore.AgentRunEvent) error
}