awsservices

package
v0.1.2 Latest Latest
Warning

This package is not in the latest version of its module.

 Go to latest Published: Aug 17, 2017 License: Apache-2.0 Imports: 67 Imported by: 0

Documentation

Index

Constants

View Source 
const (
	PARENT_OF = iota // default
	APPLIES_ON
	DEPENDING_ON
)
View Source 
const ImageQuerySpec = "owner:distro:variant:arch:virtualization:store"

Variables

View Source 
var (
	Platforms = map[string]Platform{
		"canonical":       Canonical,
		"redhat":          RedHat,
		"debian":          Debian,
		"amazonlinux":     AmazonLinux,
		"suselinux":       SuseLinux,
		"microsoftserver": MicrosoftServer,
	}

	Canonical = Platform{
		Name: "canonical", Id: "099720109477", DistroName: "ubuntu", LatestVariant: "xenial",
		MatchFunc: func(s string, d Distro) bool {
			return strings.HasPrefix(s, fmt.Sprintf("%s/images/%s-ssd/%s-%s", d.Name, d.Virt, d.Name, d.Variant))
		},
	}

	RedHat = Platform{
		Name: "redhat", Id: "309956199498", DistroName: "rhel", LatestVariant: "7.3",
		MatchFunc: func(s string, d Distro) bool {
			return strings.Contains(s, fmt.Sprintf("%s-%s", d.Name, d.Variant))
		},
	}

	Debian = Platform{
		Name: "debian", Id: "379101102735", DistroName: "debian", LatestVariant: "jessie",
		MatchFunc: func(s string, d Distro) bool {
			return strings.HasPrefix(s, fmt.Sprintf("%s-%s", d.Name, d.Variant))
		},
	}

	AmazonLinux = Platform{
		Name: "amazonlinux", Id: "137112412989", LatestVariant: "hvm",
		MatchFunc: func(s string, d Distro) bool {
			return strings.HasPrefix(s, fmt.Sprintf("amzn-ami-%s", d.Variant))
		},
	}

	SuseLinux = Platform{
		Name: "suselinux", Id: "013907871322", LatestVariant: "sles-12",
		MatchFunc: func(s string, d Distro) bool {
			return strings.HasPrefix(s, fmt.Sprintf("suse-%s", d.Variant))
		},
	}

	MicrosoftServer = Platform{
		Name: "microsoftserver", Id: "801119661308", LatestVariant: "Windows_Server-2016",
		MatchFunc: func(s string, d Distro) bool {
			return strings.HasPrefix(s, fmt.Sprintf("%s", d.Variant))
		},
	}

	SupportedAMIOwners []string
)
View Source 
var APIPerResourceType = map[string]string{
	"instance":            "ec2",
	"subnet":              "ec2",
	"vpc":                 "ec2",
	"keypair":             "ec2",
	"securitygroup":       "ec2",
	"volume":              "ec2",
	"internetgateway":     "ec2",
	"natgateway":          "ec2",
	"routetable":          "ec2",
	"availabilityzone":    "ec2",
	"image":               "ec2",
	"importimagetask":     "ec2",
	"elasticip":           "ec2",
	"snapshot":            "ec2",
	"loadbalancer":        "elbv2",
	"targetgroup":         "elbv2",
	"listener":            "elbv2",
	"database":            "rds",
	"dbsubnetgroup":       "rds",
	"launchconfiguration": "autoscaling",
	"scalinggroup":        "autoscaling",
	"scalingpolicy":       "autoscaling",
	"repository":          "ecr",
	"containercluster":    "ecs",
	"containertask":       "ecs",
	"container":           "ecs",
	"containerinstance":   "ecs",
	"user":                "iam",
	"group":               "iam",
	"role":                "iam",
	"policy":              "iam",
	"accesskey":           "iam",
	"instanceprofile":     "iam",
	"bucket":              "s3",
	"s3object":            "s3",
	"subscription":        "sns",
	"topic":               "sns",
	"queue":               "sqs",
	"zone":                "route53",
	"record":              "route53",
	"function":            "lambda",
	"metric":              "cloudwatch",
	"alarm":               "cloudwatch",
	"distribution":        "cloudfront",
	"stack":               "cloudformation",
}
View Source 
var (
	AccessService, InfraService, StorageService, MessagingService, DnsService, LambdaService, MonitoringService, CdnService, CloudformationService cloud.Service
)
View Source 
var DefaultNetworkMonitor = &NetworkMonitor{requests: make(map[*request.Request]*req)}
View Source 
var GlobalServices = []string{
	"access",
	"dns",
	"cdn",
}
View Source 
var ResourceTypes = []string{
	"instance",
	"subnet",
	"vpc",
	"keypair",
	"securitygroup",
	"volume",
	"internetgateway",
	"natgateway",
	"routetable",
	"availabilityzone",
	"image",
	"importimagetask",
	"elasticip",
	"snapshot",
	"loadbalancer",
	"targetgroup",
	"listener",
	"database",
	"dbsubnetgroup",
	"launchconfiguration",
	"scalinggroup",
	"scalingpolicy",
	"repository",
	"containercluster",
	"containertask",
	"container",
	"containerinstance",
	"user",
	"group",
	"role",
	"policy",
	"accesskey",
	"instanceprofile",
	"bucket",
	"s3object",
	"subscription",
	"topic",
	"queue",
	"zone",
	"record",
	"function",
	"metric",
	"alarm",
	"distribution",
	"stack",
}
View Source 
var ServiceNames = []string{
	"infra",
	"access",
	"storage",
	"messaging",
	"dns",
	"lambda",
	"monitoring",
	"cdn",
	"cloudformation",
}
View Source 
var ServicePerAPI = map[string]string{
	"ec2":                    "infra",
	"elbv2":                  "infra",
	"rds":                    "infra",
	"autoscaling":            "infra",
	"ecr":                    "infra",
	"ecs":                    "infra",
	"applicationautoscaling": "infra",
	"iam":                    "access",
	"sts":                    "access",
	"s3":                     "storage",
	"sns":                    "messaging",
	"sqs":                    "messaging",
	"route53":                "dns",
	"lambda":                 "lambda",
	"cloudwatch":             "monitoring",
	"cloudfront":             "cdn",
	"cloudformation":         "cloudformation",
}
View Source 
var ServicePerResourceType = map[string]string{
	"instance":            "infra",
	"subnet":              "infra",
	"vpc":                 "infra",
	"keypair":             "infra",
	"securitygroup":       "infra",
	"volume":              "infra",
	"internetgateway":     "infra",
	"natgateway":          "infra",
	"routetable":          "infra",
	"availabilityzone":    "infra",
	"image":               "infra",
	"importimagetask":     "infra",
	"elasticip":           "infra",
	"snapshot":            "infra",
	"loadbalancer":        "infra",
	"targetgroup":         "infra",
	"listener":            "infra",
	"database":            "infra",
	"dbsubnetgroup":       "infra",
	"launchconfiguration": "infra",
	"scalinggroup":        "infra",
	"scalingpolicy":       "infra",
	"repository":          "infra",
	"containercluster":    "infra",
	"containertask":       "infra",
	"container":           "infra",
	"containerinstance":   "infra",
	"user":                "access",
	"group":               "access",
	"role":                "access",
	"policy":              "access",
	"accesskey":           "access",
	"instanceprofile":     "access",
	"bucket":              "storage",
	"s3object":            "storage",
	"subscription":        "messaging",
	"topic":               "messaging",
	"queue":               "messaging",
	"zone":                "dns",
	"record":              "dns",
	"function":            "lambda",
	"metric":              "monitoring",
	"alarm":               "monitoring",
	"distribution":        "cdn",
	"stack":               "cloudformation",
}

