01880c2e-e2ba-4ec5-8826-bcc19bd1c271

Committed 11 May 2023 07:21PM UTC coverage: 57.263% (-0.07%) from 57.331%

Build # 01880c2e-e2ba-4ec5-8826-bcc19bd1c271

Build Type

push

buildkite

Committed by GitHub

Commit Message

Adds tooling (#5283)

Run Details

369 of 369 new or added lines in 9 files covered. (100.0%)

86922 of 151794 relevant lines covered (57.26%)

2472.24 hits per line

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

11.45

/client/admin/grpcClient.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 admin

import (
        "context"

        "go.uber.org/yarpc"

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

type grpcClient struct {
        c adminv1.AdminAPIYARPCClient
}

func NewGRPCClient(c adminv1.AdminAPIYARPCClient) Client {
        return grpcClient{c}
}

func (g grpcClient) AddSearchAttribute(ctx context.Context, request *types.AddSearchAttributeRequest, opts ...yarpc.CallOption) error {
        _, err := g.c.AddSearchAttribute(ctx, proto.FromAdminAddSearchAttributeRequest(request), opts...)
        return proto.ToError(err)
}

func (g grpcClient) CloseShard(ctx context.Context, request *types.CloseShardRequest, opts ...yarpc.CallOption) error {
        _, err := g.c.CloseShard(ctx, proto.FromAdminCloseShardRequest(request), opts...)
        return proto.ToError(err)
}

func (g grpcClient) DescribeCluster(ctx context.Context, opts ...yarpc.CallOption) (*types.DescribeClusterResponse, error) {
        response, err := g.c.DescribeCluster(ctx, &adminv1.DescribeClusterRequest{}, opts...)
        return proto.ToAdminDescribeClusterResponse(response), proto.ToError(err)
}

func (g grpcClient) DescribeShardDistribution(ctx context.Context, request *types.DescribeShardDistributionRequest, opts ...yarpc.CallOption) (*types.DescribeShardDistributionResponse, error) {
        response, err := g.c.DescribeShardDistribution(ctx, proto.FromAdminDescribeShardDistributionRequest(request), opts...)
        return proto.ToAdminDescribeShardDistributionResponse(response), proto.ToError(err)
}

func (g grpcClient) DescribeHistoryHost(ctx context.Context, request *types.DescribeHistoryHostRequest, opts ...yarpc.CallOption) (*types.DescribeHistoryHostResponse, error) {
        response, err := g.c.DescribeHistoryHost(ctx, proto.FromAdminDescribeHistoryHostRequest(request), opts...)
        return proto.ToAdminDescribeHistoryHostResponse(response), proto.ToError(err)
}

func (g grpcClient) DescribeQueue(ctx context.Context, request *types.DescribeQueueRequest, opts ...yarpc.CallOption) (*types.DescribeQueueResponse, error) {
        response, err := g.c.DescribeQueue(ctx, proto.FromAdminDescribeQueueRequest(request), opts...)
        return proto.ToAdminDescribeQueueResponse(response), proto.ToError(err)
}

func (g grpcClient) DescribeWorkflowExecution(ctx context.Context, request *types.AdminDescribeWorkflowExecutionRequest, opts ...yarpc.CallOption) (*types.AdminDescribeWorkflowExecutionResponse, error) {
        response, err := g.c.DescribeWorkflowExecution(ctx, proto.FromAdminDescribeWorkflowExecutionRequest(request), opts...)
        return proto.ToAdminDescribeWorkflowExecutionResponse(response), proto.ToError(err)
}

func (g grpcClient) GetDLQReplicationMessages(ctx context.Context, request *types.GetDLQReplicationMessagesRequest, opts ...yarpc.CallOption) (*types.GetDLQReplicationMessagesResponse, error) {
        response, err := g.c.GetDLQReplicationMessages(ctx, proto.FromAdminGetDLQReplicationMessagesRequest(request), opts...)
        return proto.ToAdminGetDLQReplicationMessagesResponse(response), proto.ToError(err)
}

func (g grpcClient) GetDomainReplicationMessages(ctx context.Context, request *types.GetDomainReplicationMessagesRequest, opts ...yarpc.CallOption) (*types.GetDomainReplicationMessagesResponse, error) {
        response, err := g.c.GetDomainReplicationMessages(ctx, proto.FromAdminGetDomainReplicationMessagesRequest(request), opts...)
        return proto.ToAdminGetDomainReplicationMessagesResponse(response), proto.ToError(err)
}

func (g grpcClient) GetReplicationMessages(ctx context.Context, request *types.GetReplicationMessagesRequest, opts ...yarpc.CallOption) (*types.GetReplicationMessagesResponse, error) {
        response, err := g.c.GetReplicationMessages(ctx, proto.FromAdminGetReplicationMessagesRequest(request), opts...)
        return proto.ToAdminGetReplicationMessagesResponse(response), proto.ToError(err)
}

func (g grpcClient) GetWorkflowExecutionRawHistoryV2(ctx context.Context, request *types.GetWorkflowExecutionRawHistoryV2Request, opts ...yarpc.CallOption) (*types.GetWorkflowExecutionRawHistoryV2Response, error) {
        response, err := g.c.GetWorkflowExecutionRawHistoryV2(ctx, proto.FromAdminGetWorkflowExecutionRawHistoryV2Request(request), opts...)
        return proto.ToAdminGetWorkflowExecutionRawHistoryV2Response(response), proto.ToError(err)
}

func (g grpcClient) CountDLQMessages(ctx context.Context, request *types.CountDLQMessagesRequest, opts ...yarpc.CallOption) (*types.CountDLQMessagesResponse, error) {
        response, err := g.c.CountDLQMessages(ctx, proto.FromAdminCountDLQMessagesRequest(request), opts...)
        return proto.ToAdminCountDLQMessagesResponse(response), proto.ToError(err)
}

func (g grpcClient) MergeDLQMessages(ctx context.Context, request *types.MergeDLQMessagesRequest, opts ...yarpc.CallOption) (*types.MergeDLQMessagesResponse, error) {
        response, err := g.c.MergeDLQMessages(ctx, proto.FromAdminMergeDLQMessagesRequest(request), opts...)
        return proto.ToAdminMergeDLQMessagesResponse(response), proto.ToError(err)
}

func (g grpcClient) PurgeDLQMessages(ctx context.Context, request *types.PurgeDLQMessagesRequest, opts ...yarpc.CallOption) error {
        _, err := g.c.PurgeDLQMessages(ctx, proto.FromAdminPurgeDLQMessagesRequest(request), opts...)
        return proto.ToError(err)
}

func (g grpcClient) ReadDLQMessages(ctx context.Context, request *types.ReadDLQMessagesRequest, opts ...yarpc.CallOption) (*types.ReadDLQMessagesResponse, error) {
        response, err := g.c.ReadDLQMessages(ctx, proto.FromAdminReadDLQMessagesRequest(request), opts...)
        return proto.ToAdminReadDLQMessagesResponse(response), proto.ToError(err)
}

func (g grpcClient) ReapplyEvents(ctx context.Context, request *types.ReapplyEventsRequest, opts ...yarpc.CallOption) error {
        _, err := g.c.ReapplyEvents(ctx, proto.FromAdminReapplyEventsRequest(request), opts...)
        return proto.ToError(err)
}

func (g grpcClient) RefreshWorkflowTasks(ctx context.Context, request *types.RefreshWorkflowTasksRequest, opts ...yarpc.CallOption) error {
        _, err := g.c.RefreshWorkflowTasks(ctx, proto.FromAdminRefreshWorkflowTasksRequest(request), opts...)
        return proto.ToError(err)
}

func (g grpcClient) RemoveTask(ctx context.Context, request *types.RemoveTaskRequest, opts ...yarpc.CallOption) error {
        _, err := g.c.RemoveTask(ctx, proto.FromAdminRemoveTaskRequest(request), opts...)
        return proto.ToError(err)
}

func (g grpcClient) ResendReplicationTasks(ctx context.Context, request *types.ResendReplicationTasksRequest, opts ...yarpc.CallOption) error {
        _, err := g.c.ResendReplicationTasks(ctx, proto.FromAdminResendReplicationTasksRequest(request), opts...)
        return proto.ToError(err)
}

func (g grpcClient) ResetQueue(ctx context.Context, request *types.ResetQueueRequest, opts ...yarpc.CallOption) error {
        _, err := g.c.ResetQueue(ctx, proto.FromAdminResetQueueRequest(request), opts...)
        return proto.ToError(err)
}

func (g grpcClient) GetCrossClusterTasks(ctx context.Context, request *types.GetCrossClusterTasksRequest, opts ...yarpc.CallOption) (*types.GetCrossClusterTasksResponse, error) {
        response, err := g.c.GetCrossClusterTasks(ctx, proto.FromAdminGetCrossClusterTasksRequest(request), opts...)
        return proto.ToAdminGetCrossClusterTasksResponse(response), proto.ToError(err)
}

func (g grpcClient) RespondCrossClusterTasksCompleted(ctx context.Context, request *types.RespondCrossClusterTasksCompletedRequest, opts ...yarpc.CallOption) (*types.RespondCrossClusterTasksCompletedResponse, error) {
        response, err := g.c.RespondCrossClusterTasksCompleted(ctx, proto.FromAdminRespondCrossClusterTasksCompletedRequest(request), opts...)
        return proto.ToAdminRespondCrossClusterTasksCompletedResponse(response), proto.ToError(err)
}

func (g grpcClient) GetDynamicConfig(ctx context.Context, request *types.GetDynamicConfigRequest, opts ...yarpc.CallOption) (*types.GetDynamicConfigResponse, error) {
        response, err := g.c.GetDynamicConfig(ctx, proto.FromGetDynamicConfigRequest(request), opts...)
        return proto.ToGetDynamicConfigResponse(response), proto.ToError(err)
}

func (g grpcClient) UpdateDynamicConfig(ctx context.Context, request *types.UpdateDynamicConfigRequest, opts ...yarpc.CallOption) error {
        _, err := g.c.UpdateDynamicConfig(ctx, proto.FromUpdateDynamicConfigRequest(request), opts...)
        return proto.ToError(err)
}

func (g grpcClient) RestoreDynamicConfig(ctx context.Context, request *types.RestoreDynamicConfigRequest, opts ...yarpc.CallOption) error {
        _, err := g.c.RestoreDynamicConfig(ctx, proto.FromRestoreDynamicConfigRequest(request), opts...)
        return proto.ToError(err)
}

func (g grpcClient) DeleteWorkflow(ctx context.Context, request *types.AdminDeleteWorkflowRequest, opts ...yarpc.CallOption) (*types.AdminDeleteWorkflowResponse, error) {
        response, err := g.c.DeleteWorkflow(ctx, proto.FromAdminDeleteWorkflowRequest(request), opts...)
        return proto.ToAdminDeleteWorkflowResponse(response), proto.ToError(err)
}

func (g grpcClient) MaintainCorruptWorkflow(ctx context.Context, request *types.AdminMaintainWorkflowRequest, opts ...yarpc.CallOption) (*types.AdminMaintainWorkflowResponse, error) {
        response, err := g.c.MaintainCorruptWorkflow(ctx, proto.FromAdminMaintainWorkflowRequest(request), opts...)
        return proto.ToAdminMaintainWorkflowResponse(response), proto.ToError(err)
}

func (g grpcClient) ListDynamicConfig(ctx context.Context, request *types.ListDynamicConfigRequest, opts ...yarpc.CallOption) (*types.ListDynamicConfigResponse, error) {
        response, err := g.c.ListDynamicConfig(ctx, proto.FromListDynamicConfigRequest(request), opts...)
        return proto.ToListDynamicConfigResponse(response), proto.ToError(err)
}

func (g grpcClient) GetGlobalIsolationGroups(ctx context.Context, request *types.GetGlobalIsolationGroupsRequest, opts ...yarpc.CallOption) (*types.GetGlobalIsolationGroupsResponse, error) {
        response, err := g.c.GetGlobalIsolationGroups(ctx, proto.FromGetGlobalIsolationGroupsRequest(request), opts...)
        return proto.ToGetGlobalIsolationGroupsResponse(response), proto.ToError(err)
}

func (g grpcClient) UpdateGlobalIsolationGroups(ctx context.Context, request *types.UpdateGlobalIsolationGroupsRequest, opts ...yarpc.CallOption) (*types.UpdateGlobalIsolationGroupsResponse, error) {
        response, err := g.c.UpdateGlobalIsolationGroups(ctx, proto.FromUpdateGlobalIsolationGroupsRequest(request), opts...)
        return proto.ToUpdateGlobalIsolationGroupsResponse(response), proto.ToError(err)
}

func (g grpcClient) GetDomainIsolationGroups(ctx context.Context, request *types.GetDomainIsolationGroupsRequest, opts ...yarpc.CallOption) (*types.GetDomainIsolationGroupsResponse, error) {
        response, err := g.c.GetDomainIsolationGroups(ctx, proto.FromGetDomainIsolationGroupsRequest(request), opts...)
        return proto.ToGetDomainIsolationGroupsResponse(response), proto.ToError(err)
}

func (g grpcClient) UpdateDomainIsolationGroups(ctx context.Context, request *types.UpdateDomainIsolationGroupsRequest, opts ...yarpc.CallOption) (*types.UpdateDomainIsolationGroupsResponse, error) {
        response, err := g.c.UpdateDomainIsolationGroups(ctx, proto.FromUpdateDomainIsolationGroupsRequest(request), opts...)
        return proto.ToUpdateDomainIsolationGroupsResponse(response), proto.ToError(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 admin
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"
30	"github.com/uber/cadence/common/types/mapper/proto"
31	)
32
33	type grpcClient struct {
34	c adminv1.AdminAPIYARPCClient
35	}
36
37	func NewGRPCClient(c adminv1.AdminAPIYARPCClient) Client {	87✔
38	return grpcClient{c}	87✔
39	}	87✔
40
41	func (g grpcClient) AddSearchAttribute(ctx context.Context, request *types.AddSearchAttributeRequest, opts ...yarpc.CallOption) error {	×
42	_, err := g.c.AddSearchAttribute(ctx, proto.FromAdminAddSearchAttributeRequest(request), opts...)	×
43	return proto.ToError(err)	×
44	}	×
45
46	func (g grpcClient) CloseShard(ctx context.Context, request *types.CloseShardRequest, opts ...yarpc.CallOption) error {	×
47	_, err := g.c.CloseShard(ctx, proto.FromAdminCloseShardRequest(request), opts...)	×
48	return proto.ToError(err)	×
49	}	×
50
51	func (g grpcClient) DescribeCluster(ctx context.Context, opts ...yarpc.CallOption) (*types.DescribeClusterResponse, error) {	×
52	response, err := g.c.DescribeCluster(ctx, &adminv1.DescribeClusterRequest{}, opts...)	×
53	return proto.ToAdminDescribeClusterResponse(response), proto.ToError(err)	×
54	}	×
55
56	func (g grpcClient) DescribeShardDistribution(ctx context.Context, request types.DescribeShardDistributionRequest, opts ...yarpc.CallOption) (types.DescribeShardDistributionResponse, error) {	×
57	response, err := g.c.DescribeShardDistribution(ctx, proto.FromAdminDescribeShardDistributionRequest(request), opts...)	×
58	return proto.ToAdminDescribeShardDistributionResponse(response), proto.ToError(err)	×
59	}	×
60
61	func (g grpcClient) DescribeHistoryHost(ctx context.Context, request types.DescribeHistoryHostRequest, opts ...yarpc.CallOption) (types.DescribeHistoryHostResponse, error) {	×
62	response, err := g.c.DescribeHistoryHost(ctx, proto.FromAdminDescribeHistoryHostRequest(request), opts...)	×
63	return proto.ToAdminDescribeHistoryHostResponse(response), proto.ToError(err)	×
64	}	×
65
66	func (g grpcClient) DescribeQueue(ctx context.Context, request types.DescribeQueueRequest, opts ...yarpc.CallOption) (types.DescribeQueueResponse, error) {	×
67	response, err := g.c.DescribeQueue(ctx, proto.FromAdminDescribeQueueRequest(request), opts...)	×
68	return proto.ToAdminDescribeQueueResponse(response), proto.ToError(err)	×
69	}	×
70
71	func (g grpcClient) DescribeWorkflowExecution(ctx context.Context, request types.AdminDescribeWorkflowExecutionRequest, opts ...yarpc.CallOption) (types.AdminDescribeWorkflowExecutionResponse, error) {	×
72	response, err := g.c.DescribeWorkflowExecution(ctx, proto.FromAdminDescribeWorkflowExecutionRequest(request), opts...)	×
73	return proto.ToAdminDescribeWorkflowExecutionResponse(response), proto.ToError(err)	×
74	}	×
75
76	func (g grpcClient) GetDLQReplicationMessages(ctx context.Context, request types.GetDLQReplicationMessagesRequest, opts ...yarpc.CallOption) (types.GetDLQReplicationMessagesResponse, error) {	×
77	response, err := g.c.GetDLQReplicationMessages(ctx, proto.FromAdminGetDLQReplicationMessagesRequest(request), opts...)	×
78	return proto.ToAdminGetDLQReplicationMessagesResponse(response), proto.ToError(err)	×
79	}	×
80
81	func (g grpcClient) GetDomainReplicationMessages(ctx context.Context, request types.GetDomainReplicationMessagesRequest, opts ...yarpc.CallOption) (types.GetDomainReplicationMessagesResponse, error) {	147✔
82	response, err := g.c.GetDomainReplicationMessages(ctx, proto.FromAdminGetDomainReplicationMessagesRequest(request), opts...)	147✔
83	return proto.ToAdminGetDomainReplicationMessagesResponse(response), proto.ToError(err)	147✔
84	}	147✔
85
86	func (g grpcClient) GetReplicationMessages(ctx context.Context, request types.GetReplicationMessagesRequest, opts ...yarpc.CallOption) (types.GetReplicationMessagesResponse, error) {	42✔
87	response, err := g.c.GetReplicationMessages(ctx, proto.FromAdminGetReplicationMessagesRequest(request), opts...)	42✔
88	return proto.ToAdminGetReplicationMessagesResponse(response), proto.ToError(err)	42✔
89	}	42✔
90
91	func (g grpcClient) GetWorkflowExecutionRawHistoryV2(ctx context.Context, request types.GetWorkflowExecutionRawHistoryV2Request, opts ...yarpc.CallOption) (types.GetWorkflowExecutionRawHistoryV2Response, error) {	×
92	response, err := g.c.GetWorkflowExecutionRawHistoryV2(ctx, proto.FromAdminGetWorkflowExecutionRawHistoryV2Request(request), opts...)	×
93	return proto.ToAdminGetWorkflowExecutionRawHistoryV2Response(response), proto.ToError(err)	×
94	}	×
95
96	func (g grpcClient) CountDLQMessages(ctx context.Context, request types.CountDLQMessagesRequest, opts ...yarpc.CallOption) (types.CountDLQMessagesResponse, error) {	×
97	response, err := g.c.CountDLQMessages(ctx, proto.FromAdminCountDLQMessagesRequest(request), opts...)	×
98	return proto.ToAdminCountDLQMessagesResponse(response), proto.ToError(err)	×
99	}	×
100
101	func (g grpcClient) MergeDLQMessages(ctx context.Context, request types.MergeDLQMessagesRequest, opts ...yarpc.CallOption) (types.MergeDLQMessagesResponse, error) {	×
102	response, err := g.c.MergeDLQMessages(ctx, proto.FromAdminMergeDLQMessagesRequest(request), opts...)	×
103	return proto.ToAdminMergeDLQMessagesResponse(response), proto.ToError(err)	×
104	}	×
105
106	func (g grpcClient) PurgeDLQMessages(ctx context.Context, request *types.PurgeDLQMessagesRequest, opts ...yarpc.CallOption) error {	×
107	_, err := g.c.PurgeDLQMessages(ctx, proto.FromAdminPurgeDLQMessagesRequest(request), opts...)	×
108	return proto.ToError(err)	×
109	}	×
110
111	func (g grpcClient) ReadDLQMessages(ctx context.Context, request types.ReadDLQMessagesRequest, opts ...yarpc.CallOption) (types.ReadDLQMessagesResponse, error) {	×
112	response, err := g.c.ReadDLQMessages(ctx, proto.FromAdminReadDLQMessagesRequest(request), opts...)	×
113	return proto.ToAdminReadDLQMessagesResponse(response), proto.ToError(err)	×
114	}	×
115
116	func (g grpcClient) ReapplyEvents(ctx context.Context, request *types.ReapplyEventsRequest, opts ...yarpc.CallOption) error {	×
117	_, err := g.c.ReapplyEvents(ctx, proto.FromAdminReapplyEventsRequest(request), opts...)	×
118	return proto.ToError(err)	×
119	}	×
120
121	func (g grpcClient) RefreshWorkflowTasks(ctx context.Context, request *types.RefreshWorkflowTasksRequest, opts ...yarpc.CallOption) error {	×
122	_, err := g.c.RefreshWorkflowTasks(ctx, proto.FromAdminRefreshWorkflowTasksRequest(request), opts...)	×
123	return proto.ToError(err)	×
124	}	×
125
126	func (g grpcClient) RemoveTask(ctx context.Context, request *types.RemoveTaskRequest, opts ...yarpc.CallOption) error {	×
127	_, err := g.c.RemoveTask(ctx, proto.FromAdminRemoveTaskRequest(request), opts...)	×
128	return proto.ToError(err)	×
129	}	×
130
131	func (g grpcClient) ResendReplicationTasks(ctx context.Context, request *types.ResendReplicationTasksRequest, opts ...yarpc.CallOption) error {	×
132	_, err := g.c.ResendReplicationTasks(ctx, proto.FromAdminResendReplicationTasksRequest(request), opts...)	×
133	return proto.ToError(err)	×
134	}	×
135
136	func (g grpcClient) ResetQueue(ctx context.Context, request *types.ResetQueueRequest, opts ...yarpc.CallOption) error {	×
137	_, err := g.c.ResetQueue(ctx, proto.FromAdminResetQueueRequest(request), opts...)	×
138	return proto.ToError(err)	×
139	}	×
140
141	func (g grpcClient) GetCrossClusterTasks(ctx context.Context, request types.GetCrossClusterTasksRequest, opts ...yarpc.CallOption) (types.GetCrossClusterTasksResponse, error) {	72✔
142	response, err := g.c.GetCrossClusterTasks(ctx, proto.FromAdminGetCrossClusterTasksRequest(request), opts...)	72✔
143	return proto.ToAdminGetCrossClusterTasksResponse(response), proto.ToError(err)	72✔
144	}	72✔
145
146	func (g grpcClient) RespondCrossClusterTasksCompleted(ctx context.Context, request types.RespondCrossClusterTasksCompletedRequest, opts ...yarpc.CallOption) (types.RespondCrossClusterTasksCompletedResponse, error) {	×
147	response, err := g.c.RespondCrossClusterTasksCompleted(ctx, proto.FromAdminRespondCrossClusterTasksCompletedRequest(request), opts...)	×
148	return proto.ToAdminRespondCrossClusterTasksCompletedResponse(response), proto.ToError(err)	×
149	}	×
150
151	func (g grpcClient) GetDynamicConfig(ctx context.Context, request types.GetDynamicConfigRequest, opts ...yarpc.CallOption) (types.GetDynamicConfigResponse, error) {	×
152	response, err := g.c.GetDynamicConfig(ctx, proto.FromGetDynamicConfigRequest(request), opts...)	×
153	return proto.ToGetDynamicConfigResponse(response), proto.ToError(err)	×
154	}	×
155
156	func (g grpcClient) UpdateDynamicConfig(ctx context.Context, request *types.UpdateDynamicConfigRequest, opts ...yarpc.CallOption) error {	×
157	_, err := g.c.UpdateDynamicConfig(ctx, proto.FromUpdateDynamicConfigRequest(request), opts...)	×
158	return proto.ToError(err)	×
159	}	×
160
161	func (g grpcClient) RestoreDynamicConfig(ctx context.Context, request *types.RestoreDynamicConfigRequest, opts ...yarpc.CallOption) error {	×
162	_, err := g.c.RestoreDynamicConfig(ctx, proto.FromRestoreDynamicConfigRequest(request), opts...)	×
163	return proto.ToError(err)	×
164	}	×
165
166	func (g grpcClient) DeleteWorkflow(ctx context.Context, request types.AdminDeleteWorkflowRequest, opts ...yarpc.CallOption) (types.AdminDeleteWorkflowResponse, error) {	×
167	response, err := g.c.DeleteWorkflow(ctx, proto.FromAdminDeleteWorkflowRequest(request), opts...)	×
168	return proto.ToAdminDeleteWorkflowResponse(response), proto.ToError(err)	×
169	}	×
170
171	func (g grpcClient) MaintainCorruptWorkflow(ctx context.Context, request types.AdminMaintainWorkflowRequest, opts ...yarpc.CallOption) (types.AdminMaintainWorkflowResponse, error) {	×
172	response, err := g.c.MaintainCorruptWorkflow(ctx, proto.FromAdminMaintainWorkflowRequest(request), opts...)	×
173	return proto.ToAdminMaintainWorkflowResponse(response), proto.ToError(err)	×
174	}	×
175
176	func (g grpcClient) ListDynamicConfig(ctx context.Context, request types.ListDynamicConfigRequest, opts ...yarpc.CallOption) (types.ListDynamicConfigResponse, error) {	×
177	response, err := g.c.ListDynamicConfig(ctx, proto.FromListDynamicConfigRequest(request), opts...)	×
178	return proto.ToListDynamicConfigResponse(response), proto.ToError(err)	×
179	}	×
180
181	func (g grpcClient) GetGlobalIsolationGroups(ctx context.Context, request types.GetGlobalIsolationGroupsRequest, opts ...yarpc.CallOption) (types.GetGlobalIsolationGroupsResponse, error) {	×
182	response, err := g.c.GetGlobalIsolationGroups(ctx, proto.FromGetGlobalIsolationGroupsRequest(request), opts...)	×
183	return proto.ToGetGlobalIsolationGroupsResponse(response), proto.ToError(err)	×
184	}	×
185
186	func (g grpcClient) UpdateGlobalIsolationGroups(ctx context.Context, request types.UpdateGlobalIsolationGroupsRequest, opts ...yarpc.CallOption) (types.UpdateGlobalIsolationGroupsResponse, error) {	×
187	response, err := g.c.UpdateGlobalIsolationGroups(ctx, proto.FromUpdateGlobalIsolationGroupsRequest(request), opts...)	×
188	return proto.ToUpdateGlobalIsolationGroupsResponse(response), proto.ToError(err)	×
189	}	×
190
191	func (g grpcClient) GetDomainIsolationGroups(ctx context.Context, request types.GetDomainIsolationGroupsRequest, opts ...yarpc.CallOption) (types.GetDomainIsolationGroupsResponse, error) {	×
192	response, err := g.c.GetDomainIsolationGroups(ctx, proto.FromGetDomainIsolationGroupsRequest(request), opts...)	×
193	return proto.ToGetDomainIsolationGroupsResponse(response), proto.ToError(err)	×
194	}	×
195
196	func (g grpcClient) UpdateDomainIsolationGroups(ctx context.Context, request types.UpdateDomainIsolationGroupsRequest, opts ...yarpc.CallOption) (types.UpdateDomainIsolationGroupsResponse, error) {	×
197	response, err := g.c.UpdateDomainIsolationGroups(ctx, proto.FromUpdateDomainIsolationGroupsRequest(request), opts...)	×
198	return proto.ToUpdateDomainIsolationGroupsResponse(response), proto.ToError(err)	×
199	}	×

uber / cadence / 01880c2e-e2ba-4ec5-8826-bcc19bd1c271

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