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

72.73

/common/isolationgroup/isolationgroupapi/global-api-handlers.go

// The MIT License (MIT)

// Copyright (c) 2017-2020 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 isolationgroupapi

import (
        "context"
        "errors"
        "fmt"

        "github.com/uber/cadence/common/dynamicconfig"
        "github.com/uber/cadence/common/types"
)

func (z *handlerImpl) UpdateGlobalState(ctx context.Context, in types.UpdateGlobalIsolationGroupsRequest) error {
        mappedInput, err := MapUpdateGlobalIsolationGroupsRequest(in.IsolationGroups)
        if err != nil {
                return err
        }
        return z.globalIsolationGroupDrains.UpdateValue(
                dynamicconfig.DefaultIsolationGroupConfigStoreManagerGlobalMapping,
                mappedInput,
        )
}

func (z *handlerImpl) GetGlobalState(ctx context.Context) (*types.GetGlobalIsolationGroupsResponse, error) {
        res, err := z.globalIsolationGroupDrains.GetListValue(dynamicconfig.DefaultIsolationGroupConfigStoreManagerGlobalMapping, nil)
        if err != nil {
                var e types.EntityNotExistsError
                if errors.As(err, &e) {
                        return &types.GetGlobalIsolationGroupsResponse{}, nil
                }
                return nil, fmt.Errorf("failed to get global isolation groups from datastore: %w", err)
        }
        resp, err := MapDynamicConfigResponse(res)
        if err != nil {
                return nil, fmt.Errorf("failed to get global isolation groups from datastore: %w", err)
        }
        return &types.GetGlobalIsolationGroupsResponse{IsolationGroups: resp}, nil
}

1	// The MIT License (MIT)
2
3	// Copyright (c) 2017-2020 Uber Technologies Inc.
4
5	// Permission is hereby granted, free of charge, to any person obtaining a copy
6	// of this software and associated documentation files (the "Software"), to deal
7	// in the Software without restriction, including without limitation the rights
8	// to use, copy, modify, merge, publish, distribute, sublicense, and/or sell
9	// copies of the Software, and to permit persons to whom the Software is
10	// furnished to do so, subject to the following conditions:
11	//
12	// The above copyright notice and this permission notice shall be included in all
13	// copies or substantial portions of the Software.
14	//
15	// THE SOFTWARE IS PROVIDED "AS IS", WITHOUT WARRANTY OF ANY KIND, EXPRESS OR
16	// IMPLIED, INCLUDING BUT NOT LIMITED TO THE WARRANTIES OF MERCHANTABILITY,
17	// FITNESS FOR A PARTICULAR PURPOSE AND NONINFRINGEMENT. IN NO EVENT SHALL THE
18	// AUTHORS OR COPYRIGHT HOLDERS BE LIABLE FOR ANY CLAIM, DAMAGES OR OTHER
19	// LIABILITY, WHETHER IN AN ACTION OF CONTRACT, TORT OR OTHERWISE, ARISING FROM,
20	// OUT OF OR IN CONNECTION WITH THE SOFTWARE OR THE USE OR OTHER DEALINGS IN THE
21	// SOFTWARE.
22
23	package isolationgroupapi
24
25	import (
26	"context"
27	"errors"
28	"fmt"
29
30	"github.com/uber/cadence/common/dynamicconfig"
31	"github.com/uber/cadence/common/types"
32	)
33
34	func (z *handlerImpl) UpdateGlobalState(ctx context.Context, in types.UpdateGlobalIsolationGroupsRequest) error {	1✔
35	mappedInput, err := MapUpdateGlobalIsolationGroupsRequest(in.IsolationGroups)	1✔
36	if err != nil {	1✔
37	return err	×
38	}	×
39	return z.globalIsolationGroupDrains.UpdateValue(	1✔
40	dynamicconfig.DefaultIsolationGroupConfigStoreManagerGlobalMapping,	1✔
41	mappedInput,	1✔
42	)	1✔
43	}
44
45	func (z handlerImpl) GetGlobalState(ctx context.Context) (types.GetGlobalIsolationGroupsResponse, error) {	2✔
46	res, err := z.globalIsolationGroupDrains.GetListValue(dynamicconfig.DefaultIsolationGroupConfigStoreManagerGlobalMapping, nil)	2✔
47	if err != nil {	3✔
48	var e types.EntityNotExistsError	1✔
49	if errors.As(err, &e) {	1✔
50	return &types.GetGlobalIsolationGroupsResponse{}, nil	×
51	}	×
52	return nil, fmt.Errorf("failed to get global isolation groups from datastore: %w", err)	1✔
53	}
54	resp, err := MapDynamicConfigResponse(res)	1✔
55	if err != nil {	1✔
56	return nil, fmt.Errorf("failed to get global isolation groups from datastore: %w", err)	×
57	}	×
58	return &types.GetGlobalIsolationGroupsResponse{IsolationGroups: resp}, nil	1✔
59	}

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