| // Copyright Istio Authors |
| // |
| // Licensed under the Apache License, Version 2.0 (the "License"); |
| // you may not use this file except in compliance with the License. |
| // You may obtain a copy of the License at |
| // |
| // http://www.apache.org/licenses/LICENSE-2.0 |
| // |
| // Unless required by applicable law or agreed to in writing, software |
| // distributed under the License is distributed on an "AS IS" BASIS, |
| // WITHOUT WARRANTIES OR CONDITIONS OF ANY KIND, either express or implied. |
| // See the License for the specific language governing permissions and |
| // limitations under the License. |
| |
| package model |
| |
| import ( |
| "fmt" |
| "strings" |
| ) |
| |
| import ( |
| "github.com/hashicorp/go-multierror" |
| ) |
| |
| import ( |
| "github.com/apache/dubbo-go-pixiu/pkg/config/labels" |
| "github.com/apache/dubbo-go-pixiu/pkg/config/validation" |
| ) |
| |
| // UnixAddressPrefix is the prefix used to indicate an address is for a Unix Domain socket. It is used in |
| // ServiceEntry.Endpoint.Address message. |
| const ( |
| UnixAddressPrefix = "unix://" |
| PodIPAddressPrefix = "0.0.0.0" |
| LocalhostAddressPrefix = "127.0.0.1" |
| ) |
| |
| // Validate ensures that the service object is well-defined |
| func (s *Service) Validate() error { |
| var errs error |
| if len(s.Hostname) == 0 { |
| errs = multierror.Append(errs, fmt.Errorf("invalid empty hostname")) |
| } |
| parts := strings.Split(string(s.Hostname), ".") |
| for _, part := range parts { |
| if !labels.IsDNS1123Label(part) { |
| errs = multierror.Append(errs, fmt.Errorf("invalid hostname part: %q", part)) |
| } |
| } |
| |
| // Require at least one port |
| if len(s.Ports) == 0 { |
| errs = multierror.Append(errs, fmt.Errorf("service must have at least one declared port")) |
| } |
| |
| // Port names can be empty if there exists only one port |
| for _, port := range s.Ports { |
| if port.Name == "" { |
| if len(s.Ports) > 1 { |
| errs = multierror.Append(errs, |
| fmt.Errorf("empty port names are not allowed for services with multiple ports")) |
| } |
| } else if !labels.IsDNS1123Label(port.Name) { |
| errs = multierror.Append(errs, fmt.Errorf("invalid name: %q", port.Name)) |
| } |
| if err := validation.ValidatePort(port.Port); err != nil { |
| errs = multierror.Append(errs, |
| fmt.Errorf("invalid service port value %d for %q: %v", port.Port, port.Name, err)) |
| } |
| } |
| return errs |
| } |
| |
| // Validate ensures that the service instance is well-defined |
| func (instance *ServiceInstance) Validate() error { |
| var errs error |
| if instance.Service == nil { |
| errs = multierror.Append(errs, fmt.Errorf("missing service in the instance")) |
| } else if err := instance.Service.Validate(); err != nil { |
| errs = multierror.Append(errs, err) |
| } |
| |
| if instance.Endpoint != nil { |
| if err := instance.Endpoint.Labels.Validate(); err != nil { |
| errs = multierror.Append(errs, err) |
| } |
| |
| if err := validation.ValidatePort(int(instance.Endpoint.EndpointPort)); err != nil { |
| errs = multierror.Append(errs, err) |
| } |
| } |
| |
| port := instance.ServicePort |
| if port == nil { |
| errs = multierror.Append(errs, fmt.Errorf("missing service port")) |
| } else if instance.Service != nil { |
| expected, ok := instance.Service.Ports.Get(port.Name) |
| if !ok { |
| errs = multierror.Append(errs, fmt.Errorf("missing service port %q", port.Name)) |
| } else { |
| if expected.Port != port.Port { |
| errs = multierror.Append(errs, |
| fmt.Errorf("unexpected service port value %d, expected %d", port.Port, expected.Port)) |
| } |
| if expected.Protocol != port.Protocol { |
| errs = multierror.Append(errs, |
| fmt.Errorf("unexpected service protocol %s, expected %s", port.Protocol, expected.Protocol)) |
| } |
| } |
| } |
| |
| return errs |
| } |