blob: 09216abf6f9536bfbd75bceaecee1c3104810d95 [file] [log] [blame]
/**
* Copyright 2019 WeBank
*
* Licensed under the Apache License, Version 2.0 (the "License");
* you may not use this file except in compliance with the License.
* You may obtain a copy of the License at
*
* http://www.apache.org/licenses/LICENSE-2.0
*
* Unless required by applicable law or agreed to in writing, software
* distributed under the License is distributed on an "AS IS" BASIS,
* WITHOUT WARRANTIES OR CONDITIONS OF ANY KIND, either express or implied.
* See the License for the specific language governing permissions and
* limitations under the License.
*/
package com.webank.wedatasphere.linkis.cs.client.http
import com.webank.wedatasphere.linkis.cs.listener.callback.imp.ContextKeyValueBean
import com.webank.wedatasphere.linkis.httpclient.dws.annotation.DWSHttpMessageResult
import com.webank.wedatasphere.linkis.httpclient.dws.response.DWSResult
/**
* created by cooperyang on 2020/2/11
* Description:
*/
abstract class ContextResult extends DWSResult
@DWSHttpMessageResult("/api/rest_j/v\\d+/contextservice/createContextID")
class ContextCreateResult extends ContextResult {
var contextId:String = _
def setContextId(contextId:String):Unit = this.contextId = contextId
def getContextId:String = this.contextId
}
@DWSHttpMessageResult("/api/rest_j/v\\d+/contextservice/resetValue")
class ContextResetResult extends ContextResult {
}
@DWSHttpMessageResult("/api/rest_j/v\\d+/contextservice/setValueByKey")
class ContextUpdateResult extends ContextResult {
}
@DWSHttpMessageResult("/api/rest_j/v\\d+/contextservice/getContext")
class ContextGetResult extends ContextResult {
var contextId:String = _
var contextKeyValues:java.util.Map[String, String] = _
def setContextId(contextId:String):Unit = this.contextId = contextId
def getContextId:String = this.contextId
def setContextKeyValues(kvs:java.util.Map[String,String]):Unit = this.contextKeyValues = kvs
def getContextKeyValues:java.util.Map[String, String] = this.contextKeyValues
}
@DWSHttpMessageResult("/api/rest_j/v\\d+/contextservice/removeValue")
class ContextRemoveResult extends ContextResult {
}
@DWSHttpMessageResult("/api/rest_j/v\\d+/contextservice/heartbeat")
class ContextHeartBeatResult extends ContextResult {
import java.util
var contextKeyValueBeans:util.List[ContextKeyValueBean] = _
def setContextKeyValueBeans(kvs:util.List[ContextKeyValueBean]):Unit = this.contextKeyValueBeans= kvs
def getContextKeyValueBeans:util.List[ContextKeyValueBean] = this.contextKeyValueBeans;
}
@DWSHttpMessageResult("/api/rest_j/v\\d+/contextservice/setValue")
class ContextSetKeyValueResult extends ContextResult {
}
@DWSHttpMessageResult("/api/rest_j/v\\d+/contextservice/removeAllValue")
class ContextResetIDResult extends ContextResult {
}
@DWSHttpMessageResult("/api/rest_j/v\\d+/contextservice/removeValue")
class ContextRemoveValueResult extends ContextResult {
}
@DWSHttpMessageResult("/api/rest_j/v\\d+/contextservice/onBindIDListener")
class ContextBindIDResult extends ContextResult {
}
@DWSHttpMessageResult("/api/rest_j/v\\d+/contextservice/onBindKeyListener")
class ContextBindKeyResult extends ContextResult {
}
@DWSHttpMessageResult("/api/rest_j/v\\d+/contextservice/searchContextValue")
class ContextSearchResult extends ContextResult {
}
@DWSHttpMessageResult("/api/rest_j/v\\d+/contextservice/getContextValue")
class ContextGetValueResult extends ContextResult {
}
// TODO: 用来匹配所有的void 不需要处理返回值的result
@DWSHttpMessageResult("/api/rest_j/v\\d+/contextservice/(createHistory|removeHistory|removeAllValueByKeyPrefix|removeAllValueByKeyPrefixAndContextType)")
class VoidResult extends ContextResult {
}
@DWSHttpMessageResult("/api/rest_j/v\\d+/contextservice/(getHistories|searchHistory)")
class ContextHistoriesGetResult extends ContextResult {
var contextHistory:java.util.List[String] = _
def getContextHistory:java.util.List[String] = this.contextHistory
def setContextHistory(contextHistory:java.util.List[String])= this.contextHistory = contextHistory
}
@DWSHttpMessageResult("/api/rest_j/v\\d+/contextservice/getHistory")
class ContextHistoryGetResult extends ContextResult {
var contextHistory:String = _
def getContextHistory:String = this.contextHistory
def setContextHistory(contextHistory:String)= this.contextHistory = contextHistory
}