Functions

func GetCloudServicesForAPIs 

func GetCloudServicesForAPIs(apis ...string) (services []cloud.Service)

func GetCloudServicesForTypes 

func GetCloudServicesForTypes(types ...string) (services []cloud.Service)

func Init 

func Init(conf map[string]interface{}, log *logger.Logger, profileSetterCallback func(val string) error) error

func IsGlobalService 

func IsGlobalService(name string) bool

func NewAccess 

func NewAccess(sess *session.Session, awsconf config, log *logger.Logger) cloud.Service

func NewCdn 

func NewCdn(sess *session.Session, awsconf config, log *logger.Logger) cloud.Service

func NewCloudformation 

func NewCloudformation(sess *session.Session, awsconf config, log *logger.Logger) cloud.Service

func NewDns 

func NewDns(sess *session.Session, awsconf config, log *logger.Logger) cloud.Service

func NewDriver 

func NewDriver(region, profile string, log ...*logger.Logger) (driver.Driver, error)

func NewInfra 

func NewInfra(sess *session.Session, awsconf config, log *logger.Logger) cloud.Service

func NewLambda 

func NewLambda(sess *session.Session, awsconf config, log *logger.Logger) cloud.Service

func NewMessaging 

func NewMessaging(sess *session.Session, awsconf config, log *logger.Logger) cloud.Service

func NewMonitoring 

func NewMonitoring(sess *session.Session, awsconf config, log *logger.Logger) cloud.Service

func NewStorage 

func NewStorage(sess *session.Session, awsconf config, log *logger.Logger) cloud.Service

func ResolveRegionAndAmiFromEnv 

func ResolveRegionAndAmiFromEnv() (region string, ami string)

func ResourceTypesPerServiceName 

func ResourceTypesPerServiceName() map[string][]string

Types

type Access 

