Update Go framework to v0.7.0

Author: kuujo

Makefile

@@ -12,7 +12,7 @@ endif
 all: build
 
 build: # @HELP build the source code
-build: deps license_check linters
+build: license_check linters
 	GOOS=linux GOARCH=amd64 go build -gcflags=-trimpath=${GOPATH} -asmflags=-trimpath=${GOPATH} -o build/_output/atomix-memory-storage-node ./cmd/atomix-memory-storage-node
 	GOOS=linux GOARCH=amd64 go build -gcflags=-trimpath=${GOPATH} -asmflags=-trimpath=${GOPATH} -o build/_output/atomix-memory-storage-driver ./cmd/atomix-memory-storage-driver
 	GOOS=linux GOARCH=amd64 go build -gcflags=-trimpath=${GOPATH} -asmflags=-trimpath=${GOPATH} -o build/_output/atomix-memory-storage-controller ./cmd/atomix-memory-storage-controller
@@ -23,7 +23,7 @@ deps: # @HELP ensure that the required dependencies are in place
 	bash -c "diff -u <(echo -n) <(git diff go.sum)"
 
 test: # @HELP run the unit tests and source code validation
-test: build
+test: deps build
 	go test github.com/atomix/atomix-memory-storage-controller/...
 
 linters: # @HELP examines Go source code and reports coding problems

cmd/atomix-memory-storage-driver/main.go

@@ -16,6 +16,7 @@ package main
 
 import (
 	"fmt"
+	protocolapi "github.com/atomix/atomix-api/go/atomix/protocol"
 	"github.com/atomix/atomix-go-framework/pkg/atomix/cluster"
 	"github.com/atomix/atomix-go-framework/pkg/atomix/driver"
 	"github.com/atomix/atomix-go-framework/pkg/atomix/driver/env"
@@ -66,10 +67,13 @@ func main() {
 
 	// Create a Raft driver
 	d := driver.NewDriver(
-		provider,
-		driver.WithDriverID("raft"),
-		driver.WithHost(host),
-		driver.WithPort(port))
+		cluster.NewCluster(
+			cluster.NewNetwork(),
+			protocolapi.ProtocolConfig{},
+			cluster.WithMemberID("memory"),
+			cluster.WithHost(host),
+			cluster.WithPort(port)),
+		provider)
 
 	// Start the node
 	if err := d.Start(); err != nil {

cmd/atomix-memory-storage-node/main.go

@@ -44,7 +44,7 @@ func main() {
 	nodeID := os.Args[1]
 	protocolConfig := parseProtocolConfig()
 
-	cluster := cluster.NewCluster(protocolConfig, cluster.WithMemberID(nodeID))
+	cluster := cluster.NewCluster(cluster.NewNetwork(), protocolConfig, cluster.WithMemberID(nodeID))
 
 	// Create an Atomix node
 	node := rsm.NewNode(cluster, local.NewProtocol())

deploy/atomix-memory-storage.yaml

@@ -142,7 +142,7 @@ spec:
     kind: MemoryStore
   drivers:
   - version: v2beta1
-    image: atomix/atomix-memory-storage-driver:v0.6.0
+    image: atomix/atomix-memory-storage-driver:latest
 ---
 apiVersion: v1
 kind: ServiceAccount
@@ -179,6 +179,7 @@ rules:
 - apiGroups:
   - apps
   resources:
+  - deployments
   - statefulsets
   verbs:
   - '*'
@@ -236,7 +237,7 @@ spec:
       serviceAccountName: atomix-memory-storage-controller
       containers:
       - name: controller
-        image: atomix/atomix-memory-storage-controller:v0.6.0
+        image: atomix/atomix-memory-storage-controller:latest
         imagePullPolicy: IfNotPresent
         readinessProbe:
           exec:
@@ -262,4 +263,4 @@ spec:
             fieldRef:
               fieldPath: metadata.namespace
         - name: DEFAULT_NODE_V2BETA1_IMAGE
-          value: atomix/atomix-memory-storage-node:v0.6.0
+          value: atomix/atomix-memory-storage-node:latest