0187fdd2-f4a4-4c9a-97b4-6604937bf7be

Committed 09 May 2023 12:23AM UTC coverage: 57.253% (-0.002%) from 57.255%

Build # 0187fdd2-f4a4-4c9a-97b4-6604937bf7be

Build Type

buildkite

Committed by David Porter

Commit Message

Merge branch 'master' into feature/zonal-partitioning

Pull Request Pull Request #5252: Feature/zonal partitioning

Run Details

1460 of 1460 new or added lines in 51 files covered. (100.0%)

86909 of 151799 relevant lines covered (57.25%)

2482.17 hits per line

Source File
Press 'n' to go to next uncovered line, 'b' for previous

4.48

/service/frontend/adminGrpcHandler.go

// Copyright (c) 2021 Uber Technologies, Inc.
//
// Permission is hereby granted, free of charge, to any person obtaining a copy
// of this software and associated documentation files (the "Software"), to deal
// in the Software without restriction, including without limitation the rights
// to use, copy, modify, merge, publish, distribute, sublicense, and/or sell
// copies of the Software, and to permit persons to whom the Software is
// furnished to do so, subject to the following conditions:
//
// The above copyright notice and this permission notice shall be included in
// all copies or substantial portions of the Software.
//
// THE SOFTWARE IS PROVIDED "AS IS", WITHOUT WARRANTY OF ANY KIND, EXPRESS OR
// IMPLIED, INCLUDING BUT NOT LIMITED TO THE WARRANTIES OF MERCHANTABILITY,
// FITNESS FOR A PARTICULAR PURPOSE AND NONINFRINGEMENT. IN NO EVENT SHALL THE
// AUTHORS OR COPYRIGHT HOLDERS BE LIABLE FOR ANY CLAIM, DAMAGES OR OTHER
// LIABILITY, WHETHER IN AN ACTION OF CONTRACT, TORT OR OTHERWISE, ARISING FROM,
// OUT OF OR IN CONNECTION WITH THE SOFTWARE OR THE USE OR OTHER DEALINGS IN
// THE SOFTWARE.

package frontend

import (
        "context"

        "go.uber.org/yarpc"

        adminv1 "github.com/uber/cadence-idl/go/proto/admin/v1"
        "github.com/uber/cadence/common/types/mapper/proto"
)

type adminGRPCHandler struct {
        h AdminHandler
}

func newAdminGRPCHandler(h AdminHandler) adminGRPCHandler {
        return adminGRPCHandler{h}
}

func (g adminGRPCHandler) register(dispatcher *yarpc.Dispatcher) {
        dispatcher.Register(adminv1.BuildAdminAPIYARPCProcedures(g))
}

func (g adminGRPCHandler) AddSearchAttribute(ctx context.Context, request *adminv1.AddSearchAttributeRequest) (*adminv1.AddSearchAttributeResponse, error) {
        err := g.h.AddSearchAttribute(ctx, proto.ToAdminAddSearchAttributeRequest(request))
        return &adminv1.AddSearchAttributeResponse{}, proto.FromError(err)
}

func (g adminGRPCHandler) CloseShard(ctx context.Context, request *adminv1.CloseShardRequest) (*adminv1.CloseShardResponse, error) {
        err := g.h.CloseShard(ctx, proto.ToAdminCloseShardRequest(request))
        return &adminv1.CloseShardResponse{}, proto.FromError(err)
}

func (g adminGRPCHandler) DescribeCluster(ctx context.Context, _ *adminv1.DescribeClusterRequest) (*adminv1.DescribeClusterResponse, error) {
        response, err := g.h.DescribeCluster(ctx)
        return proto.FromAdminDescribeClusterResponse(response), proto.FromError(err)
}

func (g adminGRPCHandler) DescribeShardDistribution(ctx context.Context, request *adminv1.DescribeShardDistributionRequest) (*adminv1.DescribeShardDistributionResponse, error) {
        response, err := g.h.DescribeShardDistribution(ctx, proto.ToAdminDescribeShardDistributionRequest(request))
        return proto.FromAdminDescribeShardDistributionResponse(response), proto.FromError(err)
}

