update cache file name base on appid and cluster

agollo_test.go

@@ -43,9 +43,9 @@ func TestAgolloStart(t *testing.T) {
 		t.Errorf("Start with app.properties should return nil, got :%v", err)
 	}
 	defer Stop()
-	defer os.Remove(defaultDumpFile)
+	defer os.Remove(defaultClient.getDumpFileName())
 
-	if err := defaultClient.loadLocal(defaultDumpFile); err != nil {
+	if err := defaultClient.loadLocal(defaultClient.getDumpFileName()); err != nil {
 		t.Errorf("loadLocal should return nil, got: %v", err)
 	}
 

client.go

@@ -3,6 +3,7 @@ package agollo
 import (
 	"context"
 	"encoding/json"
+	"fmt"
 	"net/http"
 )
 
@@ -83,7 +84,7 @@ func (c *Client) Stop() error {
 // fetchAllCinfig fetch from remote, if failed load from local file
 func (c *Client) preload() error {
 	if err := c.longPoller.preload(); err != nil {
-		return c.loadLocal(defaultDumpFile)
+		return c.loadLocal(c.getDumpFileName())
 	}
 	return nil
 }
@@ -188,7 +189,7 @@ func (c *Client) handleResult(result *result) *ChangeEvent {
 	c.setReleaseKey(result.NamespaceName, result.ReleaseKey)
 
 	// dump caches to file
-	c.dump(defaultDumpFile)
+	c.dump(c.getDumpFileName())
 
 	if len(ret.Changes) == 0 {
 		return nil
@@ -197,6 +198,10 @@ func (c *Client) handleResult(result *result) *ChangeEvent {
 	return &ret
 }
 
+func (c *Client) getDumpFileName() string {
+	return fmt.Sprintf(".%s_%s", c.conf.AppID, c.conf.Cluster)
+}
+
 func (c *Client) getReleaseKey(namespace string) string {
 	releaseKey, _ := c.releaseKeyRepo.get(namespace)
 	return releaseKey