From 3d290c45129fa92c3919512f23f4c2aafbdfe7c6 Mon Sep 17 00:00:00 2001 From: Harlow Ward Date: Sat, 20 Dec 2014 18:55:13 -0800 Subject: [PATCH] Shorten the CreateStream function name --- utils.go | 12 ++++++++---- 1 file changed, 8 insertions(+), 4 deletions(-) diff --git a/utils.go b/utils.go index 1915f88..870d7a7 100644 --- a/utils.go +++ b/utils.go @@ -89,9 +89,9 @@ func LoadConfig(config interface{}, filename string) error { return nil } -// CreateAndWaitForStreamToBecomeAvailable creates a new Kinesis stream (uses -// existing stream if exists) and waits for it to become available. -func CreateAndWaitForStreamToBecomeAvailable(k *kinesis.Kinesis, streamName string, shardCount int) { +// CreateStream creates a new Kinesis stream (uses existing stream if exists) and +// waits for it to become available. +func CreateStream(k *kinesis.Kinesis, streamName string, shardCount int) { if !StreamExists(k, streamName) { err := k.CreateStream(streamName, shardCount) @@ -123,7 +123,11 @@ func CreateAndWaitForStreamToBecomeAvailable(k *kinesis.Kinesis, streamName stri // StreamExists checks if a Kinesis stream exists. func StreamExists(k *kinesis.Kinesis, streamName string) bool { args := kinesis.NewArgs() - resp, _ := k.ListStreams(args) + resp, err := k.ListStreams(args) + if err != nil { + fmt.Printf("ListStream ERROR: %v\n", err) + return false + } for _, s := range resp.StreamNames { if s == streamName { return true