Add validate function to crd resource and do validate before creation/update (#580)

2018-04-08 00:56:13 +08:00
parent 2ef5caa5ed
commit 1d4368c23a
25 changed files with 714 additions and 114 deletions
@@ -29,6 +29,11 @@ import (
 )

 func (c *Client) WatchCreate(w *crd.KubernetesWatchTrigger) (*metav1.ObjectMeta, error) {
+	err := w.Validate()
+	if err != nil {
+		return nil, fission.AggregateValidationErrors("KubernetesWatchTrigger", err)
+	}
+
 	reqbody, err := json.Marshal(w)
 	if err != nil {
 		return nil, err