@@ -1320,6 +1320,135 @@ proxier! {
13201320 r. extensions_mut( ) . insert( labels) ;
13211321 }
13221322 ) ;
1323+ (
1324+ describe_worker,
1325+ DescribeWorkerRequest ,
1326+ DescribeWorkerResponse ,
1327+ |r| {
1328+ let labels = namespaced_request!( r) ;
1329+ r. extensions_mut( ) . insert( labels) ;
1330+ }
1331+ ) ;
1332+ (
1333+ set_worker_deployment_manager,
1334+ SetWorkerDeploymentManagerRequest ,
1335+ SetWorkerDeploymentManagerResponse ,
1336+ |r| {
1337+ let labels = namespaced_request!( r) ;
1338+ r. extensions_mut( ) . insert( labels) ;
1339+ }
1340+ ) ;
1341+ (
1342+ start_activity_execution,
1343+ StartActivityExecutionRequest ,
1344+ StartActivityExecutionResponse ,
1345+ |r| {
1346+ let mut labels = namespaced_request!( r) ;
1347+ if let Some ( ref options) = r. get_ref( ) . options {
1348+ labels. task_q( options. task_queue. clone( ) ) ;
1349+ }
1350+ r. extensions_mut( ) . insert( labels) ;
1351+ }
1352+ ) ;
1353+ (
1354+ describe_activity_execution,
1355+ DescribeActivityExecutionRequest ,
1356+ DescribeActivityExecutionResponse ,
1357+ |r| {
1358+ let labels = namespaced_request!( r) ;
1359+ r. extensions_mut( ) . insert( labels) ;
1360+ }
1361+ ) ;
1362+ (
1363+ list_activity_executions,
1364+ ListActivityExecutionsRequest ,
1365+ ListActivityExecutionsResponse ,
1366+ |r| {
1367+ let labels = namespaced_request!( r) ;
1368+ r. extensions_mut( ) . insert( labels) ;
1369+ }
1370+ ) ;
1371+ (
1372+ count_activity_executions,
1373+ CountActivityExecutionsRequest ,
1374+ CountActivityExecutionsResponse ,
1375+ |r| {
1376+ let labels = namespaced_request!( r) ;
1377+ r. extensions_mut( ) . insert( labels) ;
1378+ }
1379+ ) ;
1380+ (
1381+ get_activity_execution_result,
1382+ GetActivityExecutionResultRequest ,
1383+ GetActivityExecutionResultResponse ,
1384+ |r| {
1385+ let labels = namespaced_request!( r) ;
1386+ r. extensions_mut( ) . insert( labels) ;
1387+ }
1388+ ) ;
1389+ (
1390+ request_cancel_activity_execution,
1391+ RequestCancelActivityExecutionRequest ,
1392+ RequestCancelActivityExecutionResponse ,
1393+ |r| {
1394+ let labels = namespaced_request!( r) ;
1395+ r. extensions_mut( ) . insert( labels) ;
1396+ }
1397+ ) ;
1398+ (
1399+ terminate_activity_execution,
1400+ TerminateActivityExecutionRequest ,
1401+ TerminateActivityExecutionResponse ,
1402+ |r| {
1403+ let labels = namespaced_request!( r) ;
1404+ r. extensions_mut( ) . insert( labels) ;
1405+ }
1406+ ) ;
1407+ (
1408+ delete_activity_execution,
1409+ DeleteActivityExecutionRequest ,
1410+ DeleteActivityExecutionResponse ,
1411+ |r| {
1412+ let labels = namespaced_request!( r) ;
1413+ r. extensions_mut( ) . insert( labels) ;
1414+ }
1415+ ) ;
1416+ (
1417+ pause_activity_execution,
1418+ PauseActivityExecutionRequest ,
1419+ PauseActivityExecutionResponse ,
1420+ |r| {
1421+ let labels = namespaced_request!( r) ;
1422+ r. extensions_mut( ) . insert( labels) ;
1423+ }
1424+ ) ;
1425+ (
1426+ unpause_activity_execution,
1427+ UnpauseActivityExecutionRequest ,
1428+ UnpauseActivityExecutionResponse ,
1429+ |r| {
1430+ let labels = namespaced_request!( r) ;
1431+ r. extensions_mut( ) . insert( labels) ;
1432+ }
1433+ ) ;
1434+ (
1435+ reset_activity_execution,
1436+ ResetActivityExecutionRequest ,
1437+ ResetActivityExecutionResponse ,
1438+ |r| {
1439+ let labels = namespaced_request!( r) ;
1440+ r. extensions_mut( ) . insert( labels) ;
1441+ }
1442+ ) ;
1443+ (
1444+ update_activity_execution_options,
1445+ UpdateActivityExecutionOptionsRequest ,
1446+ UpdateActivityExecutionOptionsResponse ,
1447+ |r| {
1448+ let labels = namespaced_request!( r) ;
1449+ r. extensions_mut( ) . insert( labels) ;
1450+ }
1451+ ) ;
13231452}
13241453
13251454proxier ! {
0 commit comments