Function TestDynamicConfiguration

internal/patroni/config_test.go:219–540

(t *testing.T)

}

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

	parameters := func(in map[string]string) *postgres.ParameterSet {
		out := postgres.NewParameterSet()
		for k, v := range in {
			out.Add(k, v)
		}
		return out
	}

	rules := func(in ...string) *postgres.OrderedHBAs {
		out := new(postgres.OrderedHBAs)
		out.AppendUnstructured(in...)
		return out
	}

	for _, tt := range []struct {
		name     string
		spec     string
		hbas     *postgres.OrderedHBAs
		params   *postgres.ParameterSet
		expected map[string]any
	}{
		{
			name: "empty is valid",
			expected: map[string]any{
				"loop_wait": int32(10),
				"ttl":       int32(30),
				"postgresql": map[string]any{
					"use_pg_rewind": true,
					"use_slots":     false,
				},
			},
		},
		{
			name: "top-level passes through",
			spec: `{
				patroni: {
					dynamicConfiguration: {
						retry_timeout: 5,
					},
				},
			}`,
			expected: map[string]any{
				"loop_wait":     int32(10),
				"ttl":           int32(30),
				"retry_timeout": int64(5),
				"postgresql": map[string]any{
					"use_pg_rewind": true,
					"use_slots":     false,
				},
			},
		},
		{
			name: "top-level: spec overrides input",
			spec: `{
				patroni: {