mnq

package
v2.40.0 Latest Latest
Warning

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

 Go to latest Published: Apr 24, 2024 License: MPL-2.0 Imports: 33 Imported by: 0

Documentation

Index

Constants

View Source 
const (
	DefaultQueueMaximumMessageSize            = 262_144 // 256 KiB.
	DefaultQueueMessageRetentionPeriod        = 345_600 // 4 days.
	DefaultQueueReceiveMessageWaitTimeSeconds = 0
	DefaultQueueVisibilityTimeout             = 30
)
View Source 
const SQSFIFOQueueNameSuffix = ".fifo"

Variables

View Source 
var (
	SNSTopicAttributesToResourceMap = map[string]string{
		"ContentBasedDeduplication": "content_based_deduplication",
		"FifoTopic":                 "fifo_topic",
		"Owner":                     "owner",
		"TopicArn":                  "arn",
	}
	SNSTopicSubscriptionAttributesToResourceMap = map[string]string{
		"RedrivePolicy": "redrive_policy",
	}
)
View Source 
var SQSAttributesToResourceMap = map[string]string{
	sqs.QueueAttributeNameMaximumMessageSize:            "message_max_size",
	sqs.QueueAttributeNameMessageRetentionPeriod:        "message_max_age",
	sqs.QueueAttributeNameFifoQueue:                     "fifo_queue",
	sqs.QueueAttributeNameContentBasedDeduplication:     "content_based_deduplication",
	sqs.QueueAttributeNameReceiveMessageWaitTimeSeconds: "receive_wait_time_seconds",
	sqs.QueueAttributeNameVisibilityTimeout:             "visibility_timeout_seconds",
}

Functions

func ComposeSNSARN 

func ComposeSNSARN(region scw.Region, projectID string, resourceName string) string

func DataSourceMNQSQSRead 

func DataSourceMNQSQSRead(ctx context.Context, d *schema.ResourceData, m interface{}) diag.Diagnostics

func DataSourceSQS 

func DataSourceSQS() *schema.Resource

func DecomposeMNQID 

func DecomposeMNQID(id string) (region scw.Region, projectID string, name string, err error)

func NATSClientWithRegion 

func NATSClientWithRegion(d *schema.ResourceData, m interface{}) (nats.JetStreamContext, scw.Region, error)

func NewNatsAPIWithRegionAndID 

func NewNatsAPIWithRegionAndID(m interface{}, regionalID string) (*mnq.NatsAPI, scw.Region, string, error)

func NewSNSAPIWithRegionAndID 

func NewSNSAPIWithRegionAndID(m interface{}, regionalID string) (*mnq.SnsAPI, scw.Region, string, error)

func NewSNSClient 

func NewSNSClient(httpClient *http.Client, region string, endpoint string, accessKey string, secretKey string) (*sns.SNS, error)

func NewSQSAPIWithRegionAndID 

func NewSQSAPIWithRegionAndID(m interface{}, regionalID string) (*mnq.SqsAPI, scw.Region, string, error)

func NewSQSClient 

func NewSQSClient(httpClient *http.Client, region string, endpoint string, accessKey string, secretKey string) (*sqs.SQS, error)

func ResourceMNQNatsAccountCreate 

func ResourceMNQNatsAccountCreate(ctx context.Context, d *schema.ResourceData, m interface{}) diag.Diagnostics

func ResourceMNQNatsAccountDelete 

func ResourceMNQNatsAccountDelete(ctx context.Context, d *schema.ResourceData, m interface{}) diag.Diagnostics

func ResourceMNQNatsAccountRead 

func ResourceMNQNatsAccountRead(ctx context.Context, d *schema.ResourceData, m interface{}) diag.Diagnostics

func ResourceMNQNatsAccountUpdate 

func ResourceMNQNatsAccountUpdate(ctx context.Context, d *schema.ResourceData, m interface{}) diag.Diagnostics

func ResourceMNQNatsCredentialsCreate 

func ResourceMNQNatsCredentialsCreate(ctx context.Context, d *schema.ResourceData, m interface{}) diag.Diagnostics

func ResourceMNQNatsCredentialsDelete 

func ResourceMNQNatsCredentialsDelete(ctx context.Context, d *schema.ResourceData, m interface{}) diag.Diagnostics

func ResourceMNQNatsCredentialsRead 

func ResourceMNQNatsCredentialsRead(ctx context.Context, d *schema.ResourceData, m interface{}) diag.Diagnostics

func ResourceMNQNatsCredentialsUpdate 

func ResourceMNQNatsCredentialsUpdate(ctx context.Context, d *schema.ResourceData, m interface{}) diag.Diagnostics

func ResourceMNQSNSCreate 

func ResourceMNQSNSCreate(ctx context.Context, d *schema.ResourceData, m interface{}) diag.Diagnostics

func ResourceMNQSNSCredentialsCreate 

func ResourceMNQSNSCredentialsCreate(ctx context.Context, d *schema.ResourceData, m interface{}) diag.Diagnostics

func ResourceMNQSNSCredentialsDelete 

func ResourceMNQSNSCredentialsDelete(ctx context.Context, d *schema.ResourceData, m interface{}) diag.Diagnostics

func ResourceMNQSNSCredentialsRead 

func ResourceMNQSNSCredentialsRead(ctx context.Context, d *schema.ResourceData, m interface{}) diag.Diagnostics

func ResourceMNQSNSCredentialsUpdate 

func ResourceMNQSNSCredentialsUpdate(ctx context.Context, d *schema.ResourceData, m interface{}) diag.Diagnostics

