Function TestDelete

kv/memberlist/memberlist_client_test.go:700–749

(t *testing.T)

}

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

	c := dataCodec{}

	reg := prometheus.NewRegistry()

	var cfg KVConfig
	flagext.DefaultValues(&cfg)
	cfg.TCPTransport = TCPTransportConfig{
		BindAddrs: getLocalhostAddrs(),
		BindPort:  0, // randomize ports
	}
	cfg.GossipNodes = 1
	cfg.GossipInterval = 100 * time.Millisecond
	cfg.ObsoleteEntriesTimeout = 500 * time.Millisecond
	cfg.ClusterLabelVerificationDisabled = true
	cfg.Codecs = []codec.Codec{c}

	mkv := NewKV(cfg, log.NewNopLogger(), &staticDNSProviderMock{}, reg)
	require.NoError(t, services.StartAndAwaitRunning(context.Background(), mkv))
	defer services.StopAndAwaitTerminated(context.Background(), mkv) //nolint:errcheck

	kv, err := NewClient(mkv, c)
	require.NoError(t, err)

	const key = "test"

	val := get(t, kv, key)
	if val != nil {
		t.Error("Expected nil, got:", val)
	}

	err = cas(kv, key, updateFn("test"))
	require.NoError(t, err)

	err = kv.Delete(context.Background(), key)
	if err != nil {
		t.Fatalf("Failed to delete key %s: %v", key, err)
	}

	checkMemberlistEntry(t, kv, key, 2*time.Second)

	// Validate that there are no encoding errors during the Delete flow.
	assert.NoError(t, testutil.GatherAndCompare(reg, strings.NewReader(`
			# HELP memberlist_client_messages_to_broadcast_dropped_total Number of broadcast messages intended to be sent but were dropped due to encoding errors or for being too big
			# TYPE memberlist_client_messages_to_broadcast_dropped_total counter
			memberlist_client_messages_to_broadcast_dropped_total 0
	`), "memberlist_client_messages_to_broadcast_dropped_total"))
}

func TestDeleteMultipleClients(t *testing.T) {