Function TestJobOption

cron/options_test.go:31–241

(t *testing.T)

}

func TestJobOption(t *testing.T) {
	t.Parallel()
	var buf bytes.Buffer
	logger := log.NewSyncLogger(log.NewLogfmtLogger(&buf))
	hist := stub.Histogram{}
	count := stub.Counter{}
	metric := NewCronJobMetrics(&hist, &count)
	tracer := mocktracer.MockTracer{}
	entryCount := 0
	concurrentCount := 0
	var concurrentAccess bool

	for _, ca := range []struct {
		name    string
		stacks  []JobOption
		job     func(context.Context) error
		asserts func(t *testing.T)
	}{
		{
			"name and logging",
			[]JobOption{
				WithName("test"),
				WithLogging(logger),
			},
			func(ctx context.Context) error {
				return nil
			},
			func(t *testing.T) {
				t.Log(buf.String())
				if buf.String() == "" {
					t.Error("Expected logging output")
				}
				if strings.Contains(buf.String(), "test") == false {
					t.Error("Expected test to be in the log output")
				}
				buf = bytes.Buffer{}
			},
		},
		{
			"error and logging",
			[]JobOption{
				WithLogging(logger),
			},
			func(ctx context.Context) error {
				return errors.New("test")
			},
			func(t *testing.T) {
				t.Log(buf.String())
				if buf.String() == "" {
					t.Error("Expected logging output")
				}
				if strings.Contains(buf.String(), "error") == false {
					t.Error("Expected error to be in the log output")
				}
				buf = bytes.Buffer{}
			},
		},
		{