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-10 01:36:23 -0700
commit7db6666b9784d48f3ac7ef621714d114ff05d537 (patch)
tree5cf4e705d21a650d9bbd1391a9b56f7d5330f3a1 /weed/mq/topic.go
parent08f2dcc532551b8def152ebd3ae781711be11933 (diff)
downloadseaweedfs-7db6666b9784d48f3ac7ef621714d114ff05d537.tar.xz
seaweedfs-7db6666b9784d48f3ac7ef621714d114ff05d537.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
+}