Expose OperatorService client (#902)

client/client.go

@@ -36,6 +36,7 @@ import (
 	commonpb "go.temporal.io/api/common/v1"
 	enumspb "go.temporal.io/api/enums/v1"
 	historypb "go.temporal.io/api/history/v1"
+	"go.temporal.io/api/operatorservice/v1"
 	"go.temporal.io/api/workflowservice/v1"
 
 	"go.temporal.io/sdk/converter"
@@ -385,6 +386,9 @@ type (
 		// service are not configured with internal semantics such as automatic retries.
 		WorkflowService() workflowservice.WorkflowServiceClient
 
+		// OperatorService creates a new operator service client with the same gRPC connection as this client.
+		OperatorService() operatorservice.OperatorServiceClient
+
 		// Close client and clean up underlying resources.
 		//
 		// If this client was created via NewClientFromExisting or this client has

internal/client.go

@@ -33,6 +33,7 @@ import (
 
 	commonpb "go.temporal.io/api/common/v1"
 	enumspb "go.temporal.io/api/enums/v1"
+	"go.temporal.io/api/operatorservice/v1"
 	"go.temporal.io/api/workflowservice/v1"
 	uberatomic "go.uber.org/atomic"
 	"google.golang.org/grpc"
@@ -344,6 +345,9 @@ type (
 		// service are not configured with internal semantics such as automatic retries.
 		WorkflowService() workflowservice.WorkflowServiceClient
 
+		// OperatorService creates a new operator service client with the same gRPC connection as this client.
+		OperatorService() operatorservice.OperatorServiceClient
+
 		// Close client and clean up underlying resources.
 		Close()
 	}

internal/internal_workflow_client.go

@@ -39,6 +39,7 @@ import (
 	commonpb "go.temporal.io/api/common/v1"
 	enumspb "go.temporal.io/api/enums/v1"
 	historypb "go.temporal.io/api/history/v1"
+	"go.temporal.io/api/operatorservice/v1"
 	querypb "go.temporal.io/api/query/v1"
 	"go.temporal.io/api/serviceerror"
 	taskqueuepb "go.temporal.io/api/taskqueue/v1"
@@ -902,6 +903,11 @@ func (wc *WorkflowClient) WorkflowService() workflowservice.WorkflowServiceClien
 	return wc.workflowService
 }
 
+// OperatorService implements Client.OperatorService.
+func (wc *WorkflowClient) OperatorService() operatorservice.OperatorServiceClient {
+	return operatorservice.NewOperatorServiceClient(wc.conn)
+}
+
 // Get capabilities, lazily fetching from server if not already obtained.
 func (wc *WorkflowClient) loadCapabilities() (*workflowservice.GetSystemInfoResponse_Capabilities, error) {
 	// While we want to memoize the result here, we take care not to lock during