Documentation
¶
Index ¶
- Variables
- func QueueUpdater(config *config.Config, msg *queue.MessageBody) error
- type 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.SNSTopic) (output *cloudformation.UpdateStackOutput, err error)
- func (s *Cloudformation) WaitUntilStackDeleted() (err error)
- type Controller
Constants ¶
This section is empty.
Variables ¶
var Resource = opkit.CustomResource{ Name: "snstopic", Plural: "snstopics", Group: awsapi.GroupName, Version: awsapi.Version, Scope: apiextensionsv1beta1.NamespaceScoped, Kind: reflect.TypeOf(awsV1alpha1.SNSTopic{}).Name(), ShortNames: []string{ "sns", "topic", "topics", }, }
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 {
SNSTopic *awsV1alpha1.SNSTopic
// contains filtered or unexported fields
}
Cloudformation defines the snstopic cfts
func New ¶
func New(config *config.Config, snstopic *awsV1alpha1.SNSTopic, 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.SNSTopic) (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
Source Files