org.joyqueue.nsr.sql.service

类 SQLTopicInternalService

java.lang.Object

org.joyqueue.nsr.sql.service.SQLTopicInternalService

所有已实现的接口:

TopicInternalService

public class SQLTopicInternalService
extends Object
implements TopicInternalService

SQLTopicInternalService author: gaohaoxiang date: 2019/8/15

字段概要

字段

限定符和类型	字段和说明
protected static org.slf4j.Logger	logger

构造器概要

构造器

构造器和说明
SQLTopicInternalService(TopicRepository topicRepository, PartitionGroupRepository partitionGroupRepository, PartitionGroupReplicaRepository partitionGroupReplicaRepository)

方法概要

限定符和类型	方法和说明
org.joyqueue.domain.Topic	add(org.joyqueue.domain.Topic topic)
void	addPartitionGroup(org.joyqueue.domain.PartitionGroup group)
void	addTopic(org.joyqueue.domain.Topic topic, List<org.joyqueue.domain.PartitionGroup> partitionGroups)
org.joyqueue.model.PageResult<org.joyqueue.domain.Topic>	findUnsubscribedByQuery(org.joyqueue.model.QPageQuery<TopicQuery> pageQuery)
List<org.joyqueue.domain.Topic>	getAll()
org.joyqueue.domain.Topic	getById(String id)
List<org.joyqueue.domain.PartitionGroup>	getPartitionGroup(String namespace, String topic, Object[] groups)
org.joyqueue.domain.Topic	getTopicByCode(String namespace, String topic)
void	leaderChange(org.joyqueue.domain.PartitionGroup group)
void	leaderReport(org.joyqueue.domain.PartitionGroup group)
void	removePartitionGroup(org.joyqueue.domain.PartitionGroup group)
void	removeTopic(org.joyqueue.domain.Topic topic)
org.joyqueue.model.PageResult<org.joyqueue.domain.Topic>	search(org.joyqueue.model.QPageQuery<TopicQuery> pageQuery)
org.joyqueue.domain.Topic	update(org.joyqueue.domain.Topic topic)
Collection<Integer>	updatePartitionGroup(org.joyqueue.domain.PartitionGroup group)

从类继承的方法 java.lang.Object

clone, equals, finalize, getClass, hashCode, notify, notifyAll, toString, wait, wait, wait

字段详细资料

logger

protected static final org.slf4j.Logger logger

构造器详细资料

SQLTopicInternalService

public SQLTopicInternalService(TopicRepository topicRepository,
                               PartitionGroupRepository partitionGroupRepository,
                               PartitionGroupReplicaRepository partitionGroupReplicaRepository)

方法详细资料

getById

public org.joyqueue.domain.Topic getById(String id)

指定者:

getById 在接口中 TopicInternalService

getTopicByCode

public org.joyqueue.domain.Topic getTopicByCode(String namespace,
                                                String topic)

指定者:

getTopicByCode 在接口中 TopicInternalService

search

public org.joyqueue.model.PageResult<org.joyqueue.domain.Topic> search(org.joyqueue.model.QPageQuery<TopicQuery> pageQuery)

指定者:

search 在接口中 TopicInternalService

findUnsubscribedByQuery

public org.joyqueue.model.PageResult<org.joyqueue.domain.Topic> findUnsubscribedByQuery(org.joyqueue.model.QPageQuery<TopicQuery> pageQuery)

指定者:

findUnsubscribedByQuery 在接口中 TopicInternalService

getAll

public List<org.joyqueue.domain.Topic> getAll()

指定者:

getAll 在接口中 TopicInternalService

addTopic

public void addTopic(org.joyqueue.domain.Topic topic,
                     List<org.joyqueue.domain.PartitionGroup> partitionGroups)

指定者:

addTopic 在接口中 TopicInternalService

removeTopic

public void removeTopic(org.joyqueue.domain.Topic topic)

指定者:

removeTopic 在接口中 TopicInternalService

addPartitionGroup

public void addPartitionGroup(org.joyqueue.domain.PartitionGroup group)

指定者:

addPartitionGroup 在接口中 TopicInternalService

removePartitionGroup

public void removePartitionGroup(org.joyqueue.domain.PartitionGroup group)

指定者:

removePartitionGroup 在接口中 TopicInternalService

updatePartitionGroup

public Collection<Integer> updatePartitionGroup(org.joyqueue.domain.PartitionGroup group)

指定者:

updatePartitionGroup 在接口中 TopicInternalService

leaderReport

public void leaderReport(org.joyqueue.domain.PartitionGroup group)

指定者:

leaderReport 在接口中 TopicInternalService

leaderChange

public void leaderChange(org.joyqueue.domain.PartitionGroup group)

指定者:

leaderChange 在接口中 TopicInternalService

getPartitionGroup

public List<org.joyqueue.domain.PartitionGroup> getPartitionGroup(String namespace,
                                                                  String topic,
                                                                  Object[] groups)

指定者:

getPartitionGroup 在接口中 TopicInternalService

add

public org.joyqueue.domain.Topic add(org.joyqueue.domain.Topic topic)

指定者:

add 在接口中 TopicInternalService

update

public org.joyqueue.domain.Topic update(org.joyqueue.domain.Topic topic)

指定者:

update 在接口中 TopicInternalService