()
| 262 | } |
| 263 | |
| 264 | func (fm *functionManagerImpl) ListFunctions() (result []string) { |
| 265 | fm.functionsLock.Lock() |
| 266 | defer fm.functionsLock.Unlock() |
| 267 | result = make([]string, len(fm.functions)) |
| 268 | i := 0 |
| 269 | for k := range fm.functions { |
| 270 | result[i] = k.String() |
| 271 | i++ |
| 272 | } |
| 273 | return |
| 274 | } |
| 275 | |
| 276 | func (fm *functionManagerImpl) ProduceEvent(name string, event contube.Record) error { |
| 277 | ctx, cancel := context.WithCancel(context.Background()) |