(name string, factory contube.TubeFactory)
| 89 | } |
| 90 | |
| 91 | func WithTubeFactory(name string, factory contube.TubeFactory) ManagerOption { |
| 92 | return managerOptionFunc(func(c *managerOptions) (*managerOptions, error) { |
| 93 | c.tubeFactoryMap[name] = factory |
| 94 | return c, nil |
| 95 | }) |
| 96 | } |
| 97 | func WithQueueFactory(factory contube.TubeFactory) ManagerOption { |
| 98 | return managerOptionFunc(func(c *managerOptions) (*managerOptions, error) { |
| 99 | c.queueFactory = factory |