-
Notifications
You must be signed in to change notification settings - Fork 10
/
instanceprofiles.go
73 lines (62 loc) · 2.08 KB
/
instanceprofiles.go
1
2
3
4
5
6
7
8
9
10
11
12
13
14
15
16
17
18
19
20
21
22
23
24
25
26
27
28
29
30
31
32
33
34
35
36
37
38
39
40
41
42
43
44
45
46
47
48
49
50
51
52
53
54
55
56
57
58
59
60
61
62
63
64
65
66
67
68
69
70
71
72
73
package main
import (
"encoding/json"
"log"
"github.com/aws/aws-sdk-go/service/iam"
)
type instanceProfileList struct {
*iam.ListInstanceProfilesOutput
}
type instanceProfileNodes []instanceProfileNode
type instanceProfileNode struct {
UID string `json:"uid,omitempty"`
Type []string `json:"dgraph.type,omitempty"`
Name string `json:"name,omitempty"` // This field is only for Ratel Viz
Region string `json:"Region,omitempty"`
OwnerID string `json:"OwnerId,omitempty"`
OwnerName string `json:"OwnerName,omitempty"`
Service string `json:"Service,omitempty"`
InstanceProfileID string `json:"InstanceProfileId,omitempty"`
InstanceProfileName string `json:"InstanceProfileName,omitempty"`
Arn string `json:"Arn,omitempty"`
}
func (c *connector) listInstanceProfiles() instanceProfileList {
defer c.waitGroup.Done()
log.Println("List InstanceProfiles")
response, err := iam.New(c.awsSession).ListInstanceProfiles(&iam.ListInstanceProfilesInput{})
if err != nil {
log.Fatal(err)
}
return instanceProfileList{response}
}
func (list instanceProfileList) addNodes(c *connector) {
defer c.waitGroup.Done()
if len(list.InstanceProfiles) == 0 {
return
}
log.Println("Add InstanceProfiles Nodes")
a := make(instanceProfileNodes, 0, len(list.InstanceProfiles))
for _, i := range list.InstanceProfiles {
var b instanceProfileNode
b.Service = "iam"
b.Region = c.awsRegion
b.OwnerID = c.awsAccountID
b.OwnerName = c.awsAccountName
b.Type = []string{"InstanceProfile"}
b.Name = *i.InstanceProfileName
b.InstanceProfileName = *i.InstanceProfileName
b.InstanceProfileID = *i.InstanceProfileId
b.Arn = *i.Arn
a = append(a, b)
}
c.dgraphAddNodes(a)
c.stats.NumberOfNodes += len(a)
m := make(map[string]instanceProfileNodes)
n := make(map[string]string)
json.Unmarshal(c.dgraphQuery("InstanceProfile"), &m)
for _, i := range m["list"] {
n[i.InstanceProfileID] = i.UID
n[i.InstanceProfileName] = i.UID
}
c.ressources["InstanceProfiles"] = n
}