kinesumer

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

type ICheckpointer kinesumeriface.Checkpointer

type IError kinesumeriface.Error

type IKinesis kinesumeriface.Kinesis

type IKinesumer kinesumeriface.Kinesumer

type IProvisioner kinesumeriface.Provisioner

type IRecord kinesumeriface.Record

type Kinesumer struct {
	Kinesis      k.Kinesis
	Checkpointer k.Checkpointer
	Provisioner  k.Provisioner
	Stream       string
	Options      *Options
	// contains filtered or unexported fields
}

type Options struct {
	ListStreamsLimit    int64
	DescribeStreamLimit int64
	GetRecordsLimit     int64

	// Determines how frequently GetRecords is throttled. The zero value is
	// DefaultGetRecordsThrottle.
	GetRecordsThrottle time.Duration

	// Amount of time to poll of records if consumer lag is minimal
	PollTime            int
	MaxShardWorkers     int
	ErrHandler          func(k.Error)
	DefaultIteratorType string

	// How long to try and get shard iterator
	ShardAcquisitionTimeout time.Duration

	// ShardIteratorTimestamp is used when DefaultIteratorType is "AT_TIMESTAMP"
	ShardIteratorTimestamp time.Time
}

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

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

type ShardWorker struct {
	GetRecordsLimit int64
	// contains filtered or unexported fields
}

type Unit struct{}