diff --git a/cmd/kube-proxy/app/server.go b/cmd/kube-proxy/app/server.go index 13a751df477..ac8c4d7413c 100644 --- a/cmd/kube-proxy/app/server.go +++ b/cmd/kube-proxy/app/server.go @@ -465,7 +465,7 @@ type ProxyServer struct { IpvsInterface utilipvs.Interface IpsetInterface utilipset.Interface execer exec.Interface - Proxier proxy.ProxyProvider + Proxier proxy.Provider Broadcaster record.EventBroadcaster Recorder record.EventRecorder ConntrackConfiguration kubeproxyconfig.KubeProxyConntrackConfiguration diff --git a/cmd/kube-proxy/app/server_others.go b/cmd/kube-proxy/app/server_others.go index a43767a8136..ecd34278131 100644 --- a/cmd/kube-proxy/app/server_others.go +++ b/cmd/kube-proxy/app/server_others.go @@ -131,7 +131,7 @@ func newProxyServer( healthzUpdater = healthzServer } - var proxier proxy.ProxyProvider + var proxier proxy.Provider proxyMode := getProxyMode(string(config.Mode), kernelHandler, ipsetInterface, iptables.LinuxKernelCompatTester{}) nodeIP := net.ParseIP(config.BindAddress) diff --git a/cmd/kube-proxy/app/server_windows.go b/cmd/kube-proxy/app/server_windows.go index a2877c56f81..bef3f3be017 100644 --- a/cmd/kube-proxy/app/server_windows.go +++ b/cmd/kube-proxy/app/server_windows.go @@ -94,7 +94,7 @@ func newProxyServer(config *proxyconfigapi.KubeProxyConfiguration, cleanupAndExi healthzUpdater = healthzServer } - var proxier proxy.ProxyProvider + var proxier proxy.Provider proxyMode := getProxyMode(string(config.Mode), winkernel.WindowsKernelCompatTester{}) if proxyMode == proxyModeKernelspace { diff --git a/hack/.golint_failures b/hack/.golint_failures index 3b3b3b0ef67..1b17896a95c 100644 --- a/hack/.golint_failures +++ b/hack/.golint_failures @@ -141,7 +141,6 @@ pkg/kubemark pkg/master pkg/master/controller/crdregistration pkg/master/tunneler -pkg/proxy pkg/proxy/apis/config pkg/proxy/apis/config/v1alpha1 pkg/proxy/userspace diff --git a/pkg/kubemark/hollow_proxy.go b/pkg/kubemark/hollow_proxy.go index e2665845f1f..5a77012c74f 100644 --- a/pkg/kubemark/hollow_proxy.go +++ b/pkg/kubemark/hollow_proxy.go @@ -70,7 +70,7 @@ func NewHollowProxyOrDie( proxierMinSyncPeriod time.Duration, ) (*HollowProxy, error) { // Create proxier and service/endpoint handlers. - var proxier proxy.ProxyProvider + var proxier proxy.Provider var err error if useRealProxier { diff --git a/pkg/proxy/endpoints.go b/pkg/proxy/endpoints.go index dafd209857b..6cd334e72e2 100644 --- a/pkg/proxy/endpoints.go +++ b/pkg/proxy/endpoints.go @@ -205,7 +205,7 @@ type UpdateEndpointMapResult struct { LastChangeTriggerTimes []time.Time } -// UpdateEndpointsMap updates endpointsMap base on the given changes. +// Update updates endpointsMap base on the given changes. func (em EndpointsMap) Update(changes *EndpointChangeTracker) (result UpdateEndpointMapResult) { result.StaleEndpoints = make([]ServiceEndpoint, 0) result.StaleServiceNames = make([]ServicePortName, 0) diff --git a/pkg/proxy/iptables/proxier.go b/pkg/proxy/iptables/proxier.go index 1ce47a5e409..b6eddfeb5d3 100644 --- a/pkg/proxy/iptables/proxier.go +++ b/pkg/proxy/iptables/proxier.go @@ -235,8 +235,8 @@ func (l *listenPortOpener) OpenLocalPort(lp *utilproxy.LocalPort) (utilproxy.Clo return openLocalPort(lp) } -// Proxier implements ProxyProvider -var _ proxy.ProxyProvider = &Proxier{} +// Proxier implements proxy.Provider +var _ proxy.Provider = &Proxier{} // NewProxier returns a new Proxier given an iptables Interface instance. // Because of the iptables logic, it is assumed that there is only a single Proxier active on a machine. diff --git a/pkg/proxy/ipvs/proxier.go b/pkg/proxy/ipvs/proxier.go index 6264ea33587..f3eae341512 100644 --- a/pkg/proxy/ipvs/proxier.go +++ b/pkg/proxy/ipvs/proxier.go @@ -273,8 +273,8 @@ func (r *realIPGetter) NodeIPs() (ips []net.IP, err error) { return ips, nil } -// Proxier implements ProxyProvider -var _ proxy.ProxyProvider = &Proxier{} +// Proxier implements proxy.Provider +var _ proxy.Provider = &Proxier{} // parseExcludedCIDRs parses the input strings and returns net.IPNet // The validation has been done earlier so the error condition will never happen under normal conditions diff --git a/pkg/proxy/types.go b/pkg/proxy/types.go index 5b62f7ed948..7279093c15b 100644 --- a/pkg/proxy/types.go +++ b/pkg/proxy/types.go @@ -25,12 +25,12 @@ import ( "k8s.io/kubernetes/pkg/proxy/config" ) -// ProxyProvider is the interface provided by proxier implementations. -type ProxyProvider interface { +// Provider is the interface provided by proxier implementations. +type Provider interface { config.EndpointsHandler config.ServiceHandler - // Sync immediately synchronizes the ProxyProvider's current state to proxy rules. + // Sync immediately synchronizes the Provider's current state to proxy rules. Sync() // SyncLoop runs periodic work. // This is expected to run as a goroutine or as the main loop of the app. diff --git a/pkg/proxy/userspace/proxier.go b/pkg/proxy/userspace/proxier.go index ae55842b302..46d9e9c86cb 100644 --- a/pkg/proxy/userspace/proxier.go +++ b/pkg/proxy/userspace/proxier.go @@ -138,8 +138,8 @@ type Proxier struct { stopChan chan struct{} } -// assert Proxier is a ProxyProvider -var _ proxy.ProxyProvider = &Proxier{} +// assert Proxier is a proxy.Provider +var _ proxy.Provider = &Proxier{} // A key for the portMap. The ip has to be a string because slices can't be map // keys. diff --git a/pkg/proxy/winkernel/proxier.go b/pkg/proxy/winkernel/proxier.go index ea435210da1..22fde005c3e 100644 --- a/pkg/proxy/winkernel/proxier.go +++ b/pkg/proxy/winkernel/proxier.go @@ -510,8 +510,8 @@ type closeable interface { Close() error } -// Proxier implements ProxyProvider -var _ proxy.ProxyProvider = &Proxier{} +// Proxier implements proxy.Provider +var _ proxy.Provider = &Proxier{} // NewProxier returns a new Proxier func NewProxier( diff --git a/pkg/proxy/winuserspace/proxier.go b/pkg/proxy/winuserspace/proxier.go index 91cbd6337c8..717a0bce553 100644 --- a/pkg/proxy/winuserspace/proxier.go +++ b/pkg/proxy/winuserspace/proxier.go @@ -92,8 +92,8 @@ type Proxier struct { hostIP net.IP } -// assert Proxier is a ProxyProvider -var _ proxy.ProxyProvider = &Proxier{} +// assert Proxier is a proxy.Provider +var _ proxy.Provider = &Proxier{} // A key for the portMap. The ip has to be a string because slices can't be map // keys.