Method NewSourceTube

fs/contube/pulsar.go:57–63

(ctx context.Context, configMap ConfigMap)

}

func (f *PulsarEventQueueFactory) NewSourceTube(ctx context.Context, configMap ConfigMap) (<-chan Record, error) {
	config := SourceQueueConfig{}
	if err := configMap.ToConfigStruct(&config); err != nil {
		return nil, err
	}
	return f.newSourceChan(ctx, &config)
}

func (f *PulsarEventQueueFactory) NewSinkTube(ctx context.Context, configMap ConfigMap) (chan<- Record, error) {
	config := SinkQueueConfig{}