34
localAPIResponses = map[string]responseConstructorFn{
35
// Namespace APIs, namespace APIs does not require redirection
36
>
"DeprecateNamespace": func() any { return &workflowservice.DeprecateNamespaceResponse{} },
redirection.go
37
>
"DescribeNamespace": func() any { return &workflowservice.DescribeNamespaceResponse{} },
38
>
"ListNamespaces": func() any { return &workflowservice.ListNamespacesResponse{} },
39
>
"RegisterNamespace": func() any { return &workflowservice.RegisterNamespaceResponse{} },
40
>
"UpdateNamespace": func() any { return &workflowservice.UpdateNamespaceResponse{} },
41
42
// Cluster info APIs, Cluster info APIs does not require redirection
43
>
"GetSearchAttributes": func() any { return &workflowservice.GetSearchAttributesResponse{} },
redirection.go
44
>
"GetClusterInfo": func() any { return &workflowservice.GetClusterInfoResponse{} },
45
>
"GetSystemInfo": func() any { return &workflowservice.GetSystemInfoResponse{} },
46
}
47
48
globalAPIResponses = map[string]responseConstructorFn{
49
>
"DescribeTaskQueue": func() any { return &workflowservice.DescribeTaskQueueResponse{} },
redirection.go
50
>
"DescribeWorkflowExecution": func() any { return &workflowservice.DescribeWorkflowExecutionResponse{} },
51
>
"GetWorkflowExecutionHistory": func() any { return &workflowservice.GetWorkflowExecutionHistoryResponse{} },
52
>
"GetWorkflowExecutionHistoryReverse": func() any { return &workflowservice.GetWorkflowExecutionHistoryReverseResponse{} },
53
>
"ListArchivedWorkflowExecutions": func() any { return &workflowservice.ListArchivedWorkflowExecutionsResponse{} },
54
>
"ListClosedWorkflowExecutions": func() any { return &workflowservice.ListClosedWorkflowExecutionsResponse{} },
55
>
"ListOpenWorkflowExecutions": func() any { return &workflowservice.ListOpenWorkflowExecutionsResponse{} },
56
>
"ListWorkflowExecutions": func() any { return &workflowservice.ListWorkflowExecutionsResponse{} },
57
>
"ScanWorkflowExecutions": func() any { return &workflowservice.ScanWorkflowExecutionsResponse{} },
58
>
"CountWorkflowExecutions": func() any { return &workflowservice.CountWorkflowExecutionsResponse{} },
59
>
"PollActivityTaskQueue": func() any { return &workflowservice.PollActivityTaskQueueResponse{} },
60
>
"PollWorkflowTaskQueue": func() any { return &workflowservice.PollWorkflowTaskQueueResponse{} },
61
>
"PollNexusTaskQueue": func() any { return &workflowservice.PollNexusTaskQueueResponse{} },
62
>
"QueryWorkflow": func() any { return &workflowservice.QueryWorkflowResponse{} },
63
>
"RecordActivityTaskHeartbeat": func() any { return &workflowservice.RecordActivityTaskHeartbeatResponse{} },
64
>
"RecordActivityTaskHeartbeatById": func() any { return &workflowservice.RecordActivityTaskHeartbeatByIdResponse{} },
65
>
"RequestCancelWorkflowExecution": func() any { return &workflowservice.RequestCancelWorkflowExecutionResponse{} },
66
>
"ResetStickyTaskQueue": func() any { return &workflowservice.ResetStickyTaskQueueResponse{} },
67
>
"ShutdownWorker": func() any { return &workflowservice.ShutdownWorkerResponse{} },
68
>
"ResetWorkflowExecution": func() any { return &workflowservice.ResetWorkflowExecutionResponse{} },
69
>
"RespondActivityTaskCanceled": func() any { return &workflowservice.RespondActivityTaskCanceledResponse{} },
70
>
"RespondActivityTaskCanceledById": func() any { return &workflowservice.RespondActivityTaskCanceledByIdResponse{} },
71
>
"RespondActivityTaskCompleted": func() any { return &workflowservice.RespondActivityTaskCompletedResponse{} },
72
>
"RespondActivityTaskCompletedById": func() any { return &workflowservice.RespondActivityTaskCompletedByIdResponse{} },
73
>
"RespondActivityTaskFailed": func() any { return &workflowservice.RespondActivityTaskFailedResponse{} },
74
>
"RespondActivityTaskFailedById": func() any { return &workflowservice.RespondActivityTaskFailedByIdResponse{} },
75
>
"RespondWorkflowTaskCompleted": func() any { return &workflowservice.RespondWorkflowTaskCompletedResponse{} },
76
>
"RespondWorkflowTaskFailed": func() any { return &workflowservice.RespondWorkflowTaskFailedResponse{} },
77
>
"RespondQueryTaskCompleted": func() any { return &workflowservice.RespondQueryTaskCompletedResponse{} },
78
>
"RespondNexusTaskCompleted": func() any { return &workflowservice.RespondNexusTaskCompletedResponse{} },
79
>
"RespondNexusTaskFailed": func() any { return &workflowservice.RespondNexusTaskFailedResponse{} },
80
"SignalWithStartWorkflowExecution": func() any { return &workflowservice.SignalWithStartWorkflowExecutionResponse{} },
81
>
"SignalWorkflowExecution": func() any { return &workflowservice.SignalWorkflowExecutionResponse{} },
redirection.go
82
>
"StartWorkflowExecution": func() any { return &workflowservice.StartWorkflowExecutionResponse{} },
83
>
"ExecuteMultiOperation": func() any { return &workflowservice.ExecuteMultiOperationResponse{} },
84
>
"UpdateWorkflowExecution": func() any { return &workflowservice.UpdateWorkflowExecutionResponse{} },
85
>
"PollWorkflowExecutionUpdate": func() any { return &workflowservice.PollWorkflowExecutionUpdateResponse{} },
86
>
"TerminateWorkflowExecution": func() any { return &workflowservice.TerminateWorkflowExecutionResponse{} },
87
>
"DeleteWorkflowExecution": func() any { return &workflowservice.DeleteWorkflowExecutionResponse{} },
88
>
"ListTaskQueuePartitions": func() any { return &workflowservice.ListTaskQueuePartitionsResponse{} },
89
>
"PauseWorkflowExecution": func() any { return &workflowservice.PauseWorkflowExecutionResponse{} },
90
>
"UnpauseWorkflowExecution": func() any { return &workflowservice.UnpauseWorkflowExecutionResponse{} },
91
92
>
"CreateSchedule": func() any { return &workflowservice.CreateScheduleResponse{} },
redirection.go
93
>
"DescribeSchedule": func() any { return &workflowservice.DescribeScheduleResponse{} },
94
>
"UpdateSchedule": func() any { return &workflowservice.UpdateScheduleResponse{} },
95
>
"PatchSchedule": func() any { return &workflowservice.PatchScheduleResponse{} },
96
>
"DeleteSchedule": func() any { return &workflowservice.DeleteScheduleResponse{} },
97
>
"ListSchedules": func() any { return &workflowservice.ListSchedulesResponse{} },
98
>
"CountSchedules": func() any { return &workflowservice.CountSchedulesResponse{} },
99
>
"ListScheduleMatchingTimes": func() any { return &workflowservice.ListScheduleMatchingTimesResponse{} },
100
>
"UpdateWorkerBuildIdCompatibility": func() any { return &workflowservice.UpdateWorkerBuildIdCompatibilityResponse{} },
101
>
"GetWorkerBuildIdCompatibility": func() any { return &workflowservice.GetWorkerBuildIdCompatibilityResponse{} },
102
>
"UpdateWorkerVersioningRules": func() any { return &workflowservice.UpdateWorkerVersioningRulesResponse{} },
103
>
"GetWorkerVersioningRules": func() any { return &workflowservice.GetWorkerVersioningRulesResponse{} },
104
>
"GetWorkerTaskReachability": func() any { return &workflowservice.GetWorkerTaskReachabilityResponse{} },
105
106
>
"StartBatchOperation": func() any { return &workflowservice.StartBatchOperationResponse{} },
redirection.go
107
>
"StopBatchOperation": func() any { return &workflowservice.StopBatchOperationResponse{} },
108
>
"DescribeBatchOperation": func() any { return &workflowservice.DescribeBatchOperationResponse{} },
109
>
"ListBatchOperations": func() any { return &workflowservice.ListBatchOperationsResponse{} },
110
>
"UpdateActivityOptions": func() any { return &workflowservice.UpdateActivityOptionsResponse{} },
111
>
"PauseActivity": func() any { return &workflowservice.PauseActivityResponse{} },
112
>
"UnpauseActivity": func() any { return &workflowservice.UnpauseActivityResponse{} },
113
>
"ResetActivity": func() any { return &workflowservice.ResetActivityResponse{} },
114
>
"UpdateActivityExecutionOptions": func() any { return &workflowservice.UpdateActivityExecutionOptionsResponse{} },
115
>
"PauseActivityExecution": func() any { return &workflowservice.PauseActivityExecutionResponse{} },
116
>
"UnpauseActivityExecution": func() any { return &workflowservice.UnpauseActivityExecutionResponse{} },
117
>
"ResetActivityExecution": func() any { return &workflowservice.ResetActivityExecutionResponse{} },
118
>
"UpdateWorkflowExecutionOptions": func() any { return &workflowservice.UpdateWorkflowExecutionOptionsResponse{} },
119
120
>
"DescribeDeployment": func() any { return &workflowservice.DescribeDeploymentResponse{} }, // [cleanup-wv-pre-release]
redirection.go
121
>
"ListDeployments": func() any { return &workflowservice.ListDeploymentsResponse{} }, // [cleanup-wv-pre-release]
122
>
"GetDeploymentReachability": func() any { return &workflowservice.GetDeploymentReachabilityResponse{} }, // [cleanup-wv-pre-release]
123
>
"GetCurrentDeployment": func() any { return &workflowservice.GetCurrentDeploymentResponse{} }, // [cleanup-wv-pre-release]
124
>
"SetCurrentDeployment": func() any { return &workflowservice.SetCurrentDeploymentResponse{} }, // [cleanup-wv-pre-release]
125
>
"DescribeWorkerDeployment": func() any { return &workflowservice.DescribeWorkerDeploymentResponse{} },
126
>
"DescribeWorkerDeploymentVersion": func() any { return &workflowservice.DescribeWorkerDeploymentVersionResponse{} },
127
>
"SetWorkerDeploymentCurrentVersion": func() any { return &workflowservice.SetWorkerDeploymentCurrentVersionResponse{} },
128
>
"SetWorkerDeploymentRampingVersion": func() any { return &workflowservice.SetWorkerDeploymentRampingVersionResponse{} },
129
>
"SetWorkerDeploymentManager": func() any { return &workflowservice.SetWorkerDeploymentManagerResponse{} },
130
>
"ListWorkerDeployments": func() any { return &workflowservice.ListWorkerDeploymentsResponse{} },
131
>
"CreateWorkerDeployment": func() any { return &workflowservice.CreateWorkerDeploymentResponse{} },
132
>
"DeleteWorkerDeployment": func() any { return &workflowservice.DeleteWorkerDeploymentResponse{} },
133
>
"CreateWorkerDeploymentVersion": func() any { return &workflowservice.CreateWorkerDeploymentVersionResponse{} },
134
>
"UpdateWorkerDeploymentVersionComputeConfig": func() any { return &workflowservice.UpdateWorkerDeploymentVersionComputeConfigResponse{} },
135
>
"ValidateWorkerDeploymentVersionComputeConfig": func() any { return &workflowservice.ValidateWorkerDeploymentVersionComputeConfigResponse{} },
136
>
"DeleteWorkerDeploymentVersion": func() any { return &workflowservice.DeleteWorkerDeploymentVersionResponse{} },
137
>
"UpdateWorkerDeploymentVersionMetadata": func() any { return &workflowservice.UpdateWorkerDeploymentVersionMetadataResponse{} },
138
139
>
"CreateWorkflowRule": func() any { return &workflowservice.CreateWorkflowRuleResponse{} },
redirection.go
140
>
"DescribeWorkflowRule": func() any { return &workflowservice.DescribeWorkflowRuleResponse{} },
141
>
"DeleteWorkflowRule": func() any { return &workflowservice.DeleteWorkflowRuleResponse{} },
142
>
"ListWorkflowRules": func() any { return &workflowservice.ListWorkflowRulesResponse{} },
143
>
"TriggerWorkflowRule": func() any { return &workflowservice.TriggerWorkflowRuleResponse{} },
144
>
"RecordWorkerHeartbeat": func() any { return &workflowservice.RecordWorkerHeartbeatResponse{} },
145
>
"ListWorkers": func() any { return &workflowservice.ListWorkersResponse{} },
146
>
"CountWorkers": func() any { return &workflowservice.CountWorkersResponse{} },
147
>
"DescribeWorker": func() any { return &workflowservice.DescribeWorkerResponse{} },
148
>
"UpdateTaskQueueConfig": func() any { return &workflowservice.UpdateTaskQueueConfigResponse{} },
149
>
"FetchWorkerConfig": func() any { return &workflowservice.FetchWorkerConfigResponse{} },
150
>
"UpdateWorkerConfig": func() any { return &workflowservice.UpdateWorkerConfigResponse{} },
151
152
>
"StartActivityExecution": func() any { return &workflowservice.StartActivityExecutionResponse{} },
redirection.go
153
>
"CountActivityExecutions": func() any { return &workflowservice.CountActivityExecutionsResponse{} },
154
>
"ListActivityExecutions": func() any { return &workflowservice.ListActivityExecutionsResponse{} },
155
>
"DescribeActivityExecution": func() any { return &workflowservice.DescribeActivityExecutionResponse{} },
156
>
"PollActivityExecution": func() any { return &workflowservice.PollActivityExecutionResponse{} },
157
>
"RequestCancelActivityExecution": func() any { return &workflowservice.RequestCancelActivityExecutionResponse{} },
158
>
"TerminateActivityExecution": func() any { return &workflowservice.TerminateActivityExecutionResponse{} },
159
>
"DeleteActivityExecution": func() any { return &workflowservice.DeleteActivityExecutionResponse{} },
160
161
>
"CountNexusOperationExecutions": func() any { return &workflowservice.CountNexusOperationExecutionsResponse{} },
redirection.go
162
>
"DeleteNexusOperationExecution": func() any { return &workflowservice.DeleteNexusOperationExecutionResponse{} },
163
>
"DescribeNexusOperationExecution": func() any { return &workflowservice.DescribeNexusOperationExecutionResponse{} },
164
>
"ListNexusOperationExecutions": func() any { return &workflowservice.ListNexusOperationExecutionsResponse{} },
165
>
"PollNexusOperationExecution": func() any { return &workflowservice.PollNexusOperationExecutionResponse{} },
166
>
"RequestCancelNexusOperationExecution": func() any { return &workflowservice.RequestCancelNexusOperationExecutionResponse{} },
167
>
"StartNexusOperationExecution": func() any { return &workflowservice.StartNexusOperationExecutionResponse{} },
168
>
"TerminateNexusOperationExecution": func() any { return &workflowservice.TerminateNexusOperationExecutionResponse{} },
169
}
170
)