| 166 | } |
| 167 | |
| 168 | func GetBuiltinTubeFactoryBuilder() map[string]func(configMap common.ConfigMap) (contube.TubeFactory, error) { |
| 169 | return map[string]func(configMap common.ConfigMap) (contube.TubeFactory, error){ |
| 170 | common.PulsarTubeType: func(configMap common.ConfigMap) (contube.TubeFactory, error) { |
| 171 | return contube.NewPulsarEventQueueFactory(context.Background(), contube.ConfigMap(configMap)) |
| 172 | }, |
| 173 | //nolint:unparam |
| 174 | common.MemoryTubeType: func(_ common.ConfigMap) (contube.TubeFactory, error) { |
| 175 | return contube.NewMemoryQueueFactory(context.Background()), nil |
| 176 | }, |
| 177 | } |
| 178 | } |
| 179 | |
| 180 | func GetBuiltinRuntimeFactoryBuilder() map[string]func(configMap common.ConfigMap) (api.FunctionRuntimeFactory, error) { |
| 181 | return map[string]func(configMap common.ConfigMap) (api.FunctionRuntimeFactory, error){ |