(t string)
| 181 | } |
| 182 | |
| 183 | func (fm *functionManagerImpl) getRuntimeFactory(t string) (api.FunctionRuntimeFactory, error) { |
| 184 | factory, exist := fm.options.runtimeFactoryMap[t] |
| 185 | if !exist { |
| 186 | return nil, fmt.Errorf("failed to get runtime factory: %w, type: %s", common.ErrorRuntimeFactoryNotFound, t) |
| 187 | } |
| 188 | return factory, nil |
| 189 | } |
| 190 | |
| 191 | func (fm *functionManagerImpl) createFuncCtx() api.FunctionContext { |
| 192 | return NewFuncCtxImpl(fm.options.stateStore) |