org.joyqueue.nsr.sql.service

类 SQLPartitionGroupReplicaInternalService

java.lang.Object

org.joyqueue.nsr.sql.service.SQLPartitionGroupReplicaInternalService

所有已实现的接口:

PartitionGroupReplicaInternalService

public class SQLPartitionGroupReplicaInternalService
extends Object
implements PartitionGroupReplicaInternalService

SQLPartitionGroupReplicaInternalService author: gaohaoxiang date: 2019/8/16

构造器概要

构造器

构造器和说明
SQLPartitionGroupReplicaInternalService(PartitionGroupReplicaRepository partitionGroupReplicaRepository)

方法概要

限定符和类型	方法和说明
org.joyqueue.domain.Replica	add(org.joyqueue.domain.Replica replica)
void	delete(String id)
List<org.joyqueue.domain.Replica>	getAll()
List<org.joyqueue.domain.Replica>	getByBrokerId(Integer brokerId)
org.joyqueue.domain.Replica	getById(String id)
List<org.joyqueue.domain.Replica>	getByTopic(org.joyqueue.domain.TopicName topic)
List<org.joyqueue.domain.Replica>	getByTopicAndGroup(org.joyqueue.domain.TopicName topic, int groupNo)
org.joyqueue.domain.Replica	update(org.joyqueue.domain.Replica replica)

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

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

构造器详细资料

SQLPartitionGroupReplicaInternalService

public SQLPartitionGroupReplicaInternalService(PartitionGroupReplicaRepository partitionGroupReplicaRepository)

方法详细资料

getById

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

指定者:

getById 在接口中 PartitionGroupReplicaInternalService

getByTopic

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

指定者:

getByTopic 在接口中 PartitionGroupReplicaInternalService

getByTopicAndGroup

public List<org.joyqueue.domain.Replica> getByTopicAndGroup(org.joyqueue.domain.TopicName topic,
                                                            int groupNo)

指定者:

getByTopicAndGroup 在接口中 PartitionGroupReplicaInternalService

getByBrokerId

public List<org.joyqueue.domain.Replica> getByBrokerId(Integer brokerId)

指定者:

getByBrokerId 在接口中 PartitionGroupReplicaInternalService

getAll

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

指定者:

getAll 在接口中 PartitionGroupReplicaInternalService

add

public org.joyqueue.domain.Replica add(org.joyqueue.domain.Replica replica)

指定者:

add 在接口中 PartitionGroupReplicaInternalService

update

public org.joyqueue.domain.Replica update(org.joyqueue.domain.Replica replica)

指定者:

update 在接口中 PartitionGroupReplicaInternalService

delete

public void delete(String id)

指定者:

delete 在接口中 PartitionGroupReplicaInternalService