Go fmt

jdextraze · Nov 5, 2017 · ef50b3b · ef50b3b
1 parent ffab78e
commit ef50b3b
Show file tree

Hide file tree

Showing 5 changed files with 25 additions and 24 deletions.
diff --git a/client/errors.go b/client/errors.go
@@ -5,6 +5,7 @@ import (
 	"fmt"
 )
 
+// TODO review those
 var (
 	WrongExpectedVersion = errors.New("Wrong expected version")
 	StreamDeleted        = errors.New("Stream deleted")

diff --git a/client/transaction.go b/client/transaction.go
@@ -1,16 +1,16 @@
 package client
 
 import (
-	"github.com/jdextraze/go-gesclient/tasks"
 	"errors"
+	"github.com/jdextraze/go-gesclient/tasks"
 )
 
 type Transaction struct {
-	transactionId int64
+	transactionId   int64
 	userCredentials *UserCredentials
-	connection TransactionConnection
-	isRolledBack bool
-	isCommitted bool
+	connection      TransactionConnection
+	isRolledBack    bool
+	isCommitted     bool
 }
 
 type TransactionConnection interface {
@@ -20,7 +20,7 @@ type TransactionConnection interface {
 
 var (
 	CannotCommitRolledBackTransaction = errors.New("cannot commit a rolled back transaction")
-	TransactionIsAlreadyCommitted = errors.New("transaction is already committed")
+	TransactionIsAlreadyCommitted     = errors.New("transaction is already committed")
 )
 
 func NewTransaction(
@@ -33,9 +33,9 @@ func NewTransaction(
 	}
 
 	return &Transaction{
-		transactionId: transactionId,
+		transactionId:   transactionId,
 		userCredentials: userCredentials,
-		connection: connection,
+		connection:      connection,
 	}
 }
 

diff --git a/operations/commit_transaction.go b/operations/commit_transaction.go
@@ -1,11 +1,11 @@
 package operations
 
 import (
-	"github.com/jdextraze/go-gesclient/tasks"
-	"github.com/jdextraze/go-gesclient/client"
+	"fmt"
 	"github.com/golang/protobuf/proto"
+	"github.com/jdextraze/go-gesclient/client"
 	"github.com/jdextraze/go-gesclient/messages"
-	"fmt"
+	"github.com/jdextraze/go-gesclient/tasks"
 )
 
 type CommitTransaction struct {

diff --git a/operations/start_transaction.go b/operations/start_transaction.go
@@ -1,11 +1,11 @@
 package operations
 
 import (
-	"github.com/jdextraze/go-gesclient/client"
-	"github.com/jdextraze/go-gesclient/tasks"
+	"fmt"
 	"github.com/golang/protobuf/proto"
+	"github.com/jdextraze/go-gesclient/client"
 	"github.com/jdextraze/go-gesclient/messages"
-	"fmt"
+	"github.com/jdextraze/go-gesclient/tasks"
 )
 
 type StartTransaction struct {

diff --git a/operations/transactional_write.go b/operations/transactional_write.go
@@ -1,11 +1,11 @@
 package operations
 
 import (
-	"github.com/jdextraze/go-gesclient/tasks"
-	"github.com/jdextraze/go-gesclient/client"
+	"fmt"
 	"github.com/golang/protobuf/proto"
+	"github.com/jdextraze/go-gesclient/client"
 	"github.com/jdextraze/go-gesclient/messages"
-	"fmt"
+	"github.com/jdextraze/go-gesclient/tasks"
 )
 
 type TransactionalWrite struct {
@@ -36,26 +36,26 @@ func (o *TransactionalWrite) createRequestDto() proto.Message {
 	events := make([]*messages.NewEvent, len(o.events))
 	for i, e := range o.events {
 		var (
-			dataContentType int32
+			dataContentType     int32
 			metadataContentType int32
 		)
 		eventType := e.Type()
 		if e.IsJson() {
 			dataContentType = 1
 		}
 		events[i] = &messages.NewEvent{
-			EventId: e.EventId().Bytes(),
-			EventType: &eventType,
-			DataContentType: &dataContentType,
+			EventId:             e.EventId().Bytes(),
+			EventType:           &eventType,
+			DataContentType:     &dataContentType,
 			MetadataContentType: &metadataContentType,
-			Data: e.Data(),
-			Metadata: e.Metadata(),
+			Data:                e.Data(),
+			Metadata:            e.Metadata(),
 		}
 	}
 	return &messages.TransactionWrite{
 		TransactionId: &o.transactionId,
 		RequireMaster: &o.requireMaster,
-		Events: events,
+		Events:        events,
 	}
 }
-Original file line number
+Diff line change
@@ Expand Up / @@ -5,6 +5,7 @@ import ( @@
     	"fmt"
     )
+    // TODO review those
     var (
     	WrongExpectedVersion = errors.New("Wrong expected version")
     	StreamDeleted        = errors.New("Stream deleted")
@@ Expand Down @@