type Access struct {
	iamiface.IAMAPI
	stsiface.STSAPI
	// contains filtered or unexported fields
}

func (*Access) Drivers 

func (s *Access) Drivers() []driver.Driver

func (*Access) FetchByType 

func (s *Access) FetchByType(t string) (*graph.Graph, error)

func (*Access) FetchResources 

func (s *Access) FetchResources() (*graph.Graph, error)

func (*Access) GetIdentity 

func (s *Access) GetIdentity() (*Identity, error)

func (*Access) GetUserPolicies 

func (s *Access) GetUserPolicies(username string) (*UserPolicies, error)

func (*Access) IsSyncDisabled 

func (s *Access) IsSyncDisabled() bool

func (*Access) Name 

func (s *Access) Name() string

func (*Access) Region 

func (s *Access) Region() string

func (*Access) ResourceTypes 

func (s *Access) ResourceTypes() []string

type AwsImage 

type AwsImage struct {
	Id                 string
	Owner              string
	Location           string
	Type               string
	Architecture       string
	VirtualizationType string
	Name               string
	Created            time.Time
	Hypervisor         string
	Store              string
}

type Cdn 

type Cdn struct {
	cloudfrontiface.CloudFrontAPI
	// contains filtered or unexported fields
}

func (*Cdn) Drivers 

func (s *Cdn) Drivers() []driver.Driver

func (*Cdn) FetchByType 

func (s *Cdn) FetchByType(t string) (*graph.Graph, error)

func (*Cdn) FetchResources 

func (s *Cdn) FetchResources() (*graph.Graph, error)

func (*Cdn) IsSyncDisabled 

func (s *Cdn) IsSyncDisabled() bool

func (*Cdn) Name 

func (s *Cdn) Name() string

func (*Cdn) Region 

func (s *Cdn) Region() string

func (*Cdn) ResourceTypes 

func (s *Cdn) ResourceTypes() []string

type Cloudformation 

type Cloudformation struct {
	cloudformationiface.CloudFormationAPI
	// contains filtered or unexported fields
}

func (*Cloudformation) Drivers 

func (s *Cloudformation) Drivers() []driver.Driver

func (*Cloudformation) FetchByType 

func (s *Cloudformation) FetchByType(t string) (*graph.Graph, error)

func (*Cloudformation) FetchResources 

func (s *Cloudformation) FetchResources() (*graph.Graph, error)

func (*Cloudformation) IsSyncDisabled 

func (s *Cloudformation) IsSyncDisabled() bool

func (*Cloudformation) Name 

func (s *Cloudformation) Name() string

func (*Cloudformation) Region 

func (s *Cloudformation) Region() string

func (*Cloudformation) ResourceTypes 

func (s *Cloudformation) ResourceTypes() []string

type Distro 

type Distro struct {
	Name, Variant, Arch, Virt, Store string
}

type Dns 

type Dns struct {
	route53iface.Route53API
	// contains filtered or unexported fields
}

func (*Dns) Drivers 

func (s *Dns) Drivers() []driver.Driver

func (*Dns) FetchByType 

func (s *Dns) FetchByType(t string) (*graph.Graph, error)

func (*Dns) FetchResources 

func (s *Dns) FetchResources() (*graph.Graph, error)

func (*Dns) IsSyncDisabled 

func (s *Dns) IsSyncDisabled() bool

func (*Dns) Name 

func (s *Dns) Name() string

func (*Dns) Region 

func (s *Dns) Region() string

func (*Dns) ResourceTypes 

func (s *Dns) ResourceTypes() []string

type Identity 

type Identity struct {
	Account, Arn, UserId, ResourceType, ResourcePath, Resource string
}

func (*Identity) IsRoot 

func (i *Identity) IsRoot() bool

func (*Identity) IsUserType 

func (i *Identity) IsUserType() bool

type ImageQuery 

type ImageQuery struct {
	Platform Platform
	Distro   Distro
}

func ParseImageQuery 

func ParseImageQuery(s string) (ImageQuery, error)

func (ImageQuery) String 

func (q ImageQuery) String() string

type ImageResolver 

type ImageResolver struct {
	InfraService *Infra
}

Image resolving allows to find AWS AMIs identifiers specifying what you want instead of an id that is specific to a region. The ami query string specification is as follows:

owner:distro:variant:arch:virtualization:store

Everything optional expect for the owner.

As for now only the main specific owner are taken into account and we deal with bares machines only distribution. Here are some examples:

- canonical:ubuntu:trusty

- redhat:rhel:6.8

- redhat::6.8

- amazonlinux

- suselinux:sles-12

- canonical:::i386

- redhat::::instance-store

The default values are: Arch="x86_64", Virt="hvm", Store="ebs"

func (*ImageResolver) Resolve 

func (r *ImageResolver) Resolve(q ImageQuery) ([]*AwsImage, error)

