A B C D E F G I L M N O P R S T V W

A

addListener(EventListener<StoreEvent>) - 接口 中的方法org.joyqueue.store.StoreService

添加监听器

APP - 类 中的静态变量org.joyqueue.store.message.MessageParser

appendEntryBuffer(ByteBuffer) - 接口 中的方法org.joyqueue.store.replication.ReplicableStore

追加写入一段消息数据，给定的ByteBuffer必须满足如下条件： 1.

asyncWrite(WriteRequest...) - 接口 中的方法org.joyqueue.store.PartitionGroupStore

异步写入消息，线程安全，保证ACI，D的保证取决于WriteQosLevel

asyncWrite(EventListener<WriteResult>, WriteRequest...) - 接口 中的方法org.joyqueue.store.PartitionGroupStore

异步写入消息，线程安全，保证ACI，D的保证取决于WriteQosLevel

asyncWrite(int, ByteBuffer...) - 接口 中的方法org.joyqueue.store.transaction.TransactionStore

异步写入消息，线程安全，保证ACID(写入磁盘)

B

BatchMessageParser - org.joyqueue.store.message中的类

批消息解析器

BatchMessageParser() - 类 的构造器org.joyqueue.store.message.BatchMessageParser

BIZ_ID - 类 中的静态变量org.joyqueue.store.message.MessageParser

BODY - 类 中的静态变量org.joyqueue.store.message.MessageParser

build(byte[][]) - 类 中的静态方法org.joyqueue.store.message.MessageParser

C

CacheMetric() - 类 的构造器org.joyqueue.store.StoreManagementService.CacheMetric

clean(long, Map<Short, Long>, boolean) - 接口 中的方法org.joyqueue.store.PartitionGroupStore

clear(long) - 接口 中的方法org.joyqueue.store.replication.ReplicableStore

清空Store所有数据，并将所有位置置为position

CLIENT_IP - 类 中的静态变量org.joyqueue.store.message.MessageParser

CLIENT_TIMESTAMP - 类 中的静态变量org.joyqueue.store.message.MessageParser

commit(long) - 接口 中的方法org.joyqueue.store.replication.ReplicableStore

LEADER 收到半数以上回复后，调用此方法提交位置。

commitPosition() - 接口 中的方法org.joyqueue.store.replication.ReplicableStore

当前日志提交的位置

CRC - 类 中的静态变量org.joyqueue.store.message.MessageParser

createPartitionGroup(String, int, short[]) - 接口 中的方法org.joyqueue.store.StoreService

创建PartitionGroup。

D

disable() - 接口 中的方法org.joyqueue.store.replication.ReplicableStore

将服务状态置为false

E

enable() - 接口 中的方法org.joyqueue.store.replication.ReplicableStore

将服务状态置为true

EXPAND - 类 中的静态变量org.joyqueue.store.message.MessageParser

F

FIXED_LENGTH_1 - 类 中的静态变量org.joyqueue.store.message.MessageParser

FIXED_LENGTH_16 - 类 中的静态变量org.joyqueue.store.message.MessageParser

FIXED_LENGTH_2 - 类 中的静态变量org.joyqueue.store.message.MessageParser

FIXED_LENGTH_4 - 类 中的静态变量org.joyqueue.store.message.MessageParser

FIXED_LENGTH_8 - 类 中的静态变量org.joyqueue.store.message.MessageParser

FLAG - 类 中的静态变量org.joyqueue.store.message.MessageParser

freeSpace() - 接口 中的方法org.joyqueue.store.StoreManagementService

返回totalSpace

G

getAccessCount() - 类 中的方法org.joyqueue.store.StoreManagementService.CacheMetric

getAllTransactionStores() - 接口 中的方法org.joyqueue.store.StoreService

获取全部TransactionStore

getBatchSize(ByteBuffer) - 类 中的静态方法org.joyqueue.store.message.BatchMessageParser

getBatchSize() - 类 中的方法org.joyqueue.store.WriteRequest

getBit(ByteBuffer, int, int) - 类 中的静态方法org.joyqueue.store.message.MessageParser

getBuffer() - 类 中的方法org.joyqueue.store.WriteRequest

