Versions in this module Expand all Collapse all v0 v0.5.0 Jun 13, 2024 Changes in this version + const MemoryQueue + const PulsarQueue + func MakeMemorySinkTubeConfig(topic string) *adminclient.ModelTubeConfig + func MakeMemorySourceTubeConfig(topics ...string) []adminclient.ModelTubeConfig + func MakePulsarSinkTubeConfig(topic string) *adminclient.ModelTubeConfig + func MakePulsarSourceTubeConfig(topics ...string) []adminclient.ModelTubeConfig v0.4.0 May 7, 2024 Changes in this version + func GetInputTopics(f *adminclient.ModelFunction) ([]string, error) + func GetOutputTopic(f *adminclient.ModelFunction) (string, error) + func MakeQueueSinkTubeConfig(topic string) *adminclient.ModelTubeConfig + func MakeQueueSourceTubeConfig(subName string, topics ...string) []adminclient.ModelTubeConfig
Go to main page