(f *adminclient.ModelFunction)
| 79 | } |
| 80 | |
| 81 | func GetOutputTopic(f *adminclient.ModelFunction) (string, error) { |
| 82 | config := f.Sink.Config |
| 83 | if len(config) < 1 { |
| 84 | return "", fmt.Errorf("sink config for function %s is empty", f.Name) |
| 85 | } |
| 86 | if topic, ok := config["output"].(string); ok { |
| 87 | return topic, nil |
| 88 | } |
| 89 | return "", fmt.Errorf("sink config for function %s has no output topic", f.Name) |
| 90 | } |