luciano/kinesis-consumer
1
0
Fork 0
Code Issues Pull requests Projects Releases Packages Wiki Activity Actions

Remove unused DeleteStream function

Browse source 
The function wasn't being used and should be removed from codebase.
This commit is contained in:
Harlow Ward 2014-12-10 22:04:28 -08:00
parent 106f0d66bb
commit 4366c364d0
1 changed files with 0 additions and 12 deletions
Show stats Download patch file Download diff file Expand all files Collapse all files

12
utils.go
View file

@ -131,15 +131,3 @@ func StreamExists(k *kinesis.Kinesis, streamName string) bool {
} }
return false return false
} }
// DeleteStream deletes a current Kinesis stream.
func DeleteStream(k *kinesis.Kinesis, streamName string) {
err := k.DeleteStream("test")
if err != nil {
fmt.Printf("DeleteStream ERROR: %v\n", err)
return
}
fmt.Printf("Stream [%v] is DELETING\n", streamName)
}