sqs

package
v0.26.0 Latest Latest
Warning

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

 Go to latest Published: Jun 19, 2026 License: Apache-2.0 Imports: 22 Imported by: 0

Documentation

Index

Constants

View Source 
const (
	SendMessageFormatJSON = "json"
	SendMessageFormatXML  = "xml"
	SendMessageFormatText = "text"
)

Variables

This section is empty.

Functions

func ListQueues 

func ListQueues(ctx core.ListResourcesContext, resourceType string) ([]core.IntegrationResource, error)

Types

type Client 

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

func NewClient 

func NewClient(httpCtx core.HTTPContext, credentials *aws.Credentials, region string) *Client

func (*Client) CreateQueue 

func (c *Client) CreateQueue(name string, attributes map[string]string) (string, error)

func (*Client) DeleteQueue 

func (c *Client) DeleteQueue(queueURL string) error

func (*Client) GetQueueAttributes 

func (c *Client) GetQueueAttributes(queueURL string) (map[string]string, error)

func (*Client) ListQueues 

func (c *Client) ListQueues(prefix string) ([]Queue, error)

func (*Client) PurgeQueue 

func (c *Client) PurgeQueue(queueURL string) error

func (*Client) SendMessage 

func (c *Client) SendMessage(queueURL string, messageBody string) (string, error)

type CreateQueue 

type CreateQueue struct{}

func (*CreateQueue) Cancel 

func (c *CreateQueue) Cancel(ctx core.ExecutionContext) error

func (*CreateQueue) Cleanup 

func (c *CreateQueue) Cleanup(ctx core.SetupContext) error

func (*CreateQueue) Color 

func (c *CreateQueue) Color() string

func (*CreateQueue) Configuration 

func (c *CreateQueue) Configuration() []configuration.Field

func (*CreateQueue) Description 

func (c *CreateQueue) Description() string

func (*CreateQueue) Documentation 

func (c *CreateQueue) Documentation() string

func (*CreateQueue) ExampleOutput 

func (c *CreateQueue) ExampleOutput() map[string]any

func (*CreateQueue) Execute 

func (c *CreateQueue) Execute(ctx core.ExecutionContext) error

func (*CreateQueue) HandleHook added in v0.18.0 

func (c *CreateQueue) HandleHook(ctx core.ActionHookContext) error

func (*CreateQueue) HandleWebhook 

func (c *CreateQueue) HandleWebhook(ctx core.WebhookRequestContext) (int, *core.WebhookResponseBody, error)

func (*CreateQueue) Hooks added in v0.18.0 

func (c *CreateQueue) Hooks() []core.Hook

func (*CreateQueue) Icon 

func (c *CreateQueue) Icon() string

func (*CreateQueue) Label 

func (c *CreateQueue) Label() string

func (*CreateQueue) Name 

func (c *CreateQueue) Name() string

func (*CreateQueue) OutputChannels 

func (c *CreateQueue) OutputChannels(configuration any) []core.OutputChannel

func (*CreateQueue) ProcessQueueItem 

func (c *CreateQueue) ProcessQueueItem(ctx core.ProcessQueueContext) (*uuid.UUID, error)

func (*CreateQueue) Setup 

func (c *CreateQueue) Setup(ctx core.SetupContext) error

type CreateQueueConfiguration 

type CreateQueueConfiguration struct {
	Region    string `json:"region" mapstructure:"region"`
	QueueName string `json:"queueName" mapstructure:"queueName"`
}

type DeleteQueue 

type DeleteQueue struct{}

func (*DeleteQueue) Cancel 

func (c *DeleteQueue) Cancel(ctx core.ExecutionContext) error

func (*DeleteQueue) Cleanup 

func (c *DeleteQueue) Cleanup(ctx core.SetupContext) error

func (*DeleteQueue) Color 

func (c *DeleteQueue) Color() string

func (*DeleteQueue) Configuration 

func (c *DeleteQueue) Configuration() []configuration.Field

func (*DeleteQueue) Description 

func (c *DeleteQueue) Description() string

func (*DeleteQueue) Documentation 

func (c *DeleteQueue) Documentation() string

