1 files changed, 12 insertions, 0 deletions
diff --git a/weed/mq/broker.go b/weed/mq/broker.go
new file mode 100644
index 000000000..8debcec0b
--- /dev/null
+++ b/weed/mq/broker.go
@@ -0,0 +1,12 @@
+package mq
+
+const LAST_MINUTES = 10
+
+type TopicStat struct {
+	MessageCounts [LAST_MINUTES]int64
+	ByteCounts    [LAST_MINUTES]int64
+}
+
+func NewTopicStat() *TopicStat {
+	return &TopicStat{}
+}