(triggerName string, feedName string, parameters interface{})
| 357 | } |
| 358 | |
| 359 | func configureFeed(triggerName string, feedName string, parameters interface{}) error { |
| 360 | var fullFeedName *QualifiedName |
| 361 | var err error |
| 362 | |
| 363 | if fullFeedName, err = NewQualifiedName(feedName); err != nil { |
| 364 | return NewQualifiedNameError(feedName, err) |
| 365 | } |
| 366 | |
| 367 | res, err := invokeAction(*fullFeedName, parameters, true, false) |
| 368 | err = printInvocationResponse(*fullFeedName, true, false, res, err) |
| 369 | |
| 370 | if err != nil { |
| 371 | whisk.Debug(whisk.DbgError, "Invoke of action '%s' failed: %s\n", feedName, err) |
| 372 | errStr := wski18n.T(FEED_CONFIGURATION_FAILURE, map[string]interface{}{"feedname": feedName, "trigname": triggerName, "err": err}) |
| 373 | err = whisk.MakeWskErrorFromWskError(errors.New(errStr), err, whisk.EXIT_CODE_ERR_GENERAL, whisk.DISPLAY_MSG, whisk.DISPLAY_USAGE) |
| 374 | } else { |
| 375 | whisk.Debug(whisk.DbgInfo, "Successfully configured trigger feed via feed action '%s'\n", feedName) |
| 376 | } |
| 377 | |
| 378 | return err |
| 379 | } |
| 380 | |
| 381 | func deleteTrigger(triggerName string) error { |
| 382 | args := []string{triggerName} |
no test coverage detected