(ctx context.Context, configMap ConfigMap)
| 63 | } |
| 64 | |
| 65 | func (f *PulsarEventQueueFactory) NewSinkTube(ctx context.Context, configMap ConfigMap) (chan<- Record, error) { |
| 66 | config := SinkQueueConfig{} |
| 67 | if err := configMap.ToConfigStruct(&config); err != nil { |
| 68 | return nil, err |
| 69 | } |
| 70 | return f.newSinkChan(ctx, &config) |
| 71 | } |
| 72 | |
| 73 | func NewPulsarEventQueueFactory(ctx context.Context, configMap ConfigMap) (TubeFactory, error) { |
| 74 | config, err := NewPulsarTubeFactoryConfig(configMap) |
nothing calls this directly
no test coverage detected