(appId string)
| 45 | } |
| 46 | |
| 47 | func (c *Cluster) deleteStream(appId string) error { |
| 48 | c.setProcessName("deleting event stream") |
| 49 | c.logger.Debugf("deleting event stream with applicationId %s", appId) |
| 50 | |
| 51 | err := c.KubeClient.FabricEventStreams(c.Streams[appId].Namespace).Delete(context.TODO(), c.Streams[appId].Name, metav1.DeleteOptions{}) |
| 52 | if err != nil { |
| 53 | return fmt.Errorf("could not delete event stream %q with applicationId %s: %v", c.Streams[appId].Name, appId, err) |
| 54 | } |
| 55 | c.logger.Infof("event stream %q with applicationId %s has been successfully deleted", c.Streams[appId].Name, appId) |
| 56 | delete(c.Streams, appId) |
| 57 | |
| 58 | return nil |
| 59 | } |
| 60 | |
| 61 | func (c *Cluster) deleteStreams() error { |
| 62 | // check if stream CRD is installed before trying a delete |
no test coverage detected