aboutsummaryrefslogtreecommitdiff
path: root/weed/mq/topic.go
diff options
context:
space:
mode:
authorchrislu <chris.lu@gmail.com>2022-07-10 01:36:23 -0700
committerchrislu <chris.lu@gmail.com>2022-07-28 23:24:38 -0700
commit8060fdcac56bae36b53764d7ad23a142a865e67d (patch)
tree319d671fa6628fcde7003f18293f8088ae90d187 /weed/mq/topic.go
parentf25e273e328a9959f4dcef13c5f78e427c0bf7a0 (diff)
downloadseaweedfs-8060fdcac56bae36b53764d7ad23a142a865e67d.tar.xz
seaweedfs-8060fdcac56bae36b53764d7ad23a142a865e67d.zip
remove old code
Diffstat (limited to 'weed/mq/topic.go')
-rw-r--r--weed/mq/topic.go23
1 files changed, 23 insertions, 0 deletions
diff --git a/weed/mq/topic.go b/weed/mq/topic.go
new file mode 100644
index 000000000..fc1923af1
--- /dev/null
+++ b/weed/mq/topic.go
@@ -0,0 +1,23 @@
+package mq
+
+import "time"
+
+type Namespace string
+
+type Topic struct {
+ namespace Namespace
+ name string
+}
+
+type Partition struct {
+ rangeStart int
+ rangeStop int // exclusive
+ ringSize int
+}
+
+type Segment struct {
+ topic Topic
+ id int32
+ partition Partition
+ lastModified time.Time
+}