coretask

Dec 15, 2025

Changes in this version

+ type Interceptor func(ctx context.Context, task UntypedTask, next func(context.Context) (any, error)) (any, error)

type LocalRunner

+ func (r *LocalRunner) AddInterceptor(interceptor Interceptor)

+ func (r *LocalRunner) Tasks() []UntypedTask

type TaskRunner

+ AddInterceptor func(interceptor Interceptor)

+ Tasks func() []UntypedTask

Nov 17, 2025

Changes in this version

+ const KHISystemPrefix

+ const LocalRunnerTaskStatPhaseRunning

+ const LocalRunnerTaskStatPhaseStopped

+ const LocalRunnerTaskStatPhaseWaiting

+ var DefaultTaskGraphResolver = NewGraphResolver(100, &RequiredTaskLabelGraphResolverRule{}, &TaskDependencyGraphResolverRule{}, ...)

+ var LabelKeyRequiredTask = NewTaskLabelKey[bool](KHISystemPrefix + "required-task")

+ var LabelKeySubsequentTaskRefs = NewTaskLabelKey[[]taskid.UntypedTaskReference](KHISystemPrefix + "subsquent-task-refs")

+ var LabelKeyTaskSelectionPriority = NewTaskLabelKey[int](KHISystemPrefix + "task-selection-priority")

+ func GetTaskResultFromLocalRunner[TaskResult any](runner *LocalRunner, taskRef taskid.TaskReference[TaskResult]) (TaskResult, bool)

+ func GetTaskResultOptional[T any](ctx context.Context, reference taskid.TaskReference[T]) (T, bool)

+ func GetTaskResult[T any](ctx context.Context, reference taskid.TaskReference[T]) T

+ func HasDependency(taskSet *TaskSet, dependencyFrom UntypedTask, dependencyTo UntypedTask) (bool, error)

+ func NewEqualFilter[T comparable](labelKey TaskLabelKey[T], value T, includeUndefined bool) filter.TypedMapFilter[T]

+ func NewLabelSet(labelOpts ...LabelOpt) *typedmap.ReadonlyTypedMap

+ func NewRequiredTaskLabel() *requiredTaskLabelImpl

+ func RegisterTasks(registry TaskRegistry, tasks ...UntypedTask) error

+ func WrapErrorWithTaskInformation(ctx context.Context, err error) error

+ type GraphResolver struct

+ MaxIteration int

+ Rules []GraphResolverRule

+ func NewGraphResolver(maxIteration int, rules ...GraphResolverRule) *GraphResolver

+ func (r *GraphResolver) Resolve(requiredTasks []UntypedTask, availableTasks []UntypedTask) ([]UntypedTask, error)

+ type GraphResolverRule interface

+ Name func() string

+ Resolve func(currentGraphTasks []UntypedTask, availableTasks []UntypedTask) (GraphResolverRuleResult, error)

+ type GraphResolverRuleResult struct

+ Changed bool

+ Tasks []UntypedTask

+ type LabelOpt interface

+ Write func(labels *typedmap.TypedMap)

+ func FromLabels(labels *typedmap.ReadonlyTypedMap) []LabelOpt

+ func NewSubsequentTaskRefsTaskLabel(refs ...taskid.UntypedTaskReference) LabelOpt

+ func WithLabelValue[T any](labelKey TaskLabelKey[T], value T) LabelOpt

+ func WithSelectionPriority(priority int) LabelOpt

+ type LabelPredicate = func(v T) bool

+ type LocalRunner struct

+ func NewLocalRunner(taskSet *TaskSet) (*LocalRunner, error)

+ func (r *LocalRunner) Result() (*typedmap.ReadonlyTypedMap, error)

+ func (r *LocalRunner) Run(ctx context.Context) error

+ func (r *LocalRunner) TaskStatuses() []*LocalRunnerTaskStat

+ func (r *LocalRunner) Wait() <-chan interface{}

+ type LocalRunnerTaskStat struct

+ EndTime time.Time

+ Error error

+ Phase string

+ StartTime time.Time

+ type RequiredTaskLabelGraphResolverRule struct

+ func (r *RequiredTaskLabelGraphResolverRule) Name() string

+ func (r *RequiredTaskLabelGraphResolverRule) Resolve(currentGraphTasks []UntypedTask, availableTasks []UntypedTask) (GraphResolverRuleResult, error)

+ type SubsequentTaskRefsGraphResolverRule struct

+ func (s *SubsequentTaskRefsGraphResolverRule) Name() string

+ func (s *SubsequentTaskRefsGraphResolverRule) Resolve(currentGraphTasks []UntypedTask, availableTasks []UntypedTask) (GraphResolverRuleResult, error)

+ type Task interface

+ ID func() taskid.TaskImplementationID[TaskResult]

+ Run func(ctx context.Context) (TaskResult, error)

+ type TaskDependencyGraphResolverRule struct

+ func (d *TaskDependencyGraphResolverRule) Name() string

+ func (d *TaskDependencyGraphResolverRule) Resolve(currentGraphTasks []UntypedTask, availableTasks []UntypedTask) (GraphResolverRuleResult, error)

+ type TaskImpl struct

+ func NewTask[TaskResult any](taskId taskid.TaskImplementationID[TaskResult], ...) *TaskImpl[TaskResult]

+ func (c *TaskImpl[TaskResult]) Dependencies() []taskid.UntypedTaskReference

+ func (c *TaskImpl[TaskResult]) ID() taskid.TaskImplementationID[TaskResult]

+ func (c *TaskImpl[TaskResult]) Labels() *typedmap.ReadonlyTypedMap

+ func (c *TaskImpl[TaskResult]) Run(ctx context.Context) (TaskResult, error)

+ func (c *TaskImpl[TaskResult]) UntypedID() taskid.UntypedTaskImplementationID

+ func (c *TaskImpl[TaskResult]) UntypedRun(ctx context.Context) (any, error)

+ type TaskLabelKey = typedmap.TypedKey[LabelValueType]

+ func NewTaskLabelKey[T any](key string) TaskLabelKey[T]

+ type TaskRegistry interface

+ AddTask func(task UntypedTask) error

+ type TaskRunner interface

+ Result func() (*typedmap.ReadonlyTypedMap, error)

+ Run func(ctx context.Context) error

+ Wait func() <-chan interface{}

+ type TaskSet struct

+ func NewTaskSet(tasks []UntypedTask) (*TaskSet, error)

+ func Subset[T any](taskSet *TaskSet, mapFilter filter.TypedMapFilter[T]) *TaskSet

+ func (s *TaskSet) Add(newTask UntypedTask) error

+ func (s *TaskSet) DumpGraphviz() (string, error)

+ func (s *TaskSet) Get(id string) (UntypedTask, error)

+ func (s *TaskSet) GetAll() []UntypedTask

+ func (s *TaskSet) Remove(id string) error

+ func (s *TaskSet) ToRunnableTaskSet() (*TaskSet, error)

+ type UntypedTask interface

+ Dependencies func() []taskid.UntypedTaskReference

+ Labels func() *typedmap.ReadonlyTypedMap

+ UntypedID func() taskid.UntypedTaskImplementationID

+ UntypedRun func(ctx context.Context) (any, error)