func (*DeleteQueue) ExampleOutput 

func (c *DeleteQueue) ExampleOutput() map[string]any

func (*DeleteQueue) Execute 

func (c *DeleteQueue) Execute(ctx core.ExecutionContext) error

func (*DeleteQueue) HandleHook added in v0.18.0 

func (c *DeleteQueue) HandleHook(ctx core.ActionHookContext) error

func (*DeleteQueue) HandleWebhook 

func (c *DeleteQueue) HandleWebhook(ctx core.WebhookRequestContext) (int, *core.WebhookResponseBody, error)

func (*DeleteQueue) Hooks added in v0.18.0 

func (c *DeleteQueue) Hooks() []core.Hook

func (*DeleteQueue) Icon 

func (c *DeleteQueue) Icon() string

func (*DeleteQueue) Label 

func (c *DeleteQueue) Label() string

func (*DeleteQueue) Name 

func (c *DeleteQueue) Name() string

func (*DeleteQueue) OutputChannels 

func (c *DeleteQueue) OutputChannels(configuration any) []core.OutputChannel

func (*DeleteQueue) ProcessQueueItem 

func (c *DeleteQueue) ProcessQueueItem(ctx core.ProcessQueueContext) (*uuid.UUID, error)

func (*DeleteQueue) Setup 

func (c *DeleteQueue) Setup(ctx core.SetupContext) error

type DeleteQueueConfiguration 

type DeleteQueueConfiguration struct {
	Region string `json:"region" mapstructure:"region"`
	Queue  string `json:"queue" mapstructure:"queue"`
}

type GetQueue 

type GetQueue struct{}

func (*GetQueue) Cancel 

func (c *GetQueue) Cancel(ctx core.ExecutionContext) error

func (*GetQueue) Cleanup 

func (c *GetQueue) Cleanup(ctx core.SetupContext) error

func (*GetQueue) Color 

func (c *GetQueue) Color() string

func (*GetQueue) Configuration 

func (c *GetQueue) Configuration() []configuration.Field

func (*GetQueue) Description 

func (c *GetQueue) Description() string

func (*GetQueue) Documentation 

func (c *GetQueue) Documentation() string

func (*GetQueue) ExampleOutput 

func (c *GetQueue) ExampleOutput() map[string]any

func (*GetQueue) Execute 

func (c *GetQueue) Execute(ctx core.ExecutionContext) error

func (*GetQueue) HandleHook added in v0.18.0 

func (c *GetQueue) HandleHook(ctx core.ActionHookContext) error

func (*GetQueue) HandleWebhook 

func (c *GetQueue) HandleWebhook(ctx core.WebhookRequestContext) (int, *core.WebhookResponseBody, error)

func (*GetQueue) Hooks added in v0.18.0 

func (c *GetQueue) Hooks() []core.Hook

func (*GetQueue) Icon 

func (c *GetQueue) Icon() string

func (*GetQueue) Label 

func (c *GetQueue) Label() string

func (*GetQueue) Name 

func (c *GetQueue) Name() string

func (*GetQueue) OutputChannels 

func (c *GetQueue) OutputChannels(configuration any) []core.OutputChannel

func (*GetQueue) ProcessQueueItem 

func (c *GetQueue) ProcessQueueItem(ctx core.ProcessQueueContext) (*uuid.UUID, error)

func (*GetQueue) Setup 

func (c *GetQueue) Setup(ctx core.SetupContext) error

type GetQueueConfiguration 

type GetQueueConfiguration struct {
	Region string `json:"region" mapstructure:"region"`
	Queue  string `json:"queue" mapstructure:"queue"`
}

type PurgeQueue 

type PurgeQueue struct{}

func (*PurgeQueue) Cancel 

func (c *PurgeQueue) Cancel(ctx core.ExecutionContext) error

func (*PurgeQueue) Cleanup 

func (c *PurgeQueue) Cleanup(ctx core.SetupContext) error

func (*PurgeQueue) Color 

func (c *PurgeQueue) Color() string

func (*PurgeQueue) Configuration 

func (c *PurgeQueue) Configuration() []configuration.Field

