org.joyqueue.nsr.sql.service

类 SQLPartitionGroupInternalService

java.lang.Object

org.joyqueue.nsr.sql.service.SQLPartitionGroupInternalService

所有已实现的接口:

PartitionGroupInternalService

public class SQLPartitionGroupInternalService
extends Object
implements PartitionGroupInternalService

SQLPartitionGroupInternalService author: gaohaoxiang date: 2019/8/16

构造器概要

构造器

构造器和说明
SQLPartitionGroupInternalService(PartitionGroupRepository partitionGroupRepository)

方法概要

限定符和类型	方法和说明
org.joyqueue.domain.PartitionGroup	add(org.joyqueue.domain.PartitionGroup partitionGroup)
void	delete(String id)
List<org.joyqueue.domain.PartitionGroup>	getAll()
org.joyqueue.domain.PartitionGroup	getById(String id)
List<org.joyqueue.domain.PartitionGroup>	getByTopic(org.joyqueue.domain.TopicName topic)
org.joyqueue.domain.PartitionGroup	getByTopicAndGroup(org.joyqueue.domain.TopicName topic, int group)
org.joyqueue.domain.PartitionGroup	update(org.joyqueue.domain.PartitionGroup partitionGroup)

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

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

构造器详细资料

SQLPartitionGroupInternalService

public SQLPartitionGroupInternalService(PartitionGroupRepository partitionGroupRepository)

方法详细资料

getById

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

指定者:

getById 在接口中 PartitionGroupInternalService

getByTopicAndGroup

public org.joyqueue.domain.PartitionGroup getByTopicAndGroup(org.joyqueue.domain.TopicName topic,
                                                             int group)

指定者:

getByTopicAndGroup 在接口中 PartitionGroupInternalService

getByTopic

public List<org.joyqueue.domain.PartitionGroup> getByTopic(org.joyqueue.domain.TopicName topic)

指定者:

getByTopic 在接口中 PartitionGroupInternalService

getAll

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

指定者:

getAll 在接口中 PartitionGroupInternalService

add

public org.joyqueue.domain.PartitionGroup add(org.joyqueue.domain.PartitionGroup partitionGroup)

指定者:

add 在接口中 PartitionGroupInternalService

update

public org.joyqueue.domain.PartitionGroup update(org.joyqueue.domain.PartitionGroup partitionGroup)

指定者:

update 在接口中 PartitionGroupInternalService

delete

public void delete(String id)

指定者:

delete 在接口中 PartitionGroupInternalService