mirror of
https://github.com/k3s-io/kubernetes.git
synced 2025-07-23 11:50:44 +00:00
update polymorphichelpers for external types
This commit is contained in:
parent
23111ad414
commit
608bf0de1f
@ -31,6 +31,7 @@ go_library(
|
|||||||
"//pkg/controller:go_default_library",
|
"//pkg/controller:go_default_library",
|
||||||
"//pkg/kubectl:go_default_library",
|
"//pkg/kubectl:go_default_library",
|
||||||
"//pkg/kubectl/genericclioptions:go_default_library",
|
"//pkg/kubectl/genericclioptions:go_default_library",
|
||||||
|
"//pkg/kubectl/scheme:go_default_library",
|
||||||
"//staging/src/k8s.io/api/apps/v1:go_default_library",
|
"//staging/src/k8s.io/api/apps/v1:go_default_library",
|
||||||
"//staging/src/k8s.io/api/apps/v1beta1:go_default_library",
|
"//staging/src/k8s.io/api/apps/v1beta1:go_default_library",
|
||||||
"//staging/src/k8s.io/api/apps/v1beta2:go_default_library",
|
"//staging/src/k8s.io/api/apps/v1beta2:go_default_library",
|
||||||
|
@ -19,6 +19,11 @@ package polymorphichelpers
|
|||||||
import (
|
import (
|
||||||
"fmt"
|
"fmt"
|
||||||
|
|
||||||
|
appsv1 "k8s.io/api/apps/v1"
|
||||||
|
appsv1beta1 "k8s.io/api/apps/v1beta1"
|
||||||
|
appsv1beta2 "k8s.io/api/apps/v1beta2"
|
||||||
|
corev1 "k8s.io/api/core/v1"
|
||||||
|
extensionsv1beta1 "k8s.io/api/extensions/v1beta1"
|
||||||
"k8s.io/apimachinery/pkg/runtime"
|
"k8s.io/apimachinery/pkg/runtime"
|
||||||
api "k8s.io/kubernetes/pkg/apis/core"
|
api "k8s.io/kubernetes/pkg/apis/core"
|
||||||
"k8s.io/kubernetes/pkg/apis/extensions"
|
"k8s.io/kubernetes/pkg/apis/extensions"
|
||||||
@ -33,16 +38,31 @@ func mapBasedSelectorForObject(object runtime.Object) (string, error) {
|
|||||||
switch t := object.(type) {
|
switch t := object.(type) {
|
||||||
case *api.ReplicationController:
|
case *api.ReplicationController:
|
||||||
return kubectl.MakeLabels(t.Spec.Selector), nil
|
return kubectl.MakeLabels(t.Spec.Selector), nil
|
||||||
|
case *corev1.ReplicationController:
|
||||||
|
return kubectl.MakeLabels(t.Spec.Selector), nil
|
||||||
|
|
||||||
case *api.Pod:
|
case *api.Pod:
|
||||||
if len(t.Labels) == 0 {
|
if len(t.Labels) == 0 {
|
||||||
return "", fmt.Errorf("the pod has no labels and cannot be exposed")
|
return "", fmt.Errorf("the pod has no labels and cannot be exposed")
|
||||||
}
|
}
|
||||||
return kubectl.MakeLabels(t.Labels), nil
|
return kubectl.MakeLabels(t.Labels), nil
|
||||||
|
case *corev1.Pod:
|
||||||
|
if len(t.Labels) == 0 {
|
||||||
|
return "", fmt.Errorf("the pod has no labels and cannot be exposed")
|
||||||
|
}
|
||||||
|
return kubectl.MakeLabels(t.Labels), nil
|
||||||
|
|
||||||
case *api.Service:
|
case *api.Service:
|
||||||
if t.Spec.Selector == nil {
|
if t.Spec.Selector == nil {
|
||||||
return "", fmt.Errorf("the service has no pod selector set")
|
return "", fmt.Errorf("the service has no pod selector set")
|
||||||
}
|
}
|
||||||
return kubectl.MakeLabels(t.Spec.Selector), nil
|
return kubectl.MakeLabels(t.Spec.Selector), nil
|
||||||
|
case *corev1.Service:
|
||||||
|
if t.Spec.Selector == nil {
|
||||||
|
return "", fmt.Errorf("the service has no pod selector set")
|
||||||
|
}
|
||||||
|
return kubectl.MakeLabels(t.Spec.Selector), nil
|
||||||
|
|
||||||
case *extensions.Deployment:
|
case *extensions.Deployment:
|
||||||
// TODO(madhusudancs): Make this smarter by admitting MatchExpressions with Equals
|
// TODO(madhusudancs): Make this smarter by admitting MatchExpressions with Equals
|
||||||
// operator, DoubleEquals operator and In operator with only one element in the set.
|
// operator, DoubleEquals operator and In operator with only one element in the set.
|
||||||
@ -50,6 +70,35 @@ func mapBasedSelectorForObject(object runtime.Object) (string, error) {
|
|||||||
return "", fmt.Errorf("couldn't convert expressions - \"%+v\" to map-based selector format", t.Spec.Selector.MatchExpressions)
|
return "", fmt.Errorf("couldn't convert expressions - \"%+v\" to map-based selector format", t.Spec.Selector.MatchExpressions)
|
||||||
}
|
}
|
||||||
return kubectl.MakeLabels(t.Spec.Selector.MatchLabels), nil
|
return kubectl.MakeLabels(t.Spec.Selector.MatchLabels), nil
|
||||||
|
case *extensionsv1beta1.Deployment:
|
||||||
|
// TODO(madhusudancs): Make this smarter by admitting MatchExpressions with Equals
|
||||||
|
// operator, DoubleEquals operator and In operator with only one element in the set.
|
||||||
|
if len(t.Spec.Selector.MatchExpressions) > 0 {
|
||||||
|
return "", fmt.Errorf("couldn't convert expressions - \"%+v\" to map-based selector format", t.Spec.Selector.MatchExpressions)
|
||||||
|
}
|
||||||
|
return kubectl.MakeLabels(t.Spec.Selector.MatchLabels), nil
|
||||||
|
case *appsv1.Deployment:
|
||||||
|
// TODO(madhusudancs): Make this smarter by admitting MatchExpressions with Equals
|
||||||
|
// operator, DoubleEquals operator and In operator with only one element in the set.
|
||||||
|
if len(t.Spec.Selector.MatchExpressions) > 0 {
|
||||||
|
return "", fmt.Errorf("couldn't convert expressions - \"%+v\" to map-based selector format", t.Spec.Selector.MatchExpressions)
|
||||||
|
}
|
||||||
|
return kubectl.MakeLabels(t.Spec.Selector.MatchLabels), nil
|
||||||
|
case *appsv1beta2.Deployment:
|
||||||
|
// TODO(madhusudancs): Make this smarter by admitting MatchExpressions with Equals
|
||||||
|
// operator, DoubleEquals operator and In operator with only one element in the set.
|
||||||
|
if len(t.Spec.Selector.MatchExpressions) > 0 {
|
||||||
|
return "", fmt.Errorf("couldn't convert expressions - \"%+v\" to map-based selector format", t.Spec.Selector.MatchExpressions)
|
||||||
|
}
|
||||||
|
return kubectl.MakeLabels(t.Spec.Selector.MatchLabels), nil
|
||||||
|
case *appsv1beta1.Deployment:
|
||||||
|
// TODO(madhusudancs): Make this smarter by admitting MatchExpressions with Equals
|
||||||
|
// operator, DoubleEquals operator and In operator with only one element in the set.
|
||||||
|
if len(t.Spec.Selector.MatchExpressions) > 0 {
|
||||||
|
return "", fmt.Errorf("couldn't convert expressions - \"%+v\" to map-based selector format", t.Spec.Selector.MatchExpressions)
|
||||||
|
}
|
||||||
|
return kubectl.MakeLabels(t.Spec.Selector.MatchLabels), nil
|
||||||
|
|
||||||
case *extensions.ReplicaSet:
|
case *extensions.ReplicaSet:
|
||||||
// TODO(madhusudancs): Make this smarter by admitting MatchExpressions with Equals
|
// TODO(madhusudancs): Make this smarter by admitting MatchExpressions with Equals
|
||||||
// operator, DoubleEquals operator and In operator with only one element in the set.
|
// operator, DoubleEquals operator and In operator with only one element in the set.
|
||||||
@ -57,6 +106,28 @@ func mapBasedSelectorForObject(object runtime.Object) (string, error) {
|
|||||||
return "", fmt.Errorf("couldn't convert expressions - \"%+v\" to map-based selector format", t.Spec.Selector.MatchExpressions)
|
return "", fmt.Errorf("couldn't convert expressions - \"%+v\" to map-based selector format", t.Spec.Selector.MatchExpressions)
|
||||||
}
|
}
|
||||||
return kubectl.MakeLabels(t.Spec.Selector.MatchLabels), nil
|
return kubectl.MakeLabels(t.Spec.Selector.MatchLabels), nil
|
||||||
|
case *extensionsv1beta1.ReplicaSet:
|
||||||
|
// TODO(madhusudancs): Make this smarter by admitting MatchExpressions with Equals
|
||||||
|
// operator, DoubleEquals operator and In operator with only one element in the set.
|
||||||
|
if len(t.Spec.Selector.MatchExpressions) > 0 {
|
||||||
|
return "", fmt.Errorf("couldn't convert expressions - \"%+v\" to map-based selector format", t.Spec.Selector.MatchExpressions)
|
||||||
|
}
|
||||||
|
return kubectl.MakeLabels(t.Spec.Selector.MatchLabels), nil
|
||||||
|
case *appsv1.ReplicaSet:
|
||||||
|
// TODO(madhusudancs): Make this smarter by admitting MatchExpressions with Equals
|
||||||
|
// operator, DoubleEquals operator and In operator with only one element in the set.
|
||||||
|
if len(t.Spec.Selector.MatchExpressions) > 0 {
|
||||||
|
return "", fmt.Errorf("couldn't convert expressions - \"%+v\" to map-based selector format", t.Spec.Selector.MatchExpressions)
|
||||||
|
}
|
||||||
|
return kubectl.MakeLabels(t.Spec.Selector.MatchLabels), nil
|
||||||
|
case *appsv1beta2.ReplicaSet:
|
||||||
|
// TODO(madhusudancs): Make this smarter by admitting MatchExpressions with Equals
|
||||||
|
// operator, DoubleEquals operator and In operator with only one element in the set.
|
||||||
|
if len(t.Spec.Selector.MatchExpressions) > 0 {
|
||||||
|
return "", fmt.Errorf("couldn't convert expressions - \"%+v\" to map-based selector format", t.Spec.Selector.MatchExpressions)
|
||||||
|
}
|
||||||
|
return kubectl.MakeLabels(t.Spec.Selector.MatchLabels), nil
|
||||||
|
|
||||||
default:
|
default:
|
||||||
return "", fmt.Errorf("cannot extract pod selector from %T", object)
|
return "", fmt.Errorf("cannot extract pod selector from %T", object)
|
||||||
}
|
}
|
||||||
|
@ -20,10 +20,15 @@ import (
|
|||||||
"errors"
|
"errors"
|
||||||
"fmt"
|
"fmt"
|
||||||
|
|
||||||
|
appsv1 "k8s.io/api/apps/v1"
|
||||||
|
appsv1beta1 "k8s.io/api/apps/v1beta1"
|
||||||
|
appsv1beta2 "k8s.io/api/apps/v1beta2"
|
||||||
|
extensionsv1beta1 "k8s.io/api/extensions/v1beta1"
|
||||||
"k8s.io/apimachinery/pkg/apis/meta/v1/unstructured"
|
"k8s.io/apimachinery/pkg/apis/meta/v1/unstructured"
|
||||||
"k8s.io/apimachinery/pkg/runtime"
|
"k8s.io/apimachinery/pkg/runtime"
|
||||||
"k8s.io/kubernetes/pkg/api/legacyscheme"
|
"k8s.io/kubernetes/pkg/api/legacyscheme"
|
||||||
"k8s.io/kubernetes/pkg/apis/extensions"
|
"k8s.io/kubernetes/pkg/apis/extensions"
|
||||||
|
"k8s.io/kubernetes/pkg/kubectl/scheme"
|
||||||
)
|
)
|
||||||
|
|
||||||
// Currently only supports Deployments.
|
// Currently only supports Deployments.
|
||||||
@ -35,6 +40,35 @@ func defaultObjectPauser(obj runtime.Object) ([]byte, error) {
|
|||||||
}
|
}
|
||||||
obj.Spec.Paused = true
|
obj.Spec.Paused = true
|
||||||
return runtime.Encode(internalVersionJSONEncoder(), obj)
|
return runtime.Encode(internalVersionJSONEncoder(), obj)
|
||||||
|
|
||||||
|
case *extensionsv1beta1.Deployment:
|
||||||
|
if obj.Spec.Paused {
|
||||||
|
return nil, errors.New("is already paused")
|
||||||
|
}
|
||||||
|
obj.Spec.Paused = true
|
||||||
|
return runtime.Encode(scheme.Codecs.LegacyCodec(extensionsv1beta1.SchemeGroupVersion), obj)
|
||||||
|
|
||||||
|
case *appsv1.Deployment:
|
||||||
|
if obj.Spec.Paused {
|
||||||
|
return nil, errors.New("is already paused")
|
||||||
|
}
|
||||||
|
obj.Spec.Paused = true
|
||||||
|
return runtime.Encode(scheme.Codecs.LegacyCodec(appsv1.SchemeGroupVersion), obj)
|
||||||
|
|
||||||
|
case *appsv1beta2.Deployment:
|
||||||
|
if obj.Spec.Paused {
|
||||||
|
return nil, errors.New("is already paused")
|
||||||
|
}
|
||||||
|
obj.Spec.Paused = true
|
||||||
|
return runtime.Encode(scheme.Codecs.LegacyCodec(appsv1beta2.SchemeGroupVersion), obj)
|
||||||
|
|
||||||
|
case *appsv1beta1.Deployment:
|
||||||
|
if obj.Spec.Paused {
|
||||||
|
return nil, errors.New("is already paused")
|
||||||
|
}
|
||||||
|
obj.Spec.Paused = true
|
||||||
|
return runtime.Encode(scheme.Codecs.LegacyCodec(appsv1beta1.SchemeGroupVersion), obj)
|
||||||
|
|
||||||
default:
|
default:
|
||||||
return nil, fmt.Errorf("pausing is not supported")
|
return nil, fmt.Errorf("pausing is not supported")
|
||||||
}
|
}
|
||||||
|
@ -20,8 +20,13 @@ import (
|
|||||||
"errors"
|
"errors"
|
||||||
"fmt"
|
"fmt"
|
||||||
|
|
||||||
|
appsv1 "k8s.io/api/apps/v1"
|
||||||
|
appsv1beta1 "k8s.io/api/apps/v1beta1"
|
||||||
|
appsv1beta2 "k8s.io/api/apps/v1beta2"
|
||||||
|
extensionsv1beta1 "k8s.io/api/extensions/v1beta1"
|
||||||
"k8s.io/apimachinery/pkg/runtime"
|
"k8s.io/apimachinery/pkg/runtime"
|
||||||
"k8s.io/kubernetes/pkg/apis/extensions"
|
"k8s.io/kubernetes/pkg/apis/extensions"
|
||||||
|
"k8s.io/kubernetes/pkg/kubectl/scheme"
|
||||||
)
|
)
|
||||||
|
|
||||||
func defaultObjectResumer(obj runtime.Object) ([]byte, error) {
|
func defaultObjectResumer(obj runtime.Object) ([]byte, error) {
|
||||||
@ -32,6 +37,35 @@ func defaultObjectResumer(obj runtime.Object) ([]byte, error) {
|
|||||||
}
|
}
|
||||||
obj.Spec.Paused = false
|
obj.Spec.Paused = false
|
||||||
return runtime.Encode(internalVersionJSONEncoder(), obj)
|
return runtime.Encode(internalVersionJSONEncoder(), obj)
|
||||||
|
|
||||||
|
case *extensionsv1beta1.Deployment:
|
||||||
|
if !obj.Spec.Paused {
|
||||||
|
return nil, errors.New("is not paused")
|
||||||
|
}
|
||||||
|
obj.Spec.Paused = false
|
||||||
|
return runtime.Encode(scheme.Codecs.LegacyCodec(extensionsv1beta1.SchemeGroupVersion), obj)
|
||||||
|
|
||||||
|
case *appsv1.Deployment:
|
||||||
|
if !obj.Spec.Paused {
|
||||||
|
return nil, errors.New("is not paused")
|
||||||
|
}
|
||||||
|
obj.Spec.Paused = false
|
||||||
|
return runtime.Encode(scheme.Codecs.LegacyCodec(appsv1.SchemeGroupVersion), obj)
|
||||||
|
|
||||||
|
case *appsv1beta2.Deployment:
|
||||||
|
if !obj.Spec.Paused {
|
||||||
|
return nil, errors.New("is not paused")
|
||||||
|
}
|
||||||
|
obj.Spec.Paused = false
|
||||||
|
return runtime.Encode(scheme.Codecs.LegacyCodec(appsv1beta2.SchemeGroupVersion), obj)
|
||||||
|
|
||||||
|
case *appsv1beta1.Deployment:
|
||||||
|
if !obj.Spec.Paused {
|
||||||
|
return nil, errors.New("is not paused")
|
||||||
|
}
|
||||||
|
obj.Spec.Paused = false
|
||||||
|
return runtime.Encode(scheme.Codecs.LegacyCodec(appsv1beta1.SchemeGroupVersion), obj)
|
||||||
|
|
||||||
default:
|
default:
|
||||||
return nil, fmt.Errorf("resuming is not supported")
|
return nil, fmt.Errorf("resuming is not supported")
|
||||||
}
|
}
|
||||||
|
@ -20,6 +20,11 @@ import (
|
|||||||
"fmt"
|
"fmt"
|
||||||
"strconv"
|
"strconv"
|
||||||
|
|
||||||
|
appsv1 "k8s.io/api/apps/v1"
|
||||||
|
appsv1beta1 "k8s.io/api/apps/v1beta1"
|
||||||
|
appsv1beta2 "k8s.io/api/apps/v1beta2"
|
||||||
|
corev1 "k8s.io/api/core/v1"
|
||||||
|
extensionsv1beta1 "k8s.io/api/extensions/v1beta1"
|
||||||
"k8s.io/apimachinery/pkg/runtime"
|
"k8s.io/apimachinery/pkg/runtime"
|
||||||
api "k8s.io/kubernetes/pkg/apis/core"
|
api "k8s.io/kubernetes/pkg/apis/core"
|
||||||
"k8s.io/kubernetes/pkg/apis/extensions"
|
"k8s.io/kubernetes/pkg/apis/extensions"
|
||||||
@ -28,21 +33,45 @@ import (
|
|||||||
func portsForObject(object runtime.Object) ([]string, error) {
|
func portsForObject(object runtime.Object) ([]string, error) {
|
||||||
switch t := object.(type) {
|
switch t := object.(type) {
|
||||||
case *api.ReplicationController:
|
case *api.ReplicationController:
|
||||||
|
return getPortsInternal(t.Spec.Template.Spec), nil
|
||||||
|
case *corev1.ReplicationController:
|
||||||
return getPorts(t.Spec.Template.Spec), nil
|
return getPorts(t.Spec.Template.Spec), nil
|
||||||
|
|
||||||
case *api.Pod:
|
case *api.Pod:
|
||||||
|
return getPortsInternal(t.Spec), nil
|
||||||
|
case *corev1.Pod:
|
||||||
return getPorts(t.Spec), nil
|
return getPorts(t.Spec), nil
|
||||||
|
|
||||||
case *api.Service:
|
case *api.Service:
|
||||||
|
return getServicePortsInternal(t.Spec), nil
|
||||||
|
case *corev1.Service:
|
||||||
return getServicePorts(t.Spec), nil
|
return getServicePorts(t.Spec), nil
|
||||||
|
|
||||||
case *extensions.Deployment:
|
case *extensions.Deployment:
|
||||||
|
return getPortsInternal(t.Spec.Template.Spec), nil
|
||||||
|
case *extensionsv1beta1.Deployment:
|
||||||
return getPorts(t.Spec.Template.Spec), nil
|
return getPorts(t.Spec.Template.Spec), nil
|
||||||
|
case *appsv1.Deployment:
|
||||||
|
return getPorts(t.Spec.Template.Spec), nil
|
||||||
|
case *appsv1beta2.Deployment:
|
||||||
|
return getPorts(t.Spec.Template.Spec), nil
|
||||||
|
case *appsv1beta1.Deployment:
|
||||||
|
return getPorts(t.Spec.Template.Spec), nil
|
||||||
|
|
||||||
case *extensions.ReplicaSet:
|
case *extensions.ReplicaSet:
|
||||||
|
return getPortsInternal(t.Spec.Template.Spec), nil
|
||||||
|
case *extensionsv1beta1.ReplicaSet:
|
||||||
|
return getPorts(t.Spec.Template.Spec), nil
|
||||||
|
case *appsv1.ReplicaSet:
|
||||||
|
return getPorts(t.Spec.Template.Spec), nil
|
||||||
|
case *appsv1beta2.ReplicaSet:
|
||||||
return getPorts(t.Spec.Template.Spec), nil
|
return getPorts(t.Spec.Template.Spec), nil
|
||||||
default:
|
default:
|
||||||
return nil, fmt.Errorf("cannot extract ports from %T", object)
|
return nil, fmt.Errorf("cannot extract ports from %T", object)
|
||||||
}
|
}
|
||||||
}
|
}
|
||||||
|
|
||||||
func getPorts(spec api.PodSpec) []string {
|
func getPortsInternal(spec api.PodSpec) []string {
|
||||||
result := []string{}
|
result := []string{}
|
||||||
for _, container := range spec.Containers {
|
for _, container := range spec.Containers {
|
||||||
for _, port := range container.Ports {
|
for _, port := range container.Ports {
|
||||||
@ -53,7 +82,25 @@ func getPorts(spec api.PodSpec) []string {
|
|||||||
}
|
}
|
||||||
|
|
||||||
// Extracts the ports exposed by a service from the given service spec.
|
// Extracts the ports exposed by a service from the given service spec.
|
||||||
func getServicePorts(spec api.ServiceSpec) []string {
|
func getServicePortsInternal(spec api.ServiceSpec) []string {
|
||||||
|
result := []string{}
|
||||||
|
for _, servicePort := range spec.Ports {
|
||||||
|
result = append(result, strconv.Itoa(int(servicePort.Port)))
|
||||||
|
}
|
||||||
|
return result
|
||||||
|
}
|
||||||
|
|
||||||
|
func getPorts(spec corev1.PodSpec) []string {
|
||||||
|
result := []string{}
|
||||||
|
for _, container := range spec.Containers {
|
||||||
|
for _, port := range container.Ports {
|
||||||
|
result = append(result, strconv.Itoa(int(port.ContainerPort)))
|
||||||
|
}
|
||||||
|
}
|
||||||
|
return result
|
||||||
|
}
|
||||||
|
|
||||||
|
func getServicePorts(spec corev1.ServiceSpec) []string {
|
||||||
result := []string{}
|
result := []string{}
|
||||||
for _, servicePort := range spec.Ports {
|
for _, servicePort := range spec.Ports {
|
||||||
result = append(result, strconv.Itoa(int(servicePort.Port)))
|
result = append(result, strconv.Itoa(int(servicePort.Port)))
|
||||||
|
@ -20,6 +20,11 @@ import (
|
|||||||
"fmt"
|
"fmt"
|
||||||
"strconv"
|
"strconv"
|
||||||
|
|
||||||
|
appsv1 "k8s.io/api/apps/v1"
|
||||||
|
appsv1beta1 "k8s.io/api/apps/v1beta1"
|
||||||
|
appsv1beta2 "k8s.io/api/apps/v1beta2"
|
||||||
|
corev1 "k8s.io/api/core/v1"
|
||||||
|
extensionsv1beta1 "k8s.io/api/extensions/v1beta1"
|
||||||
"k8s.io/apimachinery/pkg/runtime"
|
"k8s.io/apimachinery/pkg/runtime"
|
||||||
api "k8s.io/kubernetes/pkg/apis/core"
|
api "k8s.io/kubernetes/pkg/apis/core"
|
||||||
"k8s.io/kubernetes/pkg/apis/extensions"
|
"k8s.io/kubernetes/pkg/apis/extensions"
|
||||||
@ -29,21 +34,46 @@ func protocolsForObject(object runtime.Object) (map[string]string, error) {
|
|||||||
// TODO: replace with a swagger schema based approach (identify pod selector via schema introspection)
|
// TODO: replace with a swagger schema based approach (identify pod selector via schema introspection)
|
||||||
switch t := object.(type) {
|
switch t := object.(type) {
|
||||||
case *api.ReplicationController:
|
case *api.ReplicationController:
|
||||||
|
return getProtocolsInternal(t.Spec.Template.Spec), nil
|
||||||
|
case *corev1.ReplicationController:
|
||||||
return getProtocols(t.Spec.Template.Spec), nil
|
return getProtocols(t.Spec.Template.Spec), nil
|
||||||
|
|
||||||
case *api.Pod:
|
case *api.Pod:
|
||||||
|
return getProtocolsInternal(t.Spec), nil
|
||||||
|
case *corev1.Pod:
|
||||||
return getProtocols(t.Spec), nil
|
return getProtocols(t.Spec), nil
|
||||||
|
|
||||||
case *api.Service:
|
case *api.Service:
|
||||||
|
return getServiceProtocolsInternal(t.Spec), nil
|
||||||
|
case *corev1.Service:
|
||||||
return getServiceProtocols(t.Spec), nil
|
return getServiceProtocols(t.Spec), nil
|
||||||
|
|
||||||
case *extensions.Deployment:
|
case *extensions.Deployment:
|
||||||
|
return getProtocolsInternal(t.Spec.Template.Spec), nil
|
||||||
|
case *extensionsv1beta1.Deployment:
|
||||||
return getProtocols(t.Spec.Template.Spec), nil
|
return getProtocols(t.Spec.Template.Spec), nil
|
||||||
|
case *appsv1.Deployment:
|
||||||
|
return getProtocols(t.Spec.Template.Spec), nil
|
||||||
|
case *appsv1beta2.Deployment:
|
||||||
|
return getProtocols(t.Spec.Template.Spec), nil
|
||||||
|
case *appsv1beta1.Deployment:
|
||||||
|
return getProtocols(t.Spec.Template.Spec), nil
|
||||||
|
|
||||||
case *extensions.ReplicaSet:
|
case *extensions.ReplicaSet:
|
||||||
|
return getProtocolsInternal(t.Spec.Template.Spec), nil
|
||||||
|
case *extensionsv1beta1.ReplicaSet:
|
||||||
return getProtocols(t.Spec.Template.Spec), nil
|
return getProtocols(t.Spec.Template.Spec), nil
|
||||||
|
case *appsv1.ReplicaSet:
|
||||||
|
return getProtocols(t.Spec.Template.Spec), nil
|
||||||
|
case *appsv1beta2.ReplicaSet:
|
||||||
|
return getProtocols(t.Spec.Template.Spec), nil
|
||||||
|
|
||||||
default:
|
default:
|
||||||
return nil, fmt.Errorf("cannot extract protocols from %T", object)
|
return nil, fmt.Errorf("cannot extract protocols from %T", object)
|
||||||
}
|
}
|
||||||
}
|
}
|
||||||
|
|
||||||
func getProtocols(spec api.PodSpec) map[string]string {
|
func getProtocolsInternal(spec api.PodSpec) map[string]string {
|
||||||
result := make(map[string]string)
|
result := make(map[string]string)
|
||||||
for _, container := range spec.Containers {
|
for _, container := range spec.Containers {
|
||||||
for _, port := range container.Ports {
|
for _, port := range container.Ports {
|
||||||
@ -54,7 +84,26 @@ func getProtocols(spec api.PodSpec) map[string]string {
|
|||||||
}
|
}
|
||||||
|
|
||||||
// Extracts the protocols exposed by a service from the given service spec.
|
// Extracts the protocols exposed by a service from the given service spec.
|
||||||
func getServiceProtocols(spec api.ServiceSpec) map[string]string {
|
func getServiceProtocolsInternal(spec api.ServiceSpec) map[string]string {
|
||||||
|
result := make(map[string]string)
|
||||||
|
for _, servicePort := range spec.Ports {
|
||||||
|
result[strconv.Itoa(int(servicePort.Port))] = string(servicePort.Protocol)
|
||||||
|
}
|
||||||
|
return result
|
||||||
|
}
|
||||||
|
|
||||||
|
func getProtocols(spec corev1.PodSpec) map[string]string {
|
||||||
|
result := make(map[string]string)
|
||||||
|
for _, container := range spec.Containers {
|
||||||
|
for _, port := range container.Ports {
|
||||||
|
result[strconv.Itoa(int(port.ContainerPort))] = string(port.Protocol)
|
||||||
|
}
|
||||||
|
}
|
||||||
|
return result
|
||||||
|
}
|
||||||
|
|
||||||
|
// Extracts the protocols exposed by a service from the given service spec.
|
||||||
|
func getServiceProtocols(spec corev1.ServiceSpec) map[string]string {
|
||||||
result := make(map[string]string)
|
result := make(map[string]string)
|
||||||
for _, servicePort := range spec.Ports {
|
for _, servicePort := range spec.Ports {
|
||||||
result[strconv.Itoa(int(servicePort.Port))] = string(servicePort.Protocol)
|
result[strconv.Itoa(int(servicePort.Port))] = string(servicePort.Protocol)
|
||||||
|
Loading…
Reference in New Issue
Block a user