分布式系统进阶

72 篇文章
11 人订阅

全部文章

扫帚的影子

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

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

532
扫帚的影子

Influxdb的Http请求处理流程

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

897
扫帚的影子

Influxdb启动流程分析

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

761
扫帚的影子

Influxdb 数据写入流程

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

823
扫帚的影子

Influxdb授权验证流程

561
扫帚的影子

Query请求的执行流程分析

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

522
扫帚的影子

Influxdb的Meta data分析

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

622
扫帚的影子

Influxdb Cluster下的数据写入

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

632
扫帚的影子

Cluster版本中的Meta

584
扫帚的影子

Influxdb 编译

691
扫帚的影子

KafkaBridge - Kafka Client SDK 开源啦~~~

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

351
扫帚的影子

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

2135
扫帚的影子

Kafka Mirror Maker 使用和图解

1124
扫帚的影子

Folly库编译官方说的相关依赖开始编译

1843
扫帚的影子

FBString分析与使用FBString简介

简单来说,使用了三层存储策略+内存分配策略+大小端支持,特别是配合使用 jemalloc, 减少磁盘碎片,加快并发下的分配速度和性能。

782
扫帚的影子

Kafka源码分析-网络层-1

702
扫帚的影子

BGP科谱

991
扫帚的影子

Kafka源码分析-网络层-3

上面的id即为我们在上篇介绍的非常重要的ConnectionId; (2) connect: 使用nio的SocketChannel连接到给定的地址,并且注册...

662
扫帚的影子

Kafka的Request和Response

每个Request和Response都由RequestHeader(ResponseHeader) + 具体的消费体构成;

752
扫帚的影子

Kafka源码分析-网络层-2

这里面最主要的就是accept(key, processors(currentProcessor)) (4) accept: 设置新连接socket的参数后交...

741

扫码关注云+社区