mirror of
https://github.com/k3s-io/kubernetes.git
synced 2025-08-11 13:02:14 +00:00
[gce provider] Ran hack/update-cloudprovider-gce.sh
This commit is contained in:
parent
c516a35d4d
commit
5d02573e56
@ -3018,6 +3018,7 @@ type BetaBackendServices interface {
|
|||||||
Insert(ctx context.Context, key *meta.Key, obj *beta.BackendService) error
|
Insert(ctx context.Context, key *meta.Key, obj *beta.BackendService) error
|
||||||
Delete(ctx context.Context, key *meta.Key) error
|
Delete(ctx context.Context, key *meta.Key) error
|
||||||
SetSecurityPolicy(context.Context, *meta.Key, *beta.SecurityPolicyReference) error
|
SetSecurityPolicy(context.Context, *meta.Key, *beta.SecurityPolicyReference) error
|
||||||
|
Update(context.Context, *meta.Key, *beta.BackendService) error
|
||||||
}
|
}
|
||||||
|
|
||||||
// NewMockBetaBackendServices returns a new mock for BackendServices.
|
// NewMockBetaBackendServices returns a new mock for BackendServices.
|
||||||
@ -3058,6 +3059,7 @@ type MockBetaBackendServices struct {
|
|||||||
InsertHook func(ctx context.Context, key *meta.Key, obj *beta.BackendService, m *MockBetaBackendServices) (bool, error)
|
InsertHook func(ctx context.Context, key *meta.Key, obj *beta.BackendService, m *MockBetaBackendServices) (bool, error)
|
||||||
DeleteHook func(ctx context.Context, key *meta.Key, m *MockBetaBackendServices) (bool, error)
|
DeleteHook func(ctx context.Context, key *meta.Key, m *MockBetaBackendServices) (bool, error)
|
||||||
SetSecurityPolicyHook func(context.Context, *meta.Key, *beta.SecurityPolicyReference, *MockBetaBackendServices) error
|
SetSecurityPolicyHook func(context.Context, *meta.Key, *beta.SecurityPolicyReference, *MockBetaBackendServices) error
|
||||||
|
UpdateHook func(context.Context, *meta.Key, *beta.BackendService, *MockBetaBackendServices) error
|
||||||
|
|
||||||
// X is extra state that can be used as part of the mock. Generated code
|
// X is extra state that can be used as part of the mock. Generated code
|
||||||
// will not use this field.
|
// will not use this field.
|
||||||
@ -3211,6 +3213,14 @@ func (m *MockBetaBackendServices) SetSecurityPolicy(ctx context.Context, key *me
|
|||||||
return nil
|
return nil
|
||||||
}
|
}
|
||||||
|
|
||||||
|
// Update is a mock for the corresponding method.
|
||||||
|
func (m *MockBetaBackendServices) Update(ctx context.Context, key *meta.Key, arg0 *beta.BackendService) error {
|
||||||
|
if m.UpdateHook != nil {
|
||||||
|
return m.UpdateHook(ctx, key, arg0, m)
|
||||||
|
}
|
||||||
|
return nil
|
||||||
|
}
|
||||||
|
|
||||||
// GCEBetaBackendServices is a simplifying adapter for the GCE BackendServices.
|
// GCEBetaBackendServices is a simplifying adapter for the GCE BackendServices.
|
||||||
type GCEBetaBackendServices struct {
|
type GCEBetaBackendServices struct {
|
||||||
s *Service
|
s *Service
|
||||||
@ -3386,6 +3396,39 @@ func (g *GCEBetaBackendServices) SetSecurityPolicy(ctx context.Context, key *met
|
|||||||
return err
|
return err
|
||||||
}
|
}
|
||||||
|
|
||||||
|
// Update is a method on GCEBetaBackendServices.
|
||||||
|
func (g *GCEBetaBackendServices) Update(ctx context.Context, key *meta.Key, arg0 *beta.BackendService) error {
|
||||||
|
glog.V(5).Infof("GCEBetaBackendServices.Update(%v, %v, ...): called", ctx, key)
|
||||||
|
|
||||||
|
if !key.Valid() {
|
||||||
|
glog.V(2).Infof("GCEBetaBackendServices.Update(%v, %v, ...): key is invalid (%#v)", ctx, key, key)
|
||||||
|
return fmt.Errorf("invalid GCE key (%+v)", key)
|
||||||
|
}
|
||||||
|
projectID := g.s.ProjectRouter.ProjectID(ctx, "beta", "BackendServices")
|
||||||
|
rk := &RateLimitKey{
|
||||||
|
ProjectID: projectID,
|
||||||
|
Operation: "Update",
|
||||||
|
Version: meta.Version("beta"),
|
||||||
|
Service: "BackendServices",
|
||||||
|
}
|
||||||
|
glog.V(5).Infof("GCEBetaBackendServices.Update(%v, %v, ...): projectID = %v, rk = %+v", ctx, key, projectID, rk)
|
||||||
|
|
||||||
|
if err := g.s.RateLimiter.Accept(ctx, rk); err != nil {
|
||||||
|
glog.V(4).Infof("GCEBetaBackendServices.Update(%v, %v, ...): RateLimiter error: %v", ctx, key, err)
|
||||||
|
return err
|
||||||
|
}
|
||||||
|
call := g.s.Beta.BackendServices.Update(projectID, key.Name, arg0)
|
||||||
|
call.Context(ctx)
|
||||||
|
op, err := call.Do()
|
||||||
|
if err != nil {
|
||||||
|
glog.V(4).Infof("GCEBetaBackendServices.Update(%v, %v, ...) = %+v", ctx, key, err)
|
||||||
|
return err
|
||||||
|
}
|
||||||
|
err = g.s.WaitForCompletion(ctx, op)
|
||||||
|
glog.V(4).Infof("GCEBetaBackendServices.Update(%v, %v, ...) = %+v", ctx, key, err)
|
||||||
|
return err
|
||||||
|
}
|
||||||
|
|
||||||
// AlphaBackendServices is an interface that allows for mocking of BackendServices.
|
// AlphaBackendServices is an interface that allows for mocking of BackendServices.
|
||||||
type AlphaBackendServices interface {
|
type AlphaBackendServices interface {
|
||||||
Get(ctx context.Context, key *meta.Key) (*alpha.BackendService, error)
|
Get(ctx context.Context, key *meta.Key) (*alpha.BackendService, error)
|
||||||
|
Loading…
Reference in New Issue
Block a user