Async Mesos

这是一个用于 Mesos V1 HTTP 调度器 API 的异步客户端。查看文档或测试以开始使用。

lib.rs:

异步 Mesos 客户端

此软件包提供对 Mesos 调度器 HTTP API 的异步客户端。

安装

只需将依赖项添加到您的 Cargo.toml

[dependencies]
async_mesos = 0.1

入门

use async_mesos::mesos;
use async_mesos::client::Client;
use futures::{future, Future, Stream};
use hyper::Uri;
use tokio_core::reactor::Core;

// Create a Tokio core handle.
let mut core = Core::new().expect("Could not create core.");
let handle = core.handle();

// Create the Mesos framework info to register a new framework.
let mut framework_info = mesos::FrameworkInfo::new();
framework_info.set_user(String::from("donnie"));
framework_info.set_name(String::from("Example FOO Framework"));

// Connect to Mesos scheduler API.
let uri = "https://127.0.0.1:5050/api/v1/scheduler"
    .parse::<Uri>()
    .expect("Could not parse Uri.");
let future_client = Client::connect(&handle, uri, framework_info);

// Process first HEARTBEAT event
let work = future_client
    .into_stream()
    .map(|(_, events)| events)
    .flatten()
    .map(|event| event.get_field_type())
    .take(1)
    .collect();

core.run(work).unwrap();