errors.go

package dagtask

import (
	"errors"
	"fmt"
)

var (
	ErrCycle              = errors.New("dagtask: dependency cycle detected")
	ErrDuplicateKey       = errors.New("dagtask: duplicate task key")
	ErrUnknownDependency  = errors.New("dagtask: unknown dependency")
	ErrAlreadyExecuted    = errors.New("dagtask: dag already executed")
	ErrEmptyKey           = errors.New("dagtask: empty task key")
	ErrNilRun             = errors.New("dagtask: nil task run function")
)

type cycleError struct {
	path []string
}

func (e *cycleError) Error() string {
	return fmt.Sprintf("dagtask: dependency cycle detected: %v", e.path)
}

func (e *cycleError) Unwrap() error {
	return ErrCycle
}

type duplicateKeyError struct {
	key string
}

func (e *duplicateKeyError) Error() string {
	return fmt.Sprintf("dagtask: duplicate task key %q", e.key)
}

func (e *duplicateKeyError) Unwrap() error {
	return ErrDuplicateKey
}

type unknownDependencyError struct {
	task string
	dep  string
}

func (e *unknownDependencyError) Error() string {
	return fmt.Sprintf("dagtask: task %q depends on unknown key %q", e.task, e.dep)
}

func (e *unknownDependencyError) Unwrap() error {
	return ErrUnknownDependency
}

type PanicError struct {
	Key string
	Val any
}

func (e *PanicError) Error() string {
	return fmt.Sprintf("dagtask: task %q panicked: %v", e.Key, e.Val)
}