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

Update function name to represent functionality

Browse source
This commit is contained in:
Harlow Ward 2016-04-30 09:14:25 -07:00
parent 855af23684
commit 7fccc9da9f
1 changed files with 2 additions and 2 deletions
Show stats Download patch file Download diff file Expand all files Collapse all files

4
examples/seed/main.go
View file

@ -17,7 +17,7 @@ import (
// curl https://s3.amazonaws.com/kinesis.test/users.txt -o /tmp/users.txt // curl https://s3.amazonaws.com/kinesis.test/users.txt -o /tmp/users.txt
var stream = flag.String("s", "", "Stream name") var stream = flag.String("s", "", "Stream name")
func putToS3(svc *kinesis.Kinesis, data string, partitionKey string) { func putToKinesis(svc *kinesis.Kinesis, data string, partitionKey string) {
params := &kinesis.PutRecordInput{ params := &kinesis.PutRecordInput{
Data: []byte(data), Data: []byte(data),
PartitionKey: aws.String(partitionKey), PartitionKey: aws.String(partitionKey),
@ -45,7 +45,7 @@ func main() {
wg.Add(1) wg.Add(1)
go func() { go func() {
for data := range jobCh { for data := range jobCh {
putToS3(svc, data, string(i)) putToKinesis(svc, data, string(i))
} }
wg.Done() wg.Done()
}() }()