sqs

package
v0.75.1 Latest Latest
Warning

This package is not in the latest version of its module.

Go to latest
Published: May 7, 2024 License: Apache-2.0 Imports: 12 Imported by: 0

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

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

Variables

This section is empty.

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

Jump to

Keyboard shortcuts

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