package parser // read node recieved on kafka // create a node in the node file // save domains in another file with node ID // parallel routine // look throught domain names and if find some that exists already, create the // edge file const ( NodesFilename = "nodes.json" EdgesFilename = "edges.json" ) func ParseEvent(domains []string) { // saveDomains() // go findDomainEdges() } // Helpers