sqs

package module

v0.0.0-...-2b56179 Latest Latest Go to latest Published: Mar 19, 2020 License: BSD-3-Clause Imports: 10 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/project-flogo/aws-contrib

Links

Open Source Insights

README ¶

AWS SQS Trigger

The SQS trigger provides your Flogo application the ability to read data from SQ.

Installation

Flogo CLI

flogo install github.com/project-flogo/aws-contrib/trigger/sqs

Configuration

To configure AWS credentials see configuring-sdk

Settings:

Name	Type	Description
region	string	The region of SQS trigger.

Handler Settings:

Name	Type	Description
queueUrl	string	The url of the SQS queue

Output:

Name	Type	Description
data	array	The array containing messages from SQS.

Documentation ¶

Index ¶

type Factory
- func (t *Factory) Metadata() *trigger.Metadata
- func (t *Factory) New(config *trigger.Config) (trigger.Trigger, error)
type Handler
type HandlerSettings
type Output
- func (o *Output) FromMap(values map[string]interface{}) error
- func (o *Output) ToMap() map[string]interface{}
type Settings
type Trigger

Constants ¶

This section is empty.

Variables ¶

This section is empty.

Functions ¶

This section is empty.

Types ¶

type Factory ¶

type Factory struct {
}

func (*Factory) Metadata ¶

func (t *Factory) Metadata() *trigger.Metadata

Metadata implements trigger.Trigger.Metadata

func (*Factory) New ¶

func (t *Factory) New(config *trigger.Config) (trigger.Trigger, error)

type Handler ¶

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

type HandlerSettings ¶

type HandlerSettings struct {
	QueueURL string `md:"queueUrl,required"`
}

type Output ¶

type Output struct {
	Data []interface{} `md:"data"`
}

func (*Output) FromMap ¶

func (o *Output) FromMap(values map[string]interface{}) error

func (*Output) ToMap ¶

func (o *Output) ToMap() map[string]interface{}

type Settings ¶

type Settings struct {
	Region string `md:"region"`
}

type Trigger ¶

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

func (*Trigger) Initialize ¶

func (t *Trigger) Initialize(ctx trigger.InitContext) error

func (*Trigger) Start ¶

func (t *Trigger) Start() error

func (*Trigger) Stop ¶

func (t *Trigger) Stop() error

Stop implements util.Managed.Stop

Source Files ¶

View all Source files

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