func (g adminGRPCHandler) DescribeHistoryHost(ctx context.Context, request *adminv1.DescribeHistoryHostRequest) (*adminv1.DescribeHistoryHostResponse, error) {
        response, err := g.h.DescribeHistoryHost(ctx, proto.ToAdminDescribeHistoryHostRequest(request))
        return proto.FromAdminDescribeHistoryHostResponse(response), proto.FromError(err)
}

func (g adminGRPCHandler) DescribeQueue(ctx context.Context, request *adminv1.DescribeQueueRequest) (*adminv1.DescribeQueueResponse, error) {
        response, err := g.h.DescribeQueue(ctx, proto.ToAdminDescribeQueueRequest(request))
        return proto.FromAdminDescribeQueueResponse(response), proto.FromError(err)
}

func (g adminGRPCHandler) DescribeWorkflowExecution(ctx context.Context, request *adminv1.DescribeWorkflowExecutionRequest) (*adminv1.DescribeWorkflowExecutionResponse, error) {
        response, err := g.h.DescribeWorkflowExecution(ctx, proto.ToAdminDescribeWorkflowExecutionRequest(request))
        return proto.FromAdminDescribeWorkflowExecutionResponse(response), proto.FromError(err)
}

func (g adminGRPCHandler) GetDLQReplicationMessages(ctx context.Context, request *adminv1.GetDLQReplicationMessagesRequest) (*adminv1.GetDLQReplicationMessagesResponse, error) {
        response, err := g.h.GetDLQReplicationMessages(ctx, proto.ToAdminGetDLQReplicationMessagesRequest(request))
        return proto.FromAdminGetDLQReplicationMessagesResponse(response), proto.FromError(err)
}

func (g adminGRPCHandler) GetDomainReplicationMessages(ctx context.Context, request *adminv1.GetDomainReplicationMessagesRequest) (*adminv1.GetDomainReplicationMessagesResponse, error) {
        response, err := g.h.GetDomainReplicationMessages(ctx, proto.ToAdminGetDomainReplicationMessagesRequest(request))
        return proto.FromAdminGetDomainReplicationMessagesResponse(response), proto.FromError(err)
}

func (g adminGRPCHandler) GetReplicationMessages(ctx context.Context, request *adminv1.GetReplicationMessagesRequest) (*adminv1.GetReplicationMessagesResponse, error) {
        response, err := g.h.GetReplicationMessages(ctx, proto.ToAdminGetReplicationMessagesRequest(request))
        return proto.FromAdminGetReplicationMessagesResponse(response), proto.FromError(err)
}

func (g adminGRPCHandler) GetWorkflowExecutionRawHistoryV2(ctx context.Context, request *adminv1.GetWorkflowExecutionRawHistoryV2Request) (*adminv1.GetWorkflowExecutionRawHistoryV2Response, error) {
        response, err := g.h.GetWorkflowExecutionRawHistoryV2(ctx, proto.ToAdminGetWorkflowExecutionRawHistoryV2Request(request))
        return proto.FromAdminGetWorkflowExecutionRawHistoryV2Response(response), proto.FromError(err)
}

func (g adminGRPCHandler) CountDLQMessages(ctx context.Context, request *adminv1.CountDLQMessagesRequest) (*adminv1.CountDLQMessagesResponse, error) {
        response, err := g.h.CountDLQMessages(ctx, proto.ToAdminCountDLQMessagesRequest(request))
        return proto.FromAdminCountDLQMessagesResponse(response), proto.FromError(err)
}

func (g adminGRPCHandler) MergeDLQMessages(ctx context.Context, request *adminv1.MergeDLQMessagesRequest) (*adminv1.MergeDLQMessagesResponse, error) {
        response, err := g.h.MergeDLQMessages(ctx, proto.ToAdminMergeDLQMessagesRequest(request))
        return proto.FromAdminMergeDLQMessagesResponse(response), proto.FromError(err)
}

