commit
2a3b30bbd3
4 changed files with 11 additions and 16 deletions
|
@ -86,12 +86,7 @@ func (e1 *Config) Equal(e2 *Config) bool {
|
||||||
return false
|
return false
|
||||||
}
|
}
|
||||||
|
|
||||||
match = sets.StringElementsMatch(e1.AuthCacheDuration, e2.AuthCacheDuration)
|
return sets.StringElementsMatch(e1.AuthCacheDuration, e2.AuthCacheDuration)
|
||||||
if !match {
|
|
||||||
return false
|
|
||||||
}
|
|
||||||
|
|
||||||
return true
|
|
||||||
}
|
}
|
||||||
|
|
||||||
var (
|
var (
|
||||||
|
|
|
@ -168,7 +168,7 @@ func TestHeaderAnnotations(t *testing.T) {
|
||||||
i, err := NewParser(&resolver.Mock{}).Parse(ing)
|
i, err := NewParser(&resolver.Mock{}).Parse(ing)
|
||||||
if test.expErr {
|
if test.expErr {
|
||||||
if err == nil {
|
if err == nil {
|
||||||
t.Errorf("%v: expected error but retuned nil", err.Error())
|
t.Error("expected error but retuned nil")
|
||||||
}
|
}
|
||||||
continue
|
continue
|
||||||
}
|
}
|
||||||
|
@ -216,7 +216,7 @@ func TestCacheDurationAnnotations(t *testing.T) {
|
||||||
i, err := NewParser(&resolver.Mock{}).Parse(ing)
|
i, err := NewParser(&resolver.Mock{}).Parse(ing)
|
||||||
if test.expErr {
|
if test.expErr {
|
||||||
if err == nil {
|
if err == nil {
|
||||||
t.Errorf("%v: expected error but retuned nil", err.Error())
|
t.Errorf("expected error but retuned nil")
|
||||||
}
|
}
|
||||||
continue
|
continue
|
||||||
}
|
}
|
||||||
|
|
|
@ -227,7 +227,7 @@ type Location struct {
|
||||||
// Backend describes the name of the backend to use.
|
// Backend describes the name of the backend to use.
|
||||||
Backend string `json:"backend"`
|
Backend string `json:"backend"`
|
||||||
// Service describes the referenced services from the ingress
|
// Service describes the referenced services from the ingress
|
||||||
Service *apiv1.Service `json:"service,omitempty"`
|
Service *apiv1.Service `json:"service,omitempty" hash:"ignore"`
|
||||||
// Port describes to which port from the service
|
// Port describes to which port from the service
|
||||||
Port intstr.IntOrString `json:"port"`
|
Port intstr.IntOrString `json:"port"`
|
||||||
// Overwrite the Host header passed into the backend. Defaults to
|
// Overwrite the Host header passed into the backend. Defaults to
|
||||||
|
@ -290,7 +290,7 @@ type Location struct {
|
||||||
ClientBodyBufferSize string `json:"clientBodyBufferSize,omitempty"`
|
ClientBodyBufferSize string `json:"clientBodyBufferSize,omitempty"`
|
||||||
// DefaultBackend allows the use of a custom default backend for this location.
|
// DefaultBackend allows the use of a custom default backend for this location.
|
||||||
// +optional
|
// +optional
|
||||||
DefaultBackend *apiv1.Service `json:"defaultBackend,omitempty"`
|
DefaultBackend *apiv1.Service `json:"defaultBackend,omitempty" hash:"ignore"`
|
||||||
// DefaultBackendUpstreamName is the upstream-formatted string for the name of
|
// DefaultBackendUpstreamName is the upstream-formatted string for the name of
|
||||||
// this location's custom default backend
|
// this location's custom default backend
|
||||||
DefaultBackendUpstreamName string `json:"defaultBackendUpstreamName,omitempty"`
|
DefaultBackendUpstreamName string `json:"defaultBackendUpstreamName,omitempty"`
|
||||||
|
@ -327,7 +327,7 @@ type Location struct {
|
||||||
// The endpoints must provide the TLS termination exposing the required SSL certificate.
|
// The endpoints must provide the TLS termination exposing the required SSL certificate.
|
||||||
// The ingress controller only pipes the underlying TCP connection
|
// The ingress controller only pipes the underlying TCP connection
|
||||||
type SSLPassthroughBackend struct {
|
type SSLPassthroughBackend struct {
|
||||||
Service *apiv1.Service `json:"service,omitempty"`
|
Service *apiv1.Service `json:"service,omitempty" hash:"ignore"`
|
||||||
Port intstr.IntOrString `json:"port"`
|
Port intstr.IntOrString `json:"port"`
|
||||||
// Backend describes the endpoints to use.
|
// Backend describes the endpoints to use.
|
||||||
Backend string `json:"namespace,omitempty"`
|
Backend string `json:"namespace,omitempty"`
|
||||||
|
@ -344,7 +344,7 @@ type L4Service struct {
|
||||||
// Endpoints active endpoints of the service
|
// Endpoints active endpoints of the service
|
||||||
Endpoints []Endpoint `json:"endpoints,omitempty"`
|
Endpoints []Endpoint `json:"endpoints,omitempty"`
|
||||||
// k8s Service
|
// k8s Service
|
||||||
Service *apiv1.Service `json:"service,omitempty"`
|
Service *apiv1.Service `json:"service,omitempty" hash:"ignore"`
|
||||||
}
|
}
|
||||||
|
|
||||||
// L4Backend describes the kubernetes service behind L4 Ingress service
|
// L4Backend describes the kubernetes service behind L4 Ingress service
|
||||||
|
@ -365,8 +365,8 @@ type ProxyProtocol struct {
|
||||||
|
|
||||||
// Ingress holds the definition of an Ingress plus its annotations
|
// Ingress holds the definition of an Ingress plus its annotations
|
||||||
type Ingress struct {
|
type Ingress struct {
|
||||||
networking.Ingress
|
networking.Ingress `hash:"ignore"`
|
||||||
ParsedAnnotations *annotations.Ingress
|
ParsedAnnotations *annotations.Ingress `json:"parsedAnnotations"`
|
||||||
}
|
}
|
||||||
|
|
||||||
// GeneralConfig holds the definition of lua general configuration data
|
// GeneralConfig holds the definition of lua general configuration data
|
||||||
|
|
|
@ -122,13 +122,13 @@ func NetworkingIngressAvailable(client clientset.Interface) bool {
|
||||||
return false
|
return false
|
||||||
}
|
}
|
||||||
|
|
||||||
serverVersion, _ := client.Discovery().ServerVersion()
|
serverVersion, err := client.Discovery().ServerVersion()
|
||||||
if err != nil {
|
if err != nil {
|
||||||
klog.Errorf("unexpected error parsing Kubernetes version: %v", err)
|
klog.Errorf("unexpected error parsing Kubernetes version: %v", err)
|
||||||
return false
|
return false
|
||||||
}
|
}
|
||||||
|
|
||||||
runningVersion, _ := version.ParseGeneric(serverVersion.String())
|
runningVersion, err := version.ParseGeneric(serverVersion.String())
|
||||||
if err != nil {
|
if err != nil {
|
||||||
klog.Errorf("unexpected error parsing running Kubernetes version: %v", err)
|
klog.Errorf("unexpected error parsing running Kubernetes version: %v", err)
|
||||||
return false
|
return false
|
||||||
|
|
Loading…
Reference in a new issue