Function TestInitTaskGroup

pkg/redis/redis_test.go:33–78

(t *testing.T)

)

func TestInitTaskGroup(t *testing.T) {
	for _, tc := range []struct {
		Name           string
		Populate       func(context.Context, *Client) bool
		Group, Key     string
		ErrorAssertion func(*testing.T, error) bool
	}{
		{
			Name:           "no streams/no groups",
			Populate:       func(ctx context.Context, cl *Client) bool { return true },
			Group:          "testGroup",
			Key:            "testKey",
			ErrorAssertion: func(t *testing.T, err error) bool { return assertions.New(t).So(err, should.BeNil) },
		},
		{
			Name: "streams exist/groups exist",
			Populate: func(ctx context.Context, cl *Client) bool {
				_, a := test.MustNewTFromContext(ctx)
				_, err := cl.XGroupCreateMkStream(ctx, InputTaskKey(cl.Key("testKey")), cl.Key("testGroup"), "0").Result()
				if !a.So(err, should.BeNil) {
					return false
				}
				_, err = cl.XGroupCreateMkStream(ctx, ReadyTaskKey(cl.Key("testKey")), cl.Key("testGroup"), "0").Result()
				return a.So(err, should.BeNil)
			},
			Group:          "testGroup",
			Key:            "testKey",
			ErrorAssertion: func(t *testing.T, err error) bool { return assertions.New(t).So(err, should.BeNil) },
		},
	} {
		test.RunSubtest(t, test.SubtestConfig{
			Name:     tc.Name,
			Parallel: true,
			Func: func(ctx context.Context, t *testing.T, a *assertions.Assertion) {
				cl, flush := test.NewRedis(ctx, "redis_test")
				defer flush()
				defer cl.Close()

				a.So(tc.Populate(ctx, cl), should.BeTrue)

				err := InitTaskGroup(ctx, cl, cl.Key(tc.Group), cl.Key(tc.Key))
				a.So(tc.ErrorAssertion(t, err), should.BeTrue)
			},
		})
	}
}

func TestAddTask(t *testing.T) {
	a, ctx := test.New(t)