Function TestNewRedisFactory

otredis/dependency_test.go:17–47

(t *testing.T)

)

func TestNewRedisFactory(t *testing.T) {
	for _, c := range []struct {
		name   string
		reload bool
	}{
		{"reload", true},
		{"not reload", false},
	} {
		t.Run(c.name, func(t *testing.T) {
			dispatcher := &events.SyncDispatcher{}
			redisOut, cleanup := provideRedisFactory(&providersOption{reloadable: c.reload})(factoryIn{
				Conf: config.MapAdapter{"redis": map[string]RedisUniversalOptions{
					"default":     {},
					"alternative": {},
				}},
				Logger:     log.NewNopLogger(),
				Tracer:     nil,
				Dispatcher: dispatcher,
			})
			def, err := redisOut.Factory.Make("default")
			assert.NoError(t, err)
			assert.NotNil(t, def)
			alt, err := redisOut.Factory.Make("alternative")
			assert.NoError(t, err)
			assert.NotNil(t, alt)
			assert.NotNil(t, cleanup)
			assert.Equal(t, c.reload, dispatcher.ListenerCount(events.OnReload) == 1)
			cleanup()
		})
	}
}

func TestProvideConfigs(t *testing.T) {
	var r redis.UniversalOptions