func (c *Kinesis) GetRecords(input *GetRecordsInput) (*GetRecordsOutput, error) {
	req, out := c.GetRecordsRequest(input)
	err := req.Send()
	return out, err
}
Gets data records from an Amazon Kinesis stream's shard.

Specify a shard iterator using the ShardIterator parameter. The shard iterator
specifies the position in the shard from which you want to start reading
data records sequentially. If there are no records available in the portion
of the shard that the iterator points to, GetRecords returns an empty list.
Note that it might take multiple calls to get to a portion of the shard that
contains records.

You can scale by provisioning multiple shards per stream while considering
service limits (for more information, see Streams Limits (http://docs.aws.amazon.com/kinesis/latest/dev/service-sizes-and-limits.html)
in the Amazon Kinesis Streams Developer Guide). Your application should have
one thread per shard, each reading continuously from its stream. To read
from a stream continually, call GetRecords in a loop. Use GetShardIterator
to get the shard iterator to specify in the first GetRecords call. GetRecords
returns a new shard iterator in NextShardIterator. Specify the shard iterator
returned in NextShardIterator in subsequent calls to GetRecords. Note that
if the shard has been closed, the shard iterator can't return more data and
GetRecords returns null in NextShardIterator. You can terminate the loop
when the shard is closed, or when the shard iterator reaches the record with
the sequence number or other attribute that marks it as the last record to
process.

Each data record can be up to 1 MB in size, and each shard can read up to
2 MB per second. You can ensure that your calls don't exceed the maximum
supported size or throughput by using the Limit parameter to specify the
maximum number of records that GetRecords can return. Consider your average
record size when determining this limit.

The size of the data returned by GetRecords varies depending on the utilization
of the shard. The maximum size of data that GetRecords can return is 10 MB.
If a call returns this amount of data, subsequent calls made within the next
5 seconds throw ProvisionedThroughputExceededException. If there is insufficient
provisioned throughput on the shard, subsequent calls made within the next
1 second throw ProvisionedThroughputExceededException. Note that GetRecords
won't return any data when it throws an exception. For this reason, we recommend
that you wait one second between calls to GetRecords; however, it's possible
that the application will get exceptions for longer than 1 second.

To detect whether the application is falling behind in processing, you can
use the MillisBehindLatest response attribute. You can also monitor the stream
using CloudWatch metrics and other mechanisms (see Monitoring (http://docs.aws.amazon.com/kinesis/latest/dev/monitoring.html)
in the Amazon Kinesis Streams Developer Guide).

Each Amazon Kinesis record includes a value, ApproximateArrivalTimestamp,
that is set when a stream successfully receives and stores a record. This
is commonly referred to as a server-side timestamp, whereas a client-side
timestamp is set when a data producer creates or sends the record to a stream
(a data producer is any data source putting data records into a stream, for
example with PutRecords). The timestamp has millisecond precision. There
are no guarantees about the timestamp accuracy, or that the timestamp is
always increasing. For example, records in a shard or across a stream might
have timestamps that are out of order.
package kinesis
import (
	"fmt"
	"time"
	"github.com/aws/aws-sdk-go/aws/awsutil"
	"github.com/aws/aws-sdk-go/aws/request"
	"github.com/aws/aws-sdk-go/private/protocol"
	"github.com/aws/aws-sdk-go/private/protocol/jsonrpc"
)
const opAddTagsToStream = "AddTagsToStream"
func (c *Kinesis) AddTagsToStreamRequest(input *AddTagsToStreamInput) (req *request.Request, output *AddTagsToStreamOutput) {
	op := &request.Operation{
		Name:       opAddTagsToStream,
		HTTPMethod: "POST",
		HTTPPath:   "/",
	}
	if input == nil {
		input = &AddTagsToStreamInput{}
	}
	req = c.newRequest(op, input, output)
	req.Handlers.Unmarshal.Remove(jsonrpc.UnmarshalHandler)
	req.Handlers.Unmarshal.PushBackNamed(protocol.UnmarshalDiscardBodyHandler)
	output = &AddTagsToStreamOutput{}
	req.Data = output
	return
}
func (c *Kinesis) AddTagsToStream(input *AddTagsToStreamInput) (*AddTagsToStreamOutput, error) {
	req, out := c.AddTagsToStreamRequest(input)
	err := req.Send()
	return out, err
}
const opCreateStream = "CreateStream"
func (c *Kinesis) CreateStreamRequest(input *CreateStreamInput) (req *request.Request, output *CreateStreamOutput) {
	op := &request.Operation{
		Name:       opCreateStream,
		HTTPMethod: "POST",
		HTTPPath:   "/",
	}
	if input == nil {
		input = &CreateStreamInput{}
	}
	req = c.newRequest(op, input, output)
	req.Handlers.Unmarshal.Remove(jsonrpc.UnmarshalHandler)
	req.Handlers.Unmarshal.PushBackNamed(protocol.UnmarshalDiscardBodyHandler)
	output = &CreateStreamOutput{}
	req.Data = output
	return
}
func (c *Kinesis) CreateStream(input *CreateStreamInput) (*CreateStreamOutput, error) {
	req, out := c.CreateStreamRequest(input)
	err := req.Send()
	return out, err
}
const opDecreaseStreamRetentionPeriod = "DecreaseStreamRetentionPeriod"
func (c *Kinesis) DecreaseStreamRetentionPeriodRequest(input *DecreaseStreamRetentionPeriodInput) (req *request.Request, output *DecreaseStreamRetentionPeriodOutput) {
	op := &request.Operation{
		Name:       opDecreaseStreamRetentionPeriod,
		HTTPMethod: "POST",
		HTTPPath:   "/",
	}
	if input == nil {
		input = &DecreaseStreamRetentionPeriodInput{}
	}
	req = c.newRequest(op, input, output)
	req.Handlers.Unmarshal.Remove(jsonrpc.UnmarshalHandler)
	req.Handlers.Unmarshal.PushBackNamed(protocol.UnmarshalDiscardBodyHandler)
	output = &DecreaseStreamRetentionPeriodOutput{}
	req.Data = output
	return
}
func (c *Kinesis) DecreaseStreamRetentionPeriod(input *DecreaseStreamRetentionPeriodInput) (*DecreaseStreamRetentionPeriodOutput, error) {
	req, out := c.DecreaseStreamRetentionPeriodRequest(input)
	err := req.Send()
	return out, err
}
const opDeleteStream = "DeleteStream"
func (c *Kinesis) DeleteStreamRequest(input *DeleteStreamInput) (req *request.Request, output *DeleteStreamOutput) {
	op := &request.Operation{
		Name:       opDeleteStream,
		HTTPMethod: "POST",
		HTTPPath:   "/",
	}
	if input == nil {
		input = &DeleteStreamInput{}
	}
	req = c.newRequest(op, input, output)
	req.Handlers.Unmarshal.Remove(jsonrpc.UnmarshalHandler)
	req.Handlers.Unmarshal.PushBackNamed(protocol.UnmarshalDiscardBodyHandler)
	output = &DeleteStreamOutput{}
	req.Data = output
	return
}
func (c *Kinesis) DeleteStream(input *DeleteStreamInput) (*DeleteStreamOutput, error) {
	req, out := c.DeleteStreamRequest(input)
	err := req.Send()
	return out, err
}
const opDescribeStream = "DescribeStream"
func (c *Kinesis) DescribeStreamRequest(input *DescribeStreamInput) (req *request.Request, output *DescribeStreamOutput) {
	op := &request.Operation{
		Name:       opDescribeStream,
		HTTPMethod: "POST",
		HTTPPath:   "/",
		Paginator: &request.Paginator{
			InputTokens:     []string{"ExclusiveStartShardId"},
			OutputTokens:    []string{"StreamDescription.Shards[-1].ShardId"},
			LimitToken:      "Limit",
			TruncationToken: "StreamDescription.HasMoreShards",
		},
	}
	if input == nil {
		input = &DescribeStreamInput{}
	}
	req = c.newRequest(op, input, output)
	output = &DescribeStreamOutput{}
	req.Data = output
	return
}
func (c *Kinesis) DescribeStream(input *DescribeStreamInput) (*DescribeStreamOutput, error) {
	req, out := c.DescribeStreamRequest(input)
	err := req.Send()
	return out, err
}
func (c *Kinesis) DescribeStreamPages(input *DescribeStreamInput, fn func(p *DescribeStreamOutput, lastPage bool) (shouldContinue bool)) error {
	page, _ := c.DescribeStreamRequest(input)
	page.Handlers.Build.PushBack(request.MakeAddToUserAgentFreeFormHandler("Paginator"))
	return page.EachPage(func(p interface{}, lastPage bool) bool {
		return fn(p.(*DescribeStreamOutput), lastPage)
	})
}
const opDisableEnhancedMonitoring = "DisableEnhancedMonitoring"
func (c *Kinesis) DisableEnhancedMonitoringRequest(input *DisableEnhancedMonitoringInput) (req *request.Request, output *EnhancedMonitoringOutput) {
	op := &request.Operation{
		Name:       opDisableEnhancedMonitoring,
		HTTPMethod: "POST",
		HTTPPath:   "/",
	}
	if input == nil {
		input = &DisableEnhancedMonitoringInput{}
	}
	req = c.newRequest(op, input, output)
	output = &EnhancedMonitoringOutput{}
	req.Data = output
	return
}
func (c *Kinesis) DisableEnhancedMonitoring(input *DisableEnhancedMonitoringInput) (*EnhancedMonitoringOutput, error) {
	req, out := c.DisableEnhancedMonitoringRequest(input)
	err := req.Send()
	return out, err
}
const opEnableEnhancedMonitoring = "EnableEnhancedMonitoring"
func (c *Kinesis) EnableEnhancedMonitoringRequest(input *EnableEnhancedMonitoringInput) (req *request.Request, output *EnhancedMonitoringOutput) {
	op := &request.Operation{
		Name:       opEnableEnhancedMonitoring,
		HTTPMethod: "POST",
		HTTPPath:   "/",
	}
	if input == nil {
		input = &EnableEnhancedMonitoringInput{}
	}
	req = c.newRequest(op, input, output)
	output = &EnhancedMonitoringOutput{}
	req.Data = output
	return
}
func (c *Kinesis) EnableEnhancedMonitoring(input *EnableEnhancedMonitoringInput) (*EnhancedMonitoringOutput, error) {
	req, out := c.EnableEnhancedMonitoringRequest(input)
	err := req.Send()
	return out, err
}
const opGetRecords = "GetRecords"
func (c *Kinesis) GetRecordsRequest(input *GetRecordsInput) (req *request.Request, output *GetRecordsOutput) {
	op := &request.Operation{
		Name:       opGetRecords,
		HTTPMethod: "POST",
		HTTPPath:   "/",
	}
	if input == nil {
		input = &GetRecordsInput{}
	}
	req = c.newRequest(op, input, output)
	output = &GetRecordsOutput{}
	req.Data = output
	return
}