Skip to content

Latest commit

 

History

History
46 lines (33 loc) · 1.54 KB

storage-extention.md

File metadata and controls

46 lines (33 loc) · 1.54 KB
Raw

数据存储扩展

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

定义您的存储提供者

  1. 定义一个类扩展 org.apache.skywalking.oap.server.library.module.ModuleProvider.
  2. 让此存储提供者继承存储模块(StorageModule).
@Override 
public Class<? extends ModuleDefine> module() {
    return StorageModule.class;
}

实现所有 DAO 接口

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

  1. IServiceInventoryCacheDAO
  2. IServiceInstanceInventoryCacheDAO
  3. IEndpointInventoryCacheDAO
  4. INetworkAddressInventoryCacheDAO
  5. IBatchDAO
  6. StorageDAO
  7. IRegisterLockDAO
  8. ITopologyQueryDAO
  9. IMetricQueryDAO
  10. ITraceQueryDAO
  11. IMetadataQueryDAO
  12. IAggregationQueryDAO
  13. IAlarmQueryDAO
  14. IHistoryDeleteDAO

注册所有的 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 链接数据存储的实现.