add more unit tests for transaction syncer

kubernetes · Feb 4, 2019 · f9208f9 · f9208f9
1 parent fcec109
commit f9208f9
Show file tree

Hide file tree

Showing 2 changed files with 352 additions and 27 deletions.
diff --git a/pkg/neg/syncers/transaction.go b/pkg/neg/syncers/transaction.go
@@ -75,7 +75,7 @@ func NewTransactionSyncer(negSyncerKey NegSyncerKey, networkEndpointGroupName st
 	}
 	// Syncer implements life cycle logic
 	syncer := newSyncer(negSyncerKey, networkEndpointGroupName, serviceLister, recorder, ts)
-	// TransactionSyncer needs syncer interface for internals
+	// transactionSyncer needs syncer interface for internals
 	ts.syncer = syncer
 	ts.retry = NewDelayRetryHandler(func() { syncer.Sync() }, NewExponentialBackendOffHandler(maxRetries, minRetryDelay, maxRetryDelay))
 	return syncer
@@ -287,7 +287,7 @@ func (s *transactionSyncer) commitTransaction(err error, networkEndpointMap map[
 	for encodedEndpoint := range networkEndpointMap {
 		entry, ok := s.transactions.Get(encodedEndpoint)
 		if !ok {
-			glog.Errorf("Endpoint %q was not found in the transaction table.")
+			glog.Errorf("Endpoint %q was not found in the transaction table.", encodedEndpoint)
 			needSync = true
 			continue
 		}