分布式系统进阶

80 篇文章
13 人订阅

全部文章

扫帚的影子

Influxdb中的Series file解析

其中的flag有两个可能的值: SeriesEntryInsertFlag:表示当前写入的SeriesKey是有效的; SeriesEntryTombsto...

663
扫帚的影子

优化你的Apache Kafka部署

Apache kafka是一套可以拿过来直接运行起来的很好的企业级流处理平台。只需要将你的客户端应用放到Kafka集群中,剩下的事件就都可以交给Kafka来处理...

602
扫帚的影子

Influxdb中TSM文件结构解析之WAL

对应的类型是Value,这是个interface,定义在tsdb/engine/tsm1/encoding.go中

1122
扫帚的影子

使用多数据中心部署来应对Kafka灾难恢复(二)

Confluent Replicator是一个Kafka connector,它运行在Kafka Connect框架内。Replicator继承了所有Kafka...

1103
扫帚的影子

InfluxDB中的inmem内存索引结构解析

1133
扫帚的影子

使用多数据中心部署来应对Kafka灾难恢复(一)使用多数据中心部署来应对灾难恢复

数据中心宕机和数据丢失能导致企业损失很多收入或者完全停摆。为了将由于事故导致的宕机和数据丢失带来的损失最小化,企业需要制定业务可持续性计划和灾难恢复策略。

1272
扫帚的影子

TSI索引解析之TSL文件

series和seriesSet其实都是用来存储SeriesID, 当SeriesID数量小于等于25个时,存到series里,反之存到seriesSet这个r...

932
扫帚的影子

Influxdb中基于磁盘的倒排索引文件TSI结构解析

基础上是按照其在文件中的结构定义的,记录了measurement包括的tagset和series id信息;

1082
扫帚的影子

Influxdb中Select查询请求结果涉及到的一些数据结构

相当于c里面的链表元素,itr指向下一个元素的指针,buf表示当前元素,即FloatPoint类型的链表的迭代器.

942
扫帚的影子

Influxdb的Http请求处理流程

3.4 关键函数之s.serverTCP(),使用之前初始化的listener和handler启动真正的http服务

1177
扫帚的影子

Influxdb启动流程分析

我们启动的话通常是 influxd run -config [config file path]

991
扫帚的影子

Influxdb 数据写入流程

因此对写入请求的处理就在函数 func (h *Handler) serveWrite(w http.ResponseWriter, r *http.Reque...

1293
扫帚的影子

Influxdb授权验证流程

841
扫帚的影子

Query请求的执行流程分析

2.1 这个MonitorFunc是一个函数类型,定义为type MonitorFunc func(<-chan struct{}) error, 它用来检查当...

852
扫帚的影子

Influxdb的Meta data分析

Influxdb定义了一个Service:Precreator Serivec(services/precreator/service.go),实现比较简单,周...

982
扫帚的影子

Influxdb Cluster下的数据写入

3.2 调用w.MetaClient.CreateShardGroup, 如果ShardGroup存在直接返回ShardGroup信息,如果不存在创建,创建过程...

1002
扫帚的影子

Cluster版本中的Meta

814
扫帚的影子

Influxdb 编译

1151
扫帚的影子

KafkaBridge - Kafka Client SDK 开源啦~~~

KafkaBridge 封装了对Kafka集群的读写操作,接口极少,简单易用,稳定可靠,支持c++/c、php、python、golang等多种语言,并特别针对...

611
扫帚的影子

利用Mesos构建多任务调度系统

3215

扫码关注云+社区