add simple timeout job

src/job/base.go

@@ -105,6 +105,8 @@ func Get(t string) Job {
 		return setVarJob
 	case "check":
 		return checkJob
+	case "timeout":
+		return timeoutJob
 	case "loop":
 		return loopJob
 	case "discard-error":

src/job/utils.go

@@ -26,6 +26,7 @@ import (
 	"context"
 	"encoding/base64"
 	"fmt"
+	"time"
 
 	"github.com/mitchellh/mapstructure"
 	"go.uber.org/zap"
@@ -81,6 +82,20 @@ func checkJob(ctx context.Context, logger *zap.Logger, _ *GlobalConfig, args con
 	return nil, nil
 }
 
+func timeoutJob(ctx context.Context, logger *zap.Logger, _ *GlobalConfig, args config.Args) (data any, err error) {
+	var jobConfig struct {
+		Value time.Duration
+	}
+
+	if err := utils.Decode(args, &jobConfig); err != nil {
+		return nil, fmt.Errorf("error parsing job config: %w", err)
+	}
+
+	time.Sleep(jobConfig.Value)
+
+	return nil, nil
+}
+
 func discardErrorJob(ctx context.Context, logger *zap.Logger, globalConfig *GlobalConfig, args config.Args) (
 	data any, err error, //nolint:unparam // data is here to match Job
 ) {