Do resources validation when validate spec files (#840)
This commit is contained in:
@@ -286,6 +286,8 @@ func (fr *FissionResources) validate() error {
|
|||||||
archives[aname] = true
|
archives[aname] = true
|
||||||
}
|
}
|
||||||
}
|
}
|
||||||
|
|
||||||
|
result = multierror.Append(result, p.Validate())
|
||||||
}
|
}
|
||||||
|
|
||||||
// error on unreferenced archives
|
// error on unreferenced archives
|
||||||
@@ -336,6 +338,8 @@ func (fr *FissionResources) validate() error {
|
|||||||
} else {
|
} else {
|
||||||
packages[mapKey(pkgMeta)] = true
|
packages[mapKey(pkgMeta)] = true
|
||||||
}
|
}
|
||||||
|
|
||||||
|
result = multierror.Append(result, f.Validate())
|
||||||
}
|
}
|
||||||
|
|
||||||
// error on unreferenced packages
|
// error on unreferenced packages
|
||||||
@@ -356,24 +360,28 @@ func (fr *FissionResources) validate() error {
|
|||||||
if err != nil {
|
if err != nil {
|
||||||
result = multierror.Append(result, err)
|
result = multierror.Append(result, err)
|
||||||
}
|
}
|
||||||
|
result = multierror.Append(result, t.Validate())
|
||||||
}
|
}
|
||||||
for _, t := range fr.kubernetesWatchTriggers {
|
for _, t := range fr.kubernetesWatchTriggers {
|
||||||
err := fr.validateFunctionReference(functions, t.Kind, &t.Metadata, t.Spec.FunctionReference)
|
err := fr.validateFunctionReference(functions, t.Kind, &t.Metadata, t.Spec.FunctionReference)
|
||||||
if err != nil {
|
if err != nil {
|
||||||
result = multierror.Append(result, err)
|
result = multierror.Append(result, err)
|
||||||
}
|
}
|
||||||
|
result = multierror.Append(result, t.Validate())
|
||||||
}
|
}
|
||||||
for _, t := range fr.timeTriggers {
|
for _, t := range fr.timeTriggers {
|
||||||
err := fr.validateFunctionReference(functions, t.Kind, &t.Metadata, t.Spec.FunctionReference)
|
err := fr.validateFunctionReference(functions, t.Kind, &t.Metadata, t.Spec.FunctionReference)
|
||||||
if err != nil {
|
if err != nil {
|
||||||
result = multierror.Append(result, err)
|
result = multierror.Append(result, err)
|
||||||
}
|
}
|
||||||
|
result = multierror.Append(result, t.Validate())
|
||||||
}
|
}
|
||||||
for _, t := range fr.messageQueueTriggers {
|
for _, t := range fr.messageQueueTriggers {
|
||||||
err := fr.validateFunctionReference(functions, t.Kind, &t.Metadata, t.Spec.FunctionReference)
|
err := fr.validateFunctionReference(functions, t.Kind, &t.Metadata, t.Spec.FunctionReference)
|
||||||
if err != nil {
|
if err != nil {
|
||||||
result = multierror.Append(result, err)
|
result = multierror.Append(result, err)
|
||||||
}
|
}
|
||||||
|
result = multierror.Append(result, t.Validate())
|
||||||
}
|
}
|
||||||
|
|
||||||
// we do not error on unreferenced functions (you can call a function through workflows,
|
// we do not error on unreferenced functions (you can call a function through workflows,
|
||||||
|
|||||||
Reference in New Issue
Block a user