flow

type Activities interface {
	activitylib.Service
	activitylib.MessageAppender
	activitylib.Tracker
	UpdateActivity(ctx context.Context, activityID string, req activitylib.UpdateRequest) (*activitytypes.Activity, error)
	AwaitActivitySlotBounded(ctx context.Context, activityID, environmentID string) error
}

type Binding struct {
	EnvironmentID string `json:"environmentId,omitempty"`
	JobID         string `json:"jobId,omitempty"`
	RunID         string `json:"runId,omitempty"`
	RootID        string `json:"rootId"`
}

type Definition struct {
	Name        string
	Version     int
	Fingerprint string
	Concurrency int
	Timeout     time.Duration
	// Activity is the template for the activity each root instance owns; an empty Type means none.
	Activity activitylib.StartRequest
	// Labels name steps on the activity; steps without one show their name.
	Labels map[string]string
	// Steps use Francis step builders with handlers wrapped by Engine.Handler.
	// The last step returns scheduler.Outcome.
	Steps   []workflow.StepSpec
	Options []workflow.Option
}

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

type Job struct {
	Engine   *Engine
	Workflow *Workflow
	JobName  string
	// Payload is every instance's input, such as the entity a per-entity job runs for.
	Payload any
	// Activity overrides the definition's activity template, such as with the entity's name.
	Activity    activitylib.StartRequest
	ScheduleFn  func(ctx context.Context) string
	ShouldRunFn func(ctx context.Context) bool
	// FallbackFn recovers a run whose instance cannot resume; nil fails the run so
	// a retry starts a fresh instance under a new attempt.
	FallbackFn      func(ctx context.Context, previous scheduler.Run) (scheduler.Outcome, error)
	ValidateRetryFn func(ctx context.Context, run scheduler.Run) error
}

type Result[T any] struct {
	Value T
	Err   string
}

type Task struct {
	workflow.Task
	// contains filtered or unexported fields
}

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