Add Stubs for Workflow Rules

temporalio · Feb 12, 2025 · 1ab8065 · 1ab8065
1 parent baf84d8
commit 1ab8065
Show file tree

Hide file tree

Showing 12 changed files with 274 additions and 3 deletions.
diff --git a/client/frontend/client_gen.go b/client/frontend/client_gen.go
diff --git a/client/frontend/metric_client_gen.go b/client/frontend/metric_client_gen.go
diff --git a/client/frontend/retryable_client_gen.go b/client/frontend/retryable_client_gen.go
diff --git a/cmd/tools/getproto/files.go b/cmd/tools/getproto/files.go
diff --git a/common/api/metadata.go b/common/api/metadata.go
@@ -158,6 +158,10 @@ var (
 		"DeleteWorkerDeploymentVersion":         {Scope: ScopeNamespace, Access: AccessWrite},
 		"UpdateWorkerDeploymentVersionMetadata": {Scope: ScopeNamespace, Access: AccessWrite},
 		"ListWorkerDeployments":                 {Scope: ScopeNamespace, Access: AccessReadOnly},
+		"CreateWorkflowRule":                    {Scope: ScopeNamespace, Access: AccessReadOnly},
+		"DescribeWorkflowRule":                  {Scope: ScopeNamespace, Access: AccessReadOnly},
+		"DeleteWorkflowRule":                    {Scope: ScopeNamespace, Access: AccessReadOnly},
+		"ListWorkflowRules":                     {Scope: ScopeNamespace, Access: AccessReadOnly},
 	}
 	operatorServiceMetadata = map[string]MethodMetadata{
 		"AddSearchAttributes":      {Scope: ScopeNamespace, Access: AccessAdmin},

diff --git a/common/rpc/interceptor/logtags/workflow_service_server_gen.go b/common/rpc/interceptor/logtags/workflow_service_server_gen.go
diff --git a/common/rpc/interceptor/redirection.go b/common/rpc/interceptor/redirection.go
@@ -146,6 +146,11 @@ var (
 		"DeleteWorkerDeployment":                func() any { return &workflowservice.DeleteWorkerDeploymentResponse{} },
 		"DeleteWorkerDeploymentVersion":         func() any { return &workflowservice.DeleteWorkerDeploymentVersionResponse{} },
 		"UpdateWorkerDeploymentVersionMetadata": func() any { return &workflowservice.UpdateWorkerDeploymentVersionMetadataResponse{} },
+
+		"CreateWorkflowRule":   func() any { return &workflowservice.CreateWorkflowRuleResponse{} },
+		"DescribeWorkflowRule": func() any { return &workflowservice.DescribeWorkflowRuleResponse{} },
+		"DeleteWorkflowRule":   func() any { return &workflowservice.DeleteWorkflowRuleResponse{} },
+		"ListWorkflowRules":    func() any { return &workflowservice.ListWorkflowRulesResponse{} },
 	}
 )
 

diff --git a/common/rpc/interceptor/redirection_test.go b/common/rpc/interceptor/redirection_test.go
@@ -202,6 +202,10 @@ func (s *redirectionInterceptorSuite) TestGlobalAPI() {
 		"DeleteWorkerDeployment":                {},
 		"DeleteWorkerDeploymentVersion":         {},
 		"UpdateWorkerDeploymentVersionMetadata": {},
+		"CreateWorkflowRule":                    {},
+		"DescribeWorkflowRule":                  {},
+		"DeleteWorkflowRule":                    {},
+		"ListWorkflowRules":                     {},
 	}, apis)
 }