topicService

Documentation

Index

• type TopicService
  • func Default() *TopicService
  • func NewTopicService() *TopicService
  • func (service *TopicService) CreateTopic(t *models.CreateTopic) error
  • func (service *TopicService) DeleteTopic(topic, clusterName string) error
  • func (service *TopicService) FindClusterByTopic(topic string) (string, bool, error)
  • func (service *TopicService) GetAllList() (topicVos []*models.TopicVo, err error)
  • func (service *TopicService) GetTopicByParam(topicType int, prefix string, srcTopics []*models.TopicVo) (destTopics []*models.TopicVo)
  • func (service *TopicService) GetTopicList(clusterName, topicPrefix string, extra bool, topicType, limit, offset int) ([]*models.TopicVo, int64, error)
  • func (service *TopicService) GetTopicStats(topic string, limit, offset int) ([]*models.TopicStats, int64, error)
  • func (service *TopicService) QueryTopicRoute(topic, clusterName string) (*route.TopicRouteData, error)
  • func (service *TopicService) UpdateTopicConfig(topicVo *models.UpdateTopic) error

Types

type TopicService

type TopicService struct {
	*modules.AbstractService
}

TopicService topic管理器 Author: tianyuliang Since: 2017/11/7

func Default

func Default() *TopicService

Default 返回默认唯一处理对象 Author: tianyuliang Since: 2017/11/7

func NewTopicService

func NewTopicService() *TopicService

NewTopicService 初始化 Author: tianyuliang Since: 2017/11/7

func (*TopicService) CreateTopic

func (service *TopicService) CreateTopic(t *models.CreateTopic) error

CreateTopic 创建Topic Author: tianyuliang Since: 2017/11/6

func (*TopicService) DeleteTopic

func (service *TopicService) DeleteTopic(topic, clusterName string) error

DeleteTopicFromCluster 删除指定集群对应broker所属的topic Author: tianyuliang Since: 2017/11/6

func (*TopicService) FindClusterByTopic

func (service *TopicService) FindClusterByTopic(topic string) (string, bool, error)

FindClusterByTopic 查询Topic归属的集群名称 Author: tianyuliang Since: 2017/11/9

func (*TopicService) GetAllList

func (service *TopicService) GetAllList() (topicVos []*models.TopicVo, err error)

List 查询所有Topic列表(不区分topic类型) Author: tianyuliang Since: 2017/11/6

func (*TopicService) GetTopicByParam

func (service *TopicService) GetTopicByParam(topicType int, prefix string, srcTopics []*models.TopicVo) (destTopics []*models.TopicVo)

GetTopicByType 查询指定类型的topic Author: tianyuliang Since: 2017/11/8

func (*TopicService) GetTopicList

func (service *TopicService) GetTopicList(clusterName, topicPrefix string, extra bool, topicType, limit, offset int) ([]*models.TopicVo, int64, error)

GetTopicList 根据Topic类型，获取所有Topic Author: tianyuliang Since: 2017/11/6

func (*TopicService) GetTopicStats

func (service *TopicService) GetTopicStats(topic string, limit, offset int) ([]*models.TopicStats, int64, error)

Stats 分页查询Topic状态 Author: tianyuliang Since: 2017/11/6

func (*TopicService) QueryTopicRoute

func (service *TopicService) QueryTopicRoute(topic, clusterName string) (*route.TopicRouteData, error)

QueryTopicRoute 查询topic路由信息 Author: tianyuliang Since: 2017/11/6

func (*TopicService) UpdateTopicConfig

func (service *TopicService) UpdateTopicConfig(topicVo *models.UpdateTopic) error

UpdateTopicConfig 更新Topic配置信息 Author: tianyuliang Since: 2017/11/6