org.joyqueue.store

接口 StoreService

public interface StoreService

Broker 存储元数据服务

方法概要

限定符和类型	方法和说明
void	addListener(EventListener<StoreEvent> listener) 添加监听器
void	createPartitionGroup(String topic, int partitionGroup, short[] partitions) 创建PartitionGroup。
List<TransactionStore>	getAllTransactionStores() 获取全部TransactionStore
StoreManagementService	getManageService() 获取管理接口 StoreManagementService 实例
StoreNodes	getNodes(String topic, int partitionGroup) 获取存储节点
ReplicableStore	getReplicableStore(String topic, int partitionGroup) 获取ReplicableStore 实例
List<PartitionGroupStore>	getStore(String topic) 获取指定 topic 下的全部 PartitionGroupStore 实例列表。
PartitionGroupStore	getStore(String topic, int partitionGroup) 获取PartitionGroupStore 实例，使用默认的Qos级别
PartitionGroupStore	getStore(String topic, int partitionGroup, QosLevel writeQosLevel) 获取PartitionGroupStore 实例
TransactionStore	getTransactionStore(String topic) 获取事务消息使用的TransactionStore
BufferPoolMonitorInfo	monitorInfo() 获取内存监控信息。
boolean	partitionGroupExists(String topic, int partitionGroup) 判断Partition group 目录是否存在， 以磁盘上的Partition group目录为准。
void	removeListener(EventListener<StoreEvent> listener) 移除监听器
void	removePartitionGroup(String topic, int partitionGroup) 删除Partition group。
void	rePartition(String topic, int partitionGroup, Short[] partitions) 变更Partition group中的Partition
void	restorePartitionGroup(String topic, int partitionGroup) 从磁盘恢复partition group，系统启动时调用
boolean	topicExists(String topic) 判断Topic 目录是否存在， 以磁盘上的Partition group目录为准。

方法详细资料

partitionGroupExists

boolean partitionGroupExists(String topic,
                             int partitionGroup)

判断Partition group 目录是否存在， 以磁盘上的Partition group目录为准。

参数:

topic - Topic

partitionGroup - Partition group

返回:

存在返回true， 否则返回false

topicExists

boolean topicExists(String topic)

判断Topic 目录是否存在， 以磁盘上的Partition group目录为准。

参数:

topic - Topic

返回:

存在返回true， 否则返回false

getTransactionStore

TransactionStore getTransactionStore(String topic)

获取事务消息使用的TransactionStore

返回:

如果 TransactionStore存在则直接返回； 如果Topic存在，TransactionStore目录文件不存在则自动创建 TransactionStore； 如果Topic不存在，返回null。

getAllTransactionStores

List<TransactionStore> getAllTransactionStores()

获取全部TransactionStore

返回:

TransactionStore列表

removePartitionGroup

void removePartitionGroup(String topic,
                          int partitionGroup)

删除Partition group。此操作不会物理上删除Partition group所在的目录，而是将数据重名为“.d.[PartitionGroup]”。

参数:

topic - Topic

partitionGroup - Partition group

restorePartitionGroup

void restorePartitionGroup(String topic,
                           int partitionGroup)
                    throws Exception

从磁盘恢复partition group，系统启动时调用

抛出:

Exception

createPartitionGroup

void createPartitionGroup(String topic,
                          int partitionGroup,
                          short[] partitions)
                   throws Exception

创建PartitionGroup。仅当topic创建或者向topic中添加partitionGroup的时候调用，需要提供节点信息。 如果磁盘上数据目录不存在，自动创建数据目录；如果磁盘上存在数据目录，自动逻辑删除这些目录，然后创建新的数据目录。

参数:

topic - Topic

partitionGroup - Partition group

partitions - Partition

抛出:

Exception

getStore

PartitionGroupStore getStore(String topic,
                             int partitionGroup,
                             QosLevel writeQosLevel)

获取PartitionGroupStore 实例

参数:

topic - Topic

partitionGroup - Partition group

writeQosLevel - 写入Qos级别

返回:

PartitionGroupStore 实例，不存在时返回null。

getStore

PartitionGroupStore getStore(String topic,
                             int partitionGroup)

获取PartitionGroupStore 实例，使用默认的Qos级别

参数:

topic - Topic

partitionGroup - Partition group

返回:

PartitionGroupStore 实例，不存在时返回null。

另请参阅:

QosLevel#REPLICATION。, getStore(java.lang.String, int, QosLevel)

getStore

List<PartitionGroupStore> getStore(String topic)

获取指定 topic 下的全部 PartitionGroupStore 实例列表。

参数:

topic - Topic

返回:

topic 下的全部 PartitionGroupStore 实例列表，topic 不存在时返回空List。

rePartition

void rePartition(String topic,
                 int partitionGroup,
                 Short[] partitions)
          throws IOException

变更Partition group中的Partition

参数:

topic - Topic

partitionGroup - Partition group

partitions - 变更后的Partition数组

抛出:

NoSuchPartitionGroupException - PartitionGroup不存在时抛出此异常

IOException - 创建/删除Partition时读写文件异常时抛出

getReplicableStore

ReplicableStore getReplicableStore(String topic,
                                   int partitionGroup)

获取ReplicableStore 实例

参数:

topic - Topic

partitionGroup - Partition group

返回:

ReplicableStore 实例，不存在时返回null。

另请参阅:

QosLevel#REPLICATION。, getStore(java.lang.String, int, QosLevel)

getManageService

StoreManagementService getManageService()

获取管理接口 StoreManagementService 实例

返回:

StoreManagementService 实例

monitorInfo

BufferPoolMonitorInfo monitorInfo()

获取内存监控信息。

返回:

内存监控对象。

getNodes

StoreNodes getNodes(String topic,
                    int partitionGroup)

获取存储节点

返回:

addListener

void addListener(EventListener<StoreEvent> listener)

添加监听器

参数:

listener -

removeListener

void removeListener(EventListener<StoreEvent> listener)

移除监听器

参数:

listener -