getByte(ByteBuffer, int) - 类 中的静态方法org.joyqueue.store.message.MessageParser

getByteBuffer(ByteBuffer, int) - 类 中的静态方法org.joyqueue.store.message.MessageParser

getBytes(ByteBuffer, int) - 类 中的静态方法org.joyqueue.store.message.MessageParser

getCode() - 类 中的方法org.joyqueue.store.ReadResult

getCode() - 类 中的方法org.joyqueue.store.WriteResult

getEntryTerm(long) - 接口 中的方法org.joyqueue.store.replication.ReplicableStore

获取指定位置的日志的任期

getFixedAttributesLength() - 类 中的静态方法org.joyqueue.store.message.MessageParser

getFlushPosition() - 类 中的方法org.joyqueue.store.StoreManagementService.PartitionGroupMetric

getGroup() - 类 中的方法org.joyqueue.store.event.StoreNodeChangeEvent

getHitCount() - 类 中的方法org.joyqueue.store.StoreManagementService.CacheMetric

getId() - 类 中的方法org.joyqueue.store.StoreNode

getIndex(short, long) - 接口 中的方法org.joyqueue.store.PartitionGroupStore

根据消息存储时间获取索引。

getIndexPosition() - 类 中的方法org.joyqueue.store.StoreManagementService.PartitionGroupMetric

getIndices() - 类 中的方法org.joyqueue.store.WriteResult

getInt(ByteBuffer, int) - 类 中的静态方法org.joyqueue.store.message.MessageParser

getLeft() - 异常错误 中的方法org.joyqueue.store.PositionUnderflowException

getLeftIndex(short) - 接口 中的方法org.joyqueue.store.PartitionGroupStore

获取分区当前的最小索引，用于初始化消费

getLeftIndex() - 类 中的方法org.joyqueue.store.StoreManagementService.PartitionMetric

getLeftIndexAndCheck(short) - 接口 中的方法org.joyqueue.store.PartitionGroupStore

获取分区当前的最小索引，并确认存储状态

getLeftPosition() - 类 中的方法org.joyqueue.store.StoreManagementService.PartitionGroupMetric

getLong(ByteBuffer, int) - 类 中的静态方法org.joyqueue.store.message.MessageParser

getManageService() - 接口 中的方法org.joyqueue.store.StoreService

获取管理接口 StoreManagementService 实例

getMaxSize() - 类 中的方法org.joyqueue.store.StoreManagementService.CacheMetric

getMessages() - 类 中的方法org.joyqueue.store.ReadResult

getMetrics() - 类 中的方法org.joyqueue.store.WriteResult

getNodes() - 类 中的方法org.joyqueue.store.event.StoreNodeChangeEvent

getNodes() - 类 中的方法org.joyqueue.store.StoreNodes

getNodes(String, int) - 接口 中的方法org.joyqueue.store.StoreService

获取存储节点

getPartition() - 类 中的方法org.joyqueue.store.StoreManagementService.PartitionMetric

getPartition() - 类 中的方法org.joyqueue.store.WriteRequest

getPartitionGroup() - 接口 中的方法org.joyqueue.store.PartitionGroupStore

获取Partition Group 序号

getPartitionGroup() - 类 中的方法org.joyqueue.store.StoreManagementService.PartitionGroupMetric

getPartitionGroupMetrics() - 类 中的方法org.joyqueue.store.StoreManagementService.TopicMetric

getPartitionMetrics() - 类 中的方法org.joyqueue.store.StoreManagementService.PartitionGroupMetric

getPosition() - 异常错误 中的方法org.joyqueue.store.PositionOverflowException

getPosition() - 异常错误 中的方法org.joyqueue.store.PositionUnderflowException

getReadableNodes() - 类 中的方法org.joyqueue.store.StoreNodes

getReplicableStore(String, int) - 接口 中的方法org.joyqueue.store.StoreService

获取ReplicableStore 实例

getReplicationPosition() - 类 中的方法org.joyqueue.store.StoreManagementService.PartitionGroupMetric

getRight() - 异常错误 中的方法org.joyqueue.store.PositionOverflowException

getRightIndex(short) - 接口 中的方法org.joyqueue.store.PartitionGroupStore