func (g adminGRPCHandler) PurgeDLQMessages(ctx context.Context, request *adminv1.PurgeDLQMessagesRequest) (*adminv1.PurgeDLQMessagesResponse, error) {
        err := g.h.PurgeDLQMessages(ctx, proto.ToAdminPurgeDLQMessagesRequest(request))
        return &adminv1.PurgeDLQMessagesResponse{}, proto.FromError(err)
}

func (g adminGRPCHandler) ReadDLQMessages(ctx context.Context, request *adminv1.ReadDLQMessagesRequest) (*adminv1.ReadDLQMessagesResponse, error) {
        response, err := g.h.ReadDLQMessages(ctx, proto.ToAdminReadDLQMessagesRequest(request))
        return proto.FromAdminReadDLQMessagesResponse(response), proto.FromError(err)
}

func (g adminGRPCHandler) ReapplyEvents(ctx context.Context, request *adminv1.ReapplyEventsRequest) (*adminv1.ReapplyEventsResponse, error) {
        err := g.h.ReapplyEvents(ctx, proto.ToAdminReapplyEventsRequest(request))
        return &adminv1.ReapplyEventsResponse{}, proto.FromError(err)
}

func (g adminGRPCHandler) RefreshWorkflowTasks(ctx context.Context, request *adminv1.RefreshWorkflowTasksRequest) (*adminv1.RefreshWorkflowTasksResponse, error) {
        err := g.h.RefreshWorkflowTasks(ctx, proto.ToAdminRefreshWorkflowTasksRequest(request))
        return &adminv1.RefreshWorkflowTasksResponse{}, proto.FromError(err)
}

func (g adminGRPCHandler) RemoveTask(ctx context.Context, request *adminv1.RemoveTaskRequest) (*adminv1.RemoveTaskResponse, error) {
        err := g.h.RemoveTask(ctx, proto.ToAdminRemoveTaskRequest(request))
        return &adminv1.RemoveTaskResponse{}, proto.FromError(err)
}

func (g adminGRPCHandler) ResendReplicationTasks(ctx context.Context, request *adminv1.ResendReplicationTasksRequest) (*adminv1.ResendReplicationTasksResponse, error) {
        err := g.h.ResendReplicationTasks(ctx, proto.ToAdminResendReplicationTasksRequest(request))
        return &adminv1.ResendReplicationTasksResponse{}, proto.FromError(err)
}

func (g adminGRPCHandler) ResetQueue(ctx context.Context, request *adminv1.ResetQueueRequest) (*adminv1.ResetQueueResponse, error) {
        err := g.h.ResetQueue(ctx, proto.ToAdminResetQueueRequest(request))
        return &adminv1.ResetQueueResponse{}, proto.FromError(err)
}

func (g adminGRPCHandler) GetCrossClusterTasks(ctx context.Context, request *adminv1.GetCrossClusterTasksRequest) (*adminv1.GetCrossClusterTasksResponse, error) {
        response, err := g.h.GetCrossClusterTasks(ctx, proto.ToAdminGetCrossClusterTasksRequest(request))
        return proto.FromAdminGetCrossClusterTasksResponse(response), proto.FromError(err)
}

func (g adminGRPCHandler) RespondCrossClusterTasksCompleted(ctx context.Context, request *adminv1.RespondCrossClusterTasksCompletedRequest) (*adminv1.RespondCrossClusterTasksCompletedResponse, error) {
        response, err := g.h.RespondCrossClusterTasksCompleted(ctx, proto.ToAdminRespondCrossClusterTasksCompletedRequest(request))
        return proto.FromAdminRespondCrossClusterTasksCompletedResponse(response), proto.FromError(err)
}

func (g adminGRPCHandler) GetDynamicConfig(ctx context.Context, request *adminv1.GetDynamicConfigRequest) (*adminv1.GetDynamicConfigResponse, error) {
        response, err := g.h.GetDynamicConfig(ctx, proto.ToGetDynamicConfigRequest(request))
        return proto.FromGetDynamicConfigResponse(response), proto.FromError(err)
}

func (g adminGRPCHandler) UpdateDynamicConfig(ctx context.Context, request *adminv1.UpdateDynamicConfigRequest) (*adminv1.UpdateDynamicConfigResponse, error) {
        err := g.h.UpdateDynamicConfig(ctx, proto.ToUpdateDynamicConfigRequest(request))
        return &adminv1.UpdateDynamicConfigResponse{}, proto.FromError(err)
}

