定义缓存和队列接口

2026-09-20 17:57:54 +00:00 · 2020-08-05 23:30:05 +08:00
parent 18a2aeadaa
commit b9d30eee88
1 changed files with 4 additions and 4 deletions
@@ -17,8 +17,8 @@ type Adapter interface {
 	GetQueue(name string, f func(message Message) error)
 }

-type Message struct {
-	ID     string
-	Stream string
-	Values map[string]interface{}
+type Message interface {
+	SetID(string)
+	SetStream(string)
+	SetValue(map[string]interface{})
 }