public class PartitionGroupReplicaRepository extends Object
| 构造器和说明 |
|---|
PartitionGroupReplicaRepository(BaseRepository baseRepository) |
| 限定符和类型 | 方法和说明 |
|---|---|
PartitionGroupReplicaDTO |
add(PartitionGroupReplicaDTO partitionGroupReplicaDTO) |
int |
deleteById(String id) |
List<PartitionGroupReplicaDTO> |
getAll() |
List<PartitionGroupReplicaDTO> |
getByBrokerId(long brokerId) |
PartitionGroupReplicaDTO |
getById(String id) |
List<PartitionGroupReplicaDTO> |
getByTopic(String topic,
String namespace) |
List<PartitionGroupReplicaDTO> |
getByTopicAndGroup(String topic,
String namespace,
int group) |
PartitionGroupReplicaDTO |
update(PartitionGroupReplicaDTO partitionGroupReplicaDTO) |
public PartitionGroupReplicaRepository(BaseRepository baseRepository)
public PartitionGroupReplicaDTO getById(String id)
public List<PartitionGroupReplicaDTO> getByTopic(String topic, String namespace)
public List<PartitionGroupReplicaDTO> getByTopicAndGroup(String topic, String namespace, int group)
public List<PartitionGroupReplicaDTO> getByBrokerId(long brokerId)
public List<PartitionGroupReplicaDTO> getAll()
public PartitionGroupReplicaDTO add(PartitionGroupReplicaDTO partitionGroupReplicaDTO)
public PartitionGroupReplicaDTO update(PartitionGroupReplicaDTO partitionGroupReplicaDTO)
public int deleteById(String id)
Copyright © 2020 Joyqueue Community. All rights reserved.