sqs

Mar 4, 2021

Changes in this version

+ const TagCostAllocation

+ const TagEnvironment

+ const TagName

+ const TagService

+ const TagServiceId

+ var ErrBindingDeadlineExceeded = fmt.Errorf("timeout waiting for the binding stack to reach a success or failed state")

Sep 24, 2020

Changes in this version

type Config

+ AdditionalUserPolicy string

type Provider

+ AdditionalUserPolicy string

type UserTemplateBuilder

+ AdditionalUserPolicy string

Sep 21, 2020

Changes in this version

+ type UserTemplateBuilder struct

+ AccessPolicy AccessPolicy

+ AccessPolicyActions []string

+ BindingID string

+ PermissionsBoundary string

+ PrimaryQueueARN string

+ PrimaryQueueURL string

+ ResourcePrefix string

+ SecondaryQueueARN string

+ SecondaryQueueURL string

+ Tags map[string]string

+ UserPath string

+ func (builder UserTemplateBuilder) Build() (string, error)

+ func (builder UserTemplateBuilder) CredentialsJSON() (string, error)

+ func (builder UserTemplateBuilder) GetAccessPolicy() ([]string, error)

Sep 21, 2020

Changes in this version

+ const ConditionShouldNotUseDLQ

+ const ExtFIFO

+ const ExtStandard

+ const ParamDelaySeconds

+ const ParamMaximumMessageSize

+ const ParamMessageRetentionPeriod

+ const ParamReceiveMessageWaitTimeSeconds

+ const ParamRedriveMaxReceiveCount

+ const ParamVisibilityTimeout

type QueueParams

+ func (params *QueueParams) CreateParams() []*cloudformation.Parameter

+ func (params *QueueParams) UpdateParams() []*cloudformation.Parameter

+ type QueueTemplateBuilder struct

+ FIFOQueue bool

+ QueueName string

+ Tags map[string]string

+ func (params *QueueTemplateBuilder) Build() (string, error)

+ func (params *QueueTemplateBuilder) PrimaryQueueName() string

+ func (params *QueueTemplateBuilder) SecondaryQueueName() string

Sep 18, 2020

Changes in this version

+ type AccessPolicy = string

+ const AccessPolicyConsumer

+ const AccessPolicyFull

+ const AccessPolicyProducer

type UserParams

+ AccessPolicy AccessPolicy

Sep 14, 2020

Changes in this version

+ const OutputCredentialsARN

+ const OutputPrimaryQueueARN

+ const OutputPrimaryQueueURL

+ const OutputSecondaryQueueARN

+ const OutputSecondaryQueueURL

+ const ResourceCredentials

+ const ResourcePrimaryQueue

+ const ResourceSecondaryQueue

type Client

+ GetSecretValueWithContext func(aws.Context, *secretsmanager.GetSecretValueInput, ...request.Option) (*secretsmanager.GetSecretValueOutput, error)

+ type Credentials struct

+ AWSAccessKeyID string

+ AWSRegion string

+ AWSSecretAccessKey string

+ PrimaryQueueURL string

+ SecondaryQueueURL string

type UserParams

+ BindingID string

+ PrimaryQueueARN string

+ PrimaryQueueURL string

+ ResourcePrefix string

+ SecondaryQueueARN string

+ SecondaryQueueURL string

Sep 9, 2020

Changes in this version

+ const OutputAccessKeyID

+ const OutputDeadletterQueueARN

+ const OutputDeadletterQueueURL

+ const OutputMainQueueARN

+ const OutputMainQueueURL

+ const OutputRegion

+ const OutputSecretAccessKey

+ const ResourceAccessKey

+ const ResourceDeadletterQueue

+ const ResourceMainQueue

+ const ResourcePolicy

+ const ResourceUser

+ var BindOperation = "bind"

+ var DeprovisionOperation = "deprovision"

+ var ErrStackNotFound = fmt.Errorf("cloudformation stack does not exist")

+ var ErrUpdateNotSupported = errors.New("Updating the SQS queue is currently not supported")