func (g adminGRPCHandler) RestoreDynamicConfig(ctx context.Context, request *adminv1.RestoreDynamicConfigRequest) (*adminv1.RestoreDynamicConfigResponse, error) {
        err := g.h.RestoreDynamicConfig(ctx, proto.ToRestoreDynamicConfigRequest(request))
        return &adminv1.RestoreDynamicConfigResponse{}, proto.FromError(err)
}

func (g adminGRPCHandler) DeleteWorkflow(ctx context.Context, request *adminv1.DeleteWorkflowRequest) (*adminv1.DeleteWorkflowResponse, error) {
        response, err := g.h.DeleteWorkflow(ctx, proto.ToAdminDeleteWorkflowRequest(request))
        return proto.FromAdminDeleteWorkflowResponse(response), proto.FromError(err)
}

func (g adminGRPCHandler) MaintainCorruptWorkflow(ctx context.Context, request *adminv1.MaintainCorruptWorkflowRequest) (*adminv1.MaintainCorruptWorkflowResponse, error) {
        response, err := g.h.MaintainCorruptWorkflow(ctx, proto.ToAdminMaintainWorkflowRequest(request))
        return proto.FromAdminMaintainWorkflowResponse(response), proto.FromError(err)
}

func (g adminGRPCHandler) ListDynamicConfig(ctx context.Context, request *adminv1.ListDynamicConfigRequest) (*adminv1.ListDynamicConfigResponse, error) {
        response, err := g.h.ListDynamicConfig(ctx, proto.ToListDynamicConfigRequest(request))
        return proto.FromListDynamicConfigResponse(response), proto.FromError(err)
}

func (g adminGRPCHandler) GetGlobalIsolationGroups(ctx context.Context, request *adminv1.GetGlobalIsolationGroupsRequest) (*adminv1.GetGlobalIsolationGroupsResponse, error) {
        res, err := g.h.GetGlobalIsolationGroups(ctx, proto.ToGetGlobalIsolationGroupsRequest(request))
        return proto.FromGetGlobalIsolationGroupsResponse(res), proto.FromError(err)
}

func (g adminGRPCHandler) UpdateGlobalIsolationGroups(ctx context.Context, request *adminv1.UpdateGlobalIsolationGroupsRequest) (*adminv1.UpdateGlobalIsolationGroupsResponse, error) {
        res, err := g.h.UpdateGlobalIsolationGroups(ctx, proto.ToUpdateGlobalIsolationGroupsRequest(request))
        return proto.FromUpdateGlobalIsolationGroupsResponse(res), proto.FromError(err)
}

func (g adminGRPCHandler) GetDomainIsolationGroups(ctx context.Context, request *adminv1.GetDomainIsolationGroupsRequest) (*adminv1.GetDomainIsolationGroupsResponse, error) {
        res, err := g.h.GetDomainIsolationGroups(ctx, proto.ToGetDomainIsolationGroupsRequest(request))
        return proto.FromGetDomainIsolationGroupsResponse(res), proto.FromError(err)
}

func (g adminGRPCHandler) UpdateDomainIsolationGroups(ctx context.Context, request *adminv1.UpdateDomainIsolationGroupsRequest) (*adminv1.UpdateDomainIsolationGroupsResponse, error) {
        res, err := g.h.UpdateDomainIsolationGroups(ctx, proto.ToUpdateDomainIsolationGroupsRequest(request))
        return proto.FromUpdateDomainIsolationGroupsResponse(res), proto.FromError(err)
}

