索引 (JoyQueue-Store-API 4.2.2 API)

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

A

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
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
getHitCount() - 类中的方法org.joyqueue.store.StoreManagementService.CacheMetric
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
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
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
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
getRightPosition() - 类中的方法org.joyqueue.store.StoreManagementService.PartitionGroupMetric
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.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

I

INDEX - 类中的静态变量org.joyqueue.store.message.MessageParser
isBatch(ByteBuffer) - 类中的静态方法org.joyqueue.store.message.BatchMessageParser
isEop() - 类中的方法org.joyqueue.store.ReadResult
isUsabled() - 类中的方法org.joyqueue.store.StoreManagementService.TopicMetric

L

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.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 是否存在。
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: 删除事务
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
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
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.StoreManagementService.TopicMetric
setUsedSize(long) - 类中的方法org.joyqueue.store.StoreManagementService.CacheMetric
STORAGE_TIMESTAMP - 类中的静态变量org.joyqueue.store.message.MessageParser
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度量信息
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 是否存在以Store内存中的元数据为准，有可能和磁盘上的文件不一致。
topicMetric(String) - 接口中的方法org.joyqueue.store.StoreManagementService: Topic度量信息
TopicMetric() - 类的构造器org.joyqueue.store.StoreManagementService.TopicMetric
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

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