mirror of https://github.com/k3s-io/k3s
Fix typos in kube-proxy
parent
8b3b5a9fe7
commit
ba64ae18bc
|
@ -33,7 +33,7 @@ type netlinkHandle struct {
|
||||||
isIPv6 bool
|
isIPv6 bool
|
||||||
}
|
}
|
||||||
|
|
||||||
// NewNetLinkHandle will crate a new NetLinkHandle
|
// NewNetLinkHandle will create a new NetLinkHandle
|
||||||
func NewNetLinkHandle(isIPv6 bool) NetLinkHandle {
|
func NewNetLinkHandle(isIPv6 bool) NetLinkHandle {
|
||||||
return &netlinkHandle{netlink.Handle{}, isIPv6}
|
return &netlinkHandle{netlink.Handle{}, isIPv6}
|
||||||
}
|
}
|
||||||
|
|
|
@ -669,7 +669,7 @@ func (proxier *Proxier) OnServiceDelete(service *v1.Service) {
|
||||||
proxier.OnServiceUpdate(service, nil)
|
proxier.OnServiceUpdate(service, nil)
|
||||||
}
|
}
|
||||||
|
|
||||||
// OnServiceSynced is called once all the initial even handlers were called and the state is fully propagated to local cache.
|
// OnServiceSynced is called once all the initial event handlers were called and the state is fully propagated to local cache.
|
||||||
func (proxier *Proxier) OnServiceSynced() {
|
func (proxier *Proxier) OnServiceSynced() {
|
||||||
proxier.mu.Lock()
|
proxier.mu.Lock()
|
||||||
proxier.servicesSynced = true
|
proxier.servicesSynced = true
|
||||||
|
|
|
@ -43,7 +43,7 @@ func (lp *LocalPort) String() string {
|
||||||
return fmt.Sprintf("%q (%s/%s)", lp.Description, ipPort, lp.Protocol)
|
return fmt.Sprintf("%q (%s/%s)", lp.Description, ipPort, lp.Protocol)
|
||||||
}
|
}
|
||||||
|
|
||||||
// Closeable is an interface around closing an port.
|
// Closeable is an interface around closing a port.
|
||||||
type Closeable interface {
|
type Closeable interface {
|
||||||
Close() error
|
Close() error
|
||||||
}
|
}
|
||||||
|
|
Loading…
Reference in New Issue