diff --git a/agent/ae/ae.go b/agent/ae/ae.go
index 36950df6b..6d6735b41 100644
--- a/agent/ae/ae.go
+++ b/agent/ae/ae.go
@@ -99,7 +99,7 @@ const (
 	retryFailIntv = 15 * time.Second
 )
 
-func NewStateSyner(state State, intv time.Duration, shutdownCh chan struct{}, logger *log.Logger) *StateSyncer {
+func NewStateSyncer(state State, intv time.Duration, shutdownCh chan struct{}, logger *log.Logger) *StateSyncer {
 	s := &StateSyncer{
 		State:             state,
 		Interval:          intv,
diff --git a/agent/ae/ae_test.go b/agent/ae/ae_test.go
index 2b61c9a33..d544c135c 100644
--- a/agent/ae/ae_test.go
+++ b/agent/ae/ae_test.go
@@ -29,7 +29,7 @@ func TestAE_scaleFactor(t *testing.T) {
 
 func TestAE_Pause_nestedPauseResume(t *testing.T) {
 	t.Parallel()
-	l := NewStateSyner(nil, 0, nil, nil)
+	l := NewStateSyncer(nil, 0, nil, nil)
 	if l.Paused() != false {
 		t.Fatal("syncer should be unPaused after init")
 	}
@@ -60,7 +60,7 @@ func TestAE_Pause_nestedPauseResume(t *testing.T) {
 }
 
 func TestAE_Pause_ResumeTriggersSyncChanges(t *testing.T) {
-	l := NewStateSyner(nil, 0, nil, nil)
+	l := NewStateSyncer(nil, 0, nil, nil)
 	l.Pause()
 	l.Resume()
 	select {
@@ -74,7 +74,7 @@ func TestAE_Pause_ResumeTriggersSyncChanges(t *testing.T) {
 }
 
 func TestAE_Pause_ifNotPausedRun(t *testing.T) {
-	l := NewStateSyner(nil, 0, nil, nil)
+	l := NewStateSyncer(nil, 0, nil, nil)
 
 	errCalled := errors.New("f called")
 	f := func() error { return errCalled }
diff --git a/agent/agent.go b/agent/agent.go
index d08307609..f40a02744 100644
--- a/agent/agent.go
+++ b/agent/agent.go
@@ -268,7 +268,7 @@ func (a *Agent) Start() error {
 
 	// create the state synchronization manager which performs
 	// regular and on-demand state synchronizations (anti-entropy).
-	a.sync = ae.NewStateSyner(a.State, c.AEInterval, a.shutdownCh, a.logger)
+	a.sync = ae.NewStateSyncer(a.State, c.AEInterval, a.shutdownCh, a.logger)
 
 	// create the config for the rpc server/client
 	consulCfg, err := a.consulConfig()