DurableClient class
用戶端,用於啟動、查詢、終止和引發事件至協調流程和實體實例。
屬性
| task |
在此協調流程用戶端實例上設定的工作中樞名稱。 |
方法
屬性詳細資料
taskHubName
在此協調流程用戶端實例上設定的工作中樞名稱。
taskHubName: string
屬性值
string
方法詳細資料
createCheckStatusResponse(undefined | HttpRequest, string)
建立用於檢查指定實例狀態的 HTTP 回應。
function createCheckStatusResponse(request: undefined | HttpRequest, instanceId: string): HttpResponse
參數
- request
-
undefined | HttpRequest
觸發目前協調流程實例的 HTTP 要求。
- instanceId
-
string
要檢查之協調流程實例的標識碼。
傳回
具有 Location 標頭的 HTTP 202 回應,以及包含實例管理 URL 的承載。
createHttpManagementPayload(string)
建立包含實例管理 HTTP 端點的 HttpManagementPayload 物件。
function createHttpManagementPayload(instanceId: string): HttpManagementPayload
參數
- instanceId
-
string
要檢查之協調流程實例的標識碼。
傳回
getStatus(string, GetStatusOptions)
取得指定協調流程實例的狀態。
function getStatus(instanceId: string, options?: GetStatusOptions): Promise<DurableOrchestrationStatus>
參數
- instanceId
-
string
要查詢之協調流程實例的標識碼。
- options
- GetStatusOptions
options 物件,指定額外的組態
傳回
Promise<DurableOrchestrationStatus>
getStatusAll()
取得所有協調流程實例的狀態。
function getStatusAll(): Promise<DurableOrchestrationStatus[]>
傳回
Promise<DurableOrchestrationStatus[]>
getStatusBy(OrchestrationFilter)
取得符合指定條件之所有協調流程實例的狀態。
function getStatusBy(filter: OrchestrationFilter): Promise<DurableOrchestrationStatus[]>
參數
- filter
- OrchestrationFilter
OrchestrationFilter 物件,指定要擷取的協調流程。
傳回
Promise<DurableOrchestrationStatus[]>
purgeInstanceHistory(string)
清除特定協調流程實例的歷程記錄。
function purgeInstanceHistory(instanceId: string): Promise<PurgeHistoryResult>
參數
- instanceId
-
string
要清除之協調流程實例的標識碼。
傳回
Promise<PurgeHistoryResult>
purgeInstanceHistoryBy(OrchestrationFilter)
清除符合條件之實例的協調流程歷程記錄。
function purgeInstanceHistoryBy(filter: OrchestrationFilter): Promise<PurgeHistoryResult>
參數
- filter
- OrchestrationFilter
OrchestrationFilter 物件,指定要清除的協調流程。
傳回
Promise<PurgeHistoryResult>
raiseEvent(string, string, unknown, TaskHubOptions)
將事件通知訊息傳送至等候的協調流程實例。
function raiseEvent(instanceId: string, eventName: string, eventData: unknown, options?: TaskHubOptions): Promise<void>
參數
- instanceId
-
string
將處理事件的協調流程實例標識碼。
- eventName
-
string
事件的名稱。
- eventData
-
unknown
與事件相關聯的 JSON 可串行化數據。
- options
- TaskHubOptions
物件,提供協調流程實例的TaskHubName及其相關聯連接字串的名稱
傳回
Promise<void>
承諾,會在事件通知訊息加入佇列時解決。
若要處理事件,目標協調流程實例必須使用 eventName等候名為 waitForExternalEvent(string) 的事件。
如果找不到指定的實例或未執行,此作業將不會有任何作用。
readEntityState<T>(EntityId, TaskHubOptions)
嘗試讀取實體的目前狀態。 如果實體不存在,或實體的 JSON 串行化狀態大於 16KB,則傳回未定義。
function readEntityState<T>(entityId: EntityId, options?: TaskHubOptions): Promise<EntityStateResponse<T>>
參數
- entityId
- EntityId
目標實體。
- options
- TaskHubOptions
選擇性物件,提供目標實體的TaskHubName及其相關聯連接字串的名稱
傳回
Promise<EntityStateResponse<T>>
包含實體目前狀態的回應。
rewind(string, string, TaskHubOptions)
以原因倒轉指定的失敗協調流程實例。
function rewind(instanceId: string, reason: string, options?: TaskHubOptions): Promise<void>
參數
- instanceId
-
string
要倒轉之協調流程實例的標識碼。
- reason
-
string
倒轉協調流程實例的原因。
- options
- TaskHubOptions
物件,提供協調流程實例的TaskHubName及其相關聯連接字串的名稱
傳回
Promise<void>
當倒轉訊息加入佇列時解析的承諾。
這項功能目前為預覽狀態。
signalEntity(EntityId, string, unknown, TaskHubOptions)
發出實體執行作業的訊號。
function signalEntity(entityId: EntityId, operationName?: string, operationContent?: unknown, options?: TaskHubOptions): Promise<void>
參數
- entityId
- EntityId
目標實體。
- operationName
-
string
作業的名稱。
- operationContent
-
unknown
作業的內容。
- options
- TaskHubOptions
物件,提供實體實例的TaskHubName及其相關聯連接字串的名稱
傳回
Promise<void>
startNew(string, StartNewOptions)
啟動指定協調器函式的新實例。
如果已存在具有指定標識符的協調流程實例,現有的實例將會以無訊息方式取代這個新實例。
function startNew(orchestratorFunctionName: string, options?: StartNewOptions): Promise<string>
參數
- orchestratorFunctionName
-
string
要啟動的協調器函式名稱。
- options
- StartNewOptions
選擇性物件來控制排程的協調器(例如提供輸入、instanceID)
傳回
Promise<string>
新協調流程實例的標識碼。
terminate(string, string)
終止執行中的協調流程實例。
function terminate(instanceId: string, reason: string): Promise<void>
參數
- instanceId
-
string
要終止之協調流程實例的標識碼。
- reason
-
string
終止協調流程實例的原因。
傳回
Promise<void>
在佇列終止訊息時解析的承諾。
終止協調流程實例不會影響目前協調流程實例啟動的任何即時活動函式執行或子協調流程。
waitForCompletionOrCreateCheckStatusResponse(HttpRequest, string, WaitForCompletionOptions)
建立 HTTP 回應,其中包含非已完成實例的管理 URL 承載,或包含包含已完成協調流程輸出的承載。
如果協調流程未在指定的逾時內完成,則 HTTP 回應會與 createCheckStatusResponse() 的回應相同。
function waitForCompletionOrCreateCheckStatusResponse(request: HttpRequest, instanceId: string, waitOptions?: WaitForCompletionOptions): Promise<HttpResponse>
參數
- request
- HttpRequest
觸發目前函式的 HTTP 要求。
- instanceId
-
string
要檢查之實例的唯一標識符。
- waitOptions
- WaitForCompletionOptions
options 物件,指定等候長期函式輸出的逾時時間,以及檢查輸出的頻率。
傳回
Promise<HttpResponse>