sqs

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

type ReaderConfig struct {
	amazon.Config
	Logger              *log.Logger   // Logging instance preferably with log level at <<info>>.
	ErrorLogger         *log.Logger   // Logging instance preferably with log level at <<error>>.
	MaxMessagesPerPoll  int32         // Maximum number of message for each polling process (up to 10).
	InFlightInterval    time.Duration // Total time a polling worker will lock a polled message batch, making this batch unavailable to other parallel workers.
	PollParkingDuration time.Duration // Maximum duration for a polling worker to wait for messages.
	PollInterval        time.Duration // Total time the polling worker scheduler will wait between each polling process.
	HandlerTimeout      time.Duration // Maximum duration for message handler processes (streams.ReaderHandleFunc).
}

type Writer struct {
	amazon.Writer
	// contains filtered or unexported fields
}

type WriterConfig struct {
	amazon.Config
	// The length of time, in seconds, for which a specific message is delayed. Valid
	// values: 0 to 900. Maximum: 15 minutes. Messages with a positive DelaySeconds
	// value become available for processing after the delay period is finished. If you
	// don't specify a value, the default value for the queue is applied. When you set
	// FifoQueue , you can't set DelaySeconds per message. You can set this parameter
	// only on a queue level.
	DelaySeconds int32
}