获取分区当前的最大索引，用于初始化消费

getRightIndex() - 类 中的方法org.joyqueue.store.StoreManagementService.PartitionMetric

getRightIndexAndCheck(short) - 接口 中的方法org.joyqueue.store.PartitionGroupStore

获取分区当前的最大索引，并确认状态

getRightPosition() - 类 中的方法org.joyqueue.store.StoreManagementService.PartitionGroupMetric

getRWNode() - 类 中的方法org.joyqueue.store.StoreNodes

getShort(ByteBuffer, int) - 类 中的静态方法org.joyqueue.store.message.MessageParser

getStore(String, int, QosLevel) - 接口 中的方法org.joyqueue.store.StoreService

获取PartitionGroupStore 实例

getStore(String, int) - 接口 中的方法org.joyqueue.store.StoreService

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

getStore(String) - 接口 中的方法org.joyqueue.store.StoreService

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

getString(ByteBuffer) - 类 中的静态方法org.joyqueue.store.message.MessageParser

getTopic() - 类 中的方法org.joyqueue.store.event.StoreNodeChangeEvent

getTopic() - 接口 中的方法org.joyqueue.store.PartitionGroupStore

获取Topic

getTopic() - 类 中的方法org.joyqueue.store.StoreManagementService.TopicMetric

getTotalPhysicalStorageSize() - 接口 中的方法org.joyqueue.store.PartitionGroupStore

获取当前PartitionGroup占用的磁盘空间大小

getTransactionStore(String) - 接口 中的方法org.joyqueue.store.StoreService

获取事务消息使用的TransactionStore

getUsedSize() - 类 中的方法org.joyqueue.store.StoreManagementService.CacheMetric

getWritableNode() - 类 中的方法org.joyqueue.store.StoreNodes

I

INDEX - 类 中的静态变量org.joyqueue.store.message.MessageParser

isBatch(ByteBuffer) - 类 中的静态方法org.joyqueue.store.message.BatchMessageParser

isEop() - 类 中的方法org.joyqueue.store.ReadResult

isReadable() - 类 中的方法org.joyqueue.store.StoreNode

isUsabled() - 类 中的方法org.joyqueue.store.StoreManagementService.TopicMetric

isWritable() - 类 中的方法org.joyqueue.store.StoreNode

L

lastEntryTerm() - 接口 中的方法org.joyqueue.store.replication.ReplicableStore

最后一条消息的Term

leftPosition() - 接口 中的方法org.joyqueue.store.replication.ReplicableStore

当前日志最小位置

LENGTH - 类 中的静态变量org.joyqueue.store.message.MessageParser

list() - 接口 中的方法org.joyqueue.store.transaction.TransactionStore

列出所有进行中的事务ID

listFiles(String) - 接口 中的方法org.joyqueue.store.StoreManagementService

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

listFiles(File) - 接口 中的方法org.joyqueue.store.StoreManagementService

listPartitions() - 接口 中的方法org.joyqueue.store.PartitionGroupStore

列出Partition group下所有的Partition

M

MAGIC - 类 中的静态变量org.joyqueue.store.message.MessageParser

main(String[]) - 类 中的静态方法org.joyqueue.store.message.MessageParser

MessageParser - org.joyqueue.store.message中的类

消息解析器

MessageParser() - 类 的构造器org.joyqueue.store.message.MessageParser

monitorInfo() - 接口 中的方法org.joyqueue.store.StoreService

获取内存监控信息。

N

next() - 接口 中的方法org.joyqueue.store.transaction.TransactionStore

获取下一个事务ID

NoSuchPartitionGroupException - org.joyqueue.store中的异常错误

NoSuchPartitionGroupException() - 异常错误 的构造器org.joyqueue.store.NoSuchPartitionGroupException

O

org.joyqueue.store - 程序包 org.joyqueue.store

org.joyqueue.store.event - 程序包 org.joyqueue.store.event

org.joyqueue.store.message - 程序包 org.joyqueue.store.message

org.joyqueue.store.replication - 程序包 org.joyqueue.store.replication

org.joyqueue.store.transaction - 程序包 org.joyqueue.store.transaction

P

ParseAttributeException - org.joyqueue.store.message中的异常错误

