package com.a.eye.skywalking.collector.worker;

import com.a.eye.skywalking.collector.CollectorSystem;
import com.a.eye.skywalking.collector.actor.ClusterWorkerContext;
import com.a.eye.skywalking.collector.worker.httpserver.HttpServer;
import com.a.eye.skywalking.collector.worker.storage.EsClient;
import com.a.eye.skywalking.collector.worker.storage.IndexCreator;
import com.a.eye.skywalking.collector.worker.storage.PersistenceTimer;
import org.apache.logging.log4j.LogManager;
import org.apache.logging.log4j.Logger;

/**
 * @author pengys5
 */
public class CollectorBootStartUp {
    private static final Logger logger = LogManager.getFormatterLogger(CollectorBootStartUp.class);

    public static void main(String[] args) throws Exception {
        logger.info("collector system starting....");
        CollectorSystem collectorSystem = new CollectorSystem();
        collectorSystem.boot();
        EsClient.INSTANCE.boot();
        IndexCreator.INSTANCE.create();
        PersistenceTimer.INSTANCE.boot();
        HttpServer.INSTANCE.boot((ClusterWorkerContext)collectorSystem.getClusterContext());
    }
}