Unexport TranslateFile.ReplicationRetryInterval

This commit is contained in:
Cody Soyland 2018-07-05 21:55:17 -05:00
parent 7a1d2c6980
commit e4847c498a

View file

@ -73,7 +73,7 @@ type TranslateFile struct {
PrimaryTranslateStore TranslateStore
// Delay after attempting to connect to a primary that the store will retry.
ReplicationRetryInterval time.Duration
replicationRetryInterval time.Duration
}
// NewTranslateFile returns a new instance of TranslateFile.
@ -86,7 +86,7 @@ func NewTranslateFile() *TranslateFile {
mapSize: defaultMapSize,
ReplicationRetryInterval: defaultReplicationRetryInterval,
replicationRetryInterval: defaultReplicationRetryInterval,
}
}
@ -270,7 +270,7 @@ func (s *TranslateFile) monitorReplication() {
select {
case <-s.closing:
return
case <-time.After(s.ReplicationRetryInterval):
case <-time.After(s.replicationRetryInterval):
log.Printf("pilosa: reconnecting to primary replica")
}
}