org.joyqueue.store

接口 StoreManagementService

public interface StoreManagementService

存储监控和管理服务

作者:

liyue25 Date: 2018/10/18

嵌套类概要

嵌套类

限定符和类型	接口和说明
static class	StoreManagementService.CacheMetric
static class	StoreManagementService.PartitionGroupMetric
static class	StoreManagementService.PartitionMetric
static class	StoreManagementService.TopicMetric

方法概要

限定符和类型	方法和说明
long	freeSpace() 返回totalSpace
File[]	listFiles(File directory)
File[]	listFiles(String path) 列出store中给定path的所有文件
StoreManagementService.PartitionGroupMetric	partitionGroupMetric(String topic, int partitionGroup) PartitionGroup度量信息
StoreManagementService.PartitionMetric	partitionMetric(String topic, short partition) Topic度量信息
byte[]	readFile(File file, long position, int length) 裸接口
Long[]	readIndices(File file, long position, int count, boolean includeFileHeader)
Long[]	readIndices(String topic, short partition, long index, int count) 读取索引
byte[][]	readMessages(File file, long position, int count, boolean includeFileHeader)
byte[][]	readMessages(String topic, int partitionGroup, long position, int count) 读取消息
byte[][]	readMessages(String topic, short partition, long index, int count)
byte[]	readPartitionGroupStore(String topic, int partitionGroup, long position, int length)
StoreManagementService.TopicMetric[]	storeMetrics() 获取Store度量信息
StoreManagementService.TopicMetric	topicMetric(String topic) Topic度量信息
long	totalSpace() 返回totalSpace

方法详细资料

storeMetrics

StoreManagementService.TopicMetric[] storeMetrics()

获取Store度量信息

topicMetric

StoreManagementService.TopicMetric topicMetric(String topic)

Topic度量信息

partitionGroupMetric

StoreManagementService.PartitionGroupMetric partitionGroupMetric(String topic,
                                                                 int partitionGroup)

PartitionGroup度量信息

partitionMetric

StoreManagementService.PartitionMetric partitionMetric(String topic,
                                                       short partition)

Topic度量信息

listFiles

File[] listFiles(String path)

列出store中给定path的所有文件

参数:

path - 相对store根目录的相对路径

listFiles

File[] listFiles(File directory)

totalSpace

long totalSpace()

返回totalSpace

返回:

freeSpace

long freeSpace()

返回totalSpace

返回:

readMessages

byte[][] readMessages(String topic,
                      int partitionGroup,
                      long position,
                      int count)

读取消息

readMessages

byte[][] readMessages(String topic,
                      short partition,
                      long index,
                      int count)

readMessages

byte[][] readMessages(File file,
                      long position,
                      int count,
                      boolean includeFileHeader)

readIndices

Long[] readIndices(String topic,
                   short partition,
                   long index,
                   int count)

读取索引

readIndices

Long[] readIndices(File file,
                   long position,
                   int count,
                   boolean includeFileHeader)

readFile

byte[] readFile(File file,
                long position,
                int length)

裸接口

readPartitionGroupStore

byte[] readPartitionGroupStore(String topic,
                               int partitionGroup,
                               long position,
                               int length)