Function TestLifecyclerConfig_Validate

ring/lifecycler_test.go:89–113

(t *testing.T)

}

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

	ringStore, closer := consul.NewInMemoryClient(GetCodec(), log.NewNopLogger(), nil)
	t.Cleanup(func() { assert.NoError(t, closer.Close()) })

	var ringConfig Config
	flagext.DefaultValues(&ringConfig)
	ringConfig.KVStore.Mock = ringStore

	pathToTokens := "/path/to/tokens"
	cfg := testLifecyclerConfig(ringConfig, "instance-1")
	cfg.TokensFilePath = pathToTokens

	err := cfg.Validate()
	require.NoError(t, err)
	require.Equal(t, pathToTokens, cfg.TokensFilePath)

	spreadMinimizingTokenGenerator, err := NewSpreadMinimizingTokenGenerator(cfg.ID, cfg.Zone, []string{zone(1), zone(2), zone(3)}, true)
	require.NoError(t, err)

	cfg.RingTokenGenerator = spreadMinimizingTokenGenerator
	err = cfg.Validate()
	require.Error(t, err)
}

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