2017-04-10 26 views
0

mesos-rxjavaライブラリでMesosタスクを終了させたり、フレームワークをシャットダウンする方法を探しています。 subscribe()の後、メゾスからのイベントに応じて、メゾスにコールを送信する唯一の機会があります。私は、Fenzoを別のスケジューリング・ループに統合することができました。これは、PromiseからObservableを使用してオファー・リースに応答し、Fenzoループの約束を保存することで可能です。その仕事を打ち負かすことを約束してください。しかし、まだ開始していないタスクを取り消すことはできませんし、フレームワークをシャットダウンするために解決しません。または、単に非反応的な方法でHTTPリクエストを送信するためにライブラリの認証を使用する方法がありますか?私が紛失しているクリーナーソリューションはありますか?mesos-rxjava - タスクとシャットダウンスケジューラを終了する

答えて

1

私はここでTEARDOWN Call [1]を呼び出しています。このコールがスケジューラからmesosに送信されると、クラスタ全体でフレームワークが完全にシャットダウンされます。

mesos-rxjavaクライアントに提供するObservable(Observablesを下のリンク2にまとめて織り成す例があります)にSubjectを織り込むことで、自分自身にハンドルを提供して、イベントへの直接的な反応。下のリンク3はこれをもう少し説明するGithubの問題へのリンクです。

[1] https://github.com/apache/mesos/blob/master/docs/scheduler-http-api.md#teardown
[2] https://github.com/mesosphere/mesos-rxjava/blob/master/mesos-rxjava-example/mesos-rxjava-example-framework/src/main/java/com/mesosphere/mesos/rx/java/example/framework/sleepy/Sleepy.java#L140
[3] https://github.com/mesosphere/mesos-rxjava/pull/63#issuecomment-235043568

関連する問題