解析消息异常

ParseAttributeException(String) - 异常错误 的构造器org.joyqueue.store.message.ParseAttributeException

PARTITION - 类 中的静态变量org.joyqueue.store.message.MessageParser

partitionGroupExists(String, int) - 接口 中的方法org.joyqueue.store.StoreService

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

partitionGroupMetric(String, int) - 接口 中的方法org.joyqueue.store.StoreManagementService

PartitionGroup度量信息

PartitionGroupMetric() - 类 的构造器org.joyqueue.store.StoreManagementService.PartitionGroupMetric

PartitionGroupStore - org.joyqueue.store中的接口

Partition group存储，每个Partition group属于唯一的一个Topic，在Topic范围内拥有唯一的序号，包含多个Partition。

partitionMetric(String, short) - 接口 中的方法org.joyqueue.store.StoreManagementService

Topic度量信息

PartitionMetric() - 类 的构造器org.joyqueue.store.StoreManagementService.PartitionMetric

position(long, int) - 接口 中的方法org.joyqueue.store.replication.ReplicableStore

计算日志相对于position的位置

PositionOverflowException - org.joyqueue.store中的异常错误

PositionOverflowException(long, long) - 异常错误 的构造器org.joyqueue.store.PositionOverflowException

PositionUnderflowException - org.joyqueue.store中的异常错误

PositionUnderflowException(long, long) - 异常错误 的构造器org.joyqueue.store.PositionUnderflowException

PRIORITY - 类 中的静态变量org.joyqueue.store.message.MessageParser

PROPERTY - 类 中的静态变量org.joyqueue.store.message.MessageParser

R

read(short, long, int, long) - 接口 中的方法org.joyqueue.store.PartitionGroupStore

非阻塞批量读取消息，从指定位置读取消息，如果没有消息立即返回。

readEntryBuffer(long, int) - 接口 中的方法org.joyqueue.store.replication.ReplicableStore

读取一段日志数据，起始位置由position指定，最大长度不超过length。

ReadException - org.joyqueue.store中的异常错误

ReadException(String) - 异常错误 的构造器org.joyqueue.store.ReadException

ReadException() - 异常错误 的构造器org.joyqueue.store.ReadException

ReadException(String, Throwable) - 异常错误 的构造器org.joyqueue.store.ReadException

ReadException(Throwable) - 异常错误 的构造器org.joyqueue.store.ReadException

readFile(File, long, int) - 接口 中的方法org.joyqueue.store.StoreManagementService

裸接口

readIndices(String, short, long, int) - 接口 中的方法org.joyqueue.store.StoreManagementService

读取索引

readIndices(File, long, int, boolean) - 接口 中的方法org.joyqueue.store.StoreManagementService

readIterator(int) - 接口 中的方法org.joyqueue.store.transaction.TransactionStore

获取读取的迭代器。

readMessages(String, int, long, int) - 接口 中的方法org.joyqueue.store.StoreManagementService

读取消息

readMessages(String, short, long, int) - 接口 中的方法org.joyqueue.store.StoreManagementService

readMessages(File, long, int, boolean) - 接口 中的方法org.joyqueue.store.StoreManagementService

readPartitionGroupStore(String, int, long, int) - 接口 中的方法org.joyqueue.store.StoreManagementService

ReadResult - org.joyqueue.store中的类

读消息结果

ReadResult() - 类 的构造器org.joyqueue.store.ReadResult

remove(int) - 接口 中的方法org.joyqueue.store.transaction.TransactionStore

删除事务

removeListener(EventListener<StoreEvent>) - 接口 中的方法org.joyqueue.store.StoreService

移除监听器

removePartitionGroup(String, int) - 接口 中的方法org.joyqueue.store.StoreService

删除Partition group。

rePartition(String, int, Short[]) - 接口 中的方法org.joyqueue.store.StoreService

变更Partition group中的Partition

ReplicableStore - org.joyqueue.store.replication中的接口

选举复制相关的存储接口

restorePartitionGroup(String, int) - 接口 中的方法org.joyqueue.store.StoreService

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

rightPosition() - 接口 中的方法org.joyqueue.store.replication.ReplicableStore

当前日志最大位置

