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

spelling

Browse source
This commit is contained in:
Harlow Ward 2019-04-08 21:27:08 -07:00
parent ef4daf97d1
commit 3e9760ef2f
1 changed files with 2 additions and 2 deletions
Show stats Download patch file Download diff file Expand all files Collapse all files

4
broker.go
View file

@ -49,8 +49,8 @@ func (b *broker) pollShards(ctx context.Context) {
} }
// leaseShards attempts to find new shards that need to be // leaseShards attempts to find new shards that need to be
// processed; when a new shard is found it passing the shard // processed; when a new shard is found it passes the shard
// ID back to the consumer on the shard channel // ID back to the consumer on the shardc channel
func (b *broker) leaseShards() { func (b *broker) leaseShards() {
b.shardMu.Lock() b.shardMu.Lock()
defer b.shardMu.Unlock() defer b.shardMu.Unlock()