Skip to content

Commit

Permalink
Add ElasticSearch Domain and SQS Queue
Browse files Browse the repository at this point in the history
  • Loading branch information
huit-tvachon authored and tomvachon committed Mar 5, 2018
1 parent 100cc7b commit 3926033
Show file tree
Hide file tree
Showing 2 changed files with 10 additions and 10 deletions.
8 changes: 4 additions & 4 deletions resources/elasticsearchservice-domain.go
Original file line number Diff line number Diff line change
Expand Up @@ -7,7 +7,7 @@ import (

type ESDomain struct {
svc *elasticsearchservice.ElasticsearchService
domainname *string
domainName *string
}

func init() {
Expand All @@ -27,7 +27,7 @@ func ListESDomains(sess *session.Session) ([]Resource, error) {
for _, domain := range resp.DomainNames {
resources = append(resources, &ESDomain{
svc: svc,
domainname: domain.DomainName,
domainName: domain.DomainName,
})
}

Expand All @@ -37,12 +37,12 @@ func ListESDomains(sess *session.Session) ([]Resource, error) {
func (f *ESDomain) Remove() error {

_, err := f.svc.DeleteElasticsearchDomain(&elasticsearchservice.DeleteElasticsearchDomainInput{
DomainName: f.domainname,
DomainName: f.domainName,
})

return err
}

func (f *ESDomain) String() string {
return *f.domainname
return *f.domainName
}
12 changes: 6 additions & 6 deletions resources/sqs-queues.go
Original file line number Diff line number Diff line change
Expand Up @@ -7,14 +7,14 @@ import (

type SQSQueue struct {
svc *sqs.SQS
queueurl *string
queueURL *string
}

func init() {
register("SQSQueue", ListSqsQueues)
register("SQSQueue", ListSQSQueues)
}

func ListSqsQueues(sess *session.Session) ([]Resource, error) {
func ListSQSQueues(sess *session.Session) ([]Resource, error) {
svc := sqs.New(sess)

params := &sqs.ListQueuesInput{}
Expand All @@ -27,7 +27,7 @@ func ListSqsQueues(sess *session.Session) ([]Resource, error) {
for _, queue := range resp.QueueUrls {
resources = append(resources, &SQSQueue{
svc: svc,
queueurl: queue,
queueURL: queue,
})
}

Expand All @@ -37,12 +37,12 @@ func ListSqsQueues(sess *session.Session) ([]Resource, error) {
func (f *SQSQueue) Remove() error {

_, err := f.svc.DeleteQueue(&sqs.DeleteQueueInput{
QueueUrl: f.queueurl,
QueueUrl: f.queueURL,
})

return err
}

func (f *SQSQueue) String() string {
return *f.queueurl
return *f.queueURL
}

0 comments on commit 3926033

Please sign in to comment.