Function TestFactoryOut_ProvideRunGroup

otredis/integration_test.go:18–71

(t *testing.T)

)

func TestFactoryOut_ProvideRunGroup(t *testing.T) {
	if os.Getenv("REDIS_ADDR") == "" {
		t.Skip("set REDIS_ADDR to run TestModule_ProvideRunGroup")
		return
	}
	addrs := strings.Split(os.Getenv("REDIS_ADDR"), ",")
	t.Parallel()

	ctrl := gomock.NewController(t)
	defer ctrl.Finish()

	called := false

	withValues := []interface{}{
		gomock.Eq("dbname"),
		gomock.Eq("default"),
	}

	m := mock_metrics.NewMockGauge(ctrl)
	m.EXPECT().With(withValues...).Return(m).MinTimes(1)
	m.EXPECT().Set(gomock.Any()).MinTimes(1)

	c := core.New(
		core.WithInline("redis.default.addrs", addrs),
		core.WithInline("redisMetrics.interval", "1ms"),
		core.WithInline("log.level", "none"),
	)
	c.ProvideEssentials()
	c.Provide(di.Deps{func() *Gauges {
		return &Gauges{
			Hits:       m,
			Misses:     m,
			Timeouts:   m,
			TotalConns: m,
			IdleConns:  m,
			StaleConns: m,
		}
	}})
	c.Provide(Providers(WithConfigInterceptor(func(name string, opts *redis.UniversalOptions) {
		called = true
	}), WithReload(true)))

	ctx, cancel := context.WithCancel(context.Background())

	c.Invoke(func(cli redis.UniversalClient) {
		cli.ClientID(ctx)
	})

	go c.Serve(ctx)
	<-time.After(10 * time.Millisecond)
	cancel()
	<-time.After(1000 * time.Millisecond)
	assert.True(t, called)
}