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)
Click to show internal directories.
Click to hide internal directories.