connectionService

Documentation

Index

• type ConnectionService
  • func Default() *ConnectionService
  • func NewConnectionService() *ConnectionService
  • func (service *ConnectionService) ConnectionDetail(clusterName, searchTopic string) (*models.ConnectionDetail, error)
  • func (service *ConnectionService) ConnectionOnline(searchTopic string, limit, offset int) ([]*models.ConnectionOnline, int64, error)
  • func (service *ConnectionService) SumOnlineConsumerNums(topic string) (set.Set, int, error)

Types

type ConnectionService

type ConnectionService struct {
	*modules.AbstractService
	TopicServ *topicService.TopicService
	GroupServ *groupGervice.GroupService
}

ConnectionService 在线进程Connection管理器 Author: tianyuliang Since: 2017/11/7

func Default

func Default() *ConnectionService

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

func NewConnectionService

func NewConnectionService() *ConnectionService

NewConnectionService 初始化Topic查询服务 Author: tianyuliang Since: 2017/11/7

func (*ConnectionService) ConnectionDetail

func (service *ConnectionService) ConnectionDetail(clusterName, searchTopic string) (*models.ConnectionDetail, error)

ConnectionDetail 查询在线消费进程、在线生产进程的详情 Author: tianyuliang Since: 2017/11/10

func (*ConnectionService) ConnectionOnline

func (service *ConnectionService) ConnectionOnline(searchTopic string, limit, offset int) ([]*models.ConnectionOnline, int64, error)

ConnectionOnline Author: tianyuliang Since: 2017/11/10

func (*ConnectionService) SumOnlineConsumerNums

func (service *ConnectionService) SumOnlineConsumerNums(topic string) (set.Set, int, error)

SumOnlineConsumerNums 统计topic对应的在线生产进程数 Author: tianyuliang Since: 2017/11/10