manager/dedup.go
func NewDedupManager(config *config.DedupConfig, clients *dep.ClientSet, brain *template.Brain, templates []*template.Template) (*DedupManager, error) {
	d := &DedupManager{
		config:    config,
		clients:   clients,
		brain:     brain,
		templates: templates,
		leader:    make(map[*template.Template]<-chan struct{}),
		lastWrite: make(map[*template.Template]uint64),
		updateCh:  make(chan struct{}, 1),
		stopCh:    make(chan struct{}),
	}
	return d, nil
}
func NewDedupManager(config *config.DedupConfig, clients *dep.ClientSet, brain *template.Brain, templates []*template.Template) (*DedupManager, error) {
	d := &DedupManager{
		config:    config,
		clients:   clients,
		brain:     brain,
		templates: templates,
		leader:    make(map[*template.Template]<-chan struct{}),
		lastWrite: make(map[*template.Template]uint64),
		updateCh:  make(chan struct{}, 1),
		stopCh:    make(chan struct{}),
	}
	return d, nil
}
func NewDedupManager ( config * config . DedupConfig , clients * dep . ClientSet , brain * template . Brain , templates [ ] * template . Template ) ( * DedupManager , error ) { d := & DedupManager { config : config , clients : clients , brain : brain , templates : templates , leader : make ( map [ * template . Template ] <- chan struct { } ) , lastWrite : make ( map [ * template . Template ] uint64 ) , updateCh : make ( chan struct { } , 1 ) , stopCh : make ( chan struct { } ) , } return d , nil }
// NewDedupManager creates a new Dedup manager
NewDedupManager creates a new Dedup manager