1	// Copyright (c) 2021 Uber Technologies, Inc.
2	//
3	// Permission is hereby granted, free of charge, to any person obtaining a copy
4	// of this software and associated documentation files (the "Software"), to deal
5	// in the Software without restriction, including without limitation the rights
6	// to use, copy, modify, merge, publish, distribute, sublicense, and/or sell
7	// copies of the Software, and to permit persons to whom the Software is
8	// furnished to do so, subject to the following conditions:
9	//
10	// The above copyright notice and this permission notice shall be included in
11	// all copies or substantial portions of the Software.
12	//
13	// THE SOFTWARE IS PROVIDED "AS IS", WITHOUT WARRANTY OF ANY KIND, EXPRESS OR
14	// IMPLIED, INCLUDING BUT NOT LIMITED TO THE WARRANTIES OF MERCHANTABILITY,
15	// FITNESS FOR A PARTICULAR PURPOSE AND NONINFRINGEMENT. IN NO EVENT SHALL THE
16	// AUTHORS OR COPYRIGHT HOLDERS BE LIABLE FOR ANY CLAIM, DAMAGES OR OTHER
17	// LIABILITY, WHETHER IN AN ACTION OF CONTRACT, TORT OR OTHERWISE, ARISING FROM,
18	// OUT OF OR IN CONNECTION WITH THE SOFTWARE OR THE USE OR OTHER DEALINGS IN
19	// THE SOFTWARE.
20
21	package frontend
22
23	import (
24	"context"
25
26	"go.uber.org/yarpc"
27
28	adminv1 "github.com/uber/cadence-idl/go/proto/admin/v1"
29	"github.com/uber/cadence/common/types/mapper/proto"
30	)
31
32	type adminGRPCHandler struct {
33	h AdminHandler
34	}
35
36	func newAdminGRPCHandler(h AdminHandler) adminGRPCHandler {	15✔
37	return adminGRPCHandler{h}	15✔
38	}	15✔
39
40	func (g adminGRPCHandler) register(dispatcher *yarpc.Dispatcher) {	15✔
41	dispatcher.Register(adminv1.BuildAdminAPIYARPCProcedures(g))	15✔
42	}	15✔
43
44	func (g adminGRPCHandler) AddSearchAttribute(ctx context.Context, request adminv1.AddSearchAttributeRequest) (adminv1.AddSearchAttributeResponse, error) {	×
45	err := g.h.AddSearchAttribute(ctx, proto.ToAdminAddSearchAttributeRequest(request))	×
46	return &adminv1.AddSearchAttributeResponse{}, proto.FromError(err)	×
47	}	×
48
49	func (g adminGRPCHandler) CloseShard(ctx context.Context, request adminv1.CloseShardRequest) (adminv1.CloseShardResponse, error) {	×
50	err := g.h.CloseShard(ctx, proto.ToAdminCloseShardRequest(request))	×
51	return &adminv1.CloseShardResponse{}, proto.FromError(err)	×
52	}	×
53
54	func (g adminGRPCHandler) DescribeCluster(ctx context.Context, _ adminv1.DescribeClusterRequest) (adminv1.DescribeClusterResponse, error) {	×
55	response, err := g.h.DescribeCluster(ctx)	×
56	return proto.FromAdminDescribeClusterResponse(response), proto.FromError(err)	×
57	}	×
58
59	func (g adminGRPCHandler) DescribeShardDistribution(ctx context.Context, request adminv1.DescribeShardDistributionRequest) (adminv1.DescribeShardDistributionResponse, error) {	×
60	response, err := g.h.DescribeShardDistribution(ctx, proto.ToAdminDescribeShardDistributionRequest(request))	×
61	return proto.FromAdminDescribeShardDistributionResponse(response), proto.FromError(err)	×
62	}	×
63
64	func (g adminGRPCHandler) DescribeHistoryHost(ctx context.Context, request adminv1.DescribeHistoryHostRequest) (adminv1.DescribeHistoryHostResponse, error) {	×
65	response, err := g.h.DescribeHistoryHost(ctx, proto.ToAdminDescribeHistoryHostRequest(request))	×
66	return proto.FromAdminDescribeHistoryHostResponse(response), proto.FromError(err)	×
67	}	×
68
69	func (g adminGRPCHandler) DescribeQueue(ctx context.Context, request adminv1.DescribeQueueRequest) (adminv1.DescribeQueueResponse, error) {	×
70	response, err := g.h.DescribeQueue(ctx, proto.ToAdminDescribeQueueRequest(request))	×
71	return proto.FromAdminDescribeQueueResponse(response), proto.FromError(err)	×
72	}	×
73
74	func (g adminGRPCHandler) DescribeWorkflowExecution(ctx context.Context, request adminv1.DescribeWorkflowExecutionRequest) (adminv1.DescribeWorkflowExecutionResponse, error) {	×
75	response, err := g.h.DescribeWorkflowExecution(ctx, proto.ToAdminDescribeWorkflowExecutionRequest(request))	×
76	return proto.FromAdminDescribeWorkflowExecutionResponse(response), proto.FromError(err)	×
77	}	×
78
79	func (g adminGRPCHandler) GetDLQReplicationMessages(ctx context.Context, request adminv1.GetDLQReplicationMessagesRequest) (adminv1.GetDLQReplicationMessagesResponse, error) {	×
80	response, err := g.h.GetDLQReplicationMessages(ctx, proto.ToAdminGetDLQReplicationMessagesRequest(request))	×
81	return proto.FromAdminGetDLQReplicationMessagesResponse(response), proto.FromError(err)	×
82	}	×
83
84	func (g adminGRPCHandler) GetDomainReplicationMessages(ctx context.Context, request adminv1.GetDomainReplicationMessagesRequest) (adminv1.GetDomainReplicationMessagesResponse, error) {	×
85	response, err := g.h.GetDomainReplicationMessages(ctx, proto.ToAdminGetDomainReplicationMessagesRequest(request))	×
86	return proto.FromAdminGetDomainReplicationMessagesResponse(response), proto.FromError(err)	×
87	}	×
88
89	func (g adminGRPCHandler) GetReplicationMessages(ctx context.Context, request adminv1.GetReplicationMessagesRequest) (adminv1.GetReplicationMessagesResponse, error) {	×
90	response, err := g.h.GetReplicationMessages(ctx, proto.ToAdminGetReplicationMessagesRequest(request))	×
91	return proto.FromAdminGetReplicationMessagesResponse(response), proto.FromError(err)	×
92	}	×
93
94	func (g adminGRPCHandler) GetWorkflowExecutionRawHistoryV2(ctx context.Context, request adminv1.GetWorkflowExecutionRawHistoryV2Request) (adminv1.GetWorkflowExecutionRawHistoryV2Response, error) {	×
95	response, err := g.h.GetWorkflowExecutionRawHistoryV2(ctx, proto.ToAdminGetWorkflowExecutionRawHistoryV2Request(request))	×
96	return proto.FromAdminGetWorkflowExecutionRawHistoryV2Response(response), proto.FromError(err)	×
97	}	×
98
99	func (g adminGRPCHandler) CountDLQMessages(ctx context.Context, request adminv1.CountDLQMessagesRequest) (adminv1.CountDLQMessagesResponse, error) {	×
100	response, err := g.h.CountDLQMessages(ctx, proto.ToAdminCountDLQMessagesRequest(request))	×
101	return proto.FromAdminCountDLQMessagesResponse(response), proto.FromError(err)	×
102	}	×
103
104	func (g adminGRPCHandler) MergeDLQMessages(ctx context.Context, request adminv1.MergeDLQMessagesRequest) (adminv1.MergeDLQMessagesResponse, error) {	×
105	response, err := g.h.MergeDLQMessages(ctx, proto.ToAdminMergeDLQMessagesRequest(request))	×
106	return proto.FromAdminMergeDLQMessagesResponse(response), proto.FromError(err)	×
107	}	×
108
109	func (g adminGRPCHandler) PurgeDLQMessages(ctx context.Context, request adminv1.PurgeDLQMessagesRequest) (adminv1.PurgeDLQMessagesResponse, error) {	×
110	err := g.h.PurgeDLQMessages(ctx, proto.ToAdminPurgeDLQMessagesRequest(request))	×
111	return &adminv1.PurgeDLQMessagesResponse{}, proto.FromError(err)	×
112	}	×
113
114	func (g adminGRPCHandler) ReadDLQMessages(ctx context.Context, request adminv1.ReadDLQMessagesRequest) (adminv1.ReadDLQMessagesResponse, error) {	×
115	response, err := g.h.ReadDLQMessages(ctx, proto.ToAdminReadDLQMessagesRequest(request))	×
116	return proto.FromAdminReadDLQMessagesResponse(response), proto.FromError(err)	×
117	}	×
118
119	func (g adminGRPCHandler) ReapplyEvents(ctx context.Context, request adminv1.ReapplyEventsRequest) (adminv1.ReapplyEventsResponse, error) {	×
120	err := g.h.ReapplyEvents(ctx, proto.ToAdminReapplyEventsRequest(request))	×
121	return &adminv1.ReapplyEventsResponse{}, proto.FromError(err)	×
122	}	×
123
124	func (g adminGRPCHandler) RefreshWorkflowTasks(ctx context.Context, request adminv1.RefreshWorkflowTasksRequest) (adminv1.RefreshWorkflowTasksResponse, error) {	×
125	err := g.h.RefreshWorkflowTasks(ctx, proto.ToAdminRefreshWorkflowTasksRequest(request))	×
126	return &adminv1.RefreshWorkflowTasksResponse{}, proto.FromError(err)	×
127	}	×
128
129	func (g adminGRPCHandler) RemoveTask(ctx context.Context, request adminv1.RemoveTaskRequest) (adminv1.RemoveTaskResponse, error) {	×
130	err := g.h.RemoveTask(ctx, proto.ToAdminRemoveTaskRequest(request))	×
131	return &adminv1.RemoveTaskResponse{}, proto.FromError(err)	×
132	}	×
133
134	func (g adminGRPCHandler) ResendReplicationTasks(ctx context.Context, request adminv1.ResendReplicationTasksRequest) (adminv1.ResendReplicationTasksResponse, error) {	×
135	err := g.h.ResendReplicationTasks(ctx, proto.ToAdminResendReplicationTasksRequest(request))	×
136	return &adminv1.ResendReplicationTasksResponse{}, proto.FromError(err)	×
137	}	×
138
139	func (g adminGRPCHandler) ResetQueue(ctx context.Context, request adminv1.ResetQueueRequest) (adminv1.ResetQueueResponse, error) {	×
140	err := g.h.ResetQueue(ctx, proto.ToAdminResetQueueRequest(request))	×
141	return &adminv1.ResetQueueResponse{}, proto.FromError(err)	×
142	}	×
143
144	func (g adminGRPCHandler) GetCrossClusterTasks(ctx context.Context, request adminv1.GetCrossClusterTasksRequest) (adminv1.GetCrossClusterTasksResponse, error) {	×
145	response, err := g.h.GetCrossClusterTasks(ctx, proto.ToAdminGetCrossClusterTasksRequest(request))	×
146	return proto.FromAdminGetCrossClusterTasksResponse(response), proto.FromError(err)	×
147	}	×
148
149	func (g adminGRPCHandler) RespondCrossClusterTasksCompleted(ctx context.Context, request adminv1.RespondCrossClusterTasksCompletedRequest) (adminv1.RespondCrossClusterTasksCompletedResponse, error) {	×
150	response, err := g.h.RespondCrossClusterTasksCompleted(ctx, proto.ToAdminRespondCrossClusterTasksCompletedRequest(request))	×
151	return proto.FromAdminRespondCrossClusterTasksCompletedResponse(response), proto.FromError(err)	×
152	}	×
153
154	func (g adminGRPCHandler) GetDynamicConfig(ctx context.Context, request adminv1.GetDynamicConfigRequest) (adminv1.GetDynamicConfigResponse, error) {	×
155	response, err := g.h.GetDynamicConfig(ctx, proto.ToGetDynamicConfigRequest(request))	×
156	return proto.FromGetDynamicConfigResponse(response), proto.FromError(err)	×
157	}	×
158
159	func (g adminGRPCHandler) UpdateDynamicConfig(ctx context.Context, request adminv1.UpdateDynamicConfigRequest) (adminv1.UpdateDynamicConfigResponse, error) {	×
160	err := g.h.UpdateDynamicConfig(ctx, proto.ToUpdateDynamicConfigRequest(request))	×
161	return &adminv1.UpdateDynamicConfigResponse{}, proto.FromError(err)	×
162	}	×
163
164	func (g adminGRPCHandler) RestoreDynamicConfig(ctx context.Context, request adminv1.RestoreDynamicConfigRequest) (adminv1.RestoreDynamicConfigResponse, error) {	×
165	err := g.h.RestoreDynamicConfig(ctx, proto.ToRestoreDynamicConfigRequest(request))	×
166	return &adminv1.RestoreDynamicConfigResponse{}, proto.FromError(err)	×
167	}	×
168
169	func (g adminGRPCHandler) DeleteWorkflow(ctx context.Context, request adminv1.DeleteWorkflowRequest) (adminv1.DeleteWorkflowResponse, error) {	×
170	response, err := g.h.DeleteWorkflow(ctx, proto.ToAdminDeleteWorkflowRequest(request))	×
171	return proto.FromAdminDeleteWorkflowResponse(response), proto.FromError(err)	×
172	}	×
173
174	func (g adminGRPCHandler) MaintainCorruptWorkflow(ctx context.Context, request adminv1.MaintainCorruptWorkflowRequest) (adminv1.MaintainCorruptWorkflowResponse, error) {	×
175	response, err := g.h.MaintainCorruptWorkflow(ctx, proto.ToAdminMaintainWorkflowRequest(request))	×
176	return proto.FromAdminMaintainWorkflowResponse(response), proto.FromError(err)	×
177	}	×
178
179	func (g adminGRPCHandler) ListDynamicConfig(ctx context.Context, request adminv1.ListDynamicConfigRequest) (adminv1.ListDynamicConfigResponse, error) {	×
180	response, err := g.h.ListDynamicConfig(ctx, proto.ToListDynamicConfigRequest(request))	×
181	return proto.FromListDynamicConfigResponse(response), proto.FromError(err)	×
182	}	×
183
184	func (g adminGRPCHandler) GetGlobalIsolationGroups(ctx context.Context, request adminv1.GetGlobalIsolationGroupsRequest) (adminv1.GetGlobalIsolationGroupsResponse, error) {	×
185	res, err := g.h.GetGlobalIsolationGroups(ctx, proto.ToGetGlobalIsolationGroupsRequest(request))	×
186	return proto.FromGetGlobalIsolationGroupsResponse(res), proto.FromError(err)	×
187	}	×
188
189	func (g adminGRPCHandler) UpdateGlobalIsolationGroups(ctx context.Context, request adminv1.UpdateGlobalIsolationGroupsRequest) (adminv1.UpdateGlobalIsolationGroupsResponse, error) {	×
190	res, err := g.h.UpdateGlobalIsolationGroups(ctx, proto.ToUpdateGlobalIsolationGroupsRequest(request))	×
191	return proto.FromUpdateGlobalIsolationGroupsResponse(res), proto.FromError(err)	×
192	}	×
193
194	func (g adminGRPCHandler) GetDomainIsolationGroups(ctx context.Context, request adminv1.GetDomainIsolationGroupsRequest) (adminv1.GetDomainIsolationGroupsResponse, error) {	×
195	res, err := g.h.GetDomainIsolationGroups(ctx, proto.ToGetDomainIsolationGroupsRequest(request))	×
196	return proto.FromGetDomainIsolationGroupsResponse(res), proto.FromError(err)	×
197	}	×
198
199	func (g adminGRPCHandler) UpdateDomainIsolationGroups(ctx context.Context, request adminv1.UpdateDomainIsolationGroupsRequest) (adminv1.UpdateDomainIsolationGroupsResponse, error) {	×
200	res, err := g.h.UpdateDomainIsolationGroups(ctx, proto.ToUpdateDomainIsolationGroupsRequest(request))	×
201	return proto.FromUpdateDomainIsolationGroupsResponse(res), proto.FromError(err)	×
202	}	×

uber / cadence / 0187fdd2-f4a4-4c9a-97b4-6604937bf7be

Source File Press 'n' to go to next uncovered line, 'b' for previous

Source File
Press 'n' to go to next uncovered line, 'b' for previous