sqs

Documentation

Index

• Variables
• type Msg
  • func (m *Msg) Body() []byte
  • func (m *Msg) CreationTimestampMilliseconds() int64
  • func (m *Msg) GetHash() string
• type SQSPlugin
  • func NewOrGet(r *reactor.Reactor, c map[string]interface{}) (*SQSPlugin, error)
  • func (p *SQSPlugin) Done(v lib.Msg, status bool)
  • func (p *SQSPlugin) Exit()
  • func (p *SQSPlugin) KeepAlive(ctx context.Context, t time.Duration, v lib.Msg) (err error)
  • func (p *SQSPlugin) Put(v lib.Msg) error
  • func (p *SQSPlugin) Stop()

Variables

var MessageSystemAttributeNameSentTimestamp = sqs.MessageSystemAttributeNameSentTimestamp

Types

type Msg

type Msg struct {
	URL           *string
	SQS           *sqs.SQS
	M             *sqs.DeleteMessageBatchRequestEntry
	B             []byte
	SentTimestamp int64
	Hash          string
}

Msg is the message struct that were captured by the input plugin

func (*Msg) Body

func (m *Msg) Body() []byte

Body will return the bytes of the SQS message

func (*Msg) CreationTimestampMilliseconds

func (m *Msg) CreationTimestampMilliseconds() int64

CreationTimestampMilliseconds will return the creation timestamp for the message

func (*Msg) GetHash

func (m *Msg) GetHash() string

type SQSPlugin

type SQSPlugin struct {
	URL     string
	Region  string
	Profile string
	// contains filtered or unexported fields
}

SQSPlugin struct for SQS Input plugin

func NewOrGet

func NewOrGet(r *reactor.Reactor, c map[string]interface{}) (*SQSPlugin, error)

NewOrGet create a new SQS plugin and relate it with the Reactor

func (*SQSPlugin) Done

func (p *SQSPlugin) Done(v lib.Msg, status bool)

func (*SQSPlugin) Exit

func (p *SQSPlugin) Exit()

Exit stops the pooling from SQS

func (*SQSPlugin) KeepAlive

func (p *SQSPlugin) KeepAlive(ctx context.Context, t time.Duration, v lib.Msg) (err error)

func (*SQSPlugin) Put

func (p *SQSPlugin) Put(v lib.Msg) error

Put is not needed in SQS

func (*SQSPlugin) Stop

func (p *SQSPlugin) Stop()

Stops listening