sqsqueue

Documentation

Index

• Variables
• func QueueUpdater(config *config.Config, msg *queue.MessageBody) error
• type Cloudformation
  • func New(config *config.Config, sqsqueue *awsV1alpha1.SQSQueue, topicARN string) *Cloudformation
  • func (s *Cloudformation) CreateStack() (output *cloudformation.CreateStackOutput, err error)
  • func (s *Cloudformation) DeleteStack() (err error)
  • func (s *Cloudformation) GetOutputs() (map[string]string, error)
  • func (s *Cloudformation) StackName() string
  • func (s *Cloudformation) UpdateStack(updated *awsV1alpha1.SQSQueue) (output *cloudformation.UpdateStackOutput, err error)
  • func (s *Cloudformation) WaitUntilStackDeleted() (err error)
• type Controller
  • func NewController(config *config.Config, context *opkit.Context, ...) *Controller
  • func (c *Controller) StartWatch(namespace string, stopCh chan struct{}) error

Variables

var Resource = opkit.CustomResource{
	Name:    "sqsqueue",
	Plural:  "sqsqueues",
	Group:   awsapi.GroupName,
	Version: awsapi.Version,
	Scope:   apiextensionsv1beta1.NamespaceScoped,
	Kind:    reflect.TypeOf(awsV1alpha1.SQSQueue{}).Name(),
	ShortNames: []string{
		"sqs",
		"queue",
		"queues",
	},
}

Resource is the object store definition

Functions

func QueueUpdater

func QueueUpdater(config *config.Config, msg *queue.MessageBody) error

QueueUpdater will take the messages from the queue and process them

Types

type Cloudformation

type Cloudformation struct {
	SQSQueue *awsV1alpha1.SQSQueue
	// contains filtered or unexported fields
}

Cloudformation defines the sqsqueue cfts

func New

func New(config *config.Config, sqsqueue *awsV1alpha1.SQSQueue, topicARN string) *Cloudformation

New generates a new object

func (*Cloudformation) CreateStack

func (s *Cloudformation) CreateStack() (output *cloudformation.CreateStackOutput, err error)

CreateStack will create the stack with the supplied params

func (*Cloudformation) DeleteStack

func (s *Cloudformation) DeleteStack() (err error)

DeleteStack will delete the stack

func (*Cloudformation) GetOutputs

func (s *Cloudformation) GetOutputs() (map[string]string, error)

GetOutputs return the stack outputs from the DescribeStacks call

func (*Cloudformation) StackName

func (s *Cloudformation) StackName() string

StackName returns the name of the stack based on the aws-operator-config

func (*Cloudformation) UpdateStack

func (s *Cloudformation) UpdateStack(updated *awsV1alpha1.SQSQueue) (output *cloudformation.UpdateStackOutput, err error)

UpdateStack will update the existing stack

func (*Cloudformation) WaitUntilStackDeleted

func (s *Cloudformation) WaitUntilStackDeleted() (err error)

WaitUntilStackDeleted will delete the stack

type Controller

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

Controller represents a controller object for object store custom resources

func NewController

func NewController(config *config.Config, context *opkit.Context, awsclientset awsclient.ServiceoperatorV1alpha1Interface) *Controller

NewController create controller for watching object store custom resources created

func (*Controller) StartWatch

func (c *Controller) StartWatch(namespace string, stopCh chan struct{}) error

StartWatch watches for instances of Object Store custom resources and acts on them