http

type CheckpointLister interface {
	ListRunCheckpoints(ctx context.Context, runID string, limit int) (any, error)
}

type CheckpointLoader interface {
	GetRunCheckpoint(ctx context.Context, runID string, version int64) (any, error)
}

type CheckpointResumer interface {
	ResumeFromCheckpoint(ctx context.Context, runID string, version int64) (any, error)
}

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

type HandlerConfig struct {
	Checkpoint   StepResumer
	Steps        StepsLister
	History      CheckpointLister
	Checkpoints  CheckpointLoader
	Restore      CheckpointResumer
	Fork         RunForker
	MaxBodyBytes int64
}

type RunForker interface {
	ForkRun(ctx context.Context, runID string, version int64) (any, error)
}

type StepResumer interface {
	ResumeFromStep(ctx context.Context, runID, nodeID string) (any, error)
}

type StepsLister interface {
	ListRunSteps(ctx context.Context, runID string) (any, error)
}