added job to discard errors

src/job/base.go

@@ -107,6 +107,8 @@ func Get(t string) Job {
 		return checkJob
 	case "loop":
 		return loopJob
+	case "discard-error":
+		return discardErrorJob
 	case "encrypted":
 		return encryptedJob
 	default:

src/job/utils.go

@@ -81,6 +81,34 @@ func checkJob(ctx context.Context, logger *zap.Logger, _ *GlobalConfig, args con
 	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
+) {
+	var jobConfig struct {
+		BasicJobConfig
+
+		Job config.Config
+	}
+
+	if err := ParseConfig(&jobConfig, args, *globalConfig); err != nil {
+		return nil, fmt.Errorf("error parsing job config: %w", err)
+	}
+
+	job := Get(jobConfig.Job.Type)
+	if job == nil {
+		logger.Debug("unknown job, discarding", zap.String("job", jobConfig.Job.Type))
+
+		return nil, nil
+	}
+
+	data, err = job(ctx, logger, globalConfig, jobConfig.Job.Args)
+	if err != nil {
+		logger.Debug("discarded error", zap.Error(err))
+	}
+
+	return data, nil
+}
+
 func loopJob(ctx context.Context, logger *zap.Logger, globalConfig *GlobalConfig, args config.Args) (data any, err error) {
 	ctx, cancel := context.WithCancel(ctx)
 	defer cancel()