Reduce unnecessary ETCD Put operations (#472)

auth/auth.go

@@ -5,6 +5,7 @@ import (
 
 	"github.com/projecteru2/core/auth/simple"
 	"github.com/projecteru2/core/types"
+
 	"google.golang.org/grpc"
 )
 

auth/simple/simple.go

@@ -4,6 +4,7 @@ import (
 	"context"
 
 	"github.com/projecteru2/core/types"
+
 	"google.golang.org/grpc"
 	"google.golang.org/grpc/metadata"
 )

auth/simple/simple_test.go

@@ -5,9 +5,9 @@ import (
 	"errors"
 	"testing"
 
-	"github.com/stretchr/testify/assert"
-
 	grpcmocks "github.com/projecteru2/core/3rdmocks"
+
+	"github.com/stretchr/testify/assert"
 	"google.golang.org/grpc"
 	"google.golang.org/grpc/metadata"
 )

client/client.go

@@ -11,6 +11,7 @@ import (
 	pb "github.com/projecteru2/core/rpc/gen"
 	"github.com/projecteru2/core/types"
 	"github.com/projecteru2/core/utils"
+
 	"google.golang.org/grpc"
 	"google.golang.org/grpc/keepalive"
 )

client/interceptor/retry.go

@@ -4,9 +4,9 @@ import (
 	"context"
 	"strings"
 
-	"github.com/cenkalti/backoff/v4"
 	"github.com/projecteru2/core/log"
 
+	"github.com/cenkalti/backoff/v4"
 	"google.golang.org/grpc"
 )
 

client/resolver/eru/resolver.go

@@ -6,8 +6,8 @@ import (
 
 	"github.com/projecteru2/core/client/servicediscovery"
 	"github.com/projecteru2/core/log"
-
 	"github.com/projecteru2/core/types"
+
 	"google.golang.org/grpc/resolver"
 )
 

client/servicediscovery/eru_service_discovery.go

@@ -10,9 +10,9 @@ import (
 	"github.com/projecteru2/core/client/interceptor"
 	"github.com/projecteru2/core/client/utils"
 	"github.com/projecteru2/core/log"
-
 	pb "github.com/projecteru2/core/rpc/gen"
 	"github.com/projecteru2/core/types"
+
 	"google.golang.org/grpc"
 )
 

client/utils/servicepusher.go

@@ -7,8 +7,9 @@ import (
 	"sync"
 	"time"
 
-	"github.com/go-ping/ping"
 	"github.com/projecteru2/core/log"
+
+	"github.com/go-ping/ping"
 )
 
 // EndpointPusher pushes endpoints to registered channels if the ep is L3 reachable

cluster/calcium/build.go

@@ -9,11 +9,12 @@ import (
 	"os"
 	"time"
 
-	"github.com/pkg/errors"
 	enginetypes "github.com/projecteru2/core/engine/types"
 	"github.com/projecteru2/core/log"
 	"github.com/projecteru2/core/types"
 	"github.com/projecteru2/core/utils"
+
+	"github.com/pkg/errors"
 )
 
 // BuildImage will build image

cluster/calcium/build_test.go

@@ -7,13 +7,13 @@ import (
 	"io/ioutil"
 	"testing"
 
-	"github.com/stretchr/testify/assert"
-	"github.com/stretchr/testify/mock"
-
 	enginemocks "github.com/projecteru2/core/engine/mocks"
 	schedulermocks "github.com/projecteru2/core/scheduler/mocks"
 	storemocks "github.com/projecteru2/core/store/mocks"
 	"github.com/projecteru2/core/types"
+
+	"github.com/stretchr/testify/assert"
+	"github.com/stretchr/testify/mock"
 )
 
 const (

cluster/calcium/calcium.go

@@ -5,7 +5,6 @@ import (
 	"strings"
 	"testing"
 
-	"github.com/pkg/errors"
 	"github.com/projecteru2/core/cluster"
 	"github.com/projecteru2/core/discovery"
 	"github.com/projecteru2/core/discovery/helium"
@@ -19,6 +18,8 @@ import (
 	"github.com/projecteru2/core/store/etcdv3"
 	"github.com/projecteru2/core/store/redis"
 	"github.com/projecteru2/core/types"
+
+	"github.com/pkg/errors"
 )
 
 // Calcium implement the cluster

cluster/calcium/calcium_test.go

@@ -9,15 +9,15 @@ import (
 	"testing"
 	"time"
 
-	"github.com/stretchr/testify/assert"
-	"github.com/stretchr/testify/mock"
-
 	schedulermocks "github.com/projecteru2/core/scheduler/mocks"
 	sourcemocks "github.com/projecteru2/core/source/mocks"
 	storemocks "github.com/projecteru2/core/store/mocks"
 	"github.com/projecteru2/core/types"
 	"github.com/projecteru2/core/wal"
 	walmocks "github.com/projecteru2/core/wal/mocks"
+
+	"github.com/stretchr/testify/assert"
+	"github.com/stretchr/testify/mock"
 )
 
 // DummyLock replace lock for testing

cluster/calcium/capacity.go

@@ -3,12 +3,13 @@ package calcium
 import (
 	"context"
 
-	"github.com/pkg/errors"
 	"github.com/projecteru2/core/log"
 	"github.com/projecteru2/core/resources"
 	resourcetypes "github.com/projecteru2/core/resources/types"
 	"github.com/projecteru2/core/strategy"
 	"github.com/projecteru2/core/types"
+
+	"github.com/pkg/errors"
 )
 
 // CalculateCapacity calculates capacity

cluster/calcium/capacity_test.go

@@ -12,6 +12,7 @@ import (
 	storemocks "github.com/projecteru2/core/store/mocks"
 	"github.com/projecteru2/core/strategy"
 	"github.com/projecteru2/core/types"
+
 	"github.com/stretchr/testify/assert"
 	"github.com/stretchr/testify/mock"
 )

cluster/calcium/control.go

@@ -5,11 +5,12 @@ import (
 	"context"
 	"sync"
 
-	"github.com/pkg/errors"
 	"github.com/projecteru2/core/cluster"
 	"github.com/projecteru2/core/log"
 	"github.com/projecteru2/core/types"
 	"github.com/projecteru2/core/utils"
+
+	"github.com/pkg/errors"
 )
 
 // ControlWorkload control workloads status

cluster/calcium/control_test.go

@@ -11,6 +11,7 @@ import (
 	lockmocks "github.com/projecteru2/core/lock/mocks"
 	storemocks "github.com/projecteru2/core/store/mocks"
 	"github.com/projecteru2/core/types"
+
 	"github.com/stretchr/testify/assert"
 	"github.com/stretchr/testify/mock"
 )

cluster/calcium/copy_test.go

@@ -4,12 +4,12 @@ import (
 	"context"
 	"testing"
 
-	"github.com/stretchr/testify/assert"
-
 	enginemocks "github.com/projecteru2/core/engine/mocks"
 	lockmocks "github.com/projecteru2/core/lock/mocks"
 	storemocks "github.com/projecteru2/core/store/mocks"
 	"github.com/projecteru2/core/types"
+
+	"github.com/stretchr/testify/assert"
 	"github.com/stretchr/testify/mock"
 )
 

cluster/calcium/create.go

@@ -7,9 +7,6 @@ import (
 	"sync"
 	"time"
 
-	"github.com/pkg/errors"
-	"github.com/sanity-io/litter"
-
 	"github.com/projecteru2/core/cluster"
 	enginetypes "github.com/projecteru2/core/engine/types"
 	"github.com/projecteru2/core/log"
@@ -18,6 +15,9 @@ import (
 	"github.com/projecteru2/core/types"
 	"github.com/projecteru2/core/utils"
 	"github.com/projecteru2/core/wal"
+
+	"github.com/pkg/errors"
+	"github.com/sanity-io/litter"
 )
 
 // CreateWorkload use options to create workloads

cluster/calcium/create_test.go

@@ -4,7 +4,6 @@ import (
 	"context"
 	"testing"
 
-	"github.com/pkg/errors"
 	enginemocks "github.com/projecteru2/core/engine/mocks"
 	enginetypes "github.com/projecteru2/core/engine/types"
 	lockmocks "github.com/projecteru2/core/lock/mocks"
@@ -16,6 +15,8 @@ import (
 	"github.com/projecteru2/core/types"
 	"github.com/projecteru2/core/wal"
 	walmocks "github.com/projecteru2/core/wal/mocks"
+
+	"github.com/pkg/errors"
 	"github.com/stretchr/testify/assert"
 	"github.com/stretchr/testify/mock"
 )

cluster/calcium/dissociate.go

@@ -3,11 +3,12 @@ package calcium
 import (
 	"context"
 
-	"github.com/pkg/errors"
 	"github.com/projecteru2/core/log"
 	"github.com/projecteru2/core/store"
 	"github.com/projecteru2/core/types"
 	"github.com/projecteru2/core/utils"
+
+	"github.com/pkg/errors"
 )
 
 // DissociateWorkload dissociate workload from eru, return it resource but not modity it

cluster/calcium/dissociate_test.go

@@ -4,10 +4,11 @@ import (
 	"context"
 	"testing"
 
-	"github.com/docker/go-units"
 	lockmocks "github.com/projecteru2/core/lock/mocks"
 	storemocks "github.com/projecteru2/core/store/mocks"
 	"github.com/projecteru2/core/types"
+
+	"github.com/docker/go-units"
 	"github.com/stretchr/testify/assert"
 	"github.com/stretchr/testify/mock"
 )

cluster/calcium/execute_test.go

@@ -10,6 +10,7 @@ import (
 	enginemocks "github.com/projecteru2/core/engine/mocks"
 	storemocks "github.com/projecteru2/core/store/mocks"
 	"github.com/projecteru2/core/types"
+
 	"github.com/stretchr/testify/assert"
 	"github.com/stretchr/testify/mock"
 )

cluster/calcium/helper.go

@@ -8,12 +8,13 @@ import (
 	"io/ioutil"
 	"sync"
 
-	"github.com/pkg/errors"
 	"github.com/projecteru2/core/engine"
 	enginetypes "github.com/projecteru2/core/engine/types"
 	"github.com/projecteru2/core/log"
 	"github.com/projecteru2/core/types"
 	"github.com/projecteru2/core/utils"
+
+	"github.com/pkg/errors"
 	"golang.org/x/net/context"
 )
 

cluster/calcium/hook.go

@@ -4,8 +4,9 @@ import (
 	"bytes"
 	"context"
 
-	"github.com/pkg/errors"
 	"github.com/projecteru2/core/engine"
+
+	"github.com/pkg/errors"
 )
 
 func (c *Calcium) doHook(

cluster/calcium/image.go

@@ -5,10 +5,11 @@ import (
 	"fmt"
 	"sync"
 
-	"github.com/pkg/errors"
 	"github.com/projecteru2/core/log"
 	"github.com/projecteru2/core/types"
 	"github.com/projecteru2/core/utils"
+
+	"github.com/pkg/errors"
 )
 
 // RemoveImage remove images

cluster/calcium/image_test.go

@@ -9,6 +9,7 @@ import (
 	enginemocks "github.com/projecteru2/core/engine/mocks"
 	storemocks "github.com/projecteru2/core/store/mocks"
 	"github.com/projecteru2/core/types"
+
 	"github.com/stretchr/testify/assert"
 	"github.com/stretchr/testify/mock"
 )

cluster/calcium/lambda.go

@@ -8,15 +8,15 @@ import (
 	"strconv"
 	"sync"
 
-	"github.com/google/uuid"
-	"github.com/pkg/errors"
-
 	enginetypes "github.com/projecteru2/core/engine/types"
 	"github.com/projecteru2/core/log"
 	"github.com/projecteru2/core/strategy"
 	"github.com/projecteru2/core/types"
 	"github.com/projecteru2/core/utils"
 	"github.com/projecteru2/core/wal"
+
+	"github.com/google/uuid"
+	"github.com/pkg/errors"
 )
 
 const (

cluster/calcium/lambda_test.go

@@ -8,9 +8,6 @@ import (
 	"strings"
 	"testing"
 
-	"github.com/stretchr/testify/assert"
-	"github.com/stretchr/testify/mock"
-
 	enginemocks "github.com/projecteru2/core/engine/mocks"
 	enginetypes "github.com/projecteru2/core/engine/types"
 	lockmocks "github.com/projecteru2/core/lock/mocks"
@@ -22,6 +19,9 @@ import (
 	"github.com/projecteru2/core/types"
 	"github.com/projecteru2/core/wal"
 	walmocks "github.com/projecteru2/core/wal/mocks"
+
+	"github.com/stretchr/testify/assert"
+	"github.com/stretchr/testify/mock"
 )
 
 func TestRunAndWaitFailedThenWALCommitted(t *testing.T) {

cluster/calcium/lock.go

@@ -6,12 +6,13 @@ import (
 	"sort"
 	"time"
 
-	"github.com/pkg/errors"
 	"github.com/projecteru2/core/cluster"
 	"github.com/projecteru2/core/lock"
 	"github.com/projecteru2/core/log"
 	"github.com/projecteru2/core/types"
 	"github.com/projecteru2/core/utils"
+
+	"github.com/pkg/errors"
 )
 
 func (c *Calcium) doLock(ctx context.Context, name string, timeout time.Duration) (lock lock.DistributedLock, rCtx context.Context, err error) {

cluster/calcium/lock_test.go

@@ -4,13 +4,13 @@ import (
 	"context"
 	"testing"
 
-	"github.com/stretchr/testify/assert"
-
 	enginemocks "github.com/projecteru2/core/engine/mocks"
 	"github.com/projecteru2/core/lock"
 	lockmocks "github.com/projecteru2/core/lock/mocks"
 	storemocks "github.com/projecteru2/core/store/mocks"
 	"github.com/projecteru2/core/types"
+
+	"github.com/stretchr/testify/assert"
 	"github.com/stretchr/testify/mock"
 )