input

Oct 2, 2026

Changes in this version

+ var ErrArtifactUnavailable = errors.New("artifact bytes are unavailable")

+ var ErrDocumentNotFound = errors.New("document is not part of the review")

+ var ErrStaleRequest = errors.New("request_id does not match the pending input")

+ var ErrStorage = errors.New("input storage operation failed")

+ var ErrValidation = errors.New("invalid input")

type InputForm

+ RequestedAt string

+ type PendingInputOccurrence struct

+ JobID string

+ RequestID string

+ RequestedAt string

+ TaskOrdinal int64

+ type PendingInputOptions struct

+ PageSize int

+ PageToken string

+ type PendingInputPage struct

+ Inputs []PendingInputOccurrence

+ NextPageToken string

+ type ReviewDocument struct

+ ID string

+ Name string

+ Ref artifacts.Ref

+ SizeBytes int64

type Runtime

+ func (r *Runtime) ListPendingInputsPage(ctx context.Context, tenantID string, options PendingInputOptions) (PendingInputPage, error)

+ func (r *Runtime) OpenReviewDocument(ctx context.Context, tenantID, jobID, requestID, documentID string) (*ReviewDocument, error)

+ type RuntimeError struct

+ Cause error

+ DocumentID string

+ Field string

+ FieldID string

+ Kind error

+ Operation string

+ func (e *RuntimeError) Error() string

+ func (e *RuntimeError) Is(target error) bool

+ func (e *RuntimeError) Unwrap() error

type ValidationError

+ Cause error

+ FieldID string

+ func (e ValidationError) Is(target error) bool

+ func (e ValidationError) Unwrap() error

Oct 1, 2026

Changes in this version

+ func GetAlternateOp() ops.RegisterableOp

+ type Actor struct

+ ID string

+ Kind string

type Config

+ Documents map[string]any

+ Kind string

+ Presentation map[string]any

+ Request any

+ RequestSchema map[string]any

+ ResponseSchema map[string]any

+ func (c Config) MarshalJSON() ([]byte, error)

+ type FallbackAnswers struct

+ ArtifactRefs map[string]artifacts.Ref

+ Fields map[string]any

+ Response any

+ type FormSubmission struct

+ ArtifactRefs map[string]artifacts.Ref

+ Fields map[string]any

+ RequestID string

+ Response any

+ SubmissionID string

type Input

+ IfUnanswered *UnansweredPolicy

type InputForm

+ Documents map[string]recipeartifacts.Ref

+ Fallback *FallbackAnswers

+ FallbackAt string

+ Kind string

+ Presentation map[string]any

+ Request any

+ RequestID string

+ RequestSchema map[string]any

+ ResponseSchema map[string]any

+ func (f InputForm) MarshalJSON() ([]byte, error)

type Output

+ ArtifactRefs map[string]recipeartifacts.Ref

+ Receipt *Receipt

+ type Receipt struct

+ Actor Actor

+ RequestID string

+ SubmissionID string

+ SubmittedAt time.Time

type Runtime

+ func (r *Runtime) GetForm(ctx context.Context, projectID, jobID string) (InputForm, error)

+ func (r *Runtime) SubmitFormResponse(ctx context.Context, tenantID, jobID string, submission FormSubmission, ...) (Output, error)

+ func (r *Runtime) SubmitStructuredResponse(ctx context.Context, projectID, jobID string, submission StructuredSubmission, ...) (Output, error)

+ type StructuredSubmission struct

+ ArtifactRefs map[string]recipeartifacts.Ref

+ RequestID string

+ Response any

+ SubmissionID string

+ type UnansweredPolicy struct

+ After string

+ ArtifactRefs map[string]artifacts.Ref

+ Fields map[string]any

+ Response any

May 15, 2026

Changes in this version

+ const APIFieldTypeBoolean

+ func NormalizeOutputMap(opInput map[string]interface{}, opOutput map[string]interface{}) (map[string]interface{}, error)

type Config

+ Default interface{}

type FieldType

+ const FieldTypeBoolean

type FormField

+ Default interface{}

type InputForm

+ Default interface{}

type Output

+ func NormalizeOutput(form Config, out Output) (Output, error)

May 14, 2026

Changes in this version

type Config

+ func (c Config) ValidateOpInput() error

type Input

+ func (in Input) ValidateOpInput() error

+ type ValidationError struct

+ Field string

+ Message string

+ Required bool

+ func (e ValidationError) Error() string

+ func (e ValidationError) RequiredValidationError() bool

Apr 28, 2026

Changes in this version