func (*PurgeQueue) Description 

func (c *PurgeQueue) Description() string

func (*PurgeQueue) Documentation 

func (c *PurgeQueue) Documentation() string

func (*PurgeQueue) ExampleOutput 

func (c *PurgeQueue) ExampleOutput() map[string]any

func (*PurgeQueue) Execute 

func (c *PurgeQueue) Execute(ctx core.ExecutionContext) error

func (*PurgeQueue) HandleHook added in v0.18.0 

func (c *PurgeQueue) HandleHook(ctx core.ActionHookContext) error

func (*PurgeQueue) HandleWebhook 

func (c *PurgeQueue) HandleWebhook(ctx core.WebhookRequestContext) (int, *core.WebhookResponseBody, error)

func (*PurgeQueue) Hooks added in v0.18.0 

func (c *PurgeQueue) Hooks() []core.Hook

func (*PurgeQueue) Icon 

func (c *PurgeQueue) Icon() string

func (*PurgeQueue) Label 

func (c *PurgeQueue) Label() string

func (*PurgeQueue) Name 

func (c *PurgeQueue) Name() string

func (*PurgeQueue) OutputChannels 

func (c *PurgeQueue) OutputChannels(configuration any) []core.OutputChannel

func (*PurgeQueue) ProcessQueueItem 

func (c *PurgeQueue) ProcessQueueItem(ctx core.ProcessQueueContext) (*uuid.UUID, error)

func (*PurgeQueue) Setup 

func (c *PurgeQueue) Setup(ctx core.SetupContext) error

type PurgeQueueConfiguration 

type PurgeQueueConfiguration struct {
	Region string `json:"region" mapstructure:"region"`
	Queue  string `json:"queue" mapstructure:"queue"`
}

type Queue 

type Queue struct {
	URL  string
	Name string
}

type SendMessage 

type SendMessage struct{}

func (*SendMessage) Cancel 

func (c *SendMessage) Cancel(ctx core.ExecutionContext) error

func (*SendMessage) Cleanup 

func (c *SendMessage) Cleanup(ctx core.SetupContext) error

func (*SendMessage) Color 

func (c *SendMessage) Color() string

func (*SendMessage) Configuration 

func (c *SendMessage) Configuration() []configuration.Field

func (*SendMessage) Description 

func (c *SendMessage) Description() string

func (*SendMessage) Documentation 

func (c *SendMessage) Documentation() string

func (*SendMessage) ExampleOutput 

func (c *SendMessage) ExampleOutput() map[string]any

func (*SendMessage) Execute 

func (c *SendMessage) Execute(ctx core.ExecutionContext) error

func (*SendMessage) HandleHook added in v0.18.0 

func (c *SendMessage) HandleHook(ctx core.ActionHookContext) error

func (*SendMessage) HandleWebhook 

func (c *SendMessage) HandleWebhook(ctx core.WebhookRequestContext) (int, *core.WebhookResponseBody, error)

func (*SendMessage) Hooks added in v0.18.0 

func (c *SendMessage) Hooks() []core.Hook

func (*SendMessage) Icon 

func (c *SendMessage) Icon() string

func (*SendMessage) Label 

func (c *SendMessage) Label() string

func (*SendMessage) Name 

func (c *SendMessage) Name() string

func (*SendMessage) OutputChannels 

func (c *SendMessage) OutputChannels(configuration any) []core.OutputChannel

func (*SendMessage) ProcessQueueItem 

func (c *SendMessage) ProcessQueueItem(ctx core.ProcessQueueContext) (*uuid.UUID, error)

func (*SendMessage) Setup 

func (c *SendMessage) Setup(ctx core.SetupContext) error

type SendMessageConfiguration 

type SendMessageConfiguration struct {
	Region string  `json:"region" mapstructure:"region"`
	Queue  string  `json:"queue" mapstructure:"queue"`
	Format string  `json:"format" mapstructure:"format"`
	JSON   *any    `json:"json" mapstructure:"json"`
	XML    *string `json:"xml" mapstructure:"xml"`
	Text   *string `json:"text" mapstructure:"text"`
}

Source Files

View all Source files

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.