MCPcopy Create free account

hub / github.com/burhanxz/Distributed-KV / types & classes

Types & classes178 in github.com/burhanxz/Distributed-KV

ClassAbstractLevel
Level的通用实现 @author bird
lsm/src/lsm/internal/AbstractLevel.java:19
ClassApp
fs/src/fs/App.java:3
ClassApplicationBean
rpc/src/rpc/model/ApplicationBean.java:3
ClassAsyncResult
异步结果 @author bird
rpc/src/rpc/impl/AsyncResult.java:15
InterfaceBlock
lsm/src/lsm/Block.java:5
InterfaceBlockBuilder
lsm/src/lsm/BlockBuilder.java:5
ClassBlockBuilderImpl
SSTable block的典型结构是 | record | 重启点机制优化后的数据记录 | restarts(4B) | 重启点位置信息 |restart counts(4B)| 重启点数目 每条record的典型结构 | key共享长度(4B) | key非共享长度
lsm/src/lsm/internal/BlockBuilderImpl.java:30
ClassBlockImpl
lsm/src/lsm/internal/BlockImpl.java:18
ClassBlockIterator
lsm/src/lsm/internal/BlockImpl.java:60
ClassBlockTest
example/src/lsm/BlockTest.java:23
ClassBloomFilter
filter数据格式 | bitset字节 | bitset实际大小 | m bit数组的宽度(bit数) n 加入其中的key的数量 k 使用的hash函数的个数 f False Positive的比率 @author bird
lsm/src/lsm/internal/BloomFilter.java:30
ClassBloomFilterTest
example/src/lsm/BloomFilterTest.java:13
ClassBootstrap
微服务框架的启动类 @author bird
rpc/src/rpc/bootstrap/Bootstrap.java:8
ClassBuilder
rpc/src/rpc/URL.java:24
InterfaceBuilder
rpc/src/rpc/Invocation.java:34
ClassBuilderImpl
rpc/src/rpc/impl/InvocationImpl.java:22
ClassByteBufUtils
ByteBuf 工具类 @author bird
lsm/src/lsm/base/ByteBufUtils.java:18
ClassChildrenWatcher
rpc/src/rpc/impl/ZookeeperRegistry.java:121
InterfaceClient
rpc/src/rpc/Client.java:5
ClassClientConfig
rpc/src/rpc/conf/ClientConfig.java:27
ClassClientInvoker
实际执行调用的invoker @author bird @param <T> 接口类型
rpc/src/rpc/impl/ClientInvoker.java:22
ClassClientResponseHandler
a handler designed to handle response from remote server @author bird
rpc/src/rpc/connector/ClientResponseHandler.java:20
InterfaceCluster
集群,通过一定规则合并多个invoker为一个虚拟invoker @author bird
rpc/src/rpc/Cluster.java:8
InterfaceCluster
@author bird
rpc/src/rpc/cluster/Cluster.java:8
ClassClusterInvoker
用作cluster合并产生的集群invoker @author bird @param <T> 接口类型
rpc/src/rpc/impl/ClusterInvoker.java:13
ClassClusters
rpc/src/rpc/cluster/Clusters.java:3
ClassCommonInvokerFactory
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
ClassCommonResult
普通result实现 @author bird
rpc/src/rpc/impl/CommonResult.java:11
ClassCompaction
存有compact信息 @author bird
lsm/src/lsm/base/Compaction.java:17
ClassCompactionThreadFactory
lsm/src/lsm/internal/EngineImpl.java:753
InterfaceCompactor
lsm/src/lsm/Compactor.java:3
InterfaceComputeService
rpc/src/rpc/provide/ComputeService.java:3
ClassComputeServiceImpl
rpc/src/rpc/provide/ComputeServiceImpl.java:3
ClassConfig
@author bird (暂时)利用此类进行一些全局性配置
rpc/src/rpc/conf/Config.java:10
ClassConnectionWatcher
rpc/src/rpc/impl/ZookeeperRegistry.java:96
ClassConsumerBean
rpc/src/rpc/model/ConsumerBean.java:5
ClassConsumerConfig
consumer bean 的工厂bean,利用spring IOC产生rpc代理对象 @author bird @param <T>
rpc/src/rpc/impl/ConsumerConfig.java:33
ClassConsumerConstants
消费者数据模型 作为键名,存放于URL类的parameters缓存中 @author bird
rpc/src/rpc/model/ConsumerConstants.java:11
ClassContextUtil
@author bird
rpc/src/rpc/util/ContextUtil.java:11
InterfaceCurrent
current信息 @author bird
lsm/src/lsm/Current.java:18
ClassCurrentImpl
lsm/src/lsm/internal/CurrentImpl.java:18
ClassDatas
example/src/lsm/Datas.java:12
InterfaceDirectory
rpc/src/rpc/Directory.java:5
InterfaceDistributedLock
@author bird 分布式锁 分布式锁本质上都是利用公共的外部资源来实现互斥性操作
rpc/src/rpc/lock/DistributedLock.java:8
ClassDistributedLockInvocationHandler
@author bird 是加锁动态代理的核心实现类
rpc/src/rpc/lock/DistributedLockInvocationHandler.java:12
InterfaceEngine
数据库引擎接口 @author bird
lsm/src/lsm/Engine.java:10
ClassEngineImpl
lsm/src/lsm/internal/EngineImpl.java:56
InterfaceExchanger
rpc/src/rpc/Exchanger.java:3
InterfaceExporter
rpc/src/rpc/Exporter.java:3
ClassFailfastCluster
适用于非幂等性系统的cluster实现 @author bird
rpc/src/rpc/impl/FailfastCluster.java:12
ClassFailfastClusterInvoker
适用于failfast机制集群的invoker @author bird @param <T>
rpc/src/rpc/impl/FailfastClusterInvoker.java:22
ClassFileMetaData
fileMetaData序列化格式 | number(8B) | fileSize(8B) | smallest size(4B) | smallest | largest size(4B) | largest | @author bird
lsm/src/lsm/base/FileMetaData.java:13
ClassFileUtils
LSM文件工具类,负责创建各种文件以及获取各种文件名 @author bird
lsm/src/lsm/base/FileUtils.java:12
InterfaceFilterPolicy
meta block 的过滤策略 @author bird
lsm/src/lsm/FilterPolicy.java:12
ClassHeartBeatHandler
@author bird 发送心跳包 基于WRITER_IDLE状态
rpc/src/rpc/connector/HeartBeatHandler.java:16
ClassIRequest
rpc/src/rpc/data/IRequest.java:6
ClassIResponse
represent a response from remote server @author bird
rpc/src/rpc/data/IResponse.java:9
ClassIResponseObservable
rpc/src/rpc/common/IResponseObservable.java:8
ClassIResponseObserver
rpc/src/rpc/common/IResponseObserver.java:11
ClassInternalKey
包含实际key,序列号和类型(删除或增加) 序列化结构: | seq & type (8B) | userKey | @author bird
lsm/src/lsm/base/InternalKey.java:15
ClassInternalKeyComparator
InternalKey的比较器 @author bird
lsm/src/lsm/base/InternalKeyComparator.java:12
EnumInternalKeyType
代表internal key的类型,有delete和add @author bird
lsm/src/lsm/base/InternalKey.java:157
InterfaceInvocation
存放一次方法调用所需的信息 @author bird
rpc/src/rpc/Invocation.java:12
ClassInvocationImpl
rpc/src/rpc/impl/InvocationImpl.java:10
InterfaceInvoker
rpc/src/rpc/Invoker.java:3
InterfaceInvoker
a invoker is used to invoke remote service (or method), binding to a specific server @author bird
rpc/src/rpc/connector/Invoker.java:13
ClassInvokerCreator
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
InterfaceInvokerFactory
rpc/src/rpc/connector/InvokerFactory.java:7
ClassInvokerImpl
implement invoke interface @author bird
rpc/src/rpc/connector/InvokerImpl.java:28
ClassJdkProxyFactory
利用jdk内部动态代理实现代理工厂 @author bird
rpc/src/rpc/impl/JdkProxyFactory.java:17
InterfaceLevel
代表sstable分层存储中的一个层次 @author bird
lsm/src/lsm/Level.java:15
ClassLevel0Impl
lsm/src/lsm/internal/Level0Impl.java:12
ClassLevelImpl
lsm/src/lsm/internal/LevelImpl.java:15
InterfaceLoadBalance
负载均衡策略 @author bird
rpc/src/rpc/LoadBalance.java:10
ClassLog
rpc/src/rpc/facet/Log.java:5
InterfaceLogReader
用于读取日志数据 @author bird
lsm/src/lsm/LogReader.java:13
ClassLogReaderImpl
Log reader 单线程实现 @author bird
lsm/src/lsm/internal/LogReaderImpl.java:24
ClassLogTest
example/src/lsm/LogTest.java:20
InterfaceLogWriter
用于日志写入 k-v日志记录的格式为: | record sum 总大小(4B) | internalKey size (4B) | internalKey(见InternalKey序列化结构) | value size (4B) | value | @author bird
lsm/src/lsm/LogWriter.java:16
ClassLogWriterImpl
利用mmap实现的log writer @author bird
lsm/src/lsm/internal/LogWriterImpl.java:25
ClassLookupKey
查询内容 @author bird
lsm/src/lsm/base/LookupKey.java:10
ClassLookupResult
查询结果 @author bird
lsm/src/lsm/base/LookupResult.java:11
ClassMajorCompactionHelper
major compaction过程中的辅助类 @author bird
lsm/src/lsm/internal/EngineImpl.java:596
InterfaceMemTable
lsm/src/lsm/MemTable.java:12
ClassMemTableImpl
lsm/src/lsm/internal/MemTableImpl.java:19
ClassMemTableTest
example/src/lsm/MemTableTest.java:16
InterfaceMetaBlock
lsm/src/lsm/MetaBlock.java:5
InterfaceMetaBlockBuilder
meta block 结构 | filters(各个filter数据) | filter offsets(各个filter数据的大小) | sum(filter数据总大小) | kFilterBaseLg(基数,代表多少字节的data block产生一个meta block) | @author b
lsm/src/lsm/MetaBlockBuilder.java:11
ClassMetaBlockBuilderImpl
lsm/src/lsm/internal/MetaBlockBuilderImpl.java:11
ClassMetaBlockImpl
lsm/src/lsm/internal/MetaBlockImpl.java:12
ClassMinConnectionsLB
rpc/src/rpc/loadBalance/MinConnectionsLB.java:10
ClassMmapReleaseUtil
lsm/src/lsm/base/MmapReleaseUtil.java:9
InterfaceMonitor
rpc/src/rpc/registry/Monitor.java:3
InterfaceNameService
rpc/src/rpc/provide/NameService.java:3
ClassNameServiceImpl
rpc/src/rpc/provide/NameServiceImpl.java:3
InterfaceNode
rpc/src/rpc/Node.java:3
ClassNotifiedDirectroy
可被注册中心回调通知的invoker列表组件 @author bird @param <T> 接口类型
rpc/src/rpc/impl/NotifiedDirectroy.java:25
InterfaceNotifyListener
rpc/src/rpc/NotifyListener.java:5
ClassOptions
lsm/src/lsm/base/Options.java:6
InterfaceProtocol
rpc/src/rpc/Protocol.java:3
next →1–100 of 178, ranked by callers