lambda

README

AWS Lambda Invoke

This activity allows you to invoke an AWS Lambda function.

Installation

Flogo CLI

flogo install github.com/project-flogo/aws-contrib/activity/lambda

Configuration

To configure AWS credentials see configuring-sdk

Settings:

Name	Type	Description
function	string	The name or ARN of the Lambda function - REQUIRED
clientContext	object	Information about the client to pass to the function via the context
async	bool	Perform async invocation
executionLog	bool	Include the execution log in the response
region	string	The AWS region, uses environment setting by default

Input:

Name	Type	Description
payload	object	The payload object

Output:

Name	Type	Description
status	int	The HTTP status code
result	object	The response from the function

Examples

Coming soon...

Documentation

Index

• func New(ctx activity.InitContext) (activity.Activity, error)
• type Activity
  • func (a *Activity) Eval(ctx activity.Context) (done bool, err error)
  • func (a *Activity) Metadata() *activity.Metadata
• type Input
  • func (i *Input) FromMap(values map[string]interface{}) error
  • func (i *Input) ToMap() map[string]interface{}
• type Output
  • func (o *Output) FromMap(values map[string]interface{}) error
  • func (o *Output) ToMap() map[string]interface{}
• type Settings

Functions

func New

func New(ctx activity.InitContext) (activity.Activity, error)

Types

type Activity

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

Activity is an activity that is used to invoke a lambda function

func (*Activity) Eval

func (a *Activity) Eval(ctx activity.Context) (done bool, err error)

Eval implements activity.Activity.Eval

func (*Activity) Metadata

func (a *Activity) Metadata() *activity.Metadata

Metadata returns the activity's metadata

type Input

type Input struct {
	Payload map[string]interface{} `md:"payload"` // The payload object
}

func (*Input) FromMap

func (i *Input) FromMap(values map[string]interface{}) error

func (*Input) ToMap

func (i *Input) ToMap() map[string]interface{}

type Output

type Output struct {
	Result map[string]interface{} `md:"result"` // The response from the function
	Status int                    `md:"status"` // The HTTP status code
}

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 {
	Function      string                 `md:"function,required"` // The name or ARN of the Lambda function
	ClientContext map[string]interface{} `md:"clientContext"`     // Information about the client to pass to the function via the context
	Async         bool                   `md:"async"`             // Perform async invocation
	ExecutionLog  bool                   `md:"executionLog"`      // Include the execution log in the response
	Region        string                 `md:"region"`            // The AWS region, uses environment setting by default
}