+ const APIFieldTypeCheckboxes

+ const APIFieldTypeLinearScale

+ var ErrInputNotPending = errors.New("input is not pending for job")

+ func GetAutoFillOp() ops.RegisterableOp

+ func GetOp() ops.RegisterableOp

+ type APIFieldType = openapi.FieldType

+ type APIFormField = openapi.FormField

+ type APIOption = openapi.Option

+ type Artifact struct

+ Path string

+ type Config struct

+ Context FormContext

+ Fields []FormField

+ Options []Option

+ Output *Output

+ Question string

+ Scale *LinearScale

+ Title string

+ Type FieldType

+ type FieldType string

+ const FieldTypeCheckboxGrid

+ const FieldTypeCheckboxes

+ const FieldTypeDate

+ const FieldTypeDropdown

+ const FieldTypeFileUpload

+ const FieldTypeLinearScale

+ const FieldTypeMultipleChoice

+ const FieldTypeMultipleChoiceGrid

+ const FieldTypeParagraphText

+ const FieldTypeShortAnswer

+ const FieldTypeTime

+ type FieldValidation struct

+ Max int

+ MaxLength int

+ Min int

+ MinLength int

+ Pattern string

+ type FormContext struct

+ Artifacts []Artifact

+ ArtifactsFromOutput string

+ ArtifactsGlob []GlobPattern

+ type FormField struct

+ ID string

+ Options []Option

+ Placeholder string

+ Question string

+ Required bool

+ Scale *LinearScale

+ Type FieldType

+ Validation FieldValidation

+ type FormResponse = openapi.FormResponse

+ type GlobPattern struct

+ Pattern string

+ type Input struct

+ Form Config

+ type InputCancelSignal struct

+ ActivityID string

+ Reason string

+ ResponseID string

+ type InputForm struct

+ Context FormContext

+ Fields []FormField

+ Options []Option

+ Output *Output

+ Question string

+ Scale *LinearScale

+ Timeout time.Duration

+ Title string

+ Type FieldType

+ type InputRequestSignal struct

+ ActivityID string

+ Form InputForm

+ Timeout time.Duration

+ WorkflowID string

+ type InputResponseSignal struct

+ ActivityID string

+ FormResponse FormResponse

+ RespondedAt time.Time

+ ResponseID string

+ UserID string

+ type InputTimeoutSignal struct

+ ActivityID string

+ ResponseID string

+ TimedOutAt time.Time

+ type InputWorkflowParams struct

+ ActivityID string

+ BoxID string

+ Form InputForm

+ ID string

+ Timeout time.Duration

+ type InputWorkflowResult struct

+ FormResponse map[string]interface{}

+ Metadata map[string]interface{}

+ UserID string

+ type LinearScale struct

+ Max int

+ MaxLabel string

+ Min int

+ MinLabel string

+ type Option struct

+ Label string

+ Value string

+ type Output struct

+ Fields map[string]interface{}

+ Metadata map[string]interface{}

+ Response interface{}

+ UserID string

+ type PendingInput = openapi.PendingInput

+ type Runtime struct

+ func NewRuntime(ctl workflowctl.WorkflowControl, sse ops.SSEManager) (*Runtime, error)

+ func NewRuntimeFromDeps(deps ops.ServiceDependencies2) (*Runtime, error)

+ func (r *Runtime) Cancel(ctx context.Context, projectID string, jobID string, reason string) error

+ func (r *Runtime) GetDetails(ctx context.Context, projectID string, jobID string) (*UserInputDetails, error)

+ func (r *Runtime) ListPendingInputs(ctx context.Context, projectID string) ([]PendingInput, error)

+ func (r *Runtime) SSEManager() ops.SSEManager

+ func (r *Runtime) SubmitResponse(ctx context.Context, projectID string, jobID string, output FormResponse) error

+ type SSEEvent = recipeops.SSEEvent

+ type SimpleSSEManager struct

+ func NewSimpleSSEManager() *SimpleSSEManager

+ func (m *SimpleSSEManager) Broadcast(event ops.SSEEvent)

+ func (m *SimpleSSEManager) ClearBuffer()

+ func (m *SimpleSSEManager) GetClients() int

+ func (m *SimpleSSEManager) Subscribe(clientID string) <-chan ops.SSEEvent

+ func (m *SimpleSSEManager) Unsubscribe(clientID string)

+ type UserInputDetails = openapi.UserInputDetails

+ type UserResponseSignal struct

+ Fields map[string]interface{}

+ Metadata map[string]interface{}

+ RespondedAt time.Time

+ UserID string