INNER CODE UNIT · JavaScript

enhanceConnector

lensesio/kafka-connect-ui · src/factories/connector-objects.factory.js:22

    function enhanceConnector(connector, isList) {

        var enhancedConnector;
        var connectorName = connector.name;
        var connectorConfig = connector.config;
        var connectorUiInfo = supportedConnectorsFactory.getSupportedConnectorObj(connectorConfig["connector.class"]);
        var connectorStatus = getConnectorStatus(connectorName);

        if(isList) {
            enhancedConnector =  {
                name: connectorName,
                isSource: isSource(connector),
                type: connectorUiInfo.name,
                color: connectorUiInfo.color,
                connectorState: connectorStatus.connector,// getConnectorStatus(connectorName),
                tasks: connectorStatus.tasks,
                workers: connectorConfig["tasks.max"]
            };

View source record →