S

serviceStatus() - 接口 中的方法org.joyqueue.store.replication.ReplicableStore

节点服务状态

setAccessCount(long) - 类 中的方法org.joyqueue.store.StoreManagementService.CacheMetric

setBatch(ByteBuffer, boolean) - 类 中的静态方法org.joyqueue.store.message.BatchMessageParser

setBatchSize(ByteBuffer, short) - 类 中的静态方法org.joyqueue.store.message.BatchMessageParser

setBit(ByteBuffer, int, int, boolean) - 类 中的静态方法org.joyqueue.store.message.MessageParser

setBuffer(ByteBuffer) - 类 中的方法org.joyqueue.store.WriteRequest

setByte(ByteBuffer, int, byte) - 类 中的静态方法org.joyqueue.store.message.MessageParser

setCode(JoyQueueCode) - 类 中的方法org.joyqueue.store.ReadResult

setCode(JoyQueueCode) - 类 中的方法org.joyqueue.store.WriteResult

setEop(boolean) - 类 中的方法org.joyqueue.store.ReadResult

setFlushPosition(long) - 类 中的方法org.joyqueue.store.StoreManagementService.PartitionGroupMetric

setGroup(int) - 类 中的方法org.joyqueue.store.event.StoreNodeChangeEvent

setHitCount(long) - 类 中的方法org.joyqueue.store.StoreManagementService.CacheMetric

setIndexPosition(long) - 类 中的方法org.joyqueue.store.StoreManagementService.PartitionGroupMetric

setIndices(long[]) - 类 中的方法org.joyqueue.store.WriteResult

setInt(ByteBuffer, int, int) - 类 中的静态方法org.joyqueue.store.message.MessageParser

setLeftIndex(long) - 类 中的方法org.joyqueue.store.StoreManagementService.PartitionMetric

setLeftPosition(long) - 类 中的方法org.joyqueue.store.StoreManagementService.PartitionGroupMetric

setLong(ByteBuffer, int, long) - 类 中的静态方法org.joyqueue.store.message.MessageParser

setMaxSize(long) - 类 中的方法org.joyqueue.store.StoreManagementService.CacheMetric

setMessages(ByteBuffer[]) - 类 中的方法org.joyqueue.store.ReadResult

setMetrics(long[]) - 类 中的方法org.joyqueue.store.WriteResult

setNodes(StoreNodes) - 类 中的方法org.joyqueue.store.event.StoreNodeChangeEvent

setPartition(short) - 类 中的方法org.joyqueue.store.StoreManagementService.PartitionMetric

setPartitionGroup(int) - 类 中的方法org.joyqueue.store.StoreManagementService.PartitionGroupMetric

setPartitionGroupMetrics(StoreManagementService.PartitionGroupMetric[]) - 类 中的方法org.joyqueue.store.StoreManagementService.TopicMetric

setPartitionMetrics(StoreManagementService.PartitionMetric[]) - 类 中的方法org.joyqueue.store.StoreManagementService.PartitionGroupMetric

setReplicationPosition(long) - 类 中的方法org.joyqueue.store.StoreManagementService.PartitionGroupMetric

setRightIndex(long) - 类 中的方法org.joyqueue.store.StoreManagementService.PartitionMetric

setRightPosition(long) - 接口 中的方法org.joyqueue.store.replication.ReplicableStore

设置Store的最大位置。

setRightPosition(long) - 类 中的方法org.joyqueue.store.StoreManagementService.PartitionGroupMetric

setShort(ByteBuffer, int, short) - 类 中的静态方法org.joyqueue.store.message.MessageParser

setTopic(String) - 类 中的方法org.joyqueue.store.event.StoreNodeChangeEvent

setTopic(String) - 类 中的方法org.joyqueue.store.StoreManagementService.TopicMetric

setUsedSize(long) - 类 中的方法org.joyqueue.store.StoreManagementService.CacheMetric

STORAGE_TIMESTAMP - 类 中的静态变量org.joyqueue.store.message.MessageParser

StoreEvent - org.joyqueue.store.event中的类

StoreEvent author: gaohaoxiang date: 2020/3/20

StoreEvent() - 类 的构造器org.joyqueue.store.event.StoreEvent

