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
Constants ¶
This section is empty.
Variables ¶
View Source
var ( // ErrDatacenterIDInvalid ... ErrDatacenterIDInvalid = errors.New("Datacenter VPC ID invalid") // ErrDatacenterRegionInvalid ... ErrDatacenterRegionInvalid = errors.New("Datacenter Region invalid") // ErrDatacenterCredentialsInvalid ... ErrDatacenterCredentialsInvalid = errors.New("Datacenter credentials invalid") // ErrNetworkSubnetInvalid ... ErrNetworkSubnetInvalid = errors.New("Network subnet invalid") // ErrNetworkAWSIDInvalid ... ErrNetworkAWSIDInvalid = errors.New("Network aws id invalid") )
Functions ¶
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"`
AccessKeyID string `json:"aws_access_key_id"`
SecretAccessKey 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) Error ¶
func (col *Collection) Error(err error)
Error : Will respond the current event with an error
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) 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"`
IAMInstanceProfileAWSID *string `json:"iam_instance_profile_aws_id"`
IAMInstanceProfileARN *string `json:"iam_instance_profile_arn"`
Name *string `json:"name"`
Roles []*string `json:"roles"`
Path *string `json:"path"`
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) GetSubject ¶
GetSubject : Gets the subject for this event
Click to show internal directories.
Click to hide internal directories.