rdscluster

Documentation

Index

• Variables
• func New(subject string, body []byte, cryptoKey string) ernestaws.Event
• type Collection
  • func (col *Collection) Complete()
  • func (col *Collection) Create() error
  • func (col *Collection) Delete() error
  • func (col *Collection) Error(err error)
  • func (col *Collection) Find() error
  • func (col *Collection) Get() error
  • func (col *Collection) GetBody() []byte
  • func (col *Collection) GetSubject() string
  • func (col *Collection) Process() (err error)
  • func (col *Collection) Update() error
  • func (col *Collection) Validate() error
• type Event
  • func (ev *Event) Complete()
  • func (ev *Event) Create() error
  • func (ev *Event) Delete() error
  • func (ev *Event) Error(err error)
  • func (ev *Event) Find() error
  • func (ev *Event) Get() error
  • func (ev *Event) GetBody() []byte
  • func (ev *Event) GetSubject() string
  • func (ev *Event) Process() (err error)
  • func (ev *Event) Update() error
  • func (ev *Event) Validate() error

Variables

var (
	// ErrDatacenterIDInvalid ...
	ErrDatacenterIDInvalid = errors.New("Datacenter VPC ID invalid")
	// ErrDatacenterRegionInvalid ...
	ErrDatacenterRegionInvalid = errors.New("Datacenter Region invalid")
	// ErrDatacenterCredentialsInvalid ...
	ErrDatacenterCredentialsInvalid = errors.New("Datacenter credentials invalid")
	// ErrRDSClusterNameInvalid ...
	ErrRDSClusterNameInvalid = errors.New("RDS cluster name invalid")
	// ErrRDSClusterEngineTypeInvalid ...
	ErrRDSClusterEngineTypeInvalid = errors.New("RDS cluster engine invalid")
)

Functions

func New

func New(subject string, body []byte, cryptoKey string) ernestaws.Event

New : Constructor

Types

type Collection

type Collection struct {
	ProviderType       string            `json:"_provider"`
	ComponentType      string            `json:"_component"`
	ComponentID        string            `json:"_component_id"`
	State              string            `json:"_state"`
	Action             string            `json:"_action"`
	Service            string            `json:"service"`
	AWSAccessKeyID     string            `json:"aws_access_key_id"`
	AWSSecretAccessKey string            `json:"aws_secret_access_key"`
	DatacenterRegion   string            `json:"datacenter_region"`
	Tags               map[string]string `json:"tags"`
	Results            []interface{}     `json:"components"`
	ErrorMessage       string            `json:"error,omitempty"`
	Subject            string            `json:"-"`
	Body               []byte            `json:"-"`
	CryptoKey          string            `json:"-"`
}

Collection ....

func (*Collection) Complete

func (col *Collection) Complete()

Complete : sets the state of the event to completed

func (*Collection) Create

func (col *Collection) Create() error

Create : Creates an object on aws

func (*Collection) Delete

func (col *Collection) Delete() error

Delete : Delete an object on aws

func (*Collection) Error

func (col *Collection) Error(err error)

Error : Will respond the current event with an error

func (*Collection) Find

func (col *Collection) Find() error

Find : Find rds clusters on aws

func (*Collection) Get

func (col *Collection) Get() error

Get : Gets a object on aws

func (*Collection) GetBody

func (col *Collection) GetBody() []byte

GetBody : Gets the body for this event

func (*Collection) GetSubject

func (col *Collection) GetSubject() string

GetSubject : Gets the subject for this event

func (*Collection) Process

func (col *Collection) Process() (err error)

Process : starts processing the current message

func (*Collection) Update

func (col *Collection) Update() error

Update : Updates an object on aws

func (*Collection) Validate

func (col *Collection) Validate() error

Validate checks if all criteria are met

type Event

type Event struct {
	ProviderType        string            `json:"_provider"`
	ComponentType       string            `json:"_component"`
	ComponentID         string            `json:"_component_id"`
	State               string            `json:"_state"`
	Action              string            `json:"_action"`
	ARN                 *string           `json:"arn"`
	Name                *string           `json:"name"`
	Engine              *string           `json:"engine"`
	EngineVersion       *string           `json:"engine_version,omitempty"`
	Port                *int64            `json:"port,omitempty"`
	Endpoint            *string           `json:"endpoint,omitempty"`
	AvailabilityZones   []*string         `json:"availability_zones"`
	SecurityGroups      []string          `json:"security_groups"`
	SecurityGroupAWSIDs []*string         `json:"security_group_aws_ids"`
	Networks            []string          `json:"networks"`
	NetworkAWSIDs       []*string         `json:"network_aws_ids"`
	DatabaseName        *string           `json:"database_name,omitempty"`
	DatabaseUsername    *string           `json:"database_username,omitempty"`
	DatabasePassword    *string           `json:"database_password,omitempty"`
	BackupRetention     *int64            `json:"backup_retention,omitempty"`
	BackupWindow        *string           `json:"backup_window,omitempty"`
	MaintenanceWindow   *string           `json:"maintenance_window,omitempty"`
	ReplicationSource   *string           `json:"replication_source,omitempty"`
	FinalSnapshot       *bool             `json:"final_snapshot"`
	Tags                map[string]string `json:"tags"`
	DatacenterType      string            `json:"datacenter_type"`
	DatacenterName      string            `json:"datacenter_name"`
	DatacenterRegion    string            `json:"datacenter_region"`
	AccessKeyID         string            `json:"aws_access_key_id"`
	SecretAccessKey     string            `json:"aws_secret_access_key"`
	Service             string            `json:"service"`
	ErrorMessage        string            `json:"error,omitempty"`
	Subject             string            `json:"-"`
	Body                []byte            `json:"-"`
	CryptoKey           string            `json:"-"`
}

Event stores the network data

func (*Event) Complete

func (ev *Event) Complete()

Complete : sets the state of the event to completed

func (*Event) Create

func (ev *Event) Create() error

Create : Creates a nat object on aws

func (*Event) Delete

func (ev *Event) Delete() error

Delete : Deletes a nat object on aws

func (*Event) Error

func (ev *Event) Error(err error)

Error : Will respond the current event with an error

func (*Event) Find

func (ev *Event) Find() error

Find : Find an object on aws

func (*Event) Get

func (ev *Event) Get() error

Get : Gets a nat object on aws

func (*Event) GetBody

func (ev *Event) GetBody() []byte

GetBody : Gets the body for this event

func (*Event) GetSubject

func (ev *Event) GetSubject() string

GetSubject : Gets the subject for this event

func (*Event) Process

func (ev *Event) Process() (err error)

Process : starts processing the current message

func (*Event) Update

func (ev *Event) Update() error

Update : Updates a nat object on aws

func (*Event) Validate

func (ev *Event) Validate() error

Validate checks if all criteria are met