prom-remote-api

Prometheus的Rust远程存储API。

使用

Prometheus远程存储API中有两个接口：写入/读取。

这两个接口都使用HTTP上的snappy压缩协议缓冲区编码。

此包提供了

• Rust绑定到prometheus远程存储协议缓冲区定义
• 各种Web框架实用工具，以提供远程线协议服务，由相应的功能门控器控制。可用功能
  • warp
  • actix
  • 将添加更多Web框架

任何第三方存储都可以通过实现RemoteStorage特质与Prometheus集成。

pub trait RemoteStorage: Sync {
    type Err: Send;
    type Context: Send + Sync;

    /// Write samples to remote storage.
    async fn write(&self, ctx: Self::Context, req: WriteRequest) -> Result<(), Self::Err>;

    /// Process one query within [ReadRequest](crate::types::ReadRequest).
    ///
    /// Note: Prometheus remote protocol sends multiple queries by default,
    /// use [read](crate::types::RemoteStorage::read) to serve ReadRequest.
    async fn process_query(
        &self,
        ctx: &Self::Context,
        q: Query,
    ) -> Result<QueryResult, Self::Err>;

    /// Read samples from remote storage.
    ///
    /// [ReadRequest](crate::types::ReadRequest) may contain more than one sub [queries](crate::types::Query).
    async fn read(
        &self,
        ctx: Self::Context,
        req: ReadRequest,
    ) -> Result<ReadResponse, Self::Err> {
        let results = futures::future::join_all(
            req.queries
                .into_iter()
                .map(|q| async { self.process_query(&ctx, q).await }),
        )
        .await
        .into_iter()
        .collect::<Result<Vec<_>, Self::Err>>()?;

        Ok(ReadResponse { results })
    }
}

请参阅warp-demo.rs，actix-demo.rs了解如何构建远程存储。