consumer

type Config struct {
	// ApplicationName is the name that kinsumer uses to communicate with other clients
	// consuming the same kinesis stream
	ApplicationName string

	// StreamName is the name of the stream that is being consumed from
	StreamName string

	// (Optional) Time for Kinsumer to sleep if there are no new records
	ThrottleDelay string

	// (Optional) Delay before the checkpoint for each shard is committed to the database
	CommitFrequency string

	// (Optional) How frequently the list of shards are checked
	ShardCheckFrequency string

	// (Optional) Size of the internal buffer for kinesis events
	BufferSize int
}

type KinesisPipe struct {
	// C is used to read records off the kinsumer queue
	C <-chan *Result

	sync.WaitGroup
	// contains filtered or unexported fields
}

type Result struct {
	Data  []byte
	Error error
}

type ResultPipe interface {
	// ReadChannel provides a channel from which the Results are read.
	ReadChannel() <-chan *Result

	// Close cleans up any resources associated with the pipe.
	Close()
}

type StandardInputPipe struct {
	// contains filtered or unexported fields
}