Function TestClusterClient_RoutingTable_Cluster

cluster_client_test.go:84–102

(t *testing.T)

}

func TestClusterClient_RoutingTable_Cluster(t *testing.T) {
	cluster := newTestOlricCluster(t)
	cluster.addMember(t) // Cluster coordinator
	<-time.After(250 * time.Millisecond)

	db := cluster.addMember(t)

	ctx := context.Background()
	c, err := NewClusterClient([]string{db.name})
	require.NoError(t, err)
	defer func() {
		require.NoError(t, c.Close(ctx))
	}()

	rt, err := c.RoutingTable(ctx)
	require.NoError(t, err)

	require.Len(t, rt, int(db.config.PartitionCount))
}

func TestClusterClient_Put(t *testing.T) {
	cluster := newTestOlricCluster(t)