** * Create or update a trigger. * * NOTE: this function will exit in case of a processing error since it indicates a problem parsing parameters. */
(Client *whisk.Client, fqn *QualifiedName, trigger *whisk.Trigger, overwrite bool)
| 78 | * NOTE: this function will exit in case of a processing error since it indicates a problem parsing parameters. |
| 79 | */ |
| 80 | func createOrUpdate(Client *whisk.Client, fqn *QualifiedName, trigger *whisk.Trigger, overwrite bool) { |
| 81 | // TODO get rid of these global modifiers |
| 82 | Client.Namespace = fqn.GetNamespace() |
| 83 | _, _, err := Client.Triggers.Insert(trigger, overwrite) |
| 84 | |
| 85 | if err != nil { |
| 86 | whisk.Debug(whisk.DbgError, "Client.Triggers.Insert(%+v, %t) failed: %s\n", trigger, overwrite, err) |
| 87 | var errStr string |
| 88 | if !overwrite { |
| 89 | errStr = wski18n.T("Unable to create trigger '{{.name}}': {{.err}}", |
| 90 | map[string]interface{}{"name": trigger.Name, "err": err}) |
| 91 | } else { |
| 92 | errStr = wski18n.T("Unable to update trigger '{{.name}}': {{.err}}", |
| 93 | map[string]interface{}{"name": trigger.Name, "err": err}) |
| 94 | } |
| 95 | ExitOnError(whisk.MakeWskErrorFromWskError(errors.New(errStr), err, whisk.EXIT_CODE_ERR_GENERAL, whisk.DISPLAY_MSG, whisk.NO_DISPLAY_USAGE)) |
| 96 | } |
| 97 | } |
| 98 | |
| 99 | var triggerFireCmd = &cobra.Command{ |
| 100 | Use: "fire TRIGGER_NAME [PAYLOAD]", |
no test coverage detected