consumer

type Config struct {
	StreamName      *string
	Region          *string
	AccessKeyID     string
	SecretAccessKey string
	SessionToken    string
}

type Consumer struct {
	ShardIterator []*ShardIterator
	ChData        chan string
	// contains filtered or unexported fields
}

type ShardIterator struct {
	ID       string
	Iterator *kinesis.GetShardIteratorOutput
	Position *string
}