rename package without underscopes

common/persistence/client/factory.go

@@ -32,7 +32,7 @@ import (
 	"github.com/uber/cadence/common/metrics"
 	p "github.com/uber/cadence/common/persistence"
 	"github.com/uber/cadence/common/persistence/elasticsearch"
-	"github.com/uber/cadence/common/persistence/error_injectors"
+	"github.com/uber/cadence/common/persistence/errorinjectors"
 	"github.com/uber/cadence/common/persistence/nosql"
 	pinotVisibility "github.com/uber/cadence/common/persistence/pinot"
 	"github.com/uber/cadence/common/persistence/serialization"
@@ -166,7 +166,7 @@ func (f *factoryImpl) NewTaskManager() (p.TaskManager, error) {
 	}
 	result := p.NewTaskManager(store)
 	if errorRate := f.config.ErrorInjectionRate(); errorRate != 0 {
-		result = error_injectors.NewTaskClient(result, errorRate, f.logger)
+		result = errorinjectors.NewTaskClient(result, errorRate, f.logger)
 	}
 	if ds.ratelimit != nil {
 		result = p.NewTaskPersistenceRateLimitedClient(result, ds.ratelimit, f.logger)
@@ -186,7 +186,7 @@ func (f *factoryImpl) NewShardManager() (p.ShardManager, error) {
 	}
 	result := p.NewShardManager(store)
 	if errorRate := f.config.ErrorInjectionRate(); errorRate != 0 {
-		result = error_injectors.NewShardClient(result, errorRate, f.logger)
+		result = errorinjectors.NewShardClient(result, errorRate, f.logger)
 	}
 	if ds.ratelimit != nil {
 		result = p.NewShardPersistenceRateLimitedClient(result, ds.ratelimit, f.logger)
@@ -206,7 +206,7 @@ func (f *factoryImpl) NewHistoryManager() (p.HistoryManager, error) {
 	}
 	result := p.NewHistoryV2ManagerImpl(store, f.logger, f.config.TransactionSizeLimit)
 	if errorRate := f.config.ErrorInjectionRate(); errorRate != 0 {
-		result = error_injectors.NewHistoryClient(result, errorRate, f.logger)
+		result = errorinjectors.NewHistoryClient(result, errorRate, f.logger)
 	}
 	if ds.ratelimit != nil {
 		result = p.NewHistoryPersistenceRateLimitedClient(result, ds.ratelimit, f.logger)
@@ -228,7 +228,7 @@ func (f *factoryImpl) NewDomainManager() (p.DomainManager, error) {
 	}
 	result := p.NewDomainManagerImpl(store, f.logger)
 	if errorRate := f.config.ErrorInjectionRate(); errorRate != 0 {
-		result = error_injectors.NewDomainClient(result, errorRate, f.logger)
+		result = errorinjectors.NewDomainClient(result, errorRate, f.logger)
 	}
 	if ds.ratelimit != nil {
 		result = p.NewDomainPersistenceRateLimitedClient(result, ds.ratelimit, f.logger)
@@ -248,7 +248,7 @@ func (f *factoryImpl) NewExecutionManager(shardID int) (p.ExecutionManager, erro
 	}
 	result := p.NewExecutionManagerImpl(store, f.logger)
 	if errorRate := f.config.ErrorInjectionRate(); errorRate != 0 {
-		result = error_injectors.NewWorkflowExecutionClient(result, errorRate, f.logger)
+		result = errorinjectors.NewWorkflowExecutionClient(result, errorRate, f.logger)
 	}
 	if ds.ratelimit != nil {
 		result = p.NewWorkflowExecutionPersistenceRateLimitedClient(result, ds.ratelimit, f.logger)
@@ -392,7 +392,7 @@ func (f *factoryImpl) newDBVisibilityManager(
 	}
 	result := p.NewVisibilityManagerImpl(store, f.logger)
 	if errorRate := f.config.ErrorInjectionRate(); errorRate != 0 {
-		result = error_injectors.NewVisibilityClient(result, errorRate, f.logger)
+		result = errorinjectors.NewVisibilityClient(result, errorRate, f.logger)
 	}
 	if ds.ratelimit != nil {
 		result = p.NewVisibilityPersistenceRateLimitedClient(result, ds.ratelimit, f.logger)
@@ -419,7 +419,7 @@ func (f *factoryImpl) NewDomainReplicationQueueManager() (p.QueueManager, error)
 	}
 	result := p.NewQueueManager(store)
 	if errorRate := f.config.ErrorInjectionRate(); errorRate != 0 {
-		result = error_injectors.NewQueueClient(result, errorRate, f.logger)
+		result = errorinjectors.NewQueueClient(result, errorRate, f.logger)
 	}
 	if ds.ratelimit != nil {
 		result = p.NewQueuePersistenceRateLimitedClient(result, ds.ratelimit, f.logger)
@@ -439,7 +439,7 @@ func (f *factoryImpl) NewConfigStoreManager() (p.ConfigStoreManager, error) {
 	}
 	result := p.NewConfigStoreManagerImpl(store, f.logger)
 	if errorRate := f.config.ErrorInjectionRate(); errorRate != 0 {
-		result = error_injectors.NewConfigStoreClient(result, errorRate, f.logger)
+		result = errorinjectors.NewConfigStoreClient(result, errorRate, f.logger)
 	}
 	if ds.ratelimit != nil {
 		result = p.NewConfigStorePersistenceRateLimitedClient(result, ds.ratelimit, f.logger)

common/persistence/error_injectors/config_store.go → common/persistence/errorinjectors/config_store.go

@@ -20,7 +20,7 @@
 // OUT OF OR IN CONNECTION WITH THE SOFTWARE OR THE USE OR OTHER DEALINGS IN THE
 // SOFTWARE.
 
-package error_injectors
+package errorinjectors
 
 import (
 	"context"

common/persistence/error_injectors/domain.go → common/persistence/errorinjectors/domain.go

@@ -20,7 +20,7 @@
 // OUT OF OR IN CONNECTION WITH THE SOFTWARE OR THE USE OR OTHER DEALINGS IN THE
 // SOFTWARE.
 
-package error_injectors
+package errorinjectors
 
 import (
 	"context"

common/persistence/error_injectors/history.go → common/persistence/errorinjectors/history.go

@@ -20,7 +20,7 @@
 // OUT OF OR IN CONNECTION WITH THE SOFTWARE OR THE USE OR OTHER DEALINGS IN THE
 // SOFTWARE.
 
-package error_injectors
+package errorinjectors
 
 import (
 	"context"

common/persistence/error_injectors/injectors_test.go → common/persistence/errorinjectors/injectors_test.go

@@ -20,7 +20,7 @@
 // OUT OF OR IN CONNECTION WITH THE SOFTWARE OR THE USE OR OTHER DEALINGS IN THE
 // SOFTWARE.
 
-package error_injectors
+package errorinjectors
 
 import (
 	"context"

common/persistence/error_injectors/queue.go → common/persistence/errorinjectors/queue.go

@@ -20,7 +20,7 @@
 // OUT OF OR IN CONNECTION WITH THE SOFTWARE OR THE USE OR OTHER DEALINGS IN THE
 // SOFTWARE.
 
-package error_injectors
+package errorinjectors
 
 import (
 	"context"

common/persistence/error_injectors/shard.go → common/persistence/errorinjectors/shard.go

@@ -20,7 +20,7 @@
 // OUT OF OR IN CONNECTION WITH THE SOFTWARE OR THE USE OR OTHER DEALINGS IN THE
 // SOFTWARE.
 
-package error_injectors
+package errorinjectors
 
 import (
 	"context"

common/persistence/error_injectors/task.go → common/persistence/errorinjectors/task.go

@@ -20,7 +20,7 @@
 // OUT OF OR IN CONNECTION WITH THE SOFTWARE OR THE USE OR OTHER DEALINGS IN THE
 // SOFTWARE.
 
-package error_injectors
+package errorinjectors
 
 import (
 	"context"

common/persistence/error_injectors/utils.go → common/persistence/errorinjectors/utils.go

@@ -20,7 +20,7 @@
 // OUT OF OR IN CONNECTION WITH THE SOFTWARE OR THE USE OR OTHER DEALINGS IN THE
 // SOFTWARE.
 
-package error_injectors
+package errorinjectors
 
 import (
 	"math/rand"

common/persistence/error_injectors/visibility.go → common/persistence/errorinjectors/visibility.go

@@ -20,7 +20,7 @@
 // OUT OF OR IN CONNECTION WITH THE SOFTWARE OR THE USE OR OTHER DEALINGS IN THE
 // SOFTWARE.
 
-package error_injectors
+package errorinjectors
 
 import (
 	"context"

common/persistence/error_injectors/workflow_execution.go → common/persistence/errorinjectors/workflow_execution.go

@@ -20,7 +20,7 @@
 // OUT OF OR IN CONNECTION WITH THE SOFTWARE OR THE USE OR OTHER DEALINGS IN THE
 // SOFTWARE.
 
-package error_injectors
+package errorinjectors
 
 import (
 	"context"