jp.go.nict.langrid.servicesupervisor.invocationprocessor.executor.intragrid.balancer
クラス MinLatencyBalancer

java.lang.Object
  jp.go.nict.langrid.servicesupervisor.invocationprocessor.executor.intragrid.balancer.MinLatencyBalancer

すべての実装されたインタフェース:

Balancer

public class MinLatencyBalancer
extends Object
implements Balancer

応答時間が最小の物を選択するバランサー。 endpointsの要素数が0であればnullを返す。 選択されたエンドポイントの累計呼び出し回数の平方根より少ない累計呼び出し回数を持つ エンドポイントが他にあれば、それを呼び出す。

バージョン:

$Revision: 12092 $

作成者:

$Author: Takao Nakaguchi $

コンストラクタの概要

MinLatencyBalancer()

メソッドの概要

ServiceEndpoint	balance(String serviceId, List<ServiceEndpoint> endpoints) エンドポイント間の均衡をとり、呼び出すエンドポイントを決定する。
void	failed(ServiceEndpoint endpoint, long delta, int responceCode, Exception exception)
void	succeeded(ServiceEndpoint endpoint, long delta, int responceCode)

クラス java.lang.Object から継承されたメソッド

clone, equals, finalize, getClass, hashCode, notify, notifyAll, toString, wait, wait, wait

コンストラクタの詳細

MinLatencyBalancer

public MinLatencyBalancer()

メソッドの詳細

balance

public ServiceEndpoint balance(String serviceId,
                               List<ServiceEndpoint> endpoints)

インタフェース Balancer の記述:

エンドポイント間の均衡をとり、呼び出すエンドポイントを決定する。 決定したエンドポイントの呼び出し時にエラーが発生した場合、そのエンドポイントが 取り除かれた上で再度呼び出される。 このメソッド内でエンドポイントの情報を更新しても、反映される保証はない。

定義:

インタフェース Balancer 内の balance

パラメータ:

serviceId - サービスID

endpoints - エンドポイント

戻り値:

エンドポイント

succeeded

public void succeeded(ServiceEndpoint endpoint,
                      long delta,
                      int responceCode)

定義:

インタフェース Balancer 内の succeeded

failed

public void failed(ServiceEndpoint endpoint,
                   long delta,
                   int responceCode,
                   Exception exception)

定義:

インタフェース Balancer 内の failed