weed/mq/topic/topic_partition.go


1
2
3
4
5
6
7
8
9
10
11
12
13
14

package topic

import "fmt"

type TopicPartition struct {
	Namespace  string
	Topic      string
	RangeStart int32
	RangeStop  int32
}

func (tp *TopicPartition) String() string {
	return fmt.Sprintf("%v.%v-%04d-%04d", tp.Namespace, tp.Topic, tp.RangeStart, tp.RangeStop)
}