#12 fix formating

Author: le0pard

client.go

@@ -1,56 +1,56 @@
 package kinesis
 
 import (
-  "net/http"
-  "os"
+	"net/http"
+	"os"
 )
 
 const (
-  ACCESS_ENV_KEY  = "AWS_ACCESS_KEY"
-  SECRET_ENV_KEY  = "AWS_SECRET_KEY"
-  REGION_ENV_NAME = "AWS_REGION_NAME"
+	ACCESS_ENV_KEY  = "AWS_ACCESS_KEY"
+	SECRET_ENV_KEY  = "AWS_SECRET_KEY"
+	REGION_ENV_NAME = "AWS_REGION_NAME"
 )
 
 // Auth store information about AWS Credentials
 type Auth struct {
-  AccessKey, SecretKey, Token string
+	AccessKey, SecretKey, Token string
 }
 
 // Client is like http.Client, but signs all requests using Auth.
 type Client struct {
-  Auth *Auth
-  // The http client to make requests with. If nil, http.DefaultClient is used.
-  Client *http.Client
+	Auth *Auth
+	// The http client to make requests with. If nil, http.DefaultClient is used.
+	Client *http.Client
 }
 
 // New creates a new Client.
 func NewClient(auth *Auth) *Client {
-  if auth.AccessKey == "" {
-    auth.AccessKey = os.Getenv(ACCESS_ENV_KEY)
-  }
-  if auth.SecretKey == "" {
-    auth.SecretKey = os.Getenv(SECRET_ENV_KEY)
-  }
-  return &Client{Auth: auth}
+	if auth.AccessKey == "" {
+		auth.AccessKey = os.Getenv(ACCESS_ENV_KEY)
+	}
+	if auth.SecretKey == "" {
+		auth.SecretKey = os.Getenv(SECRET_ENV_KEY)
+	}
+	return &Client{Auth: auth}
 }
 
 func GetRegion(region Region) string {
-  if region.Name == "" {
-    return os.Getenv(REGION_ENV_NAME)
-  }
-  return region.Name
+	if region.Name == "" {
+		return os.Getenv(REGION_ENV_NAME)
+	}
+	return region.Name
 }
 
 // get client
 func (c *Client) client() *http.Client {
-  if c.Client == nil {
-    return http.DefaultClient
-  }
-  return c.Client
+	if c.Client == nil {
+		return http.DefaultClient
+	}
+	return c.Client
 }
 
 // do some request, but sign it before sending
 func (c *Client) Do(req *http.Request) (resp *http.Response, err error) {
-  Sign(c.Auth, req)
-  return c.client().Do(req)
+	Sign(c.Auth, req)
+	return c.client().Do(req)
 }

examples/example.go

