Go-style fix

internal/app/app.go

@@ -16,7 +16,7 @@ import (
 	mysql_driver "github.com/go-sql-driver/mysql"
 	"github.com/gofrs/flock"
 
-	"github.com/yandex/mysync/internal/app/external_replication"
+	"github.com/yandex/mysync/internal/app/replication"
 	"github.com/yandex/mysync/internal/config"
 	"github.com/yandex/mysync/internal/dcs"
 	"github.com/yandex/mysync/internal/log"
@@ -38,7 +38,7 @@ type App struct {
 	daemonState         *DaemonState
 	daemonMutex         sync.Mutex
 	replRepairState     map[string]*ReplicationRepairState
-	ExternalReplication external_replication.IExternalReplication
+	ExternalReplication replication.IExternalReplication
 }
 
 // NewApp returns new App. Suddenly.
@@ -59,7 +59,7 @@ func NewApp(configFile, logLevel string, interactive bool) (*App, error) {
 	if logPath != "" {
 		logger.ReOpenOnSignal(syscall.SIGUSR2)
 	}
-	external_replication, err := external_replication.NewExternalReplication(config.IsExternalReplicationSupported, logger)
+	externalReplication, err := replication.NewExternalReplication(config.IsExternalReplicationSupported, logger)
 	if err != nil {
 		return nil, err
 	}
@@ -70,7 +70,7 @@ func NewApp(configFile, logLevel string, interactive bool) (*App, error) {
 		nodeFailedAt:        make(map[string]time.Time),
 		streamFromFailedAt:  make(map[string]time.Time),
 		replRepairState:     make(map[string]*ReplicationRepairState),
-		ExternalReplication: external_replication,
+		ExternalReplication: externalReplication,
 	}
 	return app, nil
 }

internal/app/external_replication/mysql_external_replication.go → internal/app/replication/mysql.go

@@ -1,4 +1,4 @@
-package external_replication
+package replication
 
 import (
 	"database/sql"
@@ -95,7 +95,7 @@ func (er *ExternalReplication) IsSupported(n *mysql.Node) (bool, error) {
 }
 
 func (er *ExternalReplication) Set(n *mysql.Node) error {
-	var replSettings mysql.MySQLReplicationSettings
+	var replSettings mysql.MyReplicationSettings
 	err := n.QueryRow(mysql.QueryGetExternalReplicationSettings, nil, &replSettings)
 	if err != nil {
 		// If no table in scheme then we consider external replication not existing so we do nothing

internal/app/external_replication/external_replication.go → internal/app/replication/replication.go

@@ -1,4 +1,4 @@
-package external_replication
+package replication
 
 import "github.com/yandex/mysync/internal/mysql"
 

internal/mysql/data.go

@@ -40,7 +40,7 @@ type ResetupStatus struct {
 	UpdateTime time.Time
 }
 
-type MySQLReplicationSettings struct {
+type MyReplicationSettings struct {
 	ChannelName    string `db:"ChannelName"`
 	SourceHost     string `db:"SourceHost"`
 	SourceUser     string `db:"SourceUser"`

internal/mysql/node.go

@@ -882,7 +882,7 @@ func (n *Node) GetReplicaStatus() (ReplicaStatus, error) {
 }
 
 func (n *Node) UpdateExternalCAFile() error {
-	var replSettings MySQLReplicationSettings
+	var replSettings MyReplicationSettings
 	err := n.QueryRow(QueryGetExternalReplicationSettings, nil, &replSettings)
 	if err != nil {
 		return nil