sqs

README

Simple Queue Service Service

This service is github.com/aws/aws-sdk-go/service/sqs.SQS proxy

To check all supported method run

    endly -s="aws/sqs"

To check method contract run endly -s="aws/sqs:methodName"

    endly -s=aws/sqs:listQueues
    endly -s=aws/sqs:setupPermission

Usage:

endly set_permission.yaml authWith=myAWSSecret.json

@set_permission.yaml

init:
  '!awsCredentials': $params.authWith


pipeline:
  setupPermission:
    action: aws/sqs:setupPermission
    credentials: $awsCredentials
    queue: ms-dataflowStorageMirrorQueue
    AWSAccountIds:
      - ${aws.accountID}
    actions:
      - '*'
    everybody: true

Documentation

Index

• Constants
• func GetClient(context *endly.Context) (*sqs.SQS, error)
• func New() endly.Service
• type SetupPermissionInput
  • func (i *SetupPermissionInput) Init() error
  • func (i *SetupPermissionInput) Validate() error

Constants

const (
	//ServiceID aws Simple Queue Service ID.
	ServiceID = "aws/sqs"
)

Functions

func GetClient

func GetClient(context *endly.Context) (*sqs.SQS, error)

GetClient returns sqs client from context

func New

func New() endly.Service

New creates a new AWS SQS service.

Types

type SetupPermissionInput

type SetupPermissionInput struct {
	sqs.AddPermissionInput
	Everybody bool
	Queue     string
	SourceArn string
}

SetupPermissionInput creates a permission if it does not exists

func (*SetupPermissionInput) Init

func (i *SetupPermissionInput) Init() error

func (*SetupPermissionInput) Validate

func (i *SetupPermissionInput) Validate() error