manager/dedup.go
func (d *DedupManager) IsLeader(tmpl *template.Template) bool {
	d.leaderLock.RLock()
	defer d.leaderLock.RUnlock()

	lockCh, ok := d.leader[tmpl]
	if !ok {
		return false
	}
	select {
	case <-lockCh:
		return false
	default:
		return true
	}
}
func (d *DedupManager) IsLeader(tmpl *template.Template) bool {
	d.leaderLock.RLock()
	defer d.leaderLock.RUnlock()

	lockCh, ok := d.leader[tmpl]
	if !ok {
		return false
	}
	select {
	case <-lockCh:
		return false
	default:
		return true
	}
}
func ( d * DedupManager ) IsLeader ( tmpl * template . Template ) bool { d . leaderLock . RLock ( ) defer d . leaderLock . RUnlock ( ) lockCh , ok := d . leader [ tmpl ] if ! ok { return false } select { case <- lockCh : return false default : return true } }
// IsLeader checks if we are currently the leader instance
IsLeader checks if we are currently the leader instance