mirror of
https://github.com/k3s-io/kubernetes.git
synced 2025-08-04 01:40:07 +00:00
Remove an unused type from kube-proxy config, move around some helpers
This commit is contained in:
parent
cae35dba5a
commit
8de0fc09aa
@ -17,10 +17,6 @@ limitations under the License.
|
|||||||
package config
|
package config
|
||||||
|
|
||||||
import (
|
import (
|
||||||
"fmt"
|
|
||||||
"sort"
|
|
||||||
"strings"
|
|
||||||
|
|
||||||
metav1 "k8s.io/apimachinery/pkg/apis/meta/v1"
|
metav1 "k8s.io/apimachinery/pkg/apis/meta/v1"
|
||||||
componentbaseconfig "k8s.io/component-base/config"
|
componentbaseconfig "k8s.io/component-base/config"
|
||||||
logsapi "k8s.io/component-base/logs/api/v1"
|
logsapi "k8s.io/component-base/logs/api/v1"
|
||||||
@ -265,17 +261,6 @@ const (
|
|||||||
ProxyModeKernelspace ProxyMode = "kernelspace"
|
ProxyModeKernelspace ProxyMode = "kernelspace"
|
||||||
)
|
)
|
||||||
|
|
||||||
// LocalMode represents modes to detect local traffic from the node
|
|
||||||
type LocalMode string
|
|
||||||
|
|
||||||
// Currently supported modes for LocalMode
|
|
||||||
const (
|
|
||||||
LocalModeClusterCIDR LocalMode = "ClusterCIDR"
|
|
||||||
LocalModeNodeCIDR LocalMode = "NodeCIDR"
|
|
||||||
LocalModeBridgeInterface LocalMode = "BridgeInterface"
|
|
||||||
LocalModeInterfaceNamePrefix LocalMode = "InterfaceNamePrefix"
|
|
||||||
)
|
|
||||||
|
|
||||||
func (m *ProxyMode) Set(s string) error {
|
func (m *ProxyMode) Set(s string) error {
|
||||||
*m = ProxyMode(s)
|
*m = ProxyMode(s)
|
||||||
return nil
|
return nil
|
||||||
@ -292,6 +277,17 @@ func (m *ProxyMode) Type() string {
|
|||||||
return "ProxyMode"
|
return "ProxyMode"
|
||||||
}
|
}
|
||||||
|
|
||||||
|
// LocalMode represents modes to detect local traffic from the node
|
||||||
|
type LocalMode string
|
||||||
|
|
||||||
|
// Currently supported modes for LocalMode
|
||||||
|
const (
|
||||||
|
LocalModeClusterCIDR LocalMode = "ClusterCIDR"
|
||||||
|
LocalModeNodeCIDR LocalMode = "NodeCIDR"
|
||||||
|
LocalModeBridgeInterface LocalMode = "BridgeInterface"
|
||||||
|
LocalModeInterfaceNamePrefix LocalMode = "InterfaceNamePrefix"
|
||||||
|
)
|
||||||
|
|
||||||
func (m *LocalMode) Set(s string) error {
|
func (m *LocalMode) Set(s string) error {
|
||||||
*m = LocalMode(s)
|
*m = LocalMode(s)
|
||||||
return nil
|
return nil
|
||||||
@ -307,33 +303,3 @@ func (m *LocalMode) String() string {
|
|||||||
func (m *LocalMode) Type() string {
|
func (m *LocalMode) Type() string {
|
||||||
return "LocalMode"
|
return "LocalMode"
|
||||||
}
|
}
|
||||||
|
|
||||||
type ConfigurationMap map[string]string
|
|
||||||
|
|
||||||
func (m *ConfigurationMap) String() string {
|
|
||||||
pairs := []string{}
|
|
||||||
for k, v := range *m {
|
|
||||||
pairs = append(pairs, fmt.Sprintf("%s=%s", k, v))
|
|
||||||
}
|
|
||||||
sort.Strings(pairs)
|
|
||||||
return strings.Join(pairs, ",")
|
|
||||||
}
|
|
||||||
|
|
||||||
func (m *ConfigurationMap) Set(value string) error {
|
|
||||||
for _, s := range strings.Split(value, ",") {
|
|
||||||
if len(s) == 0 {
|
|
||||||
continue
|
|
||||||
}
|
|
||||||
arr := strings.SplitN(s, "=", 2)
|
|
||||||
if len(arr) == 2 {
|
|
||||||
(*m)[strings.TrimSpace(arr[0])] = strings.TrimSpace(arr[1])
|
|
||||||
} else {
|
|
||||||
(*m)[strings.TrimSpace(arr[0])] = ""
|
|
||||||
}
|
|
||||||
}
|
|
||||||
return nil
|
|
||||||
}
|
|
||||||
|
|
||||||
func (*ConfigurationMap) Type() string {
|
|
||||||
return "mapStringString"
|
|
||||||
}
|
|
||||||
|
22
pkg/proxy/apis/config/zz_generated.deepcopy.go
generated
22
pkg/proxy/apis/config/zz_generated.deepcopy.go
generated
@ -26,28 +26,6 @@ import (
|
|||||||
runtime "k8s.io/apimachinery/pkg/runtime"
|
runtime "k8s.io/apimachinery/pkg/runtime"
|
||||||
)
|
)
|
||||||
|
|
||||||
// DeepCopyInto is an autogenerated deepcopy function, copying the receiver, writing into out. in must be non-nil.
|
|
||||||
func (in ConfigurationMap) DeepCopyInto(out *ConfigurationMap) {
|
|
||||||
{
|
|
||||||
in := &in
|
|
||||||
*out = make(ConfigurationMap, len(*in))
|
|
||||||
for key, val := range *in {
|
|
||||||
(*out)[key] = val
|
|
||||||
}
|
|
||||||
return
|
|
||||||
}
|
|
||||||
}
|
|
||||||
|
|
||||||
// DeepCopy is an autogenerated deepcopy function, copying the receiver, creating a new ConfigurationMap.
|
|
||||||
func (in ConfigurationMap) DeepCopy() ConfigurationMap {
|
|
||||||
if in == nil {
|
|
||||||
return nil
|
|
||||||
}
|
|
||||||
out := new(ConfigurationMap)
|
|
||||||
in.DeepCopyInto(out)
|
|
||||||
return *out
|
|
||||||
}
|
|
||||||
|
|
||||||
// DeepCopyInto is an autogenerated deepcopy function, copying the receiver, writing into out. in must be non-nil.
|
// DeepCopyInto is an autogenerated deepcopy function, copying the receiver, writing into out. in must be non-nil.
|
||||||
func (in *DetectLocalConfiguration) DeepCopyInto(out *DetectLocalConfiguration) {
|
func (in *DetectLocalConfiguration) DeepCopyInto(out *DetectLocalConfiguration) {
|
||||||
*out = *in
|
*out = *in
|
||||||
|
Loading…
Reference in New Issue
Block a user