Function MakeQueueSinkTubeConfig

admin/utils/utils.go:58–65

(queueType string, topic string)

}

func MakeQueueSinkTubeConfig(queueType string, topic string) *adminclient.ModelTubeConfig {
	return &adminclient.ModelTubeConfig{
		Type: queueType,
		Config: map[string]interface{}{
			"output": topic,
		},
	}
}

func GetInputTopics(f *adminclient.ModelFunction) ([]string, error) {
	if len(f.Source) < 1 {