type Infra 

type Infra struct {
	ec2iface.EC2API
	elbv2iface.ELBV2API
	rdsiface.RDSAPI
	autoscalingiface.AutoScalingAPI
	ecriface.ECRAPI
	ecsiface.ECSAPI
	applicationautoscalingiface.ApplicationAutoScalingAPI
	// contains filtered or unexported fields
}

func (*Infra) Drivers 

func (s *Infra) Drivers() []driver.Driver

func (*Infra) FetchByType 

func (s *Infra) FetchByType(t string) (*graph.Graph, error)

func (*Infra) FetchResources 

func (s *Infra) FetchResources() (*graph.Graph, error)

func (*Infra) IsSyncDisabled 

func (s *Infra) IsSyncDisabled() bool

func (*Infra) Name 

func (s *Infra) Name() string

func (*Infra) Region 

func (s *Infra) Region() string

func (*Infra) ResourceTypes 

func (s *Infra) ResourceTypes() []string

type Lambda 

type Lambda struct {
	lambdaiface.LambdaAPI
	// contains filtered or unexported fields
}

func (*Lambda) Drivers 

func (s *Lambda) Drivers() []driver.Driver

func (*Lambda) FetchByType 

func (s *Lambda) FetchByType(t string) (*graph.Graph, error)

func (*Lambda) FetchResources 

func (s *Lambda) FetchResources() (*graph.Graph, error)

func (*Lambda) IsSyncDisabled 

func (s *Lambda) IsSyncDisabled() bool

func (*Lambda) Name 

func (s *Lambda) Name() string

func (*Lambda) Region 

func (s *Lambda) Region() string

func (*Lambda) ResourceTypes 

func (s *Lambda) ResourceTypes() []string

type Messaging 

type Messaging struct {
	snsiface.SNSAPI
	sqsiface.SQSAPI
	// contains filtered or unexported fields
}

func (*Messaging) Drivers 

func (s *Messaging) Drivers() []driver.Driver

func (*Messaging) FetchByType 

func (s *Messaging) FetchByType(t string) (*graph.Graph, error)

func (*Messaging) FetchResources 

func (s *Messaging) FetchResources() (*graph.Graph, error)

func (*Messaging) IsSyncDisabled 

func (s *Messaging) IsSyncDisabled() bool

func (*Messaging) Name 

func (s *Messaging) Name() string

func (*Messaging) Region 

func (s *Messaging) Region() string

func (*Messaging) ResourceTypes 

func (s *Messaging) ResourceTypes() []string

type Monitoring 

type Monitoring struct {
	cloudwatchiface.CloudWatchAPI
	// contains filtered or unexported fields
}

func (*Monitoring) Drivers 

func (s *Monitoring) Drivers() []driver.Driver

func (*Monitoring) FetchByType 

func (s *Monitoring) FetchByType(t string) (*graph.Graph, error)

func (*Monitoring) FetchResources 

func (s *Monitoring) FetchResources() (*graph.Graph, error)

func (*Monitoring) IsSyncDisabled 

func (s *Monitoring) IsSyncDisabled() bool

func (*Monitoring) Name 

func (s *Monitoring) Name() string

func (*Monitoring) Region 

func (s *Monitoring) Region() string

func (*Monitoring) ResourceTypes 

func (s *Monitoring) ResourceTypes() []string

type NetworkMonitor 

type NetworkMonitor struct {
	// contains filtered or unexported fields
}

func (*NetworkMonitor) DisplayStats 

func (n *NetworkMonitor) DisplayStats(w io.Writer)

type Platform 

type Platform struct {
	Name          string
	Id            string
	DistroName    string
	LatestVariant string
	MatchFunc     func(s string, d Distro) bool
}

type Storage 

type Storage struct {
	s3iface.S3API
	// contains filtered or unexported fields
}

func (*Storage) Drivers 

func (s *Storage) Drivers() []driver.Driver

func (*Storage) FetchByType 

func (s *Storage) FetchByType(t string) (*graph.Graph, error)

func (*Storage) FetchResources 

func (s *Storage) FetchResources() (*graph.Graph, error)

func (*Storage) IsSyncDisabled 

func (s *Storage) IsSyncDisabled() bool

func (*Storage) Name 

func (s *Storage) Name() string

func (*Storage) Region 

func (s *Storage) Region() string

func (*Storage) ResourceTypes 

func (s *Storage) ResourceTypes() []string

type UserPolicies 

type UserPolicies struct {
	Username string
	Inlined  []string
	Attached []string
	ByGroup  map[string][]string
}

Source Files

View all Source files

Jump to

Keyboard shortcuts

? : This menu
/ : Search site
f or F : Jump to
y or Y : Canonical URL
go.dev uses cookies from Google to deliver and enhance the quality of its services and to analyze traffic. Learn more.