fix: example refactored

Author: Matrix86

examples/s3.go

@@ -14,13 +14,13 @@ func main() {
 	}
 
 	config := map[string]string{
-		"bucketname":      "test.storage",
-		"Endpoint":        "127.0.0.1:9000",
-		"AccessKey":       "minio",
-		"SecretAccessKey": "minio123",
-		"SessionToken":    "",
-		"Region":          "",
-		"SSLEnabled":      "false",
+		"bucketname": "test.storage",
+		"endpoint":   "127.0.0.1:9000",
+		"accessKey":  "minio",
+		"secretkey":  "minio123",
+		"token":      "",
+		"region":     "",
+		"sslenabled": "false",
 	}
 	err = s.SetConfig(config)
 	if err != nil {
@@ -36,22 +36,13 @@ func main() {
 
 	err = s.Start()
 	defer s.Close()
-
-	go func() {
-		for v := range s.GetEvents() {
+	for {
+		select {
+		case v := <-s.GetEvents():
 			fmt.Printf("EVENT: %s %s\n", v.Key, v.TypeString())
-		}
-		fmt.Println("exiting events")
-	}()
 
-	go func() {
-		for e := range s.GetErrors() {
+		case e := <-s.GetErrors():
 			fmt.Printf("ERROR: %#v\n", e)
 		}
-		fmt.Println("exiting errors")
-	}()
-
-	time.Sleep(10*time.Second)
-	s.Close()
-	time.Sleep(20*time.Second)
+	}
 }

s3.go

@@ -13,6 +13,7 @@ import (
 )
 
 type Bool bool
+
 func (bit *Bool) UnmarshalJSON(b []byte) error {
 	txt := string(b)
 	*bit = Bool(txt == "1" || txt == "true")
@@ -21,13 +22,13 @@ func (bit *Bool) UnmarshalJSON(b []byte) error {
 
 type objectInfo = minio.ObjectInfo
 type S3Configuration struct {
-	BucketName      string
-	Endpoint        string
-	AccessKey       string
-	SecretAccessKey string
-	SessionToken    string
-	Region          string
-	SSLEnabled      Bool
+	BucketName      string `json:"bucketname"`
+	Endpoint        string `json:"endpoint"`
+	AccessKey       string `json:"accesskey"`
+	SecretAccessKey string `json:"secretkey"`
+	SessionToken    string `json:"token"`
+	Region          string `json:"region"`
+	SSLEnabled      Bool   `json:"sslenabled"`
 }
 
 type S3Watcher struct {
@@ -57,8 +58,8 @@ func newS3Watcher(dir string, interval time.Duration) (Watcher, error) {
 		config: nil,
 		stop:   make(chan bool, 1),
 		WatcherBase: WatcherBase{
-			Events: make(chan Event, 100),
-			Errors: make(chan error, 100),
+			Events:      make(chan Event, 100),
+			Errors:      make(chan error, 100),
 			watchDir:    dir,
 			pollingTime: interval,
 		},