Code
Hub
Workspaces
Following
Trending
Connect
MCP
copy
Create free account
hub
/
github.com/burhanxz/Distributed-KV
/ types & classes
Types & classes
178 in github.com/burhanxz/Distributed-KV
⨍
Functions
669
◇
Types & classes
178
Class
AbstractLevel
Level的通用实现 @author bird
lsm/src/lsm/internal/AbstractLevel.java:19
Class
App
fs/src/fs/App.java:3
Class
ApplicationBean
rpc/src/rpc/model/ApplicationBean.java:3
Class
AsyncResult
异步结果 @author bird
rpc/src/rpc/impl/AsyncResult.java:15
Interface
Block
lsm/src/lsm/Block.java:5
Interface
BlockBuilder
lsm/src/lsm/BlockBuilder.java:5
Class
BlockBuilderImpl
SSTable block的典型结构是 | record | 重启点机制优化后的数据记录 | restarts(4B) | 重启点位置信息 |restart counts(4B)| 重启点数目 每条record的典型结构 | key共享长度(4B) | key非共享长度
lsm/src/lsm/internal/BlockBuilderImpl.java:30
Class
BlockImpl
lsm/src/lsm/internal/BlockImpl.java:18
Class
BlockIterator
lsm/src/lsm/internal/BlockImpl.java:60
Class
BlockTest
example/src/lsm/BlockTest.java:23
Class
BloomFilter
filter数据格式 | bitset字节 | bitset实际大小 | m bit数组的宽度(bit数) n 加入其中的key的数量 k 使用的hash函数的个数 f False Positive的比率 @author bird
lsm/src/lsm/internal/BloomFilter.java:30
Class
BloomFilterTest
example/src/lsm/BloomFilterTest.java:13
Class
Bootstrap
微服务框架的启动类 @author bird
rpc/src/rpc/bootstrap/Bootstrap.java:8
Class
Builder
rpc/src/rpc/URL.java:24
Interface
Builder
rpc/src/rpc/Invocation.java:34
Class
BuilderImpl
rpc/src/rpc/impl/InvocationImpl.java:22
Class
ByteBufUtils
ByteBuf 工具类 @author bird
lsm/src/lsm/base/ByteBufUtils.java:18
Class
ChildrenWatcher
rpc/src/rpc/impl/ZookeeperRegistry.java:121
Interface
Client
rpc/src/rpc/Client.java:5
Class
ClientConfig
rpc/src/rpc/conf/ClientConfig.java:27
Class
ClientInvoker
实际执行调用的invoker @author bird @param <T> 接口类型
rpc/src/rpc/impl/ClientInvoker.java:22
Class
ClientResponseHandler
a handler designed to handle response from remote server @author bird
rpc/src/rpc/connector/ClientResponseHandler.java:20
Interface
Cluster
集群,通过一定规则合并多个invoker为一个虚拟invoker @author bird
rpc/src/rpc/Cluster.java:8
Interface
Cluster
@author bird
rpc/src/rpc/cluster/Cluster.java:8
Class
ClusterInvoker
用作cluster合并产生的集群invoker @author bird @param <T> 接口类型
rpc/src/rpc/impl/ClusterInvoker.java:13
Class
Clusters
rpc/src/rpc/cluster/Clusters.java:3
Class
CommonInvokerFactory
a invoker factory class , and also a netty client pool introduce variants of channels every of which binding to a specific server 一个invoker工厂类,也是一个客户
rpc/src/rpc/connector/CommonInvokerFactory.java:25
Class
CommonResult
普通result实现 @author bird
rpc/src/rpc/impl/CommonResult.java:11
Class
Compaction
存有compact信息 @author bird
lsm/src/lsm/base/Compaction.java:17
Class
CompactionThreadFactory
lsm/src/lsm/internal/EngineImpl.java:753
Interface
Compactor
lsm/src/lsm/Compactor.java:3
Interface
ComputeService
rpc/src/rpc/provide/ComputeService.java:3
Class
ComputeServiceImpl
rpc/src/rpc/provide/ComputeServiceImpl.java:3
Class
Config
@author bird (暂时)利用此类进行一些全局性配置
rpc/src/rpc/conf/Config.java:10
Class
ConnectionWatcher
rpc/src/rpc/impl/ZookeeperRegistry.java:96
Class
ConsumerBean
rpc/src/rpc/model/ConsumerBean.java:5
Class
ConsumerConfig
consumer bean 的工厂bean,利用spring IOC产生rpc代理对象 @author bird @param <T>
rpc/src/rpc/impl/ConsumerConfig.java:33
Class
ConsumerConstants
消费者数据模型 作为键名,存放于URL类的parameters缓存中 @author bird
rpc/src/rpc/model/ConsumerConstants.java:11
Class
ContextUtil
@author bird
rpc/src/rpc/util/ContextUtil.java:11
Interface
Current
current信息 @author bird
lsm/src/lsm/Current.java:18
Class
CurrentImpl
lsm/src/lsm/internal/CurrentImpl.java:18
Class
Datas
example/src/lsm/Datas.java:12
Interface
Directory
rpc/src/rpc/Directory.java:5
Interface
DistributedLock
@author bird 分布式锁 分布式锁本质上都是利用公共的外部资源来实现互斥性操作
rpc/src/rpc/lock/DistributedLock.java:8
Class
DistributedLockInvocationHandler
@author bird 是加锁动态代理的核心实现类
rpc/src/rpc/lock/DistributedLockInvocationHandler.java:12
Interface
Engine
数据库引擎接口 @author bird
lsm/src/lsm/Engine.java:10
Class
EngineImpl
lsm/src/lsm/internal/EngineImpl.java:56
Interface
Exchanger
rpc/src/rpc/Exchanger.java:3
Interface
Exporter
rpc/src/rpc/Exporter.java:3
Class
FailfastCluster
适用于非幂等性系统的cluster实现 @author bird
rpc/src/rpc/impl/FailfastCluster.java:12
Class
FailfastClusterInvoker
适用于failfast机制集群的invoker @author bird @param <T>
rpc/src/rpc/impl/FailfastClusterInvoker.java:22
Class
FileMetaData
fileMetaData序列化格式 | number(8B) | fileSize(8B) | smallest size(4B) | smallest | largest size(4B) | largest | @author bird
lsm/src/lsm/base/FileMetaData.java:13
Class
FileUtils
LSM文件工具类,负责创建各种文件以及获取各种文件名 @author bird
lsm/src/lsm/base/FileUtils.java:12
Interface
FilterPolicy
meta block 的过滤策略 @author bird
lsm/src/lsm/FilterPolicy.java:12
Class
HeartBeatHandler
@author bird 发送心跳包 基于WRITER_IDLE状态
rpc/src/rpc/connector/HeartBeatHandler.java:16
Class
IRequest
rpc/src/rpc/data/IRequest.java:6
Class
IResponse
represent a response from remote server @author bird
rpc/src/rpc/data/IResponse.java:9
Class
IResponseObservable
rpc/src/rpc/common/IResponseObservable.java:8
Class
IResponseObserver
rpc/src/rpc/common/IResponseObserver.java:11
Class
InternalKey
包含实际key,序列号和类型(删除或增加) 序列化结构: | seq & type (8B) | userKey | @author bird
lsm/src/lsm/base/InternalKey.java:15
Class
InternalKeyComparator
InternalKey的比较器 @author bird
lsm/src/lsm/base/InternalKeyComparator.java:12
Enum
InternalKeyType
代表internal key的类型,有delete和add @author bird
lsm/src/lsm/base/InternalKey.java:157
Interface
Invocation
存放一次方法调用所需的信息 @author bird
rpc/src/rpc/Invocation.java:12
Class
InvocationImpl
rpc/src/rpc/impl/InvocationImpl.java:10
Interface
Invoker
rpc/src/rpc/Invoker.java:3
Interface
Invoker
a invoker is used to invoke remote service (or method), binding to a specific server @author bird
rpc/src/rpc/connector/Invoker.java:13
Class
InvokerCreator
represent a netty client introduce invoker binding to a channel .composing of a unique observable, every observer binding to a channel should register
rpc/src/rpc/connector/InvokerCreator.java:32
Interface
InvokerFactory
rpc/src/rpc/connector/InvokerFactory.java:7
Class
InvokerImpl
implement invoke interface @author bird
rpc/src/rpc/connector/InvokerImpl.java:28
Class
JdkProxyFactory
利用jdk内部动态代理实现代理工厂 @author bird
rpc/src/rpc/impl/JdkProxyFactory.java:17
Interface
Level
代表sstable分层存储中的一个层次 @author bird
lsm/src/lsm/Level.java:15
Class
Level0Impl
lsm/src/lsm/internal/Level0Impl.java:12
Class
LevelImpl
lsm/src/lsm/internal/LevelImpl.java:15
Interface
LoadBalance
负载均衡策略 @author bird
rpc/src/rpc/LoadBalance.java:10
Class
Log
rpc/src/rpc/facet/Log.java:5
Interface
LogReader
用于读取日志数据 @author bird
lsm/src/lsm/LogReader.java:13
Class
LogReaderImpl
Log reader 单线程实现 @author bird
lsm/src/lsm/internal/LogReaderImpl.java:24
Class
LogTest
example/src/lsm/LogTest.java:20
Interface
LogWriter
用于日志写入 k-v日志记录的格式为: | record sum 总大小(4B) | internalKey size (4B) | internalKey(见InternalKey序列化结构) | value size (4B) | value | @author bird
lsm/src/lsm/LogWriter.java:16
Class
LogWriterImpl
利用mmap实现的log writer @author bird
lsm/src/lsm/internal/LogWriterImpl.java:25
Class
LookupKey
查询内容 @author bird
lsm/src/lsm/base/LookupKey.java:10
Class
LookupResult
查询结果 @author bird
lsm/src/lsm/base/LookupResult.java:11
Class
MajorCompactionHelper
major compaction过程中的辅助类 @author bird
lsm/src/lsm/internal/EngineImpl.java:596
Interface
MemTable
lsm/src/lsm/MemTable.java:12
Class
MemTableImpl
lsm/src/lsm/internal/MemTableImpl.java:19
Class
MemTableTest
example/src/lsm/MemTableTest.java:16
Interface
MetaBlock
lsm/src/lsm/MetaBlock.java:5
Interface
MetaBlockBuilder
meta block 结构 | filters(各个filter数据) | filter offsets(各个filter数据的大小) | sum(filter数据总大小) | kFilterBaseLg(基数,代表多少字节的data block产生一个meta block) | @author b
lsm/src/lsm/MetaBlockBuilder.java:11
Class
MetaBlockBuilderImpl
lsm/src/lsm/internal/MetaBlockBuilderImpl.java:11
Class
MetaBlockImpl
lsm/src/lsm/internal/MetaBlockImpl.java:12
Class
MinConnectionsLB
rpc/src/rpc/loadBalance/MinConnectionsLB.java:10
Class
MmapReleaseUtil
lsm/src/lsm/base/MmapReleaseUtil.java:9
Interface
Monitor
rpc/src/rpc/registry/Monitor.java:3
Interface
NameService
rpc/src/rpc/provide/NameService.java:3
Class
NameServiceImpl
rpc/src/rpc/provide/NameServiceImpl.java:3
Interface
Node
rpc/src/rpc/Node.java:3
Class
NotifiedDirectroy
可被注册中心回调通知的invoker列表组件 @author bird @param <T> 接口类型
rpc/src/rpc/impl/NotifiedDirectroy.java:25
Interface
NotifyListener
rpc/src/rpc/NotifyListener.java:5
Class
Options
lsm/src/lsm/base/Options.java:6
Interface
Protocol
rpc/src/rpc/Protocol.java:3
next →
1–100 of 178, ranked by callers