sqs3

type Sqs3Input struct {
	*Sqs3InputConfig
	// contains filtered or unexported fields
}

type Sqs3InputConfig struct {
	// So we can default to using ProtobufDecoder.
	Decoder string
	// So we can default to using HekaFramingSplitter.
	Splitter string

	SqsQueue string `toml:"sqs_queue"`
	// Defaults to us-east-1. used for both sqs and s3.
	AwsRegion string `toml:"aws_region"`
	// Must be between 0 and 20
	WaitTimeSeconds int64 `toml:"wait_time_seconds"`
}

type SqsBody struct {
	Records []struct {
		EventName string
		S3        struct {
			Bucket struct {
				Name string
			}
			Object struct {
				Key  string
				Size int
			}
		}
	}
}