func (d *DedupManager) Start() error {
	log.Printf("[INFO] (dedup) starting de-duplication manager")

	client := d.clients.Consul()
	go d.createSession(client)

	// Start to watch each template
	for _, t := range d.templates {
		go d.watchTemplate(client, t)
	}
	return nil
}
func (d *DedupManager) Start() error {
	log.Printf("[INFO] (dedup) starting de-duplication manager")

	client := d.clients.Consul()
	go d.createSession(client)

	
	for _, t := range d.templates {
		go d.watchTemplate(client, t)
	}
	return nil
}
func ( d * DedupManager ) Start ( ) error { log . Printf ( " " ) client := d . clients . Consul ( ) go d . createSession ( client ) // Start to watch each template for _ , t := range d . templates { go d . watchTemplate ( client , t ) } return nil }
// Start is used to start the de-duplication manager
Start is used to start the de - duplication manager