20751880611

Committed 06 Jan 2026 02:47PM UTC coverage: 23.236% (-0.07%) from 23.306%

Build # 20751880611

Build Type

push

github

Committed by

web-flow

Commit Message

build(deps): bump the all-go-mod-patch-and-minor group with 14 updates (#899)

* build(deps): bump the all-go-mod-patch-and-minor group with 14 updates

Bumps the all-go-mod-patch-and-minor group with 14 updates:

| Package | From | To |
| --- | --- | --- |
| [github.com/aws/aws-sdk-go](https://github.com/aws/aws-sdk-go) | `1.55.7` | `1.55.8` |
| [github.com/go-openapi/errors](https://github.com/go-openapi/errors) | `0.22.1` | `0.22.6` |
| [github.com/go-openapi/runtime](https://github.com/go-openapi/runtime) | `0.28.0` | `0.29.2` |
| [github.com/go-openapi/strfmt](https://github.com/go-openapi/strfmt) | `0.23.0` | `0.25.0` |
| [github.com/go-openapi/validate](https://github.com/go-openapi/validate) | `0.24.0` | `0.25.1` |
| [github.com/go-swagger/go-swagger](https://github.com/go-swagger/go-swagger) | `0.32.3` | `0.33.1` |
| [github.com/zalando-incubator/kube-ingress-aws-controller](https://github.com/zalando-incubator/kube-ingress-aws-controller) | `0.17.5` | `0.18.13` |
| [golang.org/x/oauth2](https://github.com/golang/oauth2) | `0.33.0` | `0.34.0` |
| [github.com/aws/aws-sdk-go-v2/service/acm](https://github.com/aws/aws-sdk-go-v2) | `1.31.3` | `1.37.4` |
| [github.com/aws/aws-sdk-go-v2/service/autoscaling](https://github.com/aws/aws-sdk-go-v2) | `1.52.3` | `1.59.1` |
| [github.com/aws/aws-sdk-go-v2/service/cloudformation](https://github.com/aws/aws-sdk-go-v2) | `1.59.2` | `1.66.2` |
| [github.com/aws/aws-sdk-go-v2/service/ec2](https://github.com/aws/aws-sdk-go-v2) | `1.274.0` | `1.279.0` |
| [github.com/aws/aws-sdk-go-v2/service/iam](https://github.com/aws/aws-sdk-go-v2) | `1.41.1` | `1.47.5` |
| [github.com/samber/lo](https://github.com/samber/lo) | `1.51.0` | `1.52.0` |


Updates `github.com/aws/aws-sdk-go` from 1.55.7 to 1.55.8
- [Release notes](https://github.com/aws/aws-sdk-go/releases)
- [Changelog](https://github.com/aws/aws-sdk-go/blob/main/CHANGELOG_PENDING.md)
- [Commits](https://github.com/aws/aws-sdk-go/compare/v1.55.7...v1.55.8)

Upda... (continued)

Run Details

0 of 148 new or added lines in 26 files covered. (0.0%)

32 existing lines in 12 files now uncovered.

3233 of 13914 relevant lines covered (23.24%)

6.47 hits per line

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

0.0

/pkg/cluster-registry/client/node_pools/node_pools_client.go

// Code generated by go-swagger; DO NOT EDIT.

package node_pools

import (
        "fmt"

        "github.com/go-openapi/runtime"
        httptransport "github.com/go-openapi/runtime/client"
        "github.com/go-openapi/strfmt"
)

// New creates a new node pools API client.
func New(transport runtime.ClientTransport, formats strfmt.Registry) ClientService {
        return &Client{transport: transport, formats: formats}
}

// New creates a new node pools API client with basic auth credentials.
// It takes the following parameters:
// - host: http host (github.com).
// - basePath: any base path for the API client ("/v1", "/v3").
// - scheme: http scheme ("http", "https").
// - user: user for basic authentication header.
// - password: password for basic authentication header.
func NewClientWithBasicAuth(host, basePath, scheme, user, password string) ClientService {
        transport := httptransport.New(host, basePath, []string{scheme})
        transport.DefaultAuthentication = httptransport.BasicAuth(user, password)
        return &Client{transport: transport, formats: strfmt.Default}
}

// New creates a new node pools API client with a bearer token for authentication.
// It takes the following parameters:
// - host: http host (github.com).
// - basePath: any base path for the API client ("/v1", "/v3").
// - scheme: http scheme ("http", "https").
// - bearerToken: bearer token for Bearer authentication header.
func NewClientWithBearerToken(host, basePath, scheme, bearerToken string) ClientService {
        transport := httptransport.New(host, basePath, []string{scheme})
        transport.DefaultAuthentication = httptransport.BearerToken(bearerToken)
        return &Client{transport: transport, formats: strfmt.Default}
}

/*
Client for node pools API
*/
type Client struct {
        transport runtime.ClientTransport
        formats   strfmt.Registry
}

// ClientOption may be used to customize the behavior of Client methods.
type ClientOption func(*runtime.ClientOperation)

// ClientService is the interface for Client methods
type ClientService interface {
        CreateOrUpdateNodePool(params *CreateOrUpdateNodePoolParams, authInfo runtime.ClientAuthInfoWriter, opts ...ClientOption) (*CreateOrUpdateNodePoolOK, error)

        DeleteNodePool(params *DeleteNodePoolParams, authInfo runtime.ClientAuthInfoWriter, opts ...ClientOption) (*DeleteNodePoolNoContent, error)

        ListNodePools(params *ListNodePoolsParams, authInfo runtime.ClientAuthInfoWriter, opts ...ClientOption) (*ListNodePoolsOK, error)

        UpdateNodePool(params *UpdateNodePoolParams, authInfo runtime.ClientAuthInfoWriter, opts ...ClientOption) (*UpdateNodePoolOK, error)

        SetTransport(transport runtime.ClientTransport)
}

/*
CreateOrUpdateNodePool creates update node pool

Create/update a node pool.
*/
func (a *Client) CreateOrUpdateNodePool(params *CreateOrUpdateNodePoolParams, authInfo runtime.ClientAuthInfoWriter, opts ...ClientOption) (*CreateOrUpdateNodePoolOK, error) {
        // NOTE: parameters are not validated before sending
        if params == nil {
                params = NewCreateOrUpdateNodePoolParams()
        }
        op := &runtime.ClientOperation{
                ID:                 "createOrUpdateNodePool",
                Method:             "PUT",
                PathPattern:        "/kubernetes-clusters/{cluster_id}/node-pools/{node_pool_name}",
                ProducesMediaTypes: []string{"application/json"},
                ConsumesMediaTypes: []string{"application/json"},
                Schemes:            []string{"https"},
                Params:             params,
                Reader:             &CreateOrUpdateNodePoolReader{formats: a.formats},
                AuthInfo:           authInfo,
                Context:            params.Context,
                Client:             params.HTTPClient,
        }
        for _, opt := range opts {
                opt(op)
        }
        result, err := a.transport.Submit(op)
        if err != nil {
                return nil, err
        }

        // only one success response has to be checked
        success, ok := result.(*CreateOrUpdateNodePoolOK)
        if ok {
                return success, nil
        }

        // unexpected success response.

        // no default response is defined.
        //
        // safeguard: normally, in the absence of a default response, unknown success responses return an error above: so this is a codegen issue
        msg := fmt.Sprintf("unexpected success response for createOrUpdateNodePool: API contract not enforced by server. Client expected to get an error, but got: %T", result)
        panic(msg)
}

/*
DeleteNodePool deletes node pool

Deletes node pool.
*/
func (a *Client) DeleteNodePool(params *DeleteNodePoolParams, authInfo runtime.ClientAuthInfoWriter, opts ...ClientOption) (*DeleteNodePoolNoContent, error) {
        // NOTE: parameters are not validated before sending
        if params == nil {
                params = NewDeleteNodePoolParams()
        }
        op := &runtime.ClientOperation{
                ID:                 "deleteNodePool",
                Method:             "DELETE",
                PathPattern:        "/kubernetes-clusters/{cluster_id}/node-pools/{node_pool_name}",
                ProducesMediaTypes: []string{"application/json"},
                ConsumesMediaTypes: []string{"application/json"},
                Schemes:            []string{"https"},
                Params:             params,
                Reader:             &DeleteNodePoolReader{formats: a.formats},
                AuthInfo:           authInfo,
                Context:            params.Context,
                Client:             params.HTTPClient,
        }
        for _, opt := range opts {
                opt(op)
        }
        result, err := a.transport.Submit(op)
        if err != nil {
                return nil, err
        }

        // only one success response has to be checked
        success, ok := result.(*DeleteNodePoolNoContent)
        if ok {
                return success, nil
        }

        // unexpected success response.

        // no default response is defined.
        //
        // safeguard: normally, in the absence of a default response, unknown success responses return an error above: so this is a codegen issue
        msg := fmt.Sprintf("unexpected success response for deleteNodePool: API contract not enforced by server. Client expected to get an error, but got: %T", result)
        panic(msg)
}

/*
ListNodePools lists node pools

List all node pools of a cluster.
*/
func (a *Client) ListNodePools(params *ListNodePoolsParams, authInfo runtime.ClientAuthInfoWriter, opts ...ClientOption) (*ListNodePoolsOK, error) {
        // NOTE: parameters are not validated before sending
        if params == nil {
                params = NewListNodePoolsParams()
        }
        op := &runtime.ClientOperation{
                ID:                 "listNodePools",
                Method:             "GET",
                PathPattern:        "/kubernetes-clusters/{cluster_id}/node-pools",
                ProducesMediaTypes: []string{"application/json"},
                ConsumesMediaTypes: []string{"application/json"},
                Schemes:            []string{"https"},
                Params:             params,
                Reader:             &ListNodePoolsReader{formats: a.formats},
                AuthInfo:           authInfo,
                Context:            params.Context,
                Client:             params.HTTPClient,
        }
        for _, opt := range opts {
                opt(op)
        }
        result, err := a.transport.Submit(op)
        if err != nil {
                return nil, err
        }

        // only one success response has to be checked
        success, ok := result.(*ListNodePoolsOK)
        if ok {
                return success, nil
        }

        // unexpected success response.

        // no default response is defined.
        //
        // safeguard: normally, in the absence of a default response, unknown success responses return an error above: so this is a codegen issue
        msg := fmt.Sprintf("unexpected success response for listNodePools: API contract not enforced by server. Client expected to get an error, but got: %T", result)
        panic(msg)
}

/*
UpdateNodePool updates node pool

Update a node pool.
*/
func (a *Client) UpdateNodePool(params *UpdateNodePoolParams, authInfo runtime.ClientAuthInfoWriter, opts ...ClientOption) (*UpdateNodePoolOK, error) {
        // NOTE: parameters are not validated before sending
        if params == nil {
                params = NewUpdateNodePoolParams()
        }
        op := &runtime.ClientOperation{
                ID:                 "updateNodePool",
                Method:             "PATCH",
                PathPattern:        "/kubernetes-clusters/{cluster_id}/node-pools/{node_pool_name}",
                ProducesMediaTypes: []string{"application/json"},
                ConsumesMediaTypes: []string{"application/json"},
                Schemes:            []string{"https"},
                Params:             params,
                Reader:             &UpdateNodePoolReader{formats: a.formats},
                AuthInfo:           authInfo,
                Context:            params.Context,
                Client:             params.HTTPClient,
        }
        for _, opt := range opts {
                opt(op)
        }
        result, err := a.transport.Submit(op)
        if err != nil {
                return nil, err
        }

        // only one success response has to be checked
        success, ok := result.(*UpdateNodePoolOK)
        if ok {
                return success, nil
        }

        // unexpected success response.

        // no default response is defined.
        //
        // safeguard: normally, in the absence of a default response, unknown success responses return an error above: so this is a codegen issue
        msg := fmt.Sprintf("unexpected success response for updateNodePool: API contract not enforced by server. Client expected to get an error, but got: %T", result)
        panic(msg)
}

// SetTransport changes the transport on the client
func (a *Client) SetTransport(transport runtime.ClientTransport) {
        a.transport = transport
}

1	// Code generated by go-swagger; DO NOT EDIT.
2
3	package node_pools
4
5	import (
6	"fmt"
7
8	"github.com/go-openapi/runtime"
9	httptransport "github.com/go-openapi/runtime/client"
10	"github.com/go-openapi/strfmt"
11	)
12
13	// New creates a new node pools API client.
14	func New(transport runtime.ClientTransport, formats strfmt.Registry) ClientService {	×
15	return &Client{transport: transport, formats: formats}	×
16	}	×
17
18	// New creates a new node pools API client with basic auth credentials.
19	// It takes the following parameters:
20	// - host: http host (github.com).
21	// - basePath: any base path for the API client ("/v1", "/v3").
22	// - scheme: http scheme ("http", "https").
23	// - user: user for basic authentication header.
24	// - password: password for basic authentication header.
25	func NewClientWithBasicAuth(host, basePath, scheme, user, password string) ClientService {	×
26	transport := httptransport.New(host, basePath, []string{scheme})	×
27	transport.DefaultAuthentication = httptransport.BasicAuth(user, password)	×
28	return &Client{transport: transport, formats: strfmt.Default}	×
29	}	×
30
31	// New creates a new node pools API client with a bearer token for authentication.
32	// It takes the following parameters:
33	// - host: http host (github.com).
34	// - basePath: any base path for the API client ("/v1", "/v3").
35	// - scheme: http scheme ("http", "https").
36	// - bearerToken: bearer token for Bearer authentication header.
37	func NewClientWithBearerToken(host, basePath, scheme, bearerToken string) ClientService {	×
38	transport := httptransport.New(host, basePath, []string{scheme})	×
39	transport.DefaultAuthentication = httptransport.BearerToken(bearerToken)	×
40	return &Client{transport: transport, formats: strfmt.Default}	×
41	}	×
42
43	/*
44	Client for node pools API
45	*/
46	type Client struct {
47	transport runtime.ClientTransport
48	formats strfmt.Registry
49	}
50
51	// ClientOption may be used to customize the behavior of Client methods.
52	type ClientOption func(*runtime.ClientOperation)
53
54	// ClientService is the interface for Client methods
55	type ClientService interface {
56	CreateOrUpdateNodePool(params CreateOrUpdateNodePoolParams, authInfo runtime.ClientAuthInfoWriter, opts ...ClientOption) (CreateOrUpdateNodePoolOK, error)
57
58	DeleteNodePool(params DeleteNodePoolParams, authInfo runtime.ClientAuthInfoWriter, opts ...ClientOption) (DeleteNodePoolNoContent, error)
59
60	ListNodePools(params ListNodePoolsParams, authInfo runtime.ClientAuthInfoWriter, opts ...ClientOption) (ListNodePoolsOK, error)
61
62	UpdateNodePool(params UpdateNodePoolParams, authInfo runtime.ClientAuthInfoWriter, opts ...ClientOption) (UpdateNodePoolOK, error)
63
64	SetTransport(transport runtime.ClientTransport)
65	}
66
67	/*
68	CreateOrUpdateNodePool creates update node pool
69
70	Create/update a node pool.
71	*/
72	func (a Client) CreateOrUpdateNodePool(params CreateOrUpdateNodePoolParams, authInfo runtime.ClientAuthInfoWriter, opts ...ClientOption) (*CreateOrUpdateNodePoolOK, error) {	×
NEW 73	// NOTE: parameters are not validated before sending	×
74	if params == nil {	×
75	params = NewCreateOrUpdateNodePoolParams()	×
76	}	×
77	op := &runtime.ClientOperation{	×
78	ID: "createOrUpdateNodePool",	×
79	Method: "PUT",	×
80	PathPattern: "/kubernetes-clusters/{cluster_id}/node-pools/{node_pool_name}",	×
81	ProducesMediaTypes: []string{"application/json"},	×
82	ConsumesMediaTypes: []string{"application/json"},	×
83	Schemes: []string{"https"},	×
84	Params: params,	×
85	Reader: &CreateOrUpdateNodePoolReader{formats: a.formats},	×
86	AuthInfo: authInfo,	×
87	Context: params.Context,	×
88	Client: params.HTTPClient,	×
89	}	×
90	for _, opt := range opts {	×
91	opt(op)	×
92	}	×
UNCOV 93	result, err := a.transport.Submit(op)	×
94	if err != nil {	×
95	return nil, err	×
96	}	×
97
98	// only one success response has to be checked
99	success, ok := result.(*CreateOrUpdateNodePoolOK)	×
100	if ok {	×
101	return success, nil	×
102	}	×
103
104	// unexpected success response.
105
106	// no default response is defined.
107	//
108	// safeguard: normally, in the absence of a default response, unknown success responses return an error above: so this is a codegen issue
109	msg := fmt.Sprintf("unexpected success response for createOrUpdateNodePool: API contract not enforced by server. Client expected to get an error, but got: %T", result)	×
110	panic(msg)	×
111	}
112
113	/*
114	DeleteNodePool deletes node pool
115
116	Deletes node pool.
117	*/
118	func (a Client) DeleteNodePool(params DeleteNodePoolParams, authInfo runtime.ClientAuthInfoWriter, opts ...ClientOption) (*DeleteNodePoolNoContent, error) {	×
NEW 119	// NOTE: parameters are not validated before sending	×
120	if params == nil {	×
121	params = NewDeleteNodePoolParams()	×
122	}	×
123	op := &runtime.ClientOperation{	×
124	ID: "deleteNodePool",	×
125	Method: "DELETE",	×
126	PathPattern: "/kubernetes-clusters/{cluster_id}/node-pools/{node_pool_name}",	×
127	ProducesMediaTypes: []string{"application/json"},	×
128	ConsumesMediaTypes: []string{"application/json"},	×
129	Schemes: []string{"https"},	×
130	Params: params,	×
131	Reader: &DeleteNodePoolReader{formats: a.formats},	×
132	AuthInfo: authInfo,	×
133	Context: params.Context,	×
134	Client: params.HTTPClient,	×
135	}	×
136	for _, opt := range opts {	×
137	opt(op)	×
138	}	×
UNCOV 139	result, err := a.transport.Submit(op)	×
140	if err != nil {	×
141	return nil, err	×
142	}	×
143
144	// only one success response has to be checked
145	success, ok := result.(*DeleteNodePoolNoContent)	×
146	if ok {	×
147	return success, nil	×
148	}	×
149
150	// unexpected success response.
151
152	// no default response is defined.
153	//
154	// safeguard: normally, in the absence of a default response, unknown success responses return an error above: so this is a codegen issue
155	msg := fmt.Sprintf("unexpected success response for deleteNodePool: API contract not enforced by server. Client expected to get an error, but got: %T", result)	×
156	panic(msg)	×
157	}
158
159	/*
160	ListNodePools lists node pools
161
162	List all node pools of a cluster.
163	*/
164	func (a Client) ListNodePools(params ListNodePoolsParams, authInfo runtime.ClientAuthInfoWriter, opts ...ClientOption) (*ListNodePoolsOK, error) {	×
NEW 165	// NOTE: parameters are not validated before sending	×
166	if params == nil {	×
167	params = NewListNodePoolsParams()	×
168	}	×
169	op := &runtime.ClientOperation{	×
170	ID: "listNodePools",	×
171	Method: "GET",	×
172	PathPattern: "/kubernetes-clusters/{cluster_id}/node-pools",	×
173	ProducesMediaTypes: []string{"application/json"},	×
174	ConsumesMediaTypes: []string{"application/json"},	×
175	Schemes: []string{"https"},	×
176	Params: params,	×
177	Reader: &ListNodePoolsReader{formats: a.formats},	×
178	AuthInfo: authInfo,	×
179	Context: params.Context,	×
180	Client: params.HTTPClient,	×
181	}	×
182	for _, opt := range opts {	×
183	opt(op)	×
184	}	×
UNCOV 185	result, err := a.transport.Submit(op)	×
186	if err != nil {	×
187	return nil, err	×
188	}	×
189
190	// only one success response has to be checked
191	success, ok := result.(*ListNodePoolsOK)	×
192	if ok {	×
193	return success, nil	×
194	}	×
195
196	// unexpected success response.
197
198	// no default response is defined.
199	//
200	// safeguard: normally, in the absence of a default response, unknown success responses return an error above: so this is a codegen issue
201	msg := fmt.Sprintf("unexpected success response for listNodePools: API contract not enforced by server. Client expected to get an error, but got: %T", result)	×
202	panic(msg)	×
203	}
204
205	/*
206	UpdateNodePool updates node pool
207
208	Update a node pool.
209	*/
210	func (a Client) UpdateNodePool(params UpdateNodePoolParams, authInfo runtime.ClientAuthInfoWriter, opts ...ClientOption) (*UpdateNodePoolOK, error) {	×
NEW 211	// NOTE: parameters are not validated before sending	×
212	if params == nil {	×
213	params = NewUpdateNodePoolParams()	×
214	}	×
215	op := &runtime.ClientOperation{	×
216	ID: "updateNodePool",	×
217	Method: "PATCH",	×
218	PathPattern: "/kubernetes-clusters/{cluster_id}/node-pools/{node_pool_name}",	×
219	ProducesMediaTypes: []string{"application/json"},	×
220	ConsumesMediaTypes: []string{"application/json"},	×
221	Schemes: []string{"https"},	×
222	Params: params,	×
223	Reader: &UpdateNodePoolReader{formats: a.formats},	×
224	AuthInfo: authInfo,	×
225	Context: params.Context,	×
226	Client: params.HTTPClient,	×
227	}	×
228	for _, opt := range opts {	×
229	opt(op)	×
230	}	×
UNCOV 231	result, err := a.transport.Submit(op)	×
232	if err != nil {	×
233	return nil, err	×
234	}	×
235
236	// only one success response has to be checked
237	success, ok := result.(*UpdateNodePoolOK)	×
238	if ok {	×
239	return success, nil	×
240	}	×
241
242	// unexpected success response.
243
244	// no default response is defined.
245	//
246	// safeguard: normally, in the absence of a default response, unknown success responses return an error above: so this is a codegen issue
247	msg := fmt.Sprintf("unexpected success response for updateNodePool: API contract not enforced by server. Client expected to get an error, but got: %T", result)	×
248	panic(msg)	×
249	}
250
251	// SetTransport changes the transport on the client
252	func (a *Client) SetTransport(transport runtime.ClientTransport) {	×
253	a.transport = transport	×
254	}	×

zalando-incubator / cluster-lifecycle-manager / 20751880611

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