tasks/client/admin/client_gen.go at release/v1.28.x

mirror of https://github.com/hanzoai/tasks.git synced 2026-10-04 02:04:03 +00:00

Files

T

Alex ShtinandGitHub f73d049392 Refactor code generators (#7734 )

## What changed?
Refactor code generators:
1. Extracted templates to separate files.
2. Extracted common helpers to `codegen` package.
3. Simplified code generators.

All generated files are almost unchanged (removed leading empty line).

## Why?
Better maintainability.

## How did you test it?
- [ ] built
- [x] run locally and tested manually
- [ ] covered by existing tests
- [ ] added new unit test(s)
- [ ] added new functional test(s)

2025-05-09 07:58:43 +00:00

431 lines

13 KiB

Go

Raw Permalink Blame History

 // Code generated by cmd/tools/genrpcwrappers. DO NOT EDIT.
 package admin
 import (
 	"context"
 	"go.temporal.io/server/api/adminservice/v1"
 	"google.golang.org/grpc"
 )
 func (c *clientImpl) AddOrUpdateRemoteCluster(
 	ctx context.Context,
 	request *adminservice.AddOrUpdateRemoteClusterRequest,
 	opts ...grpc.CallOption,
 ) (*adminservice.AddOrUpdateRemoteClusterResponse, error) {
 	ctx, cancel := c.createContext(ctx)
 	defer cancel()
 	return c.client.AddOrUpdateRemoteCluster(ctx, request, opts...)
 }
 func (c *clientImpl) AddSearchAttributes(
 	ctx context.Context,
 	request *adminservice.AddSearchAttributesRequest,
 	opts ...grpc.CallOption,
 ) (*adminservice.AddSearchAttributesResponse, error) {
 	ctx, cancel := c.createContext(ctx)
 	defer cancel()
 	return c.client.AddSearchAttributes(ctx, request, opts...)
 }
 func (c *clientImpl) AddTasks(
 	ctx context.Context,
 	request *adminservice.AddTasksRequest,
 	opts ...grpc.CallOption,
 ) (*adminservice.AddTasksResponse, error) {
 	ctx, cancel := c.createContext(ctx)
 	defer cancel()
 	return c.client.AddTasks(ctx, request, opts...)
 }
 func (c *clientImpl) CancelDLQJob(
 	ctx context.Context,
 	request *adminservice.CancelDLQJobRequest,
 	opts ...grpc.CallOption,
 ) (*adminservice.CancelDLQJobResponse, error) {
 	ctx, cancel := c.createContext(ctx)
 	defer cancel()
 	return c.client.CancelDLQJob(ctx, request, opts...)
 }
 func (c *clientImpl) CloseShard(
 	ctx context.Context,
 	request *adminservice.CloseShardRequest,
 	opts ...grpc.CallOption,
 ) (*adminservice.CloseShardResponse, error) {
 	ctx, cancel := c.createContext(ctx)
 	defer cancel()
 	return c.client.CloseShard(ctx, request, opts...)
 }
 func (c *clientImpl) DeepHealthCheck(
 	ctx context.Context,
 	request *adminservice.DeepHealthCheckRequest,
 	opts ...grpc.CallOption,
 ) (*adminservice.DeepHealthCheckResponse, error) {
 	ctx, cancel := c.createContext(ctx)
 	defer cancel()
 	return c.client.DeepHealthCheck(ctx, request, opts...)
 }
 func (c *clientImpl) DeleteWorkflowExecution(
 	ctx context.Context,
 	request *adminservice.DeleteWorkflowExecutionRequest,
 	opts ...grpc.CallOption,
 ) (*adminservice.DeleteWorkflowExecutionResponse, error) {
 	ctx, cancel := c.createContext(ctx)
 	defer cancel()
 	return c.client.DeleteWorkflowExecution(ctx, request, opts...)
 }
 func (c *clientImpl) DescribeCluster(
 	ctx context.Context,
 	request *adminservice.DescribeClusterRequest,
 	opts ...grpc.CallOption,
 ) (*adminservice.DescribeClusterResponse, error) {
 	ctx, cancel := c.createContext(ctx)
 	defer cancel()
 	return c.client.DescribeCluster(ctx, request, opts...)
 }
 func (c *clientImpl) DescribeDLQJob(
 	ctx context.Context,
 	request *adminservice.DescribeDLQJobRequest,
 	opts ...grpc.CallOption,
 ) (*adminservice.DescribeDLQJobResponse, error) {
 	ctx, cancel := c.createContext(ctx)
 	defer cancel()
 	return c.client.DescribeDLQJob(ctx, request, opts...)
 }
 func (c *clientImpl) DescribeHistoryHost(
 	ctx context.Context,
 	request *adminservice.DescribeHistoryHostRequest,
 	opts ...grpc.CallOption,
 ) (*adminservice.DescribeHistoryHostResponse, error) {
 	ctx, cancel := c.createContext(ctx)
 	defer cancel()
 	return c.client.DescribeHistoryHost(ctx, request, opts...)
 }
 func (c *clientImpl) DescribeMutableState(
 	ctx context.Context,
 	request *adminservice.DescribeMutableStateRequest,
 	opts ...grpc.CallOption,
 ) (*adminservice.DescribeMutableStateResponse, error) {
 	ctx, cancel := c.createContext(ctx)
 	defer cancel()
 	return c.client.DescribeMutableState(ctx, request, opts...)
 }
 func (c *clientImpl) DescribeTaskQueuePartition(
 	ctx context.Context,
 	request *adminservice.DescribeTaskQueuePartitionRequest,
 	opts ...grpc.CallOption,
 ) (*adminservice.DescribeTaskQueuePartitionResponse, error) {
 	ctx, cancel := c.createContext(ctx)
 	defer cancel()
 	return c.client.DescribeTaskQueuePartition(ctx, request, opts...)
 }
 func (c *clientImpl) ForceUnloadTaskQueuePartition(
 	ctx context.Context,
 	request *adminservice.ForceUnloadTaskQueuePartitionRequest,
 	opts ...grpc.CallOption,
 ) (*adminservice.ForceUnloadTaskQueuePartitionResponse, error) {
 	ctx, cancel := c.createContext(ctx)
 	defer cancel()
 	return c.client.ForceUnloadTaskQueuePartition(ctx, request, opts...)
 }
 func (c *clientImpl) GenerateLastHistoryReplicationTasks(
 	ctx context.Context,
 	request *adminservice.GenerateLastHistoryReplicationTasksRequest,
 	opts ...grpc.CallOption,
 ) (*adminservice.GenerateLastHistoryReplicationTasksResponse, error) {
 	ctx, cancel := c.createContext(ctx)
 	defer cancel()
 	return c.client.GenerateLastHistoryReplicationTasks(ctx, request, opts...)
 }
 func (c *clientImpl) GetDLQMessages(
 	ctx context.Context,
 	request *adminservice.GetDLQMessagesRequest,
 	opts ...grpc.CallOption,
 ) (*adminservice.GetDLQMessagesResponse, error) {
 	ctx, cancel := c.createContext(ctx)
 	defer cancel()
 	return c.client.GetDLQMessages(ctx, request, opts...)
 }
 func (c *clientImpl) GetDLQReplicationMessages(
 	ctx context.Context,
 	request *adminservice.GetDLQReplicationMessagesRequest,
 	opts ...grpc.CallOption,
 ) (*adminservice.GetDLQReplicationMessagesResponse, error) {
 	ctx, cancel := c.createContext(ctx)
 	defer cancel()
 	return c.client.GetDLQReplicationMessages(ctx, request, opts...)
 }
 func (c *clientImpl) GetDLQTasks(
 	ctx context.Context,
 	request *adminservice.GetDLQTasksRequest,
 	opts ...grpc.CallOption,
 ) (*adminservice.GetDLQTasksResponse, error) {
 	ctx, cancel := c.createContext(ctx)
 	defer cancel()
 	return c.client.GetDLQTasks(ctx, request, opts...)
 }
 func (c *clientImpl) GetNamespace(
 	ctx context.Context,
 	request *adminservice.GetNamespaceRequest,
 	opts ...grpc.CallOption,
 ) (*adminservice.GetNamespaceResponse, error) {
 	ctx, cancel := c.createContext(ctx)
 	defer cancel()
 	return c.client.GetNamespace(ctx, request, opts...)
 }
 func (c *clientImpl) GetNamespaceReplicationMessages(
 	ctx context.Context,
 	request *adminservice.GetNamespaceReplicationMessagesRequest,
 	opts ...grpc.CallOption,
 ) (*adminservice.GetNamespaceReplicationMessagesResponse, error) {
 	ctx, cancel := c.createContext(ctx)
 	defer cancel()
 	return c.client.GetNamespaceReplicationMessages(ctx, request, opts...)
 }
 func (c *clientImpl) GetReplicationMessages(
 	ctx context.Context,
 	request *adminservice.GetReplicationMessagesRequest,
 	opts ...grpc.CallOption,
 ) (*adminservice.GetReplicationMessagesResponse, error) {
 	ctx, cancel := c.createContextWithLargeTimeout(ctx)
 	defer cancel()
 	return c.client.GetReplicationMessages(ctx, request, opts...)
 }
 func (c *clientImpl) GetSearchAttributes(
 	ctx context.Context,
 	request *adminservice.GetSearchAttributesRequest,
 	opts ...grpc.CallOption,
 ) (*adminservice.GetSearchAttributesResponse, error) {
 	ctx, cancel := c.createContext(ctx)
 	defer cancel()
 	return c.client.GetSearchAttributes(ctx, request, opts...)
 }
 func (c *clientImpl) GetShard(
 	ctx context.Context,
 	request *adminservice.GetShardRequest,
 	opts ...grpc.CallOption,
 ) (*adminservice.GetShardResponse, error) {
 	ctx, cancel := c.createContext(ctx)
 	defer cancel()
 	return c.client.GetShard(ctx, request, opts...)
 }
 func (c *clientImpl) GetTaskQueueTasks(
 	ctx context.Context,
 	request *adminservice.GetTaskQueueTasksRequest,
 	opts ...grpc.CallOption,
 ) (*adminservice.GetTaskQueueTasksResponse, error) {
 	ctx, cancel := c.createContext(ctx)
 	defer cancel()
 	return c.client.GetTaskQueueTasks(ctx, request, opts...)
 }
 func (c *clientImpl) GetWorkflowExecutionRawHistory(
 	ctx context.Context,
 	request *adminservice.GetWorkflowExecutionRawHistoryRequest,
 	opts ...grpc.CallOption,
 ) (*adminservice.GetWorkflowExecutionRawHistoryResponse, error) {
 	ctx, cancel := c.createContext(ctx)
 	defer cancel()
 	return c.client.GetWorkflowExecutionRawHistory(ctx, request, opts...)
 }
 func (c *clientImpl) GetWorkflowExecutionRawHistoryV2(
 	ctx context.Context,
 	request *adminservice.GetWorkflowExecutionRawHistoryV2Request,
 	opts ...grpc.CallOption,
 ) (*adminservice.GetWorkflowExecutionRawHistoryV2Response, error) {
 	ctx, cancel := c.createContext(ctx)
 	defer cancel()
 	return c.client.GetWorkflowExecutionRawHistoryV2(ctx, request, opts...)
 }
 func (c *clientImpl) ImportWorkflowExecution(
 	ctx context.Context,
 	request *adminservice.ImportWorkflowExecutionRequest,
 	opts ...grpc.CallOption,
 ) (*adminservice.ImportWorkflowExecutionResponse, error) {
 	ctx, cancel := c.createContext(ctx)
 	defer cancel()
 	return c.client.ImportWorkflowExecution(ctx, request, opts...)
 }
 func (c *clientImpl) ListClusterMembers(
 	ctx context.Context,
 	request *adminservice.ListClusterMembersRequest,
 	opts ...grpc.CallOption,
 ) (*adminservice.ListClusterMembersResponse, error) {
 	ctx, cancel := c.createContext(ctx)
 	defer cancel()
 	return c.client.ListClusterMembers(ctx, request, opts...)
 }
 func (c *clientImpl) ListClusters(
 	ctx context.Context,
 	request *adminservice.ListClustersRequest,
 	opts ...grpc.CallOption,
 ) (*adminservice.ListClustersResponse, error) {
 	ctx, cancel := c.createContext(ctx)
 	defer cancel()
 	return c.client.ListClusters(ctx, request, opts...)
 }
 func (c *clientImpl) ListHistoryTasks(
 	ctx context.Context,
 	request *adminservice.ListHistoryTasksRequest,
 	opts ...grpc.CallOption,
 ) (*adminservice.ListHistoryTasksResponse, error) {
 	ctx, cancel := c.createContext(ctx)
 	defer cancel()
 	return c.client.ListHistoryTasks(ctx, request, opts...)
 }
 func (c *clientImpl) ListQueues(
 	ctx context.Context,
 	request *adminservice.ListQueuesRequest,
 	opts ...grpc.CallOption,
 ) (*adminservice.ListQueuesResponse, error) {
 	ctx, cancel := c.createContext(ctx)
 	defer cancel()
 	return c.client.ListQueues(ctx, request, opts...)
 }
 func (c *clientImpl) MergeDLQMessages(
 	ctx context.Context,
 	request *adminservice.MergeDLQMessagesRequest,
 	opts ...grpc.CallOption,
 ) (*adminservice.MergeDLQMessagesResponse, error) {
 	ctx, cancel := c.createContext(ctx)
 	defer cancel()
 	return c.client.MergeDLQMessages(ctx, request, opts...)
 }
 func (c *clientImpl) MergeDLQTasks(
 	ctx context.Context,
 	request *adminservice.MergeDLQTasksRequest,
 	opts ...grpc.CallOption,
 ) (*adminservice.MergeDLQTasksResponse, error) {
 	ctx, cancel := c.createContext(ctx)
 	defer cancel()
 	return c.client.MergeDLQTasks(ctx, request, opts...)
 }
 func (c *clientImpl) PurgeDLQMessages(
 	ctx context.Context,
 	request *adminservice.PurgeDLQMessagesRequest,
 	opts ...grpc.CallOption,
 ) (*adminservice.PurgeDLQMessagesResponse, error) {
 	ctx, cancel := c.createContext(ctx)
 	defer cancel()
 	return c.client.PurgeDLQMessages(ctx, request, opts...)
 }
 func (c *clientImpl) PurgeDLQTasks(
 	ctx context.Context,
 	request *adminservice.PurgeDLQTasksRequest,
 	opts ...grpc.CallOption,
 ) (*adminservice.PurgeDLQTasksResponse, error) {
 	ctx, cancel := c.createContext(ctx)
 	defer cancel()
 	return c.client.PurgeDLQTasks(ctx, request, opts...)
 }
 func (c *clientImpl) ReapplyEvents(
 	ctx context.Context,
 	request *adminservice.ReapplyEventsRequest,
 	opts ...grpc.CallOption,
 ) (*adminservice.ReapplyEventsResponse, error) {
 	ctx, cancel := c.createContext(ctx)
 	defer cancel()
 	return c.client.ReapplyEvents(ctx, request, opts...)
 }
 func (c *clientImpl) RebuildMutableState(
 	ctx context.Context,
 	request *adminservice.RebuildMutableStateRequest,
 	opts ...grpc.CallOption,
 ) (*adminservice.RebuildMutableStateResponse, error) {
 	ctx, cancel := c.createContext(ctx)
 	defer cancel()
 	return c.client.RebuildMutableState(ctx, request, opts...)
 }
 func (c *clientImpl) RefreshWorkflowTasks(
 	ctx context.Context,
 	request *adminservice.RefreshWorkflowTasksRequest,
 	opts ...grpc.CallOption,
 ) (*adminservice.RefreshWorkflowTasksResponse, error) {
 	ctx, cancel := c.createContext(ctx)
 	defer cancel()
 	return c.client.RefreshWorkflowTasks(ctx, request, opts...)
 }
 func (c *clientImpl) RemoveRemoteCluster(
 	ctx context.Context,
 	request *adminservice.RemoveRemoteClusterRequest,
 	opts ...grpc.CallOption,
 ) (*adminservice.RemoveRemoteClusterResponse, error) {
 	ctx, cancel := c.createContext(ctx)
 	defer cancel()
 	return c.client.RemoveRemoteCluster(ctx, request, opts...)
 }
 func (c *clientImpl) RemoveSearchAttributes(
 	ctx context.Context,
 	request *adminservice.RemoveSearchAttributesRequest,
 	opts ...grpc.CallOption,
 ) (*adminservice.RemoveSearchAttributesResponse, error) {
 	ctx, cancel := c.createContext(ctx)
 	defer cancel()
 	return c.client.RemoveSearchAttributes(ctx, request, opts...)
 }
 func (c *clientImpl) RemoveTask(
 	ctx context.Context,
 	request *adminservice.RemoveTaskRequest,
 	opts ...grpc.CallOption,
 ) (*adminservice.RemoveTaskResponse, error) {
 	ctx, cancel := c.createContext(ctx)
 	defer cancel()
 	return c.client.RemoveTask(ctx, request, opts...)
 }
 func (c *clientImpl) ResendReplicationTasks(
 	ctx context.Context,
 	request *adminservice.ResendReplicationTasksRequest,
 	opts ...grpc.CallOption,
 ) (*adminservice.ResendReplicationTasksResponse, error) {
 	ctx, cancel := c.createContext(ctx)
 	defer cancel()
 	return c.client.ResendReplicationTasks(ctx, request, opts...)
 }
 func (c *clientImpl) SyncWorkflowState(
 	ctx context.Context,
 	request *adminservice.SyncWorkflowStateRequest,
 	opts ...grpc.CallOption,
 ) (*adminservice.SyncWorkflowStateResponse, error) {
 	ctx, cancel := c.createContext(ctx)
 	defer cancel()
 	return c.client.SyncWorkflowState(ctx, request, opts...)
 }

431 lines 13 KiB Go Raw Permalink Blame History

431 lines

13 KiB

Go

Raw Permalink Blame History