sqs

package

v1.7.1 Latest Latest Go to latest Published: Feb 14, 2024 License: MIT Imports: 17 Imported by: 0

Details

Valid go.mod file

The Go module system was introduced in Go 1.11 and is the official dependency management solution for Go.
Redistributable license

Redistributable licenses place minimal restrictions on how software can be used, modified, and redistributed.
Tagged version

Modules with tagged versions give importers more predictable builds.
Stable version

When a project reaches major version v1 it is considered stable.
Learn more about best practices

Repository

github.com/gabrielperezs/goreactor

Links

Open Source Insights

Documentation ¶

Index ¶

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

Constants ¶

This section is empty.

Variables ¶

View Source

var MessageSystemAttributeNameSentTimestamp = sqs.MessageSystemAttributeNameSentTimestamp

Functions ¶

This section is empty.

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 ¶ added in v1.7.0

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 ¶ added in v1.5.0

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 ¶ added in v1.7.1

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 ¶ added in v1.5.0

func (p *SQSPlugin) Stop()

Stops listening

Source Files ¶

View all Source files

?	: This menu
/	: Search site
f or F	: Jump to
y or Y	: Canonical URL