sparrow/pkg/queue/topic_partition_info.go

package queue

import (
	"fmt"
	"sparrow/pkg/utils"
)

type TopicPartitionInfo struct {
	Topic       string
	TenantId    string
	Partition   int
	MyPartition bool
}

func (a *TopicPartitionInfo) String() string {
	return fmt.Sprintf("%s", a.Topic)
}

func (a *TopicPartitionInfo) HashCode() string {
	return utils.Md5(a.String())
}

// ResolvePartition 生成info
func ResolvePartition(serviceType, queueName, tenantId, entityId string) *TopicPartitionInfo {
	// TODO:生成主题逻辑
	return &TopicPartitionInfo{
		Topic: queueName,
		TenantId: tenantId,
		MyPartition: true,
	}
}