sqs

package
v0.7.0 Latest Latest
Warning

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

Go to latest
Published: Feb 16, 2026 License: MIT Imports: 12 Imported by: 0

Documentation

Overview

+marmot:name=SQS +marmot:description=This plugin discovers SQS queues from AWS accounts. +marmot:status=experimental +marmot:features=Assets, Lineage

Index

Constants

This section is empty.

Variables

This section is empty.

Functions

This section is empty.

Types

type Config

type Config struct {
	plugin.BaseConfig `json:",inline"`
	*plugin.AWSConfig `json:",inline"`

	DiscoverDLQ bool `json:"discover_dlq,omitempty" description:"Discover Dead Letter Queue relationships"`
}

Config for SQS plugin +marmot:config

type SQSFields

type SQSFields struct {
	QueueArn                  string            `json:"queue_arn" metadata:"queue_arn" description:"The ARN of the SQS queue"`
	VisibilityTimeout         string            `json:"visibility_timeout" metadata:"visibility_timeout" description:"The visibility timeout for the queue"`
	MessageRetentionPeriod    string            `json:"message_retention_period" metadata:"message_retention_period" description:"Message retention period in seconds"`
	MaximumMessageSize        string            `json:"maximum_message_size" metadata:"maximum_message_size" description:"Maximum message size in bytes"`
	DelaySeconds              string            `json:"delay_seconds" metadata:"delay_seconds" description:"Delay seconds for messages"`
	ReceiveMessageWaitTime    string            `json:"receive_message_wait_time" metadata:"receive_message_wait_time" description:"Long polling wait time in seconds"`
	FifoQueue                 bool              `json:"fifo_queue" metadata:"fifo_queue" description:"Whether this is a FIFO queue"`
	ContentBasedDeduplication bool              `` /* 134-byte string literal not displayed */
	DeduplicationScope        string            `json:"deduplication_scope" metadata:"deduplication_scope" description:"Deduplication scope for FIFO queues"`
	FifoThroughputLimit       string            `json:"fifo_throughput_limit" metadata:"fifo_throughput_limit" description:"FIFO throughput limit type"`
	RedrivePolicy             string            `json:"redrive_policy" metadata:"redrive_policy" description:"Redrive policy JSON string"`
	Tags                      map[string]string `json:"tags" metadata:"tags" description:"AWS resource tags"`
}

SQSFields represents SQS-specific metadata fields +marmot:metadata

type Source

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

func (*Source) Discover

func (s *Source) Discover(ctx context.Context, pluginConfig plugin.RawPluginConfig) (*plugin.DiscoveryResult, error)

func (*Source) Validate

func (s *Source) Validate(rawConfig plugin.RawPluginConfig) (plugin.RawPluginConfig, error)

Jump to

Keyboard shortcuts

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