Question

SkyWalking 已经提供了多种存储解决方案. 在本文档中, 您可以学习如何轻松实现新存储.

定义您的存储提供者

1. 定义一个类扩展 org.apache.skywalking.oap.server.library.module.ModuleProvider。
2. 设置这个提供者为存储模块。

@Override
public Class<? extends ModuleDefine> module() {
    return StorageModule.class;
}

实现所有的 DAOs

下面是所有数据存储所需实现的 DAO 接口

• IServiceInventoryCacheDAO
• IServiceInstanceInventoryCacheDAO
• IEndpointInventoryCacheDAO
• INetworkAddressInventoryCacheDAO
• IBatchDAO
• StorageDAO
• IRegisterLockDAO
• ITopologyQueryDAO
• IMetricsQueryDAO
• ITraceQueryDAO
• IMetadataQueryDAO
• IAggregationQueryDAO
• IAlarmQueryDAO
• IHistoryDeleteDAO
• IMetricsDAO
• IRecordDAO
• IRegisterDAO
• ILogQueryDAO
• ITopNRecordsQueryDAO

注册所有的 service 实现

在 public void prepare() 方法中, 使用 this#registerServiceImplementation 方法去注册绑定您的接口实现.

样例

org.apache.skywalking.oap.server.storage.plugin.elasticsearch.StorageModuleElasticsearchProvider 或 org.apache.skywalking.oap.server.storage.plugin.jdbc.mysql.MySQLStorageProvider 是一个好的例子.

重新发布新的数据存储实现

您不必为了实现数据存储而克隆主托管库, 您可以轻松地依赖我们的 Apache 发布版本. 看一下 OpenSkywalking/SkyWalking-With-Es5x-Storage 仓库, SkyWalking v6 重新发布 ElasticSearch 5 TCP 链接数据存储的实现.