sqs

Documentation

Overview

Package sqs implements the 'aws sqs' sub-command.

Index

• Variables
• func GetSQSMetricDataInput(start *time.Time, end *time.Time, queueURL *string) *cloudwatch.GetMetricDataInput
• type AWSClients
  • func NewAWSClients() *AWSClients
  • func (c *AWSClients) AwsSQSDelete(queues map[string]string) map[string][]string
  • func (c *AWSClients) GetCloudWatchMetrics(now *time.Time, queueURL *string) (*float64, error)
  • func (c *AWSClients) IsDeadLetterQueue(queueURL *string) (bool, []string, error)
• type Queue

Variables

var (
	// AwsSqsEndpoint custom endpoint.
	AwsSqsEndpoint string

	// AwsCloudWatchEndpoint custom endpoint.
	AwsCloudWatchEndpoint string

	// AwsSQSQueuePrefix sqs queue prefix.
	AwsSQSQueuePrefix string

	// UnusedSince get list since xx.
	UnusedSince string

	// CheckTagNameUpdateDate is name for skip delete queue.
	CheckTagNameUpdateDate string
)

var (
	// Command performs the "list clusters" function.
	Command = &cobra.Command{
		Use:     "sqs",
		Aliases: []string{"sqs"},
		Short:   "AWS SQS",
		Long:    `This command will identify the queues to be cleaned.`,
		PreRun:  validation,
		Run:     printResult,
	}
)

Functions

func GetSQSMetricDataInput

func GetSQSMetricDataInput(start *time.Time, end *time.Time, queueURL *string) *cloudwatch.GetMetricDataInput

Types

type AWSClients

type AWSClients struct {
	CloudWatch *cloudwatch.CloudWatch
	SQS        *sqs.SQS
}

func NewAWSClients

func NewAWSClients() *AWSClients

func (*AWSClients) AwsSQSDelete

func (c *AWSClients) AwsSQSDelete(queues map[string]string) map[string][]string

func (*AWSClients) GetCloudWatchMetrics

func (c *AWSClients) GetCloudWatchMetrics(now *time.Time, queueURL *string) (*float64, error)

func (*AWSClients) IsDeadLetterQueue

func (c *AWSClients) IsDeadLetterQueue(queueURL *string) (bool, []string, error)

type Queue

type Queue struct {
	URL  string
	Name string
}