+ var NoExistErrMatch = "does not exist"

+ var PollingInterval = time.Second * 15

+ var ProvisionOperation = "provision"

+ var UnbindOperation = "unbind"

+ var UpdateOperation = "update"

+ func IsNotFoundError(err error) bool

+ func QueueTemplate(params QueueParams) (*goformation.Template, error)

+ func UserTemplate(params UserParams) (*goformation.Template, error)

+ type AssumeRolePolicyDocument struct

+ Statement []AssumeRolePolicyStatement

+ Version string

+ type AssumeRolePolicyStatement struct

+ Action []string

+ Condition PolicyCondition

+ Effect string

+ Principal PolicyPrincipal

type Client

+ CreateStackWithContext func(aws.Context, *cloudformation.CreateStackInput, ...request.Option) (*cloudformation.CreateStackOutput, error)

+ DeleteStackWithContext func(aws.Context, *cloudformation.DeleteStackInput, ...request.Option) (*cloudformation.DeleteStackOutput, error)

+ DescribeStacksWithContext func(aws.Context, *cloudformation.DescribeStacksInput, ...request.Option) (*cloudformation.DescribeStacksOutput, error)

+ UpdateStackWithContext func(aws.Context, *cloudformation.UpdateStackInput, ...request.Option) (*cloudformation.UpdateStackOutput, error)

type Config

+ PermissionsBoundary string

+ func NewConfig(configJSON []byte) (*Config, error)

+ type PolicyCondition struct

+ StringEquals map[string]string

+ type PolicyDocument struct

+ Statement []PolicyStatement

+ Version string

+ func NewRolePolicyDocument(resources, actions []string) PolicyDocument

+ type PolicyPrincipal struct

+ AWS []string

+ Federated []string

+ type PolicyStatement struct

+ Action []string

+ Effect string

+ Resource []string

+ type Provider struct

+ Client Client

+ Environment string

+ Logger lager.Logger

+ PermissionsBoundary string

+ ResourcePrefix string

+ Timeout time.Duration

+ func (s *Provider) Bind(ctx context.Context, bindData provideriface.BindData) (*domain.Binding, error)

+ func (s *Provider) Deprovision(ctx context.Context, deprovisionData provideriface.DeprovisionData) (*domain.DeprovisionServiceSpec, error)

+ func (s *Provider) GetBinding(ctx context.Context, getBindingData provideriface.GetBindData) (*domain.GetBindingSpec, error)

+ func (s *Provider) LastBindingOperation(ctx context.Context, ...) (*domain.LastOperation, error)

+ func (s *Provider) LastOperation(ctx context.Context, lastOperationData provideriface.LastOperationData) (*domain.LastOperation, error)

+ func (s *Provider) Provision(ctx context.Context, provisionData provideriface.ProvisionData) (*domain.ProvisionedServiceSpec, error)

+ func (s *Provider) Unbind(ctx context.Context, unbindData provideriface.UnbindData) (*domain.UnbindSpec, error)

+ func (s *Provider) Update(ctx context.Context, updateData provideriface.UpdateData) (*domain.UpdateServiceSpec, error)

+ type QueueParams struct

+ ContentBasedDeduplication bool

+ DelaySeconds int

+ FifoQueue bool

+ MaximumMessageSize int

+ MessageRetentionPeriod int

+ QueueName string

+ ReceiveMessageWaitTimeSeconds int

+ RedriveMaxReceiveCount int

+ Tags map[string]string

+ VisibilityTimeout int

+ type UserParams struct

+ DLQueueARN string

+ PermissionsBoundary string

+ QueueARN string

+ Tags map[string]string

+ UserName string

+ UserPath string

Sep 7, 2020

Changes in this version

+ type Client interface

+ type Config struct

+ AWSRegion string

+ DeployEnvironment string

+ IAMUserPath string

+ ResourcePrefix string

+ Timeout time.Duration

+ func NewSQSClientConfig(configJSON []byte) (*Config, error)

+ type SQSClient struct