func ResourceMNQSNSDelete 

func ResourceMNQSNSDelete(ctx context.Context, d *schema.ResourceData, m interface{}) diag.Diagnostics

func ResourceMNQSNSRead 

func ResourceMNQSNSRead(ctx context.Context, d *schema.ResourceData, m interface{}) diag.Diagnostics

func ResourceMNQSNSTopicCreate 

func ResourceMNQSNSTopicCreate(ctx context.Context, d *schema.ResourceData, m interface{}) diag.Diagnostics

func ResourceMNQSNSTopicDelete 

func ResourceMNQSNSTopicDelete(ctx context.Context, d *schema.ResourceData, m interface{}) diag.Diagnostics

func ResourceMNQSNSTopicRead 

func ResourceMNQSNSTopicRead(ctx context.Context, d *schema.ResourceData, m interface{}) diag.Diagnostics

func ResourceMNQSNSTopicSubscriptionCreate 

func ResourceMNQSNSTopicSubscriptionCreate(ctx context.Context, d *schema.ResourceData, m interface{}) diag.Diagnostics

func ResourceMNQSNSTopicSubscriptionDelete 

func ResourceMNQSNSTopicSubscriptionDelete(ctx context.Context, d *schema.ResourceData, m interface{}) diag.Diagnostics

func ResourceMNQSNSTopicSubscriptionRead 

func ResourceMNQSNSTopicSubscriptionRead(ctx context.Context, d *schema.ResourceData, m interface{}) diag.Diagnostics

func ResourceMNQSNSTopicUpdate 

func ResourceMNQSNSTopicUpdate(ctx context.Context, d *schema.ResourceData, m interface{}) diag.Diagnostics

func ResourceMNQSQSCreate 

func ResourceMNQSQSCreate(ctx context.Context, d *schema.ResourceData, m interface{}) diag.Diagnostics

func ResourceMNQSQSCredentialsCreate 

func ResourceMNQSQSCredentialsCreate(ctx context.Context, d *schema.ResourceData, m interface{}) diag.Diagnostics

func ResourceMNQSQSCredentialsDelete 

func ResourceMNQSQSCredentialsDelete(ctx context.Context, d *schema.ResourceData, m interface{}) diag.Diagnostics

func ResourceMNQSQSCredentialsRead 

func ResourceMNQSQSCredentialsRead(ctx context.Context, d *schema.ResourceData, m interface{}) diag.Diagnostics

func ResourceMNQSQSCredentialsUpdate 

func ResourceMNQSQSCredentialsUpdate(ctx context.Context, d *schema.ResourceData, m interface{}) diag.Diagnostics

func ResourceMNQSQSDelete 

func ResourceMNQSQSDelete(ctx context.Context, d *schema.ResourceData, m interface{}) diag.Diagnostics

func ResourceMNQSQSQueueCreate 

func ResourceMNQSQSQueueCreate(ctx context.Context, d *schema.ResourceData, m interface{}) diag.Diagnostics

func ResourceMNQSQSQueueDelete 

func ResourceMNQSQSQueueDelete(ctx context.Context, d *schema.ResourceData, m interface{}) diag.Diagnostics

func ResourceMNQSQSQueueRead 

func ResourceMNQSQSQueueRead(ctx context.Context, d *schema.ResourceData, m interface{}) diag.Diagnostics

func ResourceMNQSQSQueueUpdate 

func ResourceMNQSQSQueueUpdate(ctx context.Context, d *schema.ResourceData, m interface{}) diag.Diagnostics

func ResourceMNQSQSRead 

func ResourceMNQSQSRead(ctx context.Context, d *schema.ResourceData, m interface{}) diag.Diagnostics

func ResourceNatsAccount 

func ResourceNatsAccount() *schema.Resource

func ResourceNatsCredentials 

func ResourceNatsCredentials() *schema.Resource

func ResourceSNS 

func ResourceSNS() *schema.Resource

func ResourceSNSCredentials 

func ResourceSNSCredentials() *schema.Resource

func ResourceSNSTopic 

func ResourceSNSTopic() *schema.Resource

func ResourceSNSTopicSubscription 

func ResourceSNSTopicSubscription() *schema.Resource

func ResourceSQS 

func ResourceSQS() *schema.Resource

func ResourceSQSCredentials 

func ResourceSQSCredentials() *schema.Resource

func ResourceSQSQueue 

func ResourceSQSQueue() *schema.Resource

func SNSClientWithRegion 

func SNSClientWithRegion(d *schema.ResourceData, m interface{}) (*sns.SNS, scw.Region, error)

func SNSClientWithRegionFromID 

func SNSClientWithRegionFromID(d *schema.ResourceData, m interface{}, regionalID string) (*sns.SNS, scw.Region, error)

func SQSClientWithRegion 

func SQSClientWithRegion(d *schema.ResourceData, m interface{}) (*sqs.SQS, scw.Region, error)

Types

type ARN 

type ARN struct {
	Subject         string
	Region          scw.Region
	ProjectID       string
	ResourceName    string
	ExtraResourceID string
}

func DecomposeMNQSubscriptionID 

func DecomposeMNQSubscriptionID(id string) (arn *ARN, err error)

func (ARN) String 

func (a ARN) String() string

Source Files

View all Source files

Directories

Path Synopsis

Jump to

Keyboard shortcuts

? : This menu
/ : Search site
f or F : Jump to
y or Y : Canonical URL
go.dev uses cookies from Google to deliver and enhance the quality of its services and to analyze traffic. Learn more.