Documentation ¶
Index ¶
Constants ¶
This section is empty.
Variables ¶
This section is empty.
Functions ¶
This section is empty.
Types ¶
type Sqs3Input ¶
type Sqs3Input struct { *Sqs3InputConfig // contains filtered or unexported fields }
func (*Sqs3Input) ConfigStruct ¶
func (input *Sqs3Input) ConfigStruct() interface{}
func (*Sqs3Input) Run ¶
func (input *Sqs3Input) Run(runner pipeline.InputRunner, helper pipeline.PluginHelper) error
type Sqs3InputConfig ¶
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"` }
Click to show internal directories.
Click to hide internal directories.