StoreManagementService - org.joyqueue.store中的接口

存储监控和管理服务

StoreManagementService.CacheMetric - org.joyqueue.store中的类

StoreManagementService.PartitionGroupMetric - org.joyqueue.store中的类

StoreManagementService.PartitionMetric - org.joyqueue.store中的类

StoreManagementService.TopicMetric - org.joyqueue.store中的类

storeMetrics() - 接口 中的方法org.joyqueue.store.StoreManagementService

获取Store度量信息

StoreNode - org.joyqueue.store中的类

StoreNode author: gaohaoxiang date: 2020/3/19

StoreNode() - 类 的构造器org.joyqueue.store.StoreNode

StoreNode(int, boolean, boolean) - 类 的构造器org.joyqueue.store.StoreNode

StoreNodeChangeEvent - org.joyqueue.store.event中的类

StoreNodeChangeEvent author: gaohaoxiang date: 2020/3/20

StoreNodeChangeEvent() - 类 的构造器org.joyqueue.store.event.StoreNodeChangeEvent

StoreNodeChangeEvent(String, int, StoreNodes) - 类 的构造器org.joyqueue.store.event.StoreNodeChangeEvent

StoreNodeEvent - org.joyqueue.store.event中的类

StoreNodeEvent author: gaohaoxiang date: 2020/3/20

StoreNodeEvent() - 类 的构造器org.joyqueue.store.event.StoreNodeEvent

StoreNodes - org.joyqueue.store中的类

StoreNodes author: gaohaoxiang date: 2020/3/19

StoreNodes() - 类 的构造器org.joyqueue.store.StoreNodes

StoreNodes(StoreNode) - 类 的构造器org.joyqueue.store.StoreNodes

StoreNodes(List<StoreNode>) - 类 的构造器org.joyqueue.store.StoreNodes

StoreService - org.joyqueue.store中的接口

Broker 存储元数据服务

SYS - 类 中的静态变量org.joyqueue.store.message.MessageParser

T

TERM - 类 中的静态变量org.joyqueue.store.message.MessageParser

term() - 接口 中的方法org.joyqueue.store.replication.ReplicableStore

当前任期

term(int) - 接口 中的方法org.joyqueue.store.replication.ReplicableStore

修改任期，新任期必须必大于现任期;

topicExists(String) - 接口 中的方法org.joyqueue.store.StoreService

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

topicMetric(String) - 接口 中的方法org.joyqueue.store.StoreManagementService

Topic度量信息

TopicMetric() - 类 的构造器org.joyqueue.store.StoreManagementService.TopicMetric

toString() - 类 中的方法org.joyqueue.store.StoreNode

totalSpace() - 接口 中的方法org.joyqueue.store.StoreManagementService

返回totalSpace

TransactionStore - org.joyqueue.store.transaction中的接口

缓存事务消息的可靠存储

V

VARIABLE_LENGTH_1 - 类 中的静态变量org.joyqueue.store.message.MessageParser

VARIABLE_LENGTH_2 - 类 中的静态变量org.joyqueue.store.message.MessageParser

VARIABLE_LENGTH_4 - 类 中的静态变量org.joyqueue.store.message.MessageParser

W

WriteException - org.joyqueue.store中的异常错误

WriteException(String) - 异常错误 的构造器org.joyqueue.store.WriteException

WriteException() - 异常错误 的构造器org.joyqueue.store.WriteException

WriteException(Throwable) - 异常错误 的构造器org.joyqueue.store.WriteException

WriteRequest - org.joyqueue.store中的类

WriteRequest(short, ByteBuffer) - 类 的构造器org.joyqueue.store.WriteRequest

WriteRequest(short, ByteBuffer, int) - 类 的构造器org.joyqueue.store.WriteRequest

WriteResult - org.joyqueue.store中的类

写消息结果

WriteResult() - 类 的构造器org.joyqueue.store.WriteResult

WriteResult(JoyQueueCode, long[]) - 类 的构造器org.joyqueue.store.WriteResult

WriteResult(JoyQueueCode, long[], long[]) - 类 的构造器org.joyqueue.store.WriteResult

A B C D E F G I L M N O P R S T V W