From 5da0865ac1895bacf8de435bc6f39c9b311d2012 Mon Sep 17 00:00:00 2001 From: Harlow Ward Date: Sun, 28 Jul 2019 21:34:54 -0700 Subject: [PATCH] Add WithGroup option --- options.go | 7 +++++++ 1 file changed, 7 insertions(+) diff --git a/options.go b/options.go index 5810865..dd77da0 100644 --- a/options.go +++ b/options.go @@ -5,6 +5,13 @@ import "github.com/aws/aws-sdk-go/service/kinesis/kinesisiface" // Option is used to override defaults when creating a new Consumer type Option func(*Consumer) +// WithGroup overrides the default storage +func WithGroup(group Group) Option { + return func(c *Consumer) { + c.group = group + } +} + // WithStore overrides the default storage func WithStore(store Store) Option { return func(c *Consumer) {