Apply gofmt for example codes

Author: mingrammer

resources/201901/modularization-and-actor/actor/actor.go

@@ -1,9 +1,9 @@
 package actor
 
 import (
+	"container/list"
 	"fmt"
 	"reflect"
-	"container/list"
 )
 
 type AID struct {
@@ -15,9 +15,7 @@ func (a *AID) String() string {
 	return fmt.Sprintf("<%d, %s>", a.ActorID, a.NodeName)
 }
 
-
 type IActorReceiver interface {
-
 	GetNodeName() string
 }
 
@@ -34,10 +32,10 @@ var _ IActorReceiver = &Actor{}
 var _ iActor = &Actor{}
 
 type Actor struct {
-	aid       		*AID
-	receiver 	    reflect.Value
-	queue		    *list.List
-	inChan    		chan *ActorCall
+	aid      *AID
+	receiver reflect.Value
+	queue    *list.List
+	inChan   chan *ActorCall
 }
 
 func (a *Actor) start(receiver IActorReceiver, aid *AID) bool {
@@ -70,7 +68,6 @@ func (a *Actor) loop() {
 	}
 }
 
-
 func (a *Actor) GetNodeName() string {
 	return a.aid.NodeName
 }
@@ -94,8 +91,7 @@ func (a *Actor) process(actorCall *ActorCall) {
 	}
 }
 
