| 173 | } |
| 174 | |
| 175 | func (fm *functionManagerImpl) getTubeFactory(tubeConfig *model.TubeConfig) (contube.TubeFactory, error) { |
| 176 | factory, exist := fm.options.tubeFactoryMap[tubeConfig.Type] |
| 177 | if !exist { |
| 178 | return nil, fmt.Errorf("failed to get tube factory: %w, type: %s", common.ErrorTubeFactoryNotFound, tubeConfig.Type) |
| 179 | } |
| 180 | return factory, nil |
| 181 | } |
| 182 | |
| 183 | func (fm *functionManagerImpl) getRuntimeFactory(t string) (api.FunctionRuntimeFactory, error) { |
| 184 | factory, exist := fm.options.runtimeFactoryMap[t] |