[cache]批量刷新缓存时，会将此动作同步到集群

Author: iwind

teacluster/action_fail.go

@@ -11,5 +11,5 @@ func (this *FailAction) Name() string {
 }
 
 func (this *FailAction) TypeId() int8 {
-	return 2
+	return ActionCodeFail
 }

teacluster/action_notify.go

@@ -10,7 +10,7 @@ func (this *NotifyAction) Name() string {
 }
 
 func (this *NotifyAction) TypeId() int8 {
-	return 4
+	return ActionCodeNotify
 }
 
 func (this *NotifyAction) Execute() error {

teacluster/action_ping.go

@@ -12,5 +12,5 @@ func (this *PingAction) Name() string {
 }
 
 func (this *PingAction) TypeId() int8 {
-	return 7
+	return ActionCodePing
 }

teacluster/action_pull.go

@@ -20,5 +20,5 @@ func (this *PullAction) Execute() error {
 }
 
 func (this *PullAction) TypeId() int8 {
-	return 6
+	return ActionCodePull
 }

teacluster/action_push.go

@@ -44,5 +44,5 @@ func (this *PushAction) OnFail(fail *FailAction) error {
 }
 
 func (this *PushAction) TypeId() int8 {
-	return 5
+	return ActionCodePush
 }

teacluster/action_register.go

@@ -40,5 +40,5 @@ func (this *RegisterAction) OnFail(fail *FailAction) error {
 }
 
 func (this *RegisterAction) TypeId() int8 {
-	return 3
+	return ActionCodeRegister
 }

teacluster/action_run.go

@@ -0,0 +1,57 @@
+package teacluster
+
+import (
+	"github.com/TeaWeb/code/teacache"
+	"github.com/TeaWeb/code/teaconfigs/shared"
+	"github.com/iwind/TeaGo/logs"
+	"github.com/iwind/TeaGo/maps"
+	"github.com/iwind/TeaGo/types"
+)
+
+type RunAction struct {
+	Action
+
+	Cmd  string
+	Data maps.Map
+}
+
+func (this *RunAction) Name() string {
+	return "run"
+}
+
+func (this *RunAction) Execute() error {
+	switch this.Cmd {
+	case "cache.refresh":
+		this.runCacheRefresh()
+	}
+	return nil
+}
+
+func (this *RunAction) TypeId() int8 {
+	return ActionCodeRun
+}
+
+// clean cache with prefixes
+func (this *RunAction) runCacheRefresh() {
+	filename := this.Data.GetString("filename")
+	policy := shared.NewCachePolicyFromFile(filename)
+	if policy == nil {
+		logs.Println("[cluster][cache.refresh]can not find policy with '" + filename + "'")
+		return
+	}
+
+	manager := teacache.FindCachePolicyManager(filename)
+	if manager == nil {
+		manager = teacache.NewManagerFromConfig(policy)
+	}
+	prefixes := this.Data.GetSlice("prefixes")
+	prefixStrings := []string{}
+	for _, prefix := range prefixes {
+		prefixStrings = append(prefixStrings, types.String(prefix))
+	}
+	_, err := manager.DeletePrefixes(prefixStrings)
+	if err != nil {
+		logs.Println("[cluster][cache.refresh]delete prefixes")
+		return
+	}
+}

teacluster/action_success.go

@@ -14,5 +14,5 @@ func (this *SuccessAction) Name() string {
 }
 
 func (this *SuccessAction) TypeId() int8 {
-	return 1
+	return ActionCodeSuccess
 }

teacluster/action_sum.go

@@ -63,5 +63,5 @@ func (this *SumAction) OnFail(fail *FailAction) error {
 }
 
 func (this *SumAction) TypeId() int8 {
-	return 9
+	return ActionCodeSum
 }

teacluster/action_sync.go

@@ -66,5 +66,5 @@ func (this *SyncAction) Execute() error {
 }
 
 func (this *SyncAction) TypeId() int8 {
-	return 8
+	return ActionCodeSync
 }