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

Update godoc for allgroup description

Browse source
This commit is contained in:
Harlow Ward 2019-09-02 07:26:44 -07:00
parent ed40b5d9b4
commit 3a98baa012
1 changed files with 3 additions and 2 deletions
Show stats Download patch file Download diff file Expand all files Collapse all files

5
allgroup.go
View file

@ -21,8 +21,9 @@ func NewAllGroup(ksis kinesisiface.KinesisAPI, store Store, streamName string, l
}
}
// AllGroup caches a local list of the shards we are already processing
// and routinely polls the stream looking for new shards to process
// AllGroup is used to consume all shards from a single consumer. It
// caches a local list of the shards we are already processing
// and routinely polls the stream looking for new shards to process.
type AllGroup struct {
ksis kinesisiface.KinesisAPI
streamName string