@@ -1,101 +1,101 @@
 package main
 
 import (
-  "fmt"
-  "time"
+	"fmt"
+	"time"
 
-  kinesis "github.com/sendgridlabs/go-kinesis"
+	kinesis "github.com/sendgridlabs/go-kinesis"
 )
 
 func getRecords(ksis *kinesis.Kinesis, streamName, ShardId string) {
-  args := kinesis.NewArgs()
-  args.Add("StreamName", streamName)
-  args.Add("ShardId", ShardId)
-  args.Add("ShardIteratorType", "TRIM_HORIZON")
-  resp10, _ := ksis.GetShardIterator(args)
-
-  shardIterator := resp10.ShardIterator
-
-  for {
-    args = kinesis.NewArgs()
-    args.Add("ShardIterator", shardIterator)
-    resp11, err := ksis.GetRecords(args)
-
-    if len(resp11.Records) > 0 {
-      fmt.Printf("GetRecords Data BEGIN\n")
-      for _, d := range resp11.Records {
-        res, err := d.GetData()
-        fmt.Printf("GetRecords Data: %v, err: %v\n", string(res), err)
-      }
-      fmt.Printf("GetRecords Data END\n")
-    } else if resp11.NextShardIterator == "" || shardIterator == resp11.NextShardIterator || err != nil {
-      fmt.Printf("GetRecords ERROR: %v\n", err)
-      break
-    }
-
-    shardIterator = resp11.NextShardIterator
-  }
+	args := kinesis.NewArgs()
+	args.Add("StreamName", streamName)
+	args.Add("ShardId", ShardId)
+	args.Add("ShardIteratorType", "TRIM_HORIZON")
+	resp10, _ := ksis.GetShardIterator(args)
+
+	shardIterator := resp10.ShardIterator
+
+	for {
+		args = kinesis.NewArgs()
+		args.Add("ShardIterator", shardIterator)
+		resp11, err := ksis.GetRecords(args)
+
+		if len(resp11.Records) > 0 {
+			fmt.Printf("GetRecords Data BEGIN\n")
+			for _, d := range resp11.Records {
+				res, err := d.GetData()
+				fmt.Printf("GetRecords Data: %v, err: %v\n", string(res), err)
+			}
+			fmt.Printf("GetRecords Data END\n")
+		} else if resp11.NextShardIterator == "" || shardIterator == resp11.NextShardIterator || err != nil {
+			fmt.Printf("GetRecords ERROR: %v\n", err)
+			break
+		}
+
+		shardIterator = resp11.NextShardIterator
+	}
 }
 
 func main() {
-  fmt.Println("Begin")
-
-  streamName := "test"
-  // set env variables AWS_ACCESS_KEY and AWS_SECRET_KEY AWS_REGION_NAME
-  ksis := kinesis.New("", "", kinesis.Region{})
-
-  err := ksis.CreateStream(streamName, 2)
-  if err != nil {
-    fmt.Printf("CreateStream ERROR: %v\n", err)
-  }
-
-  args := kinesis.NewArgs()
-  resp2, _ := ksis.ListStreams(args)
-  fmt.Printf("ListStreams: %v\n", resp2)
-
-  resp3 := &kinesis.DescribeStreamResp{}
-
-  timeout := make(chan bool, 30)
-  for {
-
-    args = kinesis.NewArgs()
-    args.Add("StreamName", streamName)
-    resp3, _ = ksis.DescribeStream(args)
-    fmt.Printf("DescribeStream: %v\n", resp3)
-
-    if resp3.StreamDescription.StreamStatus != "ACTIVE" {
-      time.Sleep(4 * time.Second)
-      timeout <- true
-    } else {
-      break
-    }
-
-  }
-
-  for i := 0; i < 10; i++ {
-    args = kinesis.NewArgs()
-    args.Add("StreamName", streamName)
-    args.AddData([]byte(fmt.Sprintf("Hello AWS Kinesis %d", i)))
-    args.Add("PartitionKey", fmt.Sprintf("partitionKey-%d", i))
-    resp4, err := ksis.PutRecord(args)
-    if err != nil {
-      fmt.Printf("PutRecord err: %v\n", err)
-    } else {
-      fmt.Printf("PutRecord: %v\n", resp4)
-    }
-  }
-
-  for _, shard := range resp3.StreamDescription.Shards {
-    go getRecords(ksis, streamName, shard.ShardId)
-  }
-
-  var inputGuess string
-  fmt.Scanf("%s\n", &inputGuess)
-
-  err1 := ksis.DeleteStream("test")
-  if err1 != nil {
-    fmt.Printf("DeleteStream ERROR: %v\n", err1)
-  }
-
-  fmt.Println("End")
+	fmt.Println("Begin")
+
+	streamName := "test"
+	// set env variables AWS_ACCESS_KEY and AWS_SECRET_KEY AWS_REGION_NAME
+	ksis := kinesis.New("", "", kinesis.Region{})
+
+	err := ksis.CreateStream(streamName, 2)
+	if err != nil {
+		fmt.Printf("CreateStream ERROR: %v\n", err)
+	}
+
+	args := kinesis.NewArgs()
+	resp2, _ := ksis.ListStreams(args)
+	fmt.Printf("ListStreams: %v\n", resp2)
+
+	resp3 := &kinesis.DescribeStreamResp{}
+
+	timeout := make(chan bool, 30)
+	for {
+
+		args = kinesis.NewArgs()
+		args.Add("StreamName", streamName)
+		resp3, _ = ksis.DescribeStream(args)
+		fmt.Printf("DescribeStream: %v\n", resp3)
+
+		if resp3.StreamDescription.StreamStatus != "ACTIVE" {
+			time.Sleep(4 * time.Second)
+			timeout <- true
+		} else {
+			break
+		}
+
+	}
+
+	for i := 0; i < 10; i++ {
+		args = kinesis.NewArgs()
+		args.Add("StreamName", streamName)
+		args.AddData([]byte(fmt.Sprintf("Hello AWS Kinesis %d", i)))
+		args.Add("PartitionKey", fmt.Sprintf("partitionKey-%d", i))
+		resp4, err := ksis.PutRecord(args)
+		if err != nil {
+			fmt.Printf("PutRecord err: %v\n", err)
+		} else {
+			fmt.Printf("PutRecord: %v\n", resp4)
+		}
+	}
+
+	for _, shard := range resp3.StreamDescription.Shards {
+		go getRecords(ksis, streamName, shard.ShardId)
+	}
+
+	var inputGuess string
+	fmt.Scanf("%s\n", &inputGuess)
+
+	err1 := ksis.DeleteStream("test")
+	if err1 != nil {
+		fmt.Printf("DeleteStream ERROR: %v\n", err1)
+	}
+
+	fmt.Println("End")
 }