ec2

May 18, 2020

Changes in this version

+ func Handle(ctx context.Context, evt Event) (bool, error)

+ func Running()

+ type ChangeRecordInput struct

+ Action string

+ Name string

+ TTL int64

+ Type string

+ Value string

+ Zone string

+ type Config map[string]string

+ func NewConfig() Config

+ type Database interface

+ Find func(string) (*ec2.Instance, error)

+ Insert func(*ec2.Instance) error

+ Remove func(string) error

+ type Event struct

+ Account string

+ Detail EventDetail

+ DetailType string

+ ID string

+ Region string

+ Resources []string

+ Source string

+ Test bool

+ Time string

+ Version string

+ type EventDetail struct

+ Instance string

+ State string

+ type Handler struct

+ Max time.Duration

+ Poll time.Duration

+ func NewHandler(evt Event, ctx context.Context, cfg Config, svc Service, db Database) *Handler

+ func (h *Handler) Attach(instance *ec2.Instance) error

+ func (h *Handler) AttachAddress(instance *ec2.Instance, tagName, tagValue string) error

+ func (h *Handler) AttachRecord(instance *ec2.Instance, tagName, tagValue string) error

+ func (h *Handler) AttachVolume(instance *ec2.Instance, tagName, tagValue string) error

+ func (h *Handler) Detach(instance *ec2.Instance) error

+ func (h *Handler) Remove(id string) error

+ func (h *Handler) Retrieve(id string) (*ec2.Instance, error)

+ func (h *Handler) Running() error

+ func (h *Handler) Store(instance *ec2.Instance) error

+ func (h *Handler) Terminated() error

+ func (h *Handler) Wait(id string) (*ec2.Instance, error)

+ type InstanceDatabase struct

+ func NewDatabase(table string) *InstanceDatabase

+ func (d *InstanceDatabase) Find(id string) (*ec2.Instance, error)

+ func (d *InstanceDatabase) Insert(i *ec2.Instance) error

+ func (d *InstanceDatabase) Remove(id string) error

+ type InstanceService struct

+ Region string

+ func NewService(region string) *InstanceService

+ func (s *InstanceService) AttachAddress(instance *ec2.Instance, address *ec2.Address) error

+ func (s *InstanceService) AttachRecord(id, tagName, tagValue string) error

+ func (s *InstanceService) AttachVolume(instance *ec2.Instance, volume *ec2.Volume) error

+ func (s *InstanceService) ChangeRecord(change *ChangeRecordInput) error

+ func (s *InstanceService) FindAddress(id, tagName, tagValue string) (*ec2.Address, error)

+ func (s *InstanceService) FindVolume(id, tagName, tagValue string) (*ec2.Volume, error)

+ func (s *InstanceService) GetInstance(id string) (*ec2.Instance, error)

+ func (s *InstanceService) GetInstanceZone(id string) (string, error)

+ func (s *InstanceService) GetTags(raw []*ec2.Tag) map[string]string

+ type Service interface

+ AttachAddress func(*ec2.Instance, *ec2.Address) error

+ AttachRecord func(id, tagName, tagValue string) error

+ AttachVolume func(*ec2.Instance, *ec2.Volume) error

+ FindAddress func(id, tagName, tagValue string) (*ec2.Address, error)

+ FindVolume func(id, tagName, tagValue string) (*ec2.Volume, error)

+ GetInstance func(id string) (*ec2.Instance, error)

+ GetInstanceZone func(id string) (string, error)

+ GetTags func([]*ec2.Tag) map[string]string