github/kubernetes
1
0
Fork 0
mirror of https://github.com/k3s-io/kubernetes.git synced 2025-09-15 14:14:39 +00:00
Code Issues Projects Releases Wiki Activity

pkg/proxy/config: rename import aliases

Browse Source 
* coreinformers -> v1informers
* discovery -> discoveryv1
* discoveryinformers -> discoveryv1informers

Signed-off-by: Daman Arora <aroradaman@gmail.com>
This commit is contained in:
Daman Arora
2024-01-21 12:36:10 +05:30
parent 212c5dd216
commit d23483dd7c
1 changed files with 14 additions and 14 deletions
Download Patch File Download Diff File Expand all files Collapse all files

28
pkg/proxy/config/config.go
View File

@@ -21,10 +21,10 @@ import (
"time" "time"
v1 "k8s.io/api/core/v1" v1 "k8s.io/api/core/v1"
discovery "k8s.io/api/discovery/v1" discoveryv1 "k8s.io/api/discovery/v1"
utilruntime "k8s.io/apimachinery/pkg/util/runtime" utilruntime "k8s.io/apimachinery/pkg/util/runtime"
coreinformers "k8s.io/client-go/informers/core/v1" v1informers "k8s.io/client-go/informers/core/v1"
discoveryinformers "k8s.io/client-go/informers/discovery/v1" discoveryv1informers "k8s.io/client-go/informers/discovery/v1"
"k8s.io/client-go/tools/cache" "k8s.io/client-go/tools/cache"
"k8s.io/klog/v2" "k8s.io/klog/v2"
) )
@@ -51,13 +51,13 @@ type ServiceHandler interface {
type EndpointSliceHandler interface { type EndpointSliceHandler interface {
// OnEndpointSliceAdd is called whenever creation of new endpoint slice // OnEndpointSliceAdd is called whenever creation of new endpoint slice
// object is observed. // object is observed.
OnEndpointSliceAdd(endpointSlice *discovery.EndpointSlice) OnEndpointSliceAdd(endpointSlice *discoveryv1.EndpointSlice)
// OnEndpointSliceUpdate is called whenever modification of an existing // OnEndpointSliceUpdate is called whenever modification of an existing
// endpoint slice object is observed. // endpoint slice object is observed.
OnEndpointSliceUpdate(oldEndpointSlice, newEndpointSlice *discovery.EndpointSlice) OnEndpointSliceUpdate(oldEndpointSlice, newEndpointSlice *discoveryv1.EndpointSlice)
// OnEndpointSliceDelete is called whenever deletion of an existing // OnEndpointSliceDelete is called whenever deletion of an existing
// endpoint slice object is observed. // endpoint slice object is observed.
OnEndpointSliceDelete(endpointSlice *discovery.EndpointSlice) OnEndpointSliceDelete(endpointSlice *discoveryv1.EndpointSlice)
// OnEndpointSlicesSynced is called once all the initial event handlers were // OnEndpointSlicesSynced is called once all the initial event handlers were
// called and the state is fully propagated to local cache. // called and the state is fully propagated to local cache.
OnEndpointSlicesSynced() OnEndpointSlicesSynced()
@@ -70,7 +70,7 @@ type EndpointSliceConfig struct {
} }
// NewEndpointSliceConfig creates a new EndpointSliceConfig. // NewEndpointSliceConfig creates a new EndpointSliceConfig.
func NewEndpointSliceConfig(endpointSliceInformer discoveryinformers.EndpointSliceInformer, resyncPeriod time.Duration) *EndpointSliceConfig { func NewEndpointSliceConfig(endpointSliceInformer discoveryv1informers.EndpointSliceInformer, resyncPeriod time.Duration) *EndpointSliceConfig {
result := &EndpointSliceConfig{ result := &EndpointSliceConfig{
listerSynced: endpointSliceInformer.Informer().HasSynced, listerSynced: endpointSliceInformer.Informer().HasSynced,
} }
@@ -107,7 +107,7 @@ func (c *EndpointSliceConfig) Run(stopCh <-chan struct{}) {
} }
func (c *EndpointSliceConfig) handleAddEndpointSlice(obj interface{}) { func (c *EndpointSliceConfig) handleAddEndpointSlice(obj interface{}) {
endpointSlice, ok := obj.(*discovery.EndpointSlice) endpointSlice, ok := obj.(*discoveryv1.EndpointSlice)
if !ok { if !ok {
utilruntime.HandleError(fmt.Errorf("unexpected object type: %T", obj)) utilruntime.HandleError(fmt.Errorf("unexpected object type: %T", obj))
return return
@@ -119,12 +119,12 @@ func (c *EndpointSliceConfig) handleAddEndpointSlice(obj interface{}) {
} }
func (c *EndpointSliceConfig) handleUpdateEndpointSlice(oldObj, newObj interface{}) { func (c *EndpointSliceConfig) handleUpdateEndpointSlice(oldObj, newObj interface{}) {
oldEndpointSlice, ok := oldObj.(*discovery.EndpointSlice) oldEndpointSlice, ok := oldObj.(*discoveryv1.EndpointSlice)
if !ok { if !ok {
utilruntime.HandleError(fmt.Errorf("unexpected object type: %T", newObj)) utilruntime.HandleError(fmt.Errorf("unexpected object type: %T", newObj))
return return
} }
newEndpointSlice, ok := newObj.(*discovery.EndpointSlice) newEndpointSlice, ok := newObj.(*discoveryv1.EndpointSlice)
if !ok { if !ok {
utilruntime.HandleError(fmt.Errorf("unexpected object type: %T", newObj)) utilruntime.HandleError(fmt.Errorf("unexpected object type: %T", newObj))
return return
@@ -136,14 +136,14 @@ func (c *EndpointSliceConfig) handleUpdateEndpointSlice(oldObj, newObj interface
} }
func (c *EndpointSliceConfig) handleDeleteEndpointSlice(obj interface{}) { func (c *EndpointSliceConfig) handleDeleteEndpointSlice(obj interface{}) {
endpointSlice, ok := obj.(*discovery.EndpointSlice) endpointSlice, ok := obj.(*discoveryv1.EndpointSlice)
if !ok { if !ok {
tombstone, ok := obj.(cache.DeletedFinalStateUnknown) tombstone, ok := obj.(cache.DeletedFinalStateUnknown)
if !ok { if !ok {
utilruntime.HandleError(fmt.Errorf("unexpected object type: %T", obj)) utilruntime.HandleError(fmt.Errorf("unexpected object type: %T", obj))
return return
} }
if endpointSlice, ok = tombstone.Obj.(*discovery.EndpointSlice); !ok { if endpointSlice, ok = tombstone.Obj.(*discoveryv1.EndpointSlice); !ok {
utilruntime.HandleError(fmt.Errorf("unexpected object type: %T", obj)) utilruntime.HandleError(fmt.Errorf("unexpected object type: %T", obj))
return return
} }
@@ -161,7 +161,7 @@ type ServiceConfig struct {
} }
// NewServiceConfig creates a new ServiceConfig. // NewServiceConfig creates a new ServiceConfig.
func NewServiceConfig(serviceInformer coreinformers.ServiceInformer, resyncPeriod time.Duration) *ServiceConfig { func NewServiceConfig(serviceInformer v1informers.ServiceInformer, resyncPeriod time.Duration) *ServiceConfig {
result := &ServiceConfig{ result := &ServiceConfig{
listerSynced: serviceInformer.Informer().HasSynced, listerSynced: serviceInformer.Informer().HasSynced,
} }
@@ -288,7 +288,7 @@ type NodeConfig struct {
} }
// NewNodeConfig creates a new NodeConfig. // NewNodeConfig creates a new NodeConfig.
func NewNodeConfig(nodeInformer coreinformers.NodeInformer, resyncPeriod time.Duration) *NodeConfig { func NewNodeConfig(nodeInformer v1informers.NodeInformer, resyncPeriod time.Duration) *NodeConfig {
result := &NodeConfig{ result := &NodeConfig{
listerSynced: nodeInformer.Informer().HasSynced, listerSynced: nodeInformer.Informer().HasSynced,
} }