Package com.infoteria.asteria.flowengine2.thinclient

Class FlowAdminClient

java.lang.Object
com.infoteria.asteria.flowengine2.thinclient.AsteriaClient
com.infoteria.asteria.flowengine2.thinclient.FlowAdminClient
public class FlowAdminClient extends AsteriaClient
リクエストの取得や強制終了を行うためのクライアントクラスです。

  • Constructor Details

    • FlowAdminClient

      public FlowAdminClient(String url) throws MalformedURLException
      ASTERIAサーバーのURLを指定してクライアントを作成します。
      特に変更していない場合、URLは「http://<SERVERNAME>:21381/flow-rpc」となります。
      Throws:
      MalformedURLException

    • FlowAdminClient

      public FlowAdminClient(String server, int port) throws MalformedURLException
      ASTERIAサーバーのサーバー名とポート番号を指定してクライアントを作成します。
      Parameters:
      server - サーバー名またはIPアドレス
      port - ポート番号
      Throws:
      MalformedURLException

    • FlowAdminClient

      public FlowAdminClient(AsteriaClient client)
      別のASTERIAクライアントから接続先情報とログイン状態を引き継いでクライアントを作成します。
      Parameters:
      client - ログイン済みのAsteriaClient

  • Method Details

    • getRequestList

      public RequestInfo[] getRequestList() throws FlowClientException
      リクエスト一覧を取得します。
      Returns:
      リクエスト情報の配列
      Throws:
      FlowClientException

    • getWorkerList

      public RequestInfo[] getWorkerList() throws FlowClientException
      ワーカー一覧を取得します。
      Returns:
      リクエスト情報の配列
      Throws:
      FlowClientException

    • showRequest

      public RunningStatus showRequest(String requestId) throws FlowClientException
      実行中のリクエストの状態を取得します。
      Parameters:
      requestId - リクエストID
      Returns:
      実行情報
      Throws:
      FlowClientException

    • killRequest

      public String killRequest(String requestId) throws FlowClientException
      リクエストを強制終了します
      Parameters:
      requestId - リクエストID
      Returns:
      強制終了に成功した場合に最後に実行したコンポーネントのフルネーム
      Throws:
      FlowClientException

    • getRequestWithCheckPoint

      public CheckPointInfo[] getRequestWithCheckPoint(String yyyyMMdd, String requestId, String serverId, String ownerDomain, String ownerName, String project, String flow, String checkPointStatus, String requestStatus, String sortKey, int start, int size) throws FlowClientException
      チェックポイントフローのリクエストの一覧を取得します。
      Parameters:
      yyyyMMdd - 年月日
      requestId - リクエストID
      serverId - 担当サーバーID
      ownerDomain - プロジェクトオーナーdomain
      ownerName - プロジェクトオーナーname
      project - プロジェクト名
      flow - フロー名
      checkPointStatus - チェックポイントステータス
      requestStatus - リクエストステータス
      sortKey - ソートキー
      start - 開始番号
      size - リスト数
      Returns:
      チェックポイント情報の配列
      Throws:
      FlowClientException

    • getServerList

      public ServerInfo[] getServerList() throws FlowClientException
      サーバー一覧を取得します。
      Returns:
      サーバー情報の配列
      Throws:
      FlowClientException