trigger

type A2AEnvelope struct {
	// SourceAgentCard is the source agent's card reference.
	SourceAgentCard string `json:"source_agent_card"`
	// TargetAgentCard is the target agent's card reference.
	TargetAgentCard string `json:"target_agent_card"`
	// TargetLockDigest is the expected digest of the target agent lock.
	TargetLockDigest string `json:"target_lock_digest,omitempty"`
	// ParentTaskID is the originating task.
	ParentTaskID string `json:"parent_task_id"`
	// ParentRunID is the originating run.
	ParentRunID string `json:"parent_run_id"`
	// ContextID groups related handoffs.
	ContextID string `json:"context_id"`
	// CorrelationID for tracing.
	CorrelationID string `json:"correlation_id"`
	// MessageRole: "user", "assistant", "system".
	MessageRole string `json:"message_role"`
	// Parts are the message parts (A2A format).
	Parts []A2APart `json:"parts"`
	// ArtifactRefs reference external artifacts without embedding them.
	ArtifactRefs []ArtifactRef `json:"artifact_refs"`
	// Metadata is an arbitrary key-value map.
	Metadata map[string]string `json:"metadata"`
}

type A2APart struct {
	Type string `json:"type"`
	Data string `json:"data"`
}

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

type APIKeyMeta struct {
	ID      string
	KeyHash string
	Scopes  []string
	Revoked bool
}

type APIKeyRecord struct {
	ID          string     `json:"id"`
	KeyHash     string     `json:"key_hash"`
	Scopes      []string   `json:"scopes"`
	Description string     `json:"description"`
	CreatedAt   time.Time  `json:"created_at"`
	CreatedBy   string     `json:"created_by"`
	Revoked     bool       `json:"revoked"`
	RevokedAt   *time.Time `json:"revoked_at,omitempty"`
	LastUsedAt  *time.Time `json:"last_used_at,omitempty"`
}

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

type ArtifactRef struct {
	// URI is the artifact location (e.g. "agentpaas://artifact/<id>").
	URI string `json:"uri"`
	// Digest is the SHA-256 of the artifact.
	Digest string `json:"digest"`
	// Size is the artifact byte size.
	Size int64 `json:"size"`
}

type AuthMethod string

type Authenticator interface {
	Authenticate(context.Context) (CallerID, AuthMethod, error)
}

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

type CallerID string

type CronConfig struct {
	// Schedules is the list of cron schedules to manage.
	Schedules []*CronSchedule
	// StatePath is an optional path to a JSON file for schedule persistence.
	StatePath string
	// Audit is the audit appender for cron events.
	Audit audit.AuditAppender
	// TriggerService is the service to invoke when cron fires.
	TriggerService *TriggerService
}

type CronExpr struct {
	Minute     CronField
	Hour       CronField
	DayOfMonth CronField
	Month      CronField
	DayOfWeek  CronField
}

type CronField struct {
	Values []int
}

type CronSchedule struct {
	// Expr is the 5-field cron expression.
	Expr string
	// ScheduleID is the unique identifier for this schedule.
	ScheduleID string
	// AgentName is the target agent to invoke.
	AgentName string
	// AgentVersion is the target agent version (optional).
	AgentVersion string
	// Payload is the fixed payload bytes for the cron invoke.
	Payload []byte
	// ContentType is the payload content type.
	ContentType string
	// Timezone is the timezone (empty = local).
	Timezone string
	// MissedRunPolicy is "skip" (default) or "catchup".
	MissedRunPolicy string
	// ConcurrencyPolicy is "forbid" (default).
	ConcurrencyPolicy string
	// IdempotencyKey is an optional idempotency key prefix.
	IdempotencyKey string
}

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

type EgressChecker interface {
	IsURLAllowed(rawURL string) bool
}

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

type EventType string

type HandoffConcurrencyPolicy string

type HandoffConfig struct {
	// SourceAgent is the agent that initiates the handoff.
	SourceAgent string
	// TargetAgent is the agent to invoke.
	TargetAgent string
	// TargetAgentVersion is the target agent version (optional).
	TargetAgentVersion string
	// TargetLockDigest is the expected digest of the target agent lock.
	TargetLockDigest string
	// PayloadMode controls how the handoff payload is built.
	PayloadMode PayloadMode
	// FixedJSON is the payload for PayloadModeFixedJSON.
	FixedJSON json.RawMessage
	// ContentType for the handoff invoke request.
	ContentType string
	// MaxDepth limits handoff chain depth (default 5).
	MaxDepth int
	// IdempotencyKeyPrefix for the handoff invoke.
	IdempotencyKeyPrefix string
	// ConcurrencyPolicy controls concurrent handoffs to the target.
	ConcurrencyPolicy HandoffConcurrencyPolicy
}

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

type HandoffRequest struct {
	// SourceAgent is the agent requesting the handoff.
	SourceAgent string
	// ParentRunID is the run that triggered this handoff.
	ParentRunID string
	// ContextID groups related handoffs.
	ContextID string
	// CorrelationID for tracing (generated if empty).
	CorrelationID string
	// SummaryRef references a summary of the parent run.
	SummaryRef string
	// ArtifactRefs are artifacts from the parent run.
	ArtifactRefs []ArtifactRef
	// Metadata is passed through to the envelope.
	Metadata map[string]string
}

type HandoffResult struct {
	// Invoked is true if the handoff was triggered.
	Invoked bool
	// RunID is the new run ID (if invoked).
	RunID string
	// Envelope is the A2A envelope that was sent.
	Envelope *A2AEnvelope
	// Reason explains why the handoff was skipped or denied.
	Reason string
}

type IdempotencyEntry struct {
	Key         string    `json:"key"`
	RunID       string    `json:"run_id"`
	RequestHash string    `json:"request_hash"`
	CallerID    string    `json:"caller_id"`
	AgentName   string    `json:"agent_name"`
	CreatedAt   time.Time `json:"created_at"`
	ExpiresAt   time.Time `json:"expires_at"`
}

type IdempotencyResult int

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

type PayloadMode string

type RunEntry struct {
	RunID      string
	AgentName  string
	Status     triggerv1.RunStatus
	CreatedAt  time.Time
	StartedAt  time.Time
	FinishedAt time.Time
	CancelCtx  context.CancelFunc
	// contains filtered or unexported fields
}

type RunEvent struct {
	EventID   int64     `json:"event_id"`
	RunID     string    `json:"run_id"`
	Type      EventType `json:"type"`
	Timestamp time.Time `json:"timestamp"`
	Data      any       `json:"data,omitempty"`
}

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

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

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

type ServerConfig struct {
	GRPCAddr        string
	RESTAddr        string
	Exposed         bool
	Authenticator   Authenticator
	CORS            *CORSMiddleware
	Audit           audit.AuditAppender
	MaxPayloadBytes int
	// IdempotencyStore handles idempotency key replay/conflict.
	IdempotencyStore *IdempotencyStore
	EventBus         *EventBus
}

type TriggerService struct {
	triggerv1.UnimplementedTriggerServiceServer
	// contains filtered or unexported fields
}

type WebhookConfig struct {
	Name   string
	URL    string
	Secret string
}

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

type WebhookDelivery struct {
	Event      *RunEvent
	Hook       *WebhookConfig
	Attempt    int
	Status     string
	StatusCode int
	Error      string
	Timestamp  time.Time
}