fn create_rt_connector(
        &self,
        id: GlobalId,
        sc: ExternalSourceConnector,
    ) -> Option<RtTimestampConsumer> {
        match sc {
            ExternalSourceConnector::Kafka(kc) => {
                self.create_rt_kafka_connector(id, kc)
                    .map(|connector| RtTimestampConsumer {
                        connector: RtTimestampConnector::Kafka(connector),
                    })
            }
            ExternalSourceConnector::File(fc) => {
                self.create_rt_file_connector(id, fc)
                    .map(|connector| RtTimestampConsumer {
                        connector: RtTimestampConnector::File(connector),
                    })
            }
            ExternalSourceConnector::AvroOcf(fc) => {
                self.create_rt_ocf_connector(id, fc)
                    .map(|connector| RtTimestampConsumer {
                        connector: RtTimestampConnector::Ocf(connector),
                    })
            }
            ExternalSourceConnector::Kinesis(kinc) => self
                .create_rt_kinesis_connector(id, kinc)
                .map(|connector| RtTimestampConsumer {
                    connector: RtTimestampConnector::Kinesis(connector),
                }),
            ExternalSourceConnector::S3(s3c) => {
                self.create_rt_s3_connector(id, s3c)
                    .map(|connector| RtTimestampConsumer {
                        connector: RtTimestampConnector::S3(connector),
                    })
            }
            ExternalSourceConnector::Postgres(_) => None,
            ExternalSourceConnector::PubNub(_) => None,
        }
    }
/// Creates a RT connector
/// TODO(rkhaitan): this function burns my eyes
Creates a RT connector
TODO(rkhaitan): this function burns my eyes
Creates a RT connector TODO ( rkhaitan ) : this function burns my eyes
fn create_rt_connector(
        &self,
        id: GlobalId,
        sc: ExternalSourceConnector,
    ) -> Option<RtTimestampConsumer> {
        match sc {
            ExternalSourceConnector::Kafka(kc) => {
                self.create_rt_kafka_connector(id, kc)
                    .map(|connector| RtTimestampConsumer {
                        connector: RtTimestampConnector::Kafka(connector),
                    })
            }
            ExternalSourceConnector::File(fc) => {
                self.create_rt_file_connector(id, fc)
                    .map(|connector| RtTimestampConsumer {
                        connector: RtTimestampConnector::File(connector),
                    })
            }
            ExternalSourceConnector::AvroOcf(fc) => {
                self.create_rt_ocf_connector(id, fc)
                    .map(|connector| RtTimestampConsumer {
                        connector: RtTimestampConnector::Ocf(connector),
                    })
            }
            ExternalSourceConnector::Kinesis(kinc) => self
                .create_rt_kinesis_connector(id, kinc)
                .map(|connector| RtTimestampConsumer {
                    connector: RtTimestampConnector::Kinesis(connector),
                }),
            ExternalSourceConnector::S3(s3c) => {
                self.create_rt_s3_connector(id, s3c)
                    .map(|connector| RtTimestampConsumer {
                        connector: RtTimestampConnector::S3(connector),
                    })
            }
            ExternalSourceConnector::Postgres(_) => None,
            ExternalSourceConnector::PubNub(_) => None,
        }
    }
fn create_rt_connector ( & self , id : GlobalId , sc : ExternalSourceConnector , ) -> Option < RtTimestampConsumer > { match sc { ExternalSourceConnector :: Kafka ( kc ) => { self . create_rt_kafka_connector ( id , kc ) . map ( | connector | RtTimestampConsumer { connector : RtTimestampConnector :: Kafka ( connector ) , } ) } ExternalSourceConnector :: File ( fc ) => { self . create_rt_file_connector ( id , fc ) . map ( | connector | RtTimestampConsumer { connector : RtTimestampConnector :: File ( connector ) , } ) } ExternalSourceConnector :: AvroOcf ( fc ) => { self . create_rt_ocf_connector ( id , fc ) . map ( | connector | RtTimestampConsumer { connector : RtTimestampConnector :: Ocf ( connector ) , } ) } ExternalSourceConnector :: Kinesis ( kinc ) => self . create_rt_kinesis_connector ( id , kinc ) . map ( | connector | RtTimestampConsumer { connector : RtTimestampConnector :: Kinesis ( connector ) , } ) , ExternalSourceConnector :: S3 ( s3c ) => { self . create_rt_s3_connector ( id , s3c ) . map ( | connector | RtTimestampConsumer { connector : RtTimestampConnector :: S3 ( connector ) , } ) } ExternalSourceConnector :: Postgres ( _ ) => None , ExternalSourceConnector :: PubNub ( _ ) => None , } }
Creates a RT connector
TODO(rkhaitan): this function burns my eyes
Creates a RT connector TODO ( rkhaitan ) : this function burns my eyes
&self
id
GlobalId
sc
ExternalSourceConnector
&self
id
GlobalId
sc
ExternalSourceConnector