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