Function TestWork

worker_test.go:16–58

(t *testing.T)

)

func TestWork(t *testing.T) {
	t.Parallel()

	workers := NewWorkers()

	AddWorker(workers, &noOpWorker{})
	require.Contains(t, workers.workersMap, (noOpArgs{}).Kind())

	require.PanicsWithError(t, `worker for kind "noOp" is already registered`, func() {
		AddWorker(workers, &noOpWorker{})
	})

	type JobArgs struct {
		testutil.JobArgsReflectKind[JobArgs]
	}

	AddWorker(workers, WorkFunc(func(ctx context.Context, job *Job[JobArgs]) error {
		return nil
	}))
	require.Contains(t, workers.workersMap, (JobArgs{}).Kind())

	AddWorker(workers, WorkFunc(func(ctx context.Context, job *Job[withKindAliasesArgs]) error {
		return nil
	}))
	require.Contains(t, workers.workersMap, (withKindAliasesArgs{}).Kind())
	require.Contains(t, workers.workersMap, (withKindAliasesArgs{}).KindAliases()[0])

	require.PanicsWithError(t, `worker for kind "with_kind_alternate_alternate" is already registered`, func() {
		AddWorker(workers, WorkFunc(func(ctx context.Context, job *Job[withKindAliasesCollisionArgs]) error {
			return nil
		}))
	})

	type OtherJobArgs struct {
		testutil.JobArgsReflectKind[OtherJobArgs]
	}

	var jobArgs OtherJobArgs
	AddWorkerArgs(workers, jobArgs, WorkFunc(func(ctx context.Context, job *Job[OtherJobArgs]) error {
		return nil
	}))
	require.Contains(t, workers.workersMap, (OtherJobArgs{}).Kind())
}

type configurableArgs struct {
	uniqueOpts UniqueOpts