(configMap ConfigMap)
| 34 | } |
| 35 | |
| 36 | func NewPulsarTubeFactoryConfig(configMap ConfigMap) (*PulsarTubeFactoryConfig, error) { |
| 37 | var result PulsarTubeFactoryConfig |
| 38 | if pulsarURL, ok := configMap[PulsarURLKey].(string); ok { |
| 39 | result.PulsarURL = pulsarURL |
| 40 | } else { |
| 41 | result.PulsarURL = "pulsar://localhost:6650" |
| 42 | } |
| 43 | return &result, nil |
| 44 | } |
| 45 | |
| 46 | func (c *PulsarTubeFactoryConfig) ToConfigMap() ConfigMap { |
| 47 | return ConfigMap{ |
no outgoing calls
no test coverage detected