package manager
import (
"bytes"
"errors"
"fmt"
"net"
"net/mail"
"net/url"
"regexp"
"sort"
"strings"
"time"
"unicode/utf8"
"google.golang.org/protobuf/types/known/anypb"
common "d7y.io/api/v2/pkg/apis/common/v2"
)
var (
_ = bytes.MinRead
_ = errors.New("")
_ = fmt.Print
_ = utf8.UTFMax
_ = (*regexp.Regexp)(nil)
_ = (*strings.Reader)(nil)
_ = net.IPv4len
_ = time.Duration(0)
_ = (*url.URL)(nil)
_ = (*mail.Address)(nil)
_ = anypb.Any{}
_ = sort.Sort
_ = common.Priority(0)
)
func (m *SeedPeerCluster) Validate() error {
return m.validate(false)
}
func (m *SeedPeerCluster) ValidateAll() error {
return m.validate(true)
}
func (m *SeedPeerCluster) validate(all bool) error {
if m == nil {
return nil
}
var errors []error
if len(errors) > 0 {
return SeedPeerClusterMultiError(errors)
}
return nil
}
type SeedPeerClusterMultiError []error
func (m SeedPeerClusterMultiError) Error() string {
var msgs []string
for _, err := range m {
msgs = append(msgs, err.Error())
}
return strings.Join(msgs, "; ")
}
func (m SeedPeerClusterMultiError) AllErrors() []error { return m }
type SeedPeerClusterValidationError struct {
field string
reason string
cause error
key bool
}
func (e SeedPeerClusterValidationError) Field() string { return e.field }
func (e SeedPeerClusterValidationError) Reason() string { return e.reason }
func (e SeedPeerClusterValidationError) Cause() error { return e.cause }
func (e SeedPeerClusterValidationError) Key() bool { return e.key }
func (e SeedPeerClusterValidationError) ErrorName() string { return "SeedPeerClusterValidationError" }
func (e SeedPeerClusterValidationError) Error() string {
cause := ""
if e.cause != nil {
cause = fmt.Sprintf(" | caused by: %v", e.cause)
}
key := ""
if e.key {
key = "key for "
}
return fmt.Sprintf(
"invalid %sSeedPeerCluster.%s: %s%s",
key,
e.field,
e.reason,
cause)
}
var _ error = SeedPeerClusterValidationError{}
var _ interface {
Field() string
Reason() string
Key() bool
Cause() error
ErrorName() string
} = SeedPeerClusterValidationError{}
func (m *SeedPeer) Validate() error {
return m.validate(false)
}
func (m *SeedPeer) ValidateAll() error {
return m.validate(true)
}
func (m *SeedPeer) validate(all bool) error {
if m == nil {
return nil
}
var errors []error
if all {
switch v := interface{}(m.GetSeedPeerCluster()).(type) {
case interface{ ValidateAll() error }:
if err := v.ValidateAll(); err != nil {
errors = append(errors, SeedPeerValidationError{
field: "SeedPeerCluster",
reason: "embedded message failed validation",
cause: err,
})
}
case interface{ Validate() error }:
if err := v.Validate(); err != nil {
errors = append(errors, SeedPeerValidationError{
field: "SeedPeerCluster",
reason: "embedded message failed validation",
cause: err,
})
}
}
} else if v, ok := interface{}(m.GetSeedPeerCluster()).(interface{ Validate() error }); ok {
if err := v.Validate(); err != nil {
return SeedPeerValidationError{
field: "SeedPeerCluster",
reason: "embedded message failed validation",
cause: err,
}
}
}
for idx, item := range m.GetSchedulers() {
_, _ = idx, item
if all {
switch v := interface{}(item).(type) {
case interface{ ValidateAll() error }:
if err := v.ValidateAll(); err != nil {
errors = append(errors, SeedPeerValidationError{
field: fmt.Sprintf("Schedulers[%v]", idx),
reason: "embedded message failed validation",
cause: err,
})
}
case interface{ Validate() error }:
if err := v.Validate(); err != nil {
errors = append(errors, SeedPeerValidationError{
field: fmt.Sprintf("Schedulers[%v]", idx),
reason: "embedded message failed validation",
cause: err,
})
}
}
} else if v, ok := interface{}(item).(interface{ Validate() error }); ok {
if err := v.Validate(); err != nil {
return SeedPeerValidationError{
field: fmt.Sprintf("Schedulers[%v]", idx),
reason: "embedded message failed validation",
cause: err,
}
}
}
}
if m.Idc != nil {
}
if m.Location != nil {
}
if len(errors) > 0 {
return SeedPeerMultiError(errors)
}
return nil
}
type SeedPeerMultiError []error
func (m SeedPeerMultiError) Error() string {
var msgs []string
for _, err := range m {
msgs = append(msgs, err.Error())
}
return strings.Join(msgs, "; ")
}
func (m SeedPeerMultiError) AllErrors() []error { return m }
type SeedPeerValidationError struct {
field string
reason string
cause error
key bool
}
func (e SeedPeerValidationError) Field() string { return e.field }
func (e SeedPeerValidationError) Reason() string { return e.reason }
func (e SeedPeerValidationError) Cause() error { return e.cause }
func (e SeedPeerValidationError) Key() bool { return e.key }
func (e SeedPeerValidationError) ErrorName() string { return "SeedPeerValidationError" }
func (e SeedPeerValidationError) Error() string {
cause := ""
if e.cause != nil {
cause = fmt.Sprintf(" | caused by: %v", e.cause)
}
key := ""
if e.key {
key = "key for "
}
return fmt.Sprintf(
"invalid %sSeedPeer.%s: %s%s",
key,
e.field,
e.reason,
cause)
}
var _ error = SeedPeerValidationError{}
var _ interface {
Field() string
Reason() string
Key() bool
Cause() error
ErrorName() string
} = SeedPeerValidationError{}
func (m *GetSeedPeerRequest) Validate() error {
return m.validate(false)
}
func (m *GetSeedPeerRequest) ValidateAll() error {
return m.validate(true)
}
func (m *GetSeedPeerRequest) validate(all bool) error {
if m == nil {
return nil
}
var errors []error
if _, ok := SourceType_name[int32(m.GetSourceType())]; !ok {
err := GetSeedPeerRequestValidationError{
field: "SourceType",
reason: "value must be one of the defined enum values",
}
if !all {
return err
}
errors = append(errors, err)
}
if err := m._validateHostname(m.GetHostname()); err != nil {
err = GetSeedPeerRequestValidationError{
field: "Hostname",
reason: "value must be a valid hostname",
cause: err,
}
if !all {
return err
}
errors = append(errors, err)
}
if m.GetSeedPeerClusterId() < 1 {
err := GetSeedPeerRequestValidationError{
field: "SeedPeerClusterId",
reason: "value must be greater than or equal to 1",
}
if !all {
return err
}
errors = append(errors, err)
}
if m.GetIp() != "" {
if ip := net.ParseIP(m.GetIp()); ip == nil {
err := GetSeedPeerRequestValidationError{
field: "Ip",
reason: "value must be a valid IP address",
}
if !all {
return err
}
errors = append(errors, err)
}
}
if len(errors) > 0 {
return GetSeedPeerRequestMultiError(errors)
}
return nil
}
func (m *GetSeedPeerRequest) _validateHostname(host string) error {
s := strings.ToLower(strings.TrimSuffix(host, "."))
if len(host) > 253 {
return errors.New("hostname cannot exceed 253 characters")
}
for _, part := range strings.Split(s, ".") {
if l := len(part); l == 0 || l > 63 {
return errors.New("hostname part must be non-empty and cannot exceed 63 characters")
}
if part[0] == '-' {
return errors.New("hostname parts cannot begin with hyphens")
}
if part[len(part)-1] == '-' {
return errors.New("hostname parts cannot end with hyphens")
}
for _, r := range part {
if (r < 'a' || r > 'z') && (r < '0' || r > '9') && r != '-' {
return fmt.Errorf("hostname parts can only contain alphanumeric characters or hyphens, got %q", string(r))
}
}
}
return nil
}
type GetSeedPeerRequestMultiError []error
func (m GetSeedPeerRequestMultiError) Error() string {
var msgs []string
for _, err := range m {
msgs = append(msgs, err.Error())
}
return strings.Join(msgs, "; ")
}
func (m GetSeedPeerRequestMultiError) AllErrors() []error { return m }
type GetSeedPeerRequestValidationError struct {
field string
reason string
cause error
key bool
}
func (e GetSeedPeerRequestValidationError) Field() string { return e.field }
func (e GetSeedPeerRequestValidationError) Reason() string { return e.reason }
func (e GetSeedPeerRequestValidationError) Cause() error { return e.cause }
func (e GetSeedPeerRequestValidationError) Key() bool { return e.key }
func (e GetSeedPeerRequestValidationError) ErrorName() string {
return "GetSeedPeerRequestValidationError"
}
func (e GetSeedPeerRequestValidationError) Error() string {
cause := ""
if e.cause != nil {
cause = fmt.Sprintf(" | caused by: %v", e.cause)
}
key := ""
if e.key {
key = "key for "
}
return fmt.Sprintf(
"invalid %sGetSeedPeerRequest.%s: %s%s",
key,
e.field,
e.reason,
cause)
}
var _ error = GetSeedPeerRequestValidationError{}
var _ interface {
Field() string
Reason() string
Key() bool
Cause() error
ErrorName() string
} = GetSeedPeerRequestValidationError{}
func (m *ListSeedPeersRequest) Validate() error {
return m.validate(false)
}
func (m *ListSeedPeersRequest) ValidateAll() error {
return m.validate(true)
}
func (m *ListSeedPeersRequest) validate(all bool) error {
if m == nil {
return nil
}
var errors []error
if _, ok := SourceType_name[int32(m.GetSourceType())]; !ok {
err := ListSeedPeersRequestValidationError{
field: "SourceType",
reason: "value must be one of the defined enum values",
}
if !all {
return err
}
errors = append(errors, err)
}
if err := m._validateHostname(m.GetHostname()); err != nil {
err = ListSeedPeersRequestValidationError{
field: "Hostname",
reason: "value must be a valid hostname",
cause: err,
}
if !all {
return err
}
errors = append(errors, err)
}
if ip := net.ParseIP(m.GetIp()); ip == nil {
err := ListSeedPeersRequestValidationError{
field: "Ip",
reason: "value must be a valid IP address",
}
if !all {
return err
}
errors = append(errors, err)
}
if m.GetVersion() != "" {
if l := utf8.RuneCountInString(m.GetVersion()); l < 1 || l > 1024 {
err := ListSeedPeersRequestValidationError{
field: "Version",
reason: "value length must be between 1 and 1024 runes, inclusive",
}
if !all {
return err
}
errors = append(errors, err)
}
}
if m.GetCommit() != "" {
if l := utf8.RuneCountInString(m.GetCommit()); l < 1 || l > 1024 {
err := ListSeedPeersRequestValidationError{
field: "Commit",
reason: "value length must be between 1 and 1024 runes, inclusive",
}
if !all {
return err
}
errors = append(errors, err)
}
}
if len(errors) > 0 {
return ListSeedPeersRequestMultiError(errors)
}
return nil
}
func (m *ListSeedPeersRequest) _validateHostname(host string) error {
s := strings.ToLower(strings.TrimSuffix(host, "."))
if len(host) > 253 {
return errors.New("hostname cannot exceed 253 characters")
}
for _, part := range strings.Split(s, ".") {
if l := len(part); l == 0 || l > 63 {
return errors.New("hostname part must be non-empty and cannot exceed 63 characters")
}
if part[0] == '-' {
return errors.New("hostname parts cannot begin with hyphens")
}
if part[len(part)-1] == '-' {
return errors.New("hostname parts cannot end with hyphens")
}
for _, r := range part {
if (r < 'a' || r > 'z') && (r < '0' || r > '9') && r != '-' {
return fmt.Errorf("hostname parts can only contain alphanumeric characters or hyphens, got %q", string(r))
}
}
}
return nil
}
type ListSeedPeersRequestMultiError []error
func (m ListSeedPeersRequestMultiError) Error() string {
var msgs []string
for _, err := range m {
msgs = append(msgs, err.Error())
}
return strings.Join(msgs, "; ")
}
func (m ListSeedPeersRequestMultiError) AllErrors() []error { return m }
type ListSeedPeersRequestValidationError struct {
field string
reason string
cause error
key bool
}
func (e ListSeedPeersRequestValidationError) Field() string { return e.field }
func (e ListSeedPeersRequestValidationError) Reason() string { return e.reason }
func (e ListSeedPeersRequestValidationError) Cause() error { return e.cause }
func (e ListSeedPeersRequestValidationError) Key() bool { return e.key }
func (e ListSeedPeersRequestValidationError) ErrorName() string {
return "ListSeedPeersRequestValidationError"
}
func (e ListSeedPeersRequestValidationError) Error() string {
cause := ""
if e.cause != nil {
cause = fmt.Sprintf(" | caused by: %v", e.cause)
}
key := ""
if e.key {
key = "key for "
}
return fmt.Sprintf(
"invalid %sListSeedPeersRequest.%s: %s%s",
key,
e.field,
e.reason,
cause)
}
var _ error = ListSeedPeersRequestValidationError{}
var _ interface {
Field() string
Reason() string
Key() bool
Cause() error
ErrorName() string
} = ListSeedPeersRequestValidationError{}
func (m *ListSeedPeersResponse) Validate() error {
return m.validate(false)
}
func (m *ListSeedPeersResponse) ValidateAll() error {
return m.validate(true)
}
func (m *ListSeedPeersResponse) validate(all bool) error {
if m == nil {
return nil
}
var errors []error
for idx, item := range m.GetSeedPeers() {
_, _ = idx, item
if all {
switch v := interface{}(item).(type) {
case interface{ ValidateAll() error }:
if err := v.ValidateAll(); err != nil {
errors = append(errors, ListSeedPeersResponseValidationError{
field: fmt.Sprintf("SeedPeers[%v]", idx),
reason: "embedded message failed validation",
cause: err,
})
}
case interface{ Validate() error }:
if err := v.Validate(); err != nil {
errors = append(errors, ListSeedPeersResponseValidationError{
field: fmt.Sprintf("SeedPeers[%v]", idx),
reason: "embedded message failed validation",
cause: err,
})
}
}
} else if v, ok := interface{}(item).(interface{ Validate() error }); ok {
if err := v.Validate(); err != nil {
return ListSeedPeersResponseValidationError{
field: fmt.Sprintf("SeedPeers[%v]", idx),
reason: "embedded message failed validation",
cause: err,
}
}
}
}
if len(errors) > 0 {
return ListSeedPeersResponseMultiError(errors)
}
return nil
}
type ListSeedPeersResponseMultiError []error
func (m ListSeedPeersResponseMultiError) Error() string {
var msgs []string
for _, err := range m {
msgs = append(msgs, err.Error())
}
return strings.Join(msgs, "; ")
}
func (m ListSeedPeersResponseMultiError) AllErrors() []error { return m }
type ListSeedPeersResponseValidationError struct {
field string
reason string
cause error
key bool
}
func (e ListSeedPeersResponseValidationError) Field() string { return e.field }
func (e ListSeedPeersResponseValidationError) Reason() string { return e.reason }
func (e ListSeedPeersResponseValidationError) Cause() error { return e.cause }
func (e ListSeedPeersResponseValidationError) Key() bool { return e.key }
func (e ListSeedPeersResponseValidationError) ErrorName() string {
return "ListSeedPeersResponseValidationError"
}
func (e ListSeedPeersResponseValidationError) Error() string {
cause := ""
if e.cause != nil {
cause = fmt.Sprintf(" | caused by: %v", e.cause)
}
key := ""
if e.key {
key = "key for "
}
return fmt.Sprintf(
"invalid %sListSeedPeersResponse.%s: %s%s",
key,
e.field,
e.reason,
cause)
}
var _ error = ListSeedPeersResponseValidationError{}
var _ interface {
Field() string
Reason() string
Key() bool
Cause() error
ErrorName() string
} = ListSeedPeersResponseValidationError{}
func (m *UpdateSeedPeerRequest) Validate() error {
return m.validate(false)
}
func (m *UpdateSeedPeerRequest) ValidateAll() error {
return m.validate(true)
}
func (m *UpdateSeedPeerRequest) validate(all bool) error {
if m == nil {
return nil
}
var errors []error
if _, ok := SourceType_name[int32(m.GetSourceType())]; !ok {
err := UpdateSeedPeerRequestValidationError{
field: "SourceType",
reason: "value must be one of the defined enum values",
}
if !all {
return err
}
errors = append(errors, err)
}
if err := m._validateHostname(m.GetHostname()); err != nil {
err = UpdateSeedPeerRequestValidationError{
field: "Hostname",
reason: "value must be a valid hostname",
cause: err,
}
if !all {
return err
}
errors = append(errors, err)
}
if _, ok := _UpdateSeedPeerRequest_Type_InLookup[m.GetType()]; !ok {
err := UpdateSeedPeerRequestValidationError{
field: "Type",
reason: "value must be in list [super]",
}
if !all {
return err
}
errors = append(errors, err)
}
if ip := net.ParseIP(m.GetIp()); ip == nil {
err := UpdateSeedPeerRequestValidationError{
field: "Ip",
reason: "value must be a valid IP address",
}
if !all {
return err
}
errors = append(errors, err)
}
if val := m.GetPort(); val < 1024 || val >= 65535 {
err := UpdateSeedPeerRequestValidationError{
field: "Port",
reason: "value must be inside range [1024, 65535)",
}
if !all {
return err
}
errors = append(errors, err)
}
if val := m.GetDownloadPort(); val < 1024 || val >= 65535 {
err := UpdateSeedPeerRequestValidationError{
field: "DownloadPort",
reason: "value must be inside range [1024, 65535)",
}
if !all {
return err
}
errors = append(errors, err)
}
if m.GetSeedPeerClusterId() < 1 {
err := UpdateSeedPeerRequestValidationError{
field: "SeedPeerClusterId",
reason: "value must be greater than or equal to 1",
}
if !all {
return err
}
errors = append(errors, err)
}
if m.Idc != nil {
if m.GetIdc() != "" {
if l := utf8.RuneCountInString(m.GetIdc()); l < 1 || l > 1024 {
err := UpdateSeedPeerRequestValidationError{
field: "Idc",
reason: "value length must be between 1 and 1024 runes, inclusive",
}
if !all {
return err
}
errors = append(errors, err)
}
}
}
if m.Location != nil {
if m.GetLocation() != "" {
if utf8.RuneCountInString(m.GetLocation()) > 1024 {
err := UpdateSeedPeerRequestValidationError{
field: "Location",
reason: "value length must be at most 1024 runes",
}
if !all {
return err
}
errors = append(errors, err)
}
}
}
if len(errors) > 0 {
return UpdateSeedPeerRequestMultiError(errors)
}
return nil
}
func (m *UpdateSeedPeerRequest) _validateHostname(host string) error {
s := strings.ToLower(strings.TrimSuffix(host, "."))
if len(host) > 253 {
return errors.New("hostname cannot exceed 253 characters")
}
for _, part := range strings.Split(s, ".") {
if l := len(part); l == 0 || l > 63 {
return errors.New("hostname part must be non-empty and cannot exceed 63 characters")
}
if part[0] == '-' {
return errors.New("hostname parts cannot begin with hyphens")
}
if part[len(part)-1] == '-' {
return errors.New("hostname parts cannot end with hyphens")
}
for _, r := range part {
if (r < 'a' || r > 'z') && (r < '0' || r > '9') && r != '-' {
return fmt.Errorf("hostname parts can only contain alphanumeric characters or hyphens, got %q", string(r))
}
}
}
return nil
}
type UpdateSeedPeerRequestMultiError []error
func (m UpdateSeedPeerRequestMultiError) Error() string {
var msgs []string
for _, err := range m {
msgs = append(msgs, err.Error())
}
return strings.Join(msgs, "; ")
}
func (m UpdateSeedPeerRequestMultiError) AllErrors() []error { return m }
type UpdateSeedPeerRequestValidationError struct {
field string
reason string
cause error
key bool
}
func (e UpdateSeedPeerRequestValidationError) Field() string { return e.field }
func (e UpdateSeedPeerRequestValidationError) Reason() string { return e.reason }
func (e UpdateSeedPeerRequestValidationError) Cause() error { return e.cause }
func (e UpdateSeedPeerRequestValidationError) Key() bool { return e.key }
func (e UpdateSeedPeerRequestValidationError) ErrorName() string {
return "UpdateSeedPeerRequestValidationError"
}
func (e UpdateSeedPeerRequestValidationError) Error() string {
cause := ""
if e.cause != nil {
cause = fmt.Sprintf(" | caused by: %v", e.cause)
}
key := ""
if e.key {
key = "key for "
}
return fmt.Sprintf(
"invalid %sUpdateSeedPeerRequest.%s: %s%s",
key,
e.field,
e.reason,
cause)
}
var _ error = UpdateSeedPeerRequestValidationError{}
var _ interface {
Field() string
Reason() string
Key() bool
Cause() error
ErrorName() string
} = UpdateSeedPeerRequestValidationError{}
var _UpdateSeedPeerRequest_Type_InLookup = map[string]struct{}{
"super": {},
}
func (m *DeleteSeedPeerRequest) Validate() error {
return m.validate(false)
}
func (m *DeleteSeedPeerRequest) ValidateAll() error {
return m.validate(true)
}
func (m *DeleteSeedPeerRequest) validate(all bool) error {
if m == nil {
return nil
}
var errors []error
if _, ok := SourceType_name[int32(m.GetSourceType())]; !ok {
err := DeleteSeedPeerRequestValidationError{
field: "SourceType",
reason: "value must be one of the defined enum values",
}
if !all {
return err
}
errors = append(errors, err)
}
if err := m._validateHostname(m.GetHostname()); err != nil {
err = DeleteSeedPeerRequestValidationError{
field: "Hostname",
reason: "value must be a valid hostname",
cause: err,
}
if !all {
return err
}
errors = append(errors, err)
}
if m.GetSeedPeerClusterId() < 1 {
err := DeleteSeedPeerRequestValidationError{
field: "SeedPeerClusterId",
reason: "value must be greater than or equal to 1",
}
if !all {
return err
}
errors = append(errors, err)
}
if m.GetIp() != "" {
if ip := net.ParseIP(m.GetIp()); ip == nil {
err := DeleteSeedPeerRequestValidationError{
field: "Ip",
reason: "value must be a valid IP address",
}
if !all {
return err
}
errors = append(errors, err)
}
}
if len(errors) > 0 {
return DeleteSeedPeerRequestMultiError(errors)
}
return nil
}
func (m *DeleteSeedPeerRequest) _validateHostname(host string) error {
s := strings.ToLower(strings.TrimSuffix(host, "."))
if len(host) > 253 {
return errors.New("hostname cannot exceed 253 characters")
}
for _, part := range strings.Split(s, ".") {
if l := len(part); l == 0 || l > 63 {
return errors.New("hostname part must be non-empty and cannot exceed 63 characters")
}
if part[0] == '-' {
return errors.New("hostname parts cannot begin with hyphens")
}
if part[len(part)-1] == '-' {
return errors.New("hostname parts cannot end with hyphens")
}
for _, r := range part {
if (r < 'a' || r > 'z') && (r < '0' || r > '9') && r != '-' {
return fmt.Errorf("hostname parts can only contain alphanumeric characters or hyphens, got %q", string(r))
}
}
}
return nil
}
type DeleteSeedPeerRequestMultiError []error
func (m DeleteSeedPeerRequestMultiError) Error() string {
var msgs []string
for _, err := range m {
msgs = append(msgs, err.Error())
}
return strings.Join(msgs, "; ")
}
func (m DeleteSeedPeerRequestMultiError) AllErrors() []error { return m }
type DeleteSeedPeerRequestValidationError struct {
field string
reason string
cause error
key bool
}
func (e DeleteSeedPeerRequestValidationError) Field() string { return e.field }
func (e DeleteSeedPeerRequestValidationError) Reason() string { return e.reason }
func (e DeleteSeedPeerRequestValidationError) Cause() error { return e.cause }
func (e DeleteSeedPeerRequestValidationError) Key() bool { return e.key }
func (e DeleteSeedPeerRequestValidationError) ErrorName() string {
return "DeleteSeedPeerRequestValidationError"
}
func (e DeleteSeedPeerRequestValidationError) Error() string {
cause := ""
if e.cause != nil {
cause = fmt.Sprintf(" | caused by: %v", e.cause)
}
key := ""
if e.key {
key = "key for "
}
return fmt.Sprintf(
"invalid %sDeleteSeedPeerRequest.%s: %s%s",
key,
e.field,
e.reason,
cause)
}
var _ error = DeleteSeedPeerRequestValidationError{}
var _ interface {
Field() string
Reason() string
Key() bool
Cause() error
ErrorName() string
} = DeleteSeedPeerRequestValidationError{}
func (m *SchedulerCluster) Validate() error {
return m.validate(false)
}
func (m *SchedulerCluster) ValidateAll() error {
return m.validate(true)
}
func (m *SchedulerCluster) validate(all bool) error {
if m == nil {
return nil
}
var errors []error
if len(errors) > 0 {
return SchedulerClusterMultiError(errors)
}
return nil
}
type SchedulerClusterMultiError []error
func (m SchedulerClusterMultiError) Error() string {
var msgs []string
for _, err := range m {
msgs = append(msgs, err.Error())
}
return strings.Join(msgs, "; ")
}
func (m SchedulerClusterMultiError) AllErrors() []error { return m }
type SchedulerClusterValidationError struct {
field string
reason string
cause error
key bool
}
func (e SchedulerClusterValidationError) Field() string { return e.field }
func (e SchedulerClusterValidationError) Reason() string { return e.reason }
func (e SchedulerClusterValidationError) Cause() error { return e.cause }
func (e SchedulerClusterValidationError) Key() bool { return e.key }
func (e SchedulerClusterValidationError) ErrorName() string { return "SchedulerClusterValidationError" }
func (e SchedulerClusterValidationError) Error() string {
cause := ""
if e.cause != nil {
cause = fmt.Sprintf(" | caused by: %v", e.cause)
}
key := ""
if e.key {
key = "key for "
}
return fmt.Sprintf(
"invalid %sSchedulerCluster.%s: %s%s",
key,
e.field,
e.reason,
cause)
}
var _ error = SchedulerClusterValidationError{}
var _ interface {
Field() string
Reason() string
Key() bool
Cause() error
ErrorName() string
} = SchedulerClusterValidationError{}
func (m *Scheduler) Validate() error {
return m.validate(false)
}
func (m *Scheduler) ValidateAll() error {
return m.validate(true)
}
func (m *Scheduler) validate(all bool) error {
if m == nil {
return nil
}
var errors []error
if all {
switch v := interface{}(m.GetSchedulerCluster()).(type) {
case interface{ ValidateAll() error }:
if err := v.ValidateAll(); err != nil {
errors = append(errors, SchedulerValidationError{
field: "SchedulerCluster",
reason: "embedded message failed validation",
cause: err,
})
}
case interface{ Validate() error }:
if err := v.Validate(); err != nil {
errors = append(errors, SchedulerValidationError{
field: "SchedulerCluster",
reason: "embedded message failed validation",
cause: err,
})
}
}
} else if v, ok := interface{}(m.GetSchedulerCluster()).(interface{ Validate() error }); ok {
if err := v.Validate(); err != nil {
return SchedulerValidationError{
field: "SchedulerCluster",
reason: "embedded message failed validation",
cause: err,
}
}
}
for idx, item := range m.GetSeedPeers() {
_, _ = idx, item
if all {
switch v := interface{}(item).(type) {
case interface{ ValidateAll() error }:
if err := v.ValidateAll(); err != nil {
errors = append(errors, SchedulerValidationError{
field: fmt.Sprintf("SeedPeers[%v]", idx),
reason: "embedded message failed validation",
cause: err,
})
}
case interface{ Validate() error }:
if err := v.Validate(); err != nil {
errors = append(errors, SchedulerValidationError{
field: fmt.Sprintf("SeedPeers[%v]", idx),
reason: "embedded message failed validation",
cause: err,
})
}
}
} else if v, ok := interface{}(item).(interface{ Validate() error }); ok {
if err := v.Validate(); err != nil {
return SchedulerValidationError{
field: fmt.Sprintf("SeedPeers[%v]", idx),
reason: "embedded message failed validation",
cause: err,
}
}
}
}
if m.Idc != nil {
}
if m.Location != nil {
}
if len(errors) > 0 {
return SchedulerMultiError(errors)
}
return nil
}
type SchedulerMultiError []error
func (m SchedulerMultiError) Error() string {
var msgs []string
for _, err := range m {
msgs = append(msgs, err.Error())
}
return strings.Join(msgs, "; ")
}
func (m SchedulerMultiError) AllErrors() []error { return m }
type SchedulerValidationError struct {
field string
reason string
cause error
key bool
}
func (e SchedulerValidationError) Field() string { return e.field }
func (e SchedulerValidationError) Reason() string { return e.reason }
func (e SchedulerValidationError) Cause() error { return e.cause }
func (e SchedulerValidationError) Key() bool { return e.key }
func (e SchedulerValidationError) ErrorName() string { return "SchedulerValidationError" }
func (e SchedulerValidationError) Error() string {
cause := ""
if e.cause != nil {
cause = fmt.Sprintf(" | caused by: %v", e.cause)
}
key := ""
if e.key {
key = "key for "
}
return fmt.Sprintf(
"invalid %sScheduler.%s: %s%s",
key,
e.field,
e.reason,
cause)
}
var _ error = SchedulerValidationError{}
var _ interface {
Field() string
Reason() string
Key() bool
Cause() error
ErrorName() string
} = SchedulerValidationError{}
func (m *GetSchedulerRequest) Validate() error {
return m.validate(false)
}
func (m *GetSchedulerRequest) ValidateAll() error {
return m.validate(true)
}
func (m *GetSchedulerRequest) validate(all bool) error {
if m == nil {
return nil
}
var errors []error
if _, ok := SourceType_name[int32(m.GetSourceType())]; !ok {
err := GetSchedulerRequestValidationError{
field: "SourceType",
reason: "value must be one of the defined enum values",
}
if !all {
return err
}
errors = append(errors, err)
}
if err := m._validateHostname(m.GetHostname()); err != nil {
err = GetSchedulerRequestValidationError{
field: "Hostname",
reason: "value must be a valid hostname",
cause: err,
}
if !all {
return err
}
errors = append(errors, err)
}
if m.GetSchedulerClusterId() < 1 {
err := GetSchedulerRequestValidationError{
field: "SchedulerClusterId",
reason: "value must be greater than or equal to 1",
}
if !all {
return err
}
errors = append(errors, err)
}
if m.GetIp() != "" {
if ip := net.ParseIP(m.GetIp()); ip == nil {
err := GetSchedulerRequestValidationError{
field: "Ip",
reason: "value must be a valid IP address",
}
if !all {
return err
}
errors = append(errors, err)
}
}
if len(errors) > 0 {
return GetSchedulerRequestMultiError(errors)
}
return nil
}
func (m *GetSchedulerRequest) _validateHostname(host string) error {
s := strings.ToLower(strings.TrimSuffix(host, "."))
if len(host) > 253 {
return errors.New("hostname cannot exceed 253 characters")
}
for _, part := range strings.Split(s, ".") {
if l := len(part); l == 0 || l > 63 {
return errors.New("hostname part must be non-empty and cannot exceed 63 characters")
}
if part[0] == '-' {
return errors.New("hostname parts cannot begin with hyphens")
}
if part[len(part)-1] == '-' {
return errors.New("hostname parts cannot end with hyphens")
}
for _, r := range part {
if (r < 'a' || r > 'z') && (r < '0' || r > '9') && r != '-' {
return fmt.Errorf("hostname parts can only contain alphanumeric characters or hyphens, got %q", string(r))
}
}
}
return nil
}
type GetSchedulerRequestMultiError []error
func (m GetSchedulerRequestMultiError) Error() string {
var msgs []string
for _, err := range m {
msgs = append(msgs, err.Error())
}
return strings.Join(msgs, "; ")
}
func (m GetSchedulerRequestMultiError) AllErrors() []error { return m }
type GetSchedulerRequestValidationError struct {
field string
reason string
cause error
key bool
}
func (e GetSchedulerRequestValidationError) Field() string { return e.field }
func (e GetSchedulerRequestValidationError) Reason() string { return e.reason }
func (e GetSchedulerRequestValidationError) Cause() error { return e.cause }
func (e GetSchedulerRequestValidationError) Key() bool { return e.key }
func (e GetSchedulerRequestValidationError) ErrorName() string {
return "GetSchedulerRequestValidationError"
}
func (e GetSchedulerRequestValidationError) Error() string {
cause := ""
if e.cause != nil {
cause = fmt.Sprintf(" | caused by: %v", e.cause)
}
key := ""
if e.key {
key = "key for "
}
return fmt.Sprintf(
"invalid %sGetSchedulerRequest.%s: %s%s",
key,
e.field,
e.reason,
cause)
}
var _ error = GetSchedulerRequestValidationError{}
var _ interface {
Field() string
Reason() string
Key() bool
Cause() error
ErrorName() string
} = GetSchedulerRequestValidationError{}
func (m *UpdateSchedulerRequest) Validate() error {
return m.validate(false)
}
func (m *UpdateSchedulerRequest) ValidateAll() error {
return m.validate(true)
}
func (m *UpdateSchedulerRequest) validate(all bool) error {
if m == nil {
return nil
}
var errors []error
if _, ok := SourceType_name[int32(m.GetSourceType())]; !ok {
err := UpdateSchedulerRequestValidationError{
field: "SourceType",
reason: "value must be one of the defined enum values",
}
if !all {
return err
}
errors = append(errors, err)
}
if err := m._validateHostname(m.GetHostname()); err != nil {
err = UpdateSchedulerRequestValidationError{
field: "Hostname",
reason: "value must be a valid hostname",
cause: err,
}
if !all {
return err
}
errors = append(errors, err)
}
if m.GetSchedulerClusterId() < 1 {
err := UpdateSchedulerRequestValidationError{
field: "SchedulerClusterId",
reason: "value must be greater than or equal to 1",
}
if !all {
return err
}
errors = append(errors, err)
}
if ip := net.ParseIP(m.GetIp()); ip == nil {
err := UpdateSchedulerRequestValidationError{
field: "Ip",
reason: "value must be a valid IP address",
}
if !all {
return err
}
errors = append(errors, err)
}
if val := m.GetPort(); val < 1024 || val >= 65535 {
err := UpdateSchedulerRequestValidationError{
field: "Port",
reason: "value must be inside range [1024, 65535)",
}
if !all {
return err
}
errors = append(errors, err)
}
if m.Idc != nil {
if m.GetIdc() != "" {
if l := utf8.RuneCountInString(m.GetIdc()); l < 1 || l > 1024 {
err := UpdateSchedulerRequestValidationError{
field: "Idc",
reason: "value length must be between 1 and 1024 runes, inclusive",
}
if !all {
return err
}
errors = append(errors, err)
}
}
}
if m.Location != nil {
if m.GetLocation() != "" {
if l := utf8.RuneCountInString(m.GetLocation()); l < 1 || l > 1024 {
err := UpdateSchedulerRequestValidationError{
field: "Location",
reason: "value length must be between 1 and 1024 runes, inclusive",
}
if !all {
return err
}
errors = append(errors, err)
}
}
}
if len(errors) > 0 {
return UpdateSchedulerRequestMultiError(errors)
}
return nil
}
func (m *UpdateSchedulerRequest) _validateHostname(host string) error {
s := strings.ToLower(strings.TrimSuffix(host, "."))
if len(host) > 253 {
return errors.New("hostname cannot exceed 253 characters")
}
for _, part := range strings.Split(s, ".") {
if l := len(part); l == 0 || l > 63 {
return errors.New("hostname part must be non-empty and cannot exceed 63 characters")
}
if part[0] == '-' {
return errors.New("hostname parts cannot begin with hyphens")
}
if part[len(part)-1] == '-' {
return errors.New("hostname parts cannot end with hyphens")
}
for _, r := range part {
if (r < 'a' || r > 'z') && (r < '0' || r > '9') && r != '-' {
return fmt.Errorf("hostname parts can only contain alphanumeric characters or hyphens, got %q", string(r))
}
}
}
return nil
}
type UpdateSchedulerRequestMultiError []error
func (m UpdateSchedulerRequestMultiError) Error() string {
var msgs []string
for _, err := range m {
msgs = append(msgs, err.Error())
}
return strings.Join(msgs, "; ")
}
func (m UpdateSchedulerRequestMultiError) AllErrors() []error { return m }
type UpdateSchedulerRequestValidationError struct {
field string
reason string
cause error
key bool
}
func (e UpdateSchedulerRequestValidationError) Field() string { return e.field }
func (e UpdateSchedulerRequestValidationError) Reason() string { return e.reason }
func (e UpdateSchedulerRequestValidationError) Cause() error { return e.cause }
func (e UpdateSchedulerRequestValidationError) Key() bool { return e.key }
func (e UpdateSchedulerRequestValidationError) ErrorName() string {
return "UpdateSchedulerRequestValidationError"
}
func (e UpdateSchedulerRequestValidationError) Error() string {
cause := ""
if e.cause != nil {
cause = fmt.Sprintf(" | caused by: %v", e.cause)
}
key := ""
if e.key {
key = "key for "
}
return fmt.Sprintf(
"invalid %sUpdateSchedulerRequest.%s: %s%s",
key,
e.field,
e.reason,
cause)
}
var _ error = UpdateSchedulerRequestValidationError{}
var _ interface {
Field() string
Reason() string
Key() bool
Cause() error
ErrorName() string
} = UpdateSchedulerRequestValidationError{}
func (m *ListSchedulersRequest) Validate() error {
return m.validate(false)
}
func (m *ListSchedulersRequest) ValidateAll() error {
return m.validate(true)
}
func (m *ListSchedulersRequest) validate(all bool) error {
if m == nil {
return nil
}
var errors []error
if _, ok := SourceType_name[int32(m.GetSourceType())]; !ok {
err := ListSchedulersRequestValidationError{
field: "SourceType",
reason: "value must be one of the defined enum values",
}
if !all {
return err
}
errors = append(errors, err)
}
if err := m._validateHostname(m.GetHostname()); err != nil {
err = ListSchedulersRequestValidationError{
field: "Hostname",
reason: "value must be a valid hostname",
cause: err,
}
if !all {
return err
}
errors = append(errors, err)
}
if ip := net.ParseIP(m.GetIp()); ip == nil {
err := ListSchedulersRequestValidationError{
field: "Ip",
reason: "value must be a valid IP address",
}
if !all {
return err
}
errors = append(errors, err)
}
if m.GetVersion() != "" {
if l := utf8.RuneCountInString(m.GetVersion()); l < 1 || l > 1024 {
err := ListSchedulersRequestValidationError{
field: "Version",
reason: "value length must be between 1 and 1024 runes, inclusive",
}
if !all {
return err
}
errors = append(errors, err)
}
}
if m.GetCommit() != "" {
if l := utf8.RuneCountInString(m.GetCommit()); l < 1 || l > 1024 {
err := ListSchedulersRequestValidationError{
field: "Commit",
reason: "value length must be between 1 and 1024 runes, inclusive",
}
if !all {
return err
}
errors = append(errors, err)
}
}
if m.Idc != nil {
if m.GetIdc() != "" {
if l := utf8.RuneCountInString(m.GetIdc()); l < 1 || l > 1024 {
err := ListSchedulersRequestValidationError{
field: "Idc",
reason: "value length must be between 1 and 1024 runes, inclusive",
}
if !all {
return err
}
errors = append(errors, err)
}
}
}
if m.Location != nil {
if m.GetLocation() != "" {
if l := utf8.RuneCountInString(m.GetLocation()); l < 1 || l > 1024 {
err := ListSchedulersRequestValidationError{
field: "Location",
reason: "value length must be between 1 and 1024 runes, inclusive",
}
if !all {
return err
}
errors = append(errors, err)
}
}
}
if len(errors) > 0 {
return ListSchedulersRequestMultiError(errors)
}
return nil
}
func (m *ListSchedulersRequest) _validateHostname(host string) error {
s := strings.ToLower(strings.TrimSuffix(host, "."))
if len(host) > 253 {
return errors.New("hostname cannot exceed 253 characters")
}
for _, part := range strings.Split(s, ".") {
if l := len(part); l == 0 || l > 63 {
return errors.New("hostname part must be non-empty and cannot exceed 63 characters")
}
if part[0] == '-' {
return errors.New("hostname parts cannot begin with hyphens")
}
if part[len(part)-1] == '-' {
return errors.New("hostname parts cannot end with hyphens")
}
for _, r := range part {
if (r < 'a' || r > 'z') && (r < '0' || r > '9') && r != '-' {
return fmt.Errorf("hostname parts can only contain alphanumeric characters or hyphens, got %q", string(r))
}
}
}
return nil
}
type ListSchedulersRequestMultiError []error
func (m ListSchedulersRequestMultiError) Error() string {
var msgs []string
for _, err := range m {
msgs = append(msgs, err.Error())
}
return strings.Join(msgs, "; ")
}
func (m ListSchedulersRequestMultiError) AllErrors() []error { return m }
type ListSchedulersRequestValidationError struct {
field string
reason string
cause error
key bool
}
func (e ListSchedulersRequestValidationError) Field() string { return e.field }
func (e ListSchedulersRequestValidationError) Reason() string { return e.reason }
func (e ListSchedulersRequestValidationError) Cause() error { return e.cause }
func (e ListSchedulersRequestValidationError) Key() bool { return e.key }
func (e ListSchedulersRequestValidationError) ErrorName() string {
return "ListSchedulersRequestValidationError"
}
func (e ListSchedulersRequestValidationError) Error() string {
cause := ""
if e.cause != nil {
cause = fmt.Sprintf(" | caused by: %v", e.cause)
}
key := ""
if e.key {
key = "key for "
}
return fmt.Sprintf(
"invalid %sListSchedulersRequest.%s: %s%s",
key,
e.field,
e.reason,
cause)
}
var _ error = ListSchedulersRequestValidationError{}
var _ interface {
Field() string
Reason() string
Key() bool
Cause() error
ErrorName() string
} = ListSchedulersRequestValidationError{}
func (m *ListSchedulersResponse) Validate() error {
return m.validate(false)
}
func (m *ListSchedulersResponse) ValidateAll() error {
return m.validate(true)
}
func (m *ListSchedulersResponse) validate(all bool) error {
if m == nil {
return nil
}
var errors []error
for idx, item := range m.GetSchedulers() {
_, _ = idx, item
if all {
switch v := interface{}(item).(type) {
case interface{ ValidateAll() error }:
if err := v.ValidateAll(); err != nil {
errors = append(errors, ListSchedulersResponseValidationError{
field: fmt.Sprintf("Schedulers[%v]", idx),
reason: "embedded message failed validation",
cause: err,
})
}
case interface{ Validate() error }:
if err := v.Validate(); err != nil {
errors = append(errors, ListSchedulersResponseValidationError{
field: fmt.Sprintf("Schedulers[%v]", idx),
reason: "embedded message failed validation",
cause: err,
})
}
}
} else if v, ok := interface{}(item).(interface{ Validate() error }); ok {
if err := v.Validate(); err != nil {
return ListSchedulersResponseValidationError{
field: fmt.Sprintf("Schedulers[%v]", idx),
reason: "embedded message failed validation",
cause: err,
}
}
}
}
if len(errors) > 0 {
return ListSchedulersResponseMultiError(errors)
}
return nil
}
type ListSchedulersResponseMultiError []error
func (m ListSchedulersResponseMultiError) Error() string {
var msgs []string
for _, err := range m {
msgs = append(msgs, err.Error())
}
return strings.Join(msgs, "; ")
}
func (m ListSchedulersResponseMultiError) AllErrors() []error { return m }
type ListSchedulersResponseValidationError struct {
field string
reason string
cause error
key bool
}
func (e ListSchedulersResponseValidationError) Field() string { return e.field }
func (e ListSchedulersResponseValidationError) Reason() string { return e.reason }
func (e ListSchedulersResponseValidationError) Cause() error { return e.cause }
func (e ListSchedulersResponseValidationError) Key() bool { return e.key }
func (e ListSchedulersResponseValidationError) ErrorName() string {
return "ListSchedulersResponseValidationError"
}
func (e ListSchedulersResponseValidationError) Error() string {
cause := ""
if e.cause != nil {
cause = fmt.Sprintf(" | caused by: %v", e.cause)
}
key := ""
if e.key {
key = "key for "
}
return fmt.Sprintf(
"invalid %sListSchedulersResponse.%s: %s%s",
key,
e.field,
e.reason,
cause)
}
var _ error = ListSchedulersResponseValidationError{}
var _ interface {
Field() string
Reason() string
Key() bool
Cause() error
ErrorName() string
} = ListSchedulersResponseValidationError{}
func (m *URLPriority) Validate() error {
return m.validate(false)
}
func (m *URLPriority) ValidateAll() error {
return m.validate(true)
}
func (m *URLPriority) validate(all bool) error {
if m == nil {
return nil
}
var errors []error
if utf8.RuneCountInString(m.GetRegex()) < 1 {
err := URLPriorityValidationError{
field: "Regex",
reason: "value length must be at least 1 runes",
}
if !all {
return err
}
errors = append(errors, err)
}
if len(errors) > 0 {
return URLPriorityMultiError(errors)
}
return nil
}
type URLPriorityMultiError []error
func (m URLPriorityMultiError) Error() string {
var msgs []string
for _, err := range m {
msgs = append(msgs, err.Error())
}
return strings.Join(msgs, "; ")
}
func (m URLPriorityMultiError) AllErrors() []error { return m }
type URLPriorityValidationError struct {
field string
reason string
cause error
key bool
}
func (e URLPriorityValidationError) Field() string { return e.field }
func (e URLPriorityValidationError) Reason() string { return e.reason }
func (e URLPriorityValidationError) Cause() error { return e.cause }
func (e URLPriorityValidationError) Key() bool { return e.key }
func (e URLPriorityValidationError) ErrorName() string { return "URLPriorityValidationError" }
func (e URLPriorityValidationError) Error() string {
cause := ""
if e.cause != nil {
cause = fmt.Sprintf(" | caused by: %v", e.cause)
}
key := ""
if e.key {
key = "key for "
}
return fmt.Sprintf(
"invalid %sURLPriority.%s: %s%s",
key,
e.field,
e.reason,
cause)
}
var _ error = URLPriorityValidationError{}
var _ interface {
Field() string
Reason() string
Key() bool
Cause() error
ErrorName() string
} = URLPriorityValidationError{}
func (m *ApplicationPriority) Validate() error {
return m.validate(false)
}
func (m *ApplicationPriority) ValidateAll() error {
return m.validate(true)
}
func (m *ApplicationPriority) validate(all bool) error {
if m == nil {
return nil
}
var errors []error
for idx, item := range m.GetUrls() {
_, _ = idx, item
if all {
switch v := interface{}(item).(type) {
case interface{ ValidateAll() error }:
if err := v.ValidateAll(); err != nil {
errors = append(errors, ApplicationPriorityValidationError{
field: fmt.Sprintf("Urls[%v]", idx),
reason: "embedded message failed validation",
cause: err,
})
}
case interface{ Validate() error }:
if err := v.Validate(); err != nil {
errors = append(errors, ApplicationPriorityValidationError{
field: fmt.Sprintf("Urls[%v]", idx),
reason: "embedded message failed validation",
cause: err,
})
}
}
} else if v, ok := interface{}(item).(interface{ Validate() error }); ok {
if err := v.Validate(); err != nil {
return ApplicationPriorityValidationError{
field: fmt.Sprintf("Urls[%v]", idx),
reason: "embedded message failed validation",
cause: err,
}
}
}
}
if len(errors) > 0 {
return ApplicationPriorityMultiError(errors)
}
return nil
}
type ApplicationPriorityMultiError []error
func (m ApplicationPriorityMultiError) Error() string {
var msgs []string
for _, err := range m {
msgs = append(msgs, err.Error())
}
return strings.Join(msgs, "; ")
}
func (m ApplicationPriorityMultiError) AllErrors() []error { return m }
type ApplicationPriorityValidationError struct {
field string
reason string
cause error
key bool
}
func (e ApplicationPriorityValidationError) Field() string { return e.field }
func (e ApplicationPriorityValidationError) Reason() string { return e.reason }
func (e ApplicationPriorityValidationError) Cause() error { return e.cause }
func (e ApplicationPriorityValidationError) Key() bool { return e.key }
func (e ApplicationPriorityValidationError) ErrorName() string {
return "ApplicationPriorityValidationError"
}
func (e ApplicationPriorityValidationError) Error() string {
cause := ""
if e.cause != nil {
cause = fmt.Sprintf(" | caused by: %v", e.cause)
}
key := ""
if e.key {
key = "key for "
}
return fmt.Sprintf(
"invalid %sApplicationPriority.%s: %s%s",
key,
e.field,
e.reason,
cause)
}
var _ error = ApplicationPriorityValidationError{}
var _ interface {
Field() string
Reason() string
Key() bool
Cause() error
ErrorName() string
} = ApplicationPriorityValidationError{}
func (m *Application) Validate() error {
return m.validate(false)
}
func (m *Application) ValidateAll() error {
return m.validate(true)
}
func (m *Application) validate(all bool) error {
if m == nil {
return nil
}
var errors []error
if m.GetId() < 1 {
err := ApplicationValidationError{
field: "Id",
reason: "value must be greater than or equal to 1",
}
if !all {
return err
}
errors = append(errors, err)
}
if l := utf8.RuneCountInString(m.GetName()); l < 1 || l > 1024 {
err := ApplicationValidationError{
field: "Name",
reason: "value length must be between 1 and 1024 runes, inclusive",
}
if !all {
return err
}
errors = append(errors, err)
}
if uri, err := url.Parse(m.GetUrl()); err != nil {
err = ApplicationValidationError{
field: "Url",
reason: "value must be a valid URI",
cause: err,
}
if !all {
return err
}
errors = append(errors, err)
} else if !uri.IsAbs() {
err := ApplicationValidationError{
field: "Url",
reason: "value must be absolute",
}
if !all {
return err
}
errors = append(errors, err)
}
if m.GetPriority() == nil {
err := ApplicationValidationError{
field: "Priority",
reason: "value is required",
}
if !all {
return err
}
errors = append(errors, err)
}
if all {
switch v := interface{}(m.GetPriority()).(type) {
case interface{ ValidateAll() error }:
if err := v.ValidateAll(); err != nil {
errors = append(errors, ApplicationValidationError{
field: "Priority",
reason: "embedded message failed validation",
cause: err,
})
}
case interface{ Validate() error }:
if err := v.Validate(); err != nil {
errors = append(errors, ApplicationValidationError{
field: "Priority",
reason: "embedded message failed validation",
cause: err,
})
}
}
} else if v, ok := interface{}(m.GetPriority()).(interface{ Validate() error }); ok {
if err := v.Validate(); err != nil {
return ApplicationValidationError{
field: "Priority",
reason: "embedded message failed validation",
cause: err,
}
}
}
if len(errors) > 0 {
return ApplicationMultiError(errors)
}
return nil
}
type ApplicationMultiError []error
func (m ApplicationMultiError) Error() string {
var msgs []string
for _, err := range m {
msgs = append(msgs, err.Error())
}
return strings.Join(msgs, "; ")
}
func (m ApplicationMultiError) AllErrors() []error { return m }
type ApplicationValidationError struct {
field string
reason string
cause error
key bool
}
func (e ApplicationValidationError) Field() string { return e.field }
func (e ApplicationValidationError) Reason() string { return e.reason }
func (e ApplicationValidationError) Cause() error { return e.cause }
func (e ApplicationValidationError) Key() bool { return e.key }
func (e ApplicationValidationError) ErrorName() string { return "ApplicationValidationError" }
func (e ApplicationValidationError) Error() string {
cause := ""
if e.cause != nil {
cause = fmt.Sprintf(" | caused by: %v", e.cause)
}
key := ""
if e.key {
key = "key for "
}
return fmt.Sprintf(
"invalid %sApplication.%s: %s%s",
key,
e.field,
e.reason,
cause)
}
var _ error = ApplicationValidationError{}
var _ interface {
Field() string
Reason() string
Key() bool
Cause() error
ErrorName() string
} = ApplicationValidationError{}
func (m *ListApplicationsRequest) Validate() error {
return m.validate(false)
}
func (m *ListApplicationsRequest) ValidateAll() error {
return m.validate(true)
}
func (m *ListApplicationsRequest) validate(all bool) error {
if m == nil {
return nil
}
var errors []error
if _, ok := SourceType_name[int32(m.GetSourceType())]; !ok {
err := ListApplicationsRequestValidationError{
field: "SourceType",
reason: "value must be one of the defined enum values",
}
if !all {
return err
}
errors = append(errors, err)
}
if err := m._validateHostname(m.GetHostname()); err != nil {
err = ListApplicationsRequestValidationError{
field: "Hostname",
reason: "value must be a valid hostname",
cause: err,
}
if !all {
return err
}
errors = append(errors, err)
}
if ip := net.ParseIP(m.GetIp()); ip == nil {
err := ListApplicationsRequestValidationError{
field: "Ip",
reason: "value must be a valid IP address",
}
if !all {
return err
}
errors = append(errors, err)
}
if len(errors) > 0 {
return ListApplicationsRequestMultiError(errors)
}
return nil
}
func (m *ListApplicationsRequest) _validateHostname(host string) error {
s := strings.ToLower(strings.TrimSuffix(host, "."))
if len(host) > 253 {
return errors.New("hostname cannot exceed 253 characters")
}
for _, part := range strings.Split(s, ".") {
if l := len(part); l == 0 || l > 63 {
return errors.New("hostname part must be non-empty and cannot exceed 63 characters")
}
if part[0] == '-' {
return errors.New("hostname parts cannot begin with hyphens")
}
if part[len(part)-1] == '-' {
return errors.New("hostname parts cannot end with hyphens")
}
for _, r := range part {
if (r < 'a' || r > 'z') && (r < '0' || r > '9') && r != '-' {
return fmt.Errorf("hostname parts can only contain alphanumeric characters or hyphens, got %q", string(r))
}
}
}
return nil
}
type ListApplicationsRequestMultiError []error
func (m ListApplicationsRequestMultiError) Error() string {
var msgs []string
for _, err := range m {
msgs = append(msgs, err.Error())
}
return strings.Join(msgs, "; ")
}
func (m ListApplicationsRequestMultiError) AllErrors() []error { return m }
type ListApplicationsRequestValidationError struct {
field string
reason string
cause error
key bool
}
func (e ListApplicationsRequestValidationError) Field() string { return e.field }
func (e ListApplicationsRequestValidationError) Reason() string { return e.reason }
func (e ListApplicationsRequestValidationError) Cause() error { return e.cause }
func (e ListApplicationsRequestValidationError) Key() bool { return e.key }
func (e ListApplicationsRequestValidationError) ErrorName() string {
return "ListApplicationsRequestValidationError"
}
func (e ListApplicationsRequestValidationError) Error() string {
cause := ""
if e.cause != nil {
cause = fmt.Sprintf(" | caused by: %v", e.cause)
}
key := ""
if e.key {
key = "key for "
}
return fmt.Sprintf(
"invalid %sListApplicationsRequest.%s: %s%s",
key,
e.field,
e.reason,
cause)
}
var _ error = ListApplicationsRequestValidationError{}
var _ interface {
Field() string
Reason() string
Key() bool
Cause() error
ErrorName() string
} = ListApplicationsRequestValidationError{}
func (m *ListApplicationsResponse) Validate() error {
return m.validate(false)
}
func (m *ListApplicationsResponse) ValidateAll() error {
return m.validate(true)
}
func (m *ListApplicationsResponse) validate(all bool) error {
if m == nil {
return nil
}
var errors []error
for idx, item := range m.GetApplications() {
_, _ = idx, item
if all {
switch v := interface{}(item).(type) {
case interface{ ValidateAll() error }:
if err := v.ValidateAll(); err != nil {
errors = append(errors, ListApplicationsResponseValidationError{
field: fmt.Sprintf("Applications[%v]", idx),
reason: "embedded message failed validation",
cause: err,
})
}
case interface{ Validate() error }:
if err := v.Validate(); err != nil {
errors = append(errors, ListApplicationsResponseValidationError{
field: fmt.Sprintf("Applications[%v]", idx),
reason: "embedded message failed validation",
cause: err,
})
}
}
} else if v, ok := interface{}(item).(interface{ Validate() error }); ok {
if err := v.Validate(); err != nil {
return ListApplicationsResponseValidationError{
field: fmt.Sprintf("Applications[%v]", idx),
reason: "embedded message failed validation",
cause: err,
}
}
}
}
if len(errors) > 0 {
return ListApplicationsResponseMultiError(errors)
}
return nil
}
type ListApplicationsResponseMultiError []error
func (m ListApplicationsResponseMultiError) Error() string {
var msgs []string
for _, err := range m {
msgs = append(msgs, err.Error())
}
return strings.Join(msgs, "; ")
}
func (m ListApplicationsResponseMultiError) AllErrors() []error { return m }
type ListApplicationsResponseValidationError struct {
field string
reason string
cause error
key bool
}
func (e ListApplicationsResponseValidationError) Field() string { return e.field }
func (e ListApplicationsResponseValidationError) Reason() string { return e.reason }
func (e ListApplicationsResponseValidationError) Cause() error { return e.cause }
func (e ListApplicationsResponseValidationError) Key() bool { return e.key }
func (e ListApplicationsResponseValidationError) ErrorName() string {
return "ListApplicationsResponseValidationError"
}
func (e ListApplicationsResponseValidationError) Error() string {
cause := ""
if e.cause != nil {
cause = fmt.Sprintf(" | caused by: %v", e.cause)
}
key := ""
if e.key {
key = "key for "
}
return fmt.Sprintf(
"invalid %sListApplicationsResponse.%s: %s%s",
key,
e.field,
e.reason,
cause)
}
var _ error = ListApplicationsResponseValidationError{}
var _ interface {
Field() string
Reason() string
Key() bool
Cause() error
ErrorName() string
} = ListApplicationsResponseValidationError{}
func (m *KeepAliveRequest) Validate() error {
return m.validate(false)
}
func (m *KeepAliveRequest) ValidateAll() error {
return m.validate(true)
}
func (m *KeepAliveRequest) validate(all bool) error {
if m == nil {
return nil
}
var errors []error
if _, ok := SourceType_name[int32(m.GetSourceType())]; !ok {
err := KeepAliveRequestValidationError{
field: "SourceType",
reason: "value must be one of the defined enum values",
}
if !all {
return err
}
errors = append(errors, err)
}
if err := m._validateHostname(m.GetHostname()); err != nil {
err = KeepAliveRequestValidationError{
field: "Hostname",
reason: "value must be a valid hostname",
cause: err,
}
if !all {
return err
}
errors = append(errors, err)
}
if m.GetClusterId() < 1 {
err := KeepAliveRequestValidationError{
field: "ClusterId",
reason: "value must be greater than or equal to 1",
}
if !all {
return err
}
errors = append(errors, err)
}
if m.GetIp() != "" {
if ip := net.ParseIP(m.GetIp()); ip == nil {
err := KeepAliveRequestValidationError{
field: "Ip",
reason: "value must be a valid IP address",
}
if !all {
return err
}
errors = append(errors, err)
}
}
if len(errors) > 0 {
return KeepAliveRequestMultiError(errors)
}
return nil
}
func (m *KeepAliveRequest) _validateHostname(host string) error {
s := strings.ToLower(strings.TrimSuffix(host, "."))
if len(host) > 253 {
return errors.New("hostname cannot exceed 253 characters")
}
for _, part := range strings.Split(s, ".") {
if l := len(part); l == 0 || l > 63 {
return errors.New("hostname part must be non-empty and cannot exceed 63 characters")
}
if part[0] == '-' {
return errors.New("hostname parts cannot begin with hyphens")
}
if part[len(part)-1] == '-' {
return errors.New("hostname parts cannot end with hyphens")
}
for _, r := range part {
if (r < 'a' || r > 'z') && (r < '0' || r > '9') && r != '-' {
return fmt.Errorf("hostname parts can only contain alphanumeric characters or hyphens, got %q", string(r))
}
}
}
return nil
}
type KeepAliveRequestMultiError []error
func (m KeepAliveRequestMultiError) Error() string {
var msgs []string
for _, err := range m {
msgs = append(msgs, err.Error())
}
return strings.Join(msgs, "; ")
}
func (m KeepAliveRequestMultiError) AllErrors() []error { return m }
type KeepAliveRequestValidationError struct {
field string
reason string
cause error
key bool
}
func (e KeepAliveRequestValidationError) Field() string { return e.field }
func (e KeepAliveRequestValidationError) Reason() string { return e.reason }
func (e KeepAliveRequestValidationError) Cause() error { return e.cause }
func (e KeepAliveRequestValidationError) Key() bool { return e.key }
func (e KeepAliveRequestValidationError) ErrorName() string { return "KeepAliveRequestValidationError" }
func (e KeepAliveRequestValidationError) Error() string {
cause := ""
if e.cause != nil {
cause = fmt.Sprintf(" | caused by: %v", e.cause)
}
key := ""
if e.key {
key = "key for "
}
return fmt.Sprintf(
"invalid %sKeepAliveRequest.%s: %s%s",
key,
e.field,
e.reason,
cause)
}
var _ error = KeepAliveRequestValidationError{}
var _ interface {
Field() string
Reason() string
Key() bool
Cause() error
ErrorName() string
} = KeepAliveRequestValidationError{}