()
| 310 | } |
| 311 | |
| 312 | func (fm *functionManagerImpl) Close() error { |
| 313 | fm.functionsLock.Lock() |
| 314 | defer fm.functionsLock.Unlock() |
| 315 | for _, instances := range fm.functions { |
| 316 | for _, instance := range instances { |
| 317 | instance.Stop() |
| 318 | } |
| 319 | } |
| 320 | err := fm.options.stateStore.Close() |
| 321 | if err != nil { |
| 322 | return err |
| 323 | } |
| 324 | return nil |
| 325 | } |