-
-func (a *Actor) makeActorCall(done chan *ActorCall , function interface{}, args ...interface{}) *ActorCall {
+func (a *Actor) makeActorCall(done chan *ActorCall, function interface{}, args ...interface{}) *ActorCall {
 
 	v := reflect.ValueOf(function)
 	if v.Kind() != reflect.Func {
@@ -110,7 +106,7 @@ func (a *Actor) makeActorCall(done chan *ActorCall , function interface{}, args
 		valuedArgs[i+1] = reflect.ValueOf(x)
 	}
 
-	return &ActorCall{Function:v, Args:valuedArgs, Done:done}
+	return &ActorCall{Function: v, Args: valuedArgs, Done: done}
 
 }
 
@@ -119,4 +115,4 @@ func (a *Actor) call(function interface{}, args ...interface{}) ([]interface{},
 	a.inChan <- a.makeActorCall(done, function, args...)
 	actorCall, _ := <-done
 	return actorCall.GetResults()
-}
+}

resources/201901/modularization-and-actor/actor/actor_system.go

@@ -2,13 +2,13 @@ package actor
 
 import (
 	"context"
-	"sync"
-	"sync/atomic"
 	"fmt"
-	"runtime"
+	"net/http"
 	"reflect"
+	"runtime"
 	"strings"
-	"net/http"
+	"sync"
+	"sync/atomic"
 )
 
 type ActorProtocolType uint16
@@ -26,8 +26,8 @@ type Request struct {
 }
 
 type Response struct {
-	Err    			error
-	Results 		[]interface{}
+	Err     error
+	Results []interface{}
 }
 
 var defaultActorSystem *ActorSystem
@@ -37,20 +37,20 @@ func init() {
 }
 
 type ActorSystem struct {
-	mutex              	sync.RWMutex
-	nowActorID         	uint64
-	actorMapByAID       map[*AID]iActor
-	actorMapByNodeName 	map[string]iActor
+	mutex              sync.RWMutex
+	nowActorID         uint64
+	actorMapByAID      map[*AID]iActor
+	actorMapByNodeName map[string]iActor
 
-	server              *http.Server
-	serverCloseFunc     context.CancelFunc
+	server          *http.Server
+	serverCloseFunc context.CancelFunc
 }
 
 func newActorSystem() *ActorSystem {
 	d := &ActorSystem{
-		actorMapByAID:        make(map[*AID]iActor),
-		actorMapByNodeName:   make(map[string]iActor),
-		nowActorID:        	  0,
+		actorMapByAID:      make(map[*AID]iActor),
+		actorMapByNodeName: make(map[string]iActor),
+		nowActorID:         0,
 	}
 	return d
 }
@@ -87,7 +87,7 @@ func (as *ActorSystem) startWebActor(receiver IActorReceiver, nodeName string, a
 
 func (as *ActorSystem) createAID(nodeName string) *AID {
 	id := atomic.AddUint64(&as.nowActorID, 1)
-	return &AID{NodeName:nodeName, ActorID:id}
+	return &AID{NodeName: nodeName, ActorID: id}
 }
 
 func (as *ActorSystem) getActorByAIDWithLock(aid *AID) (iActor, error) {
@@ -114,8 +114,7 @@ func (d *ActorSystem) getActorByNodeNameWithLock(nodeName string) (iActor, error
 
 func (as *ActorSystem) createRequest(ac iActor, function interface{}, args ...interface{}) *Request {
 
-
-	req := &Request{NodeName:ac.GetNodeName()}
+	req := &Request{NodeName: ac.GetNodeName()}
 
 	v := reflect.ValueOf(function)
 	if v.Kind() == reflect.Func {
@@ -156,4 +155,4 @@ func (as *ActorSystem) findFunc(ac iActor, funcName string) (interface{}, error)
 	}
 	fn := method.Func.Interface()
 	return fn, nil
-}
+}

resources/201901/modularization-and-actor/actor/actorcall.go

@@ -3,11 +3,11 @@ package actor
 import "reflect"
 
 type ActorCall struct {
-	Function   reflect.Value
-	Args       []reflect.Value
-	Results    []reflect.Value
-	Done       chan *ActorCall
-	Error      error
+	Function reflect.Value
+	Args     []reflect.Value
+	Results  []reflect.Value
+	Done     chan *ActorCall
+	Error    error
 }
 
 func (c ActorCall) GetResults() ([]interface{}, error) {
@@ -20,11 +20,11 @@ func (c ActorCall) GetResults() ([]interface{}, error) {
 	var err error
 	for _, x := range values {
 		itf := x.Interface()
-		errorType  := reflect.TypeOf((*error)(nil)).Elem()
+		errorType := reflect.TypeOf((*error)(nil)).Elem()
 
 		switch x.Type() {
 		case errorType:
-			if castingErr, ok := itf.(error); ok  && castingErr != nil {
+			if castingErr, ok := itf.(error); ok && castingErr != nil {
 				err = x.Interface().(error)
 			}
 		default:

resources/201901/modularization-and-actor/actor/golobal.go

@@ -1,11 +1,11 @@
 package actor
 
 import (
-	"fmt"
-	"net/http"
+	"bytes"
 	"context"
 	"encoding/gob"
-	"bytes"
+	"fmt"
+	"net/http"
 )
 
 func StartActor(receiver IActorReceiver) *AID {
@@ -70,4 +70,4 @@ func httpCall(w http.ResponseWriter, req *http.Request) {
 	enc := gob.NewEncoder(&buffer)
 	enc.Encode(response)
 	w.Write(buffer.Bytes())
-}
+}

resources/201901/modularization-and-actor/actor/web_actor.go

@@ -3,31 +3,29 @@ package actor
 import (
 	"bytes"
 	"encoding/gob"
-	"net/http"
 	"fmt"
+	"net/http"
 	"reflect"
 )
 
 var _ IActorReceiver = &Actor{}
 var _ iActor = &Actor{}
 
 type WebActor struct {
-	aid       		*AID
-	receiver 	    reflect.Value
-	shutdownCh 		chan bool
+	aid        *AID
+	receiver   reflect.Value
+	shutdownCh chan bool
 
-	address		string
-	client 		*http.Client
+	address string
+	client  *http.Client
 }
 
-
 func (a *WebActor) start(receiver IActorReceiver, aid *AID) bool {
 	a.aid = aid
 	a.receiver = reflect.ValueOf(receiver)
 	return true
 }
 
-
 func (a *WebActor) GetNodeName() string {
 	return a.aid.NodeName
 }

resources/201901/modularization-and-actor/main_sample.go

@@ -1,7 +1,7 @@
 package main
 
 import (
-"sampleactor/samplestruct"
+	"sampleactor/samplestruct"
 )
 
 func main() {

resources/201901/modularization-and-actor/main_sample_local_actor.go

@@ -22,4 +22,4 @@ func main() {
 
 	//SetLevel(level int)
 	_, _ = actor.Call(heroAID, (*samplestruct.Hero).SetLevel, results[0])
-}
+}

resources/201901/modularization-and-actor/main_sample_remote_actor.go

@@ -1,16 +1,16 @@
 package main
 
 import (
-	"sampleactor/actor"
 	"context"
+	"sampleactor/actor"
 	"sampleactor/samplestruct"
 )
 
 func main() {
 
 	ctxMain, _ := context.WithCancel(context.Background())
 
-	actor.StartWebServer(ctxMain,"9999")
+	actor.StartWebServer(ctxMain, "9999")
 
 	training := samplestruct.NewTraining("Training")
 
@@ -21,4 +21,4 @@ func main() {
 		case <-ctxMain.Done():
 		}
 	}
-}
+}

resources/201901/modularization-and-actor/samplestruct/hero.go

@@ -3,15 +3,15 @@ package samplestruct
 import "fmt"
 
 type Hero struct {
-	id    int
-	level int
+	id       int
+	level    int
 	nodeName string
 }
 
 func NewHero(id int, level int, nodeName string) *Hero {
 	return &Hero{
-		id: id,
-		level: level,
+		id:       id,
+		level:    level,
 		nodeName: nodeName,
 	}
 }
@@ -27,4 +27,4 @@ func (h *Hero) SetLevel(level int) {
 
 func (h *Hero) GetNodeName() string {
 	return h.nodeName
-}
+}

resources/201901/modularization-and-actor/samplestruct/training.go

@@ -19,7 +19,7 @@ func (t *Training) TrainingHero(hero *Hero) {
 }
 
 func (t *Training) Do(level int) int {
-	newLevel := level+1
+	newLevel := level + 1
 	fmt.Printf("Training.Do: oldLevel %d, nowLevel %d \n", level, newLevel)
 	return newLevel
 }

resources/201903/codelab/2_1_cross_compile.go

@@ -7,4 +7,4 @@ func main() {
 }
 
 // GOOS=linux   GOARCH=amd64 go build 4_1_cross_compile.go
-// GOOS=windows GOARCH=amd64 go build 4_1_cross_compile.go
+// GOOS=windows GOARCH=amd64 go build 4_1_cross_compile.go

resources/201903/codelab/3_1_helloworld.go

@@ -2,8 +2,6 @@ package main
 
 import "fmt"
 
-func main(){
+func main() {
 	fmt.Println("Hello world.")
 }
-
-

resources/201903/codelab/3_2_export.go

@@ -2,8 +2,6 @@ package main
 
 import "fmt"
 
-func main(){
+func main() {
 	fmt.println("Hello world.")
 }
-
-

resources/201903/codelab/3_3_identifier.go

@@ -1,11 +1,11 @@
 package main
 
 import (
-	t "text/template"
 	h "html/template"
+	t "text/template"
 )
 
 func main() {
 	t.New("foo").Parse(`{{define "T"}}Hello, {{.}}!{{end}}`)
 	h.New("foo").Parse(`{{define "T"}}Hello, {{.}}!{{end}}`)
-}
+}

resources/201903/codelab/3_4_blank.go

@@ -10,9 +10,9 @@ import (
 func main() {
 	db, err := sql.Open("mysql", "user:password@/database")
 	if err != nil {
-		panic(err.Error())  // Just for example purpose. You should use proper error handling instead of panic
+		panic(err.Error()) // Just for example purpose. You should use proper error handling instead of panic
 	}
 	defer db.Close()
 
 	fmt.Println(db.Ping())
-}
+}

resources/201903/codelab/4_11_array.go

@@ -2,10 +2,10 @@ package main
 
 import "fmt"
 
-func main(){
-	 var a [4]int
-	 b := [2]string{"Penn", "Teller"}
-	 c := [...]bool{true, false, false}
+func main() {
+	var a [4]int
+	b := [2]string{"Penn", "Teller"}
+	c := [...]bool{true, false, false}
 
-	 fmt.Println(a,b,c)
+	fmt.Println(a, b, c)
 }