externalexecution

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

type AuthorizerOption func(*Authorizer)

type CancellationRecord struct {
	ID                    uuid.UUID
	CallerServiceID       string
	ExternalRequestID     uuid.UUID
	ActorUserID           uuid.UUID
	ReasonCode            string
	State                 string
	ExecutionKindSnapshot *string
	ExecutionIDSnapshot   *uuid.UUID
	ErrorCode             *string
	RequestedAt           time.Time
	AppliedAt             *time.Time
	FinishedAt            *time.Time
	UpdatedAt             time.Time
}

type ExecutionCancelRequest struct {
	ReasonCode string `json:"reason_code"`
}

type ExecutionCancellationResponse struct {
	CancellationID string `json:"cancellation_id"`
	State          string `json:"state"`
	ReasonCode     string `json:"reason_code"`
	ExecutionKind  string `json:"execution_kind,omitempty"`
	ExecutionID    string `json:"execution_id,omitempty"`
	RequestedAt    string `json:"requested_at"`
	AppliedAt      string `json:"applied_at,omitempty"`
	FinishedAt     string `json:"finished_at,omitempty"`
}

type ExecutionKey struct {
	CallerServiceID   string
	ExternalRequestID uuid.UUID
	ActorUserID       uuid.UUID
}

type ExecutionRecord struct {
	CallerServiceID           string
	ExternalRequestID         uuid.UUID
	RequestFingerprintVersion int16
	ActorUserID               uuid.UUID
	TargetType                string
	TargetID                  uuid.UUID
	InputFingerprint          []byte
	ExpectedContractHash      *string
	InputSchemaFingerprint    []byte
	TraceID                   string
	DownstreamReplayIdentity  []byte
	StartState                string
	StartToken                *uuid.UUID
	StartLeaseUntil           *time.Time
	AuthorizedTargetOwnerID   *uuid.UUID
	RejectionCode             *string
	ExecutionKind             *string
	ExecutionID               *uuid.UUID
	DownstreamKeyHash         []byte
	DownstreamFingerprint     []byte
}

type ExecutionRequest struct {
	ExternalRequestID    string                 `json:"external_request_id"`
	TargetType           string                 `json:"target_type"`
	TargetID             string                 `json:"target_id"`
	Input                map[string]interface{} `json:"input"`
	Metadata             map[string]interface{} `json:"metadata,omitempty"`
	TraceID              string                 `json:"trace_id"`
	ExpectedContractHash string                 `json:"expected_contract_hash"`
	InputSchema          json.RawMessage        `json:"input_schema"`
}

type ExecutionStartResponse struct {
	ExecutionID string `json:"execution_id"`
	Status      string `json:"status"`
}

type ExecutionStatusResponse struct {
	ExternalRequestID string                         `json:"external_request_id"`
	ExecutionID       string                         `json:"execution_id,omitempty"`
	TargetType        string                         `json:"target_type,omitempty"`
	Status            string                         `json:"status"`
	Output            map[string]interface{}         `json:"output,omitempty"`
	Artifacts         []runtime.RunArtifactResponse  `json:"artifacts"`
	ErrorCode         string                         `json:"error_code,omitempty"`
	ErrorMessage      string                         `json:"error_message,omitempty"`
	StartedAt         string                         `json:"started_at,omitempty"`
	FinishedAt        string                         `json:"finished_at,omitempty"`
	Cancellation      *ExecutionCancellationResponse `json:"cancellation,omitempty"`
}

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

type Principal struct {
	CallerServiceID string
	ActorUserID     uuid.UUID
}

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

type ReplayStore interface {
	Consume(context.Context, string, string, time.Duration) (bool, error)
}

type RequestBinding struct {
	Version string
	Method  string
	Path    string
	BodySHA string
}

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

type SafeExecutionError struct {
	Code    string `json:"code"`
	Message string `json:"message"`
}

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

type ServiceTokenClaims struct {
	Scope                 string `json:"scope"`
	DelegatedActor        string `json:"delegated_actor"`
	CallerServiceID       string `json:"caller_service_id"`
	RequestBindingVersion string `json:"request_binding_version,omitempty"`
	RequestMethod         string `json:"request_method,omitempty"`
	RequestPath           string `json:"request_path,omitempty"`
	RequestBodySHA256     string `json:"request_body_sha256,omitempty"`
	jwt.RegisteredClaims
}

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

type Store interface {
	ResolveTargetOwner(context.Context, string, uuid.UUID) (uuid.UUID, error)
	Reserve(context.Context, ExecutionRecord) (ExecutionRecord, error)
	PromoteLegacyReservation(context.Context, ExecutionRecord) (ExecutionRecord, error)
	Get(context.Context, string, uuid.UUID) (ExecutionRecord, error)
	ClaimStartEvaluation(context.Context, string, uuid.UUID, uuid.UUID, time.Duration) (ExecutionRecord, bool, error)
	AuthorizeStart(context.Context, string, uuid.UUID, uuid.UUID, uuid.UUID) (ExecutionRecord, bool, error)
	RejectStart(context.Context, string, uuid.UUID, uuid.UUID, string) (ExecutionRecord, bool, error)
	ReleaseStartEvaluation(context.Context, string, uuid.UUID, uuid.UUID) error
	Attach(context.Context, string, uuid.UUID, string, uuid.UUID) (ExecutionRecord, error)
	ClaimLaunch(context.Context, string, uuid.UUID, uuid.UUID, time.Duration) (ExecutionRecord, bool, error)
	AttachLaunched(context.Context, string, uuid.UUID, uuid.UUID, string, uuid.UUID) (ExecutionRecord, bool, error)
	AttachCanceledRecovery(context.Context, string, uuid.UUID, string, uuid.UUID) (ExecutionRecord, bool, error)
	GetKey(context.Context, string, uuid.UUID) (ExecutionKey, error)
	GetCancellation(context.Context, string, uuid.UUID) (CancellationRecord, error)
	RequestCancel(context.Context, string, uuid.UUID, uuid.UUID, string) (*ExecutionRecord, CancellationRecord, error)
	AdvanceCancellation(context.Context, string, uuid.UUID, string) (*ExecutionRecord, CancellationRecord, error)
	ListPendingCancellations(context.Context, int) ([]CancellationRecord, error)
}

type TargetValidationRequest struct {
	TargetType  string          `json:"target_type"`
	TargetID    string          `json:"target_id"`
	InputSchema json.RawMessage `json:"input_schema,omitempty"`
}

type TargetValidationResponse struct {
	TargetType        string `json:"target_type"`
	TargetID          string `json:"target_id"`
	TargetName        string `json:"target_name"`
	Executable        bool   `json:"executable"`
	UnavailableReason string `json:"unavailable_reason,omitempty"`
	ContractHash      string `json:"contract_hash,omitempty"`
}

type VerificationKey struct {
	KeyID     string
	PublicKey string
}

type WorkflowTargetValidation struct {
	TargetName        string
	Executable        bool
	UnavailableReason string
	ContractHash      string
}