aws

package

Go to main page

Versions in this module

v1

v1.1.9

Aug 22, 2020

v1.1.8

Jun 6, 2020

v1.1.7

Apr 18, 2020

Changes in this version

type Cloud

+ func (c *Cloud) AssociateWAFV2(ctx context.Context, resourceArn *string, webACLARN *string) (*wafv2.AssociateWebACLOutput, error)

+ func (c *Cloud) DisassociateWAFV2(ctx context.Context, resourceArn *string) (*wafv2.DisassociateWebACLOutput, error)

+ func (c *Cloud) GetWAFV2WebACLSummary(ctx context.Context, resourceArn *string) (*wafv2.WebACL, error)

+ type WAFV2API interface

+ AssociateWAFV2 func(ctx context.Context, resourceArn *string, webACLId *string) (*wafv2.AssociateWebACLOutput, error)

+ DisassociateWAFV2 func(ctx context.Context, resourceArn *string) (*wafv2.DisassociateWebACLOutput, error)

+ GetWAFV2WebACLSummary func(ctx context.Context, webACLId *string) (*wafv2.WebACL, error)

v1.1.6

Mar 23, 2020

Changes in this version

type Cloud

+ func (c *Cloud) CreateProtection(ctx context.Context, resourceArn *string, protectionName *string) (*shield.CreateProtectionOutput, error)

+ func (c *Cloud) DeleteProtection(ctx context.Context, protectionID *string) (*shield.DeleteProtectionOutput, error)

+ func (c *Cloud) GetProtection(ctx context.Context, resourceArn *string) (*shield.Protection, error)

+ func (c *Cloud) GetSubscriptionStatus(ctx context.Context) (*shield.GetSubscriptionStateOutput, error)

+ func (c *Cloud) ShieldAvailable(ctx context.Context) (bool, error)

+ type ShieldAPI interface

+ CreateProtection func(ctx context.Context, resourceArn *string, protectionName *string) (*shield.CreateProtectionOutput, error)

+ DeleteProtection func(ctx context.Context, protectionID *string) (*shield.DeleteProtectionOutput, error)

+ GetProtection func(ctx context.Context, resourceArn *string) (*shield.Protection, error)

+ GetSubscriptionStatus func(ctx context.Context) (*shield.GetSubscriptionStateOutput, error)

+ ShieldAvailable func(ctx context.Context) (bool, error)

v1.1.5

Jan 14, 2020

Changes in this version

type EC2API

+ GetClusterSubnets func(string) ([]*ec2.Subnet, error)

v1.1.4

Dec 2, 2019

Changes in this version

type Cloud

+ func (c *Cloud) GetVpcID() string

type CloudAPI

+ GetVpcID func() string

v1.1.3

Sep 16, 2019

Changes in this version

type ACMAPI

+ DescribeCertificate func(ctx context.Context, certArn string) (*acm.CertificateDetail, error)

type Cloud

+ func (c *Cloud) DescribeCertificate(ctx context.Context, certArn string) (*acm.CertificateDetail, error)

+ func (c *Cloud) DescribeSecurityGroups(ctx context.Context, input *ec2.DescribeSecurityGroupsInput) ([]*ec2.SecurityGroup, error)

+ func (c *Cloud) GetClusterName() string

type CloudAPI

+ GetClusterName func() string

type EC2API

+ DescribeSecurityGroups func(context.Context, *ec2.DescribeSecurityGroupsInput) ([]*ec2.SecurityGroup, error)

v1.1.2

Mar 1, 2019

Changes in this version

+ const ResourceTypeEnumEC2SecurityGroup

+ const ResourceTypeEnumELBLoadBalancer

type ACMAPI

+ ListCertificates func(status []string) ([]acm.CertificateSummary, error)

type Cloud

+ func (c *Cloud) DescribeNetworkInterfaces(ctx context.Context, input *ec2.DescribeNetworkInterfacesInput) ([]*ec2.NetworkInterface, error)

+ func (c *Cloud) GetVpcWithContext(ctx context.Context) (*ec2.Vpc, error)

+ func (c *Cloud) ListCertificates(status []string) ([]acm.CertificateSummary, error)

type EC2API

+ DescribeNetworkInterfaces func(context.Context, *ec2.DescribeNetworkInterfacesInput) ([]*ec2.NetworkInterface, error)

+ GetVpcWithContext func(context.Context) (*ec2.Vpc, error)

v1.1.1

Jan 18, 2019

Changes in this version

type Cloud

+ func (c *Cloud) AddListenerCertificates(ctx context.Context, i *elbv2.AddListenerCertificatesInput) (*elbv2.AddListenerCertificatesOutput, error)

+ func (c *Cloud) DescribeListenerCertificates(ctx context.Context, lsArn string) ([]*elbv2.Certificate, error)

+ func (c *Cloud) RemoveListenerCertificates(ctx context.Context, i *elbv2.RemoveListenerCertificatesInput) (*elbv2.RemoveListenerCertificatesOutput, error)

type ELBV2API

+ AddListenerCertificates func(context.Context, *elbv2.AddListenerCertificatesInput) (*elbv2.AddListenerCertificatesOutput, error)

+ DescribeListenerCertificates func(context.Context, string) ([]*elbv2.Certificate, error)

+ RemoveListenerCertificates func(context.Context, *elbv2.RemoveListenerCertificatesInput) (*elbv2.RemoveListenerCertificatesOutput, error)

v1.1.0

Jan 15, 2019

v1.0.1

Dec 6, 2018

v1.0.0

Nov 27, 2018

Changes in this version

+ const ResourceTypeEnumELBTargetGroup

+ const TagNameCluster

+ const TagNameSubnetInternalELB

+ const TagNameSubnetPublicELB

+ func Bool(v bool) *bool

+ func BoolMap(src map[string]bool) map[string]*bool

+ func BoolSlice(src []bool) []*bool

+ func BoolValue(v *bool) bool

+ func BoolValueMap(src map[string]*bool) map[string]bool

+ func BoolValueSlice(src []*bool) []bool

+ func Float64(v float64) *float64

+ func Float64Map(src map[string]float64) map[string]*float64

+ func Float64Slice(src []float64) []*float64

+ func Float64Value(v *float64) float64

+ func Float64ValueMap(src map[string]*float64) map[string]float64

+ func Float64ValueSlice(src []*float64) []float64

+ func GetVpcIDFromEC2Metadata(metadata *ec2metadata.EC2Metadata) (string, error)

+ func Int(v int) *int

+ func Int64(v int64) *int64

+ func Int64Map(src map[string]int64) map[string]*int64

+ func Int64Slice(src []int64) []*int64

+ func Int64Value(v *int64) int64

+ func Int64ValueMap(src map[string]*int64) map[string]int64

+ func Int64ValueSlice(src []*int64) []int64

+ func IntMap(src map[string]int) map[string]*int

+ func IntSlice(src []int) []*int

+ func IntValue(v *int) int

+ func IntValueMap(src map[string]*int) map[string]int

+ func IntValueSlice(src []*int) []int

+ func MillisecondsTimeValue(v *int64) time.Time

+ func NewSession(awsconfig *aws.Config, AWSDebug bool, mc metric.Collector, cc *cache.Config) *session.Session

+ func SecondsTimeValue(v *int64) time.Time

+ func String(v string) *string

+ func StringMap(src map[string]string) map[string]*string

+ func StringSlice(src []string) []*string

+ func StringValue(v *string) string

+ func StringValueMap(src map[string]*string) map[string]string

+ func StringValueSlice(src []*string) []string

+ func Time(v time.Time) *time.Time

+ func TimeMap(src map[string]time.Time) map[string]*time.Time

+ func TimeSlice(src []time.Time) []*time.Time

+ func TimeUnixMilli(t time.Time) int64

+ func TimeValue(v *time.Time) time.Time

+ func TimeValueMap(src map[string]*time.Time) map[string]time.Time

+ func TimeValueSlice(src []*time.Time) []time.Time

+ type ACMAPI interface

+ ACMAvailable func() bool

+ StatusACM func() func() error

+ type Cloud struct

+ func (c *Cloud) ACMAvailable() bool

+ func (c *Cloud) AddELBV2TagsWithContext(ctx context.Context, i *elbv2.AddTagsInput) (*elbv2.AddTagsOutput, error)

+ func (c *Cloud) AssociateWAF(ctx context.Context, resourceArn *string, webACLId *string) (*wafregional.AssociateWebACLOutput, error)

+ func (c *Cloud) AuthorizeSecurityGroupIngressWithContext(ctx context.Context, i *ec2.AuthorizeSecurityGroupIngressInput) (*ec2.AuthorizeSecurityGroupIngressOutput, error)

+ func (c *Cloud) CreateEC2TagsWithContext(ctx context.Context, i *ec2.CreateTagsInput) (*ec2.CreateTagsOutput, error)

+ func (c *Cloud) CreateListenerWithContext(ctx context.Context, i *elbv2.CreateListenerInput) (*elbv2.CreateListenerOutput, error)

+ func (c *Cloud) CreateLoadBalancerWithContext(ctx context.Context, i *elbv2.CreateLoadBalancerInput) (*elbv2.CreateLoadBalancerOutput, error)

+ func (c *Cloud) CreateRuleWithContext(ctx context.Context, i *elbv2.CreateRuleInput) (*elbv2.CreateRuleOutput, error)

+ func (c *Cloud) CreateSecurityGroupWithContext(ctx context.Context, i *ec2.CreateSecurityGroupInput) (*ec2.CreateSecurityGroupOutput, error)

+ func (c *Cloud) CreateTargetGroupWithContext(ctx context.Context, i *elbv2.CreateTargetGroupInput) (*elbv2.CreateTargetGroupOutput, error)

+ func (c *Cloud) DeleteEC2TagsWithContext(ctx context.Context, i *ec2.DeleteTagsInput) (*ec2.DeleteTagsOutput, error)

+ func (c *Cloud) DeleteListenersByArn(ctx context.Context, lsArn string) error

+ func (c *Cloud) DeleteLoadBalancerByArn(ctx context.Context, arn string) error

+ func (c *Cloud) DeleteRuleWithContext(ctx context.Context, i *elbv2.DeleteRuleInput) (*elbv2.DeleteRuleOutput, error)

+ func (c *Cloud) DeleteSecurityGroupByID(groupID string) error

+ func (c *Cloud) DeleteTargetGroupByArn(ctx context.Context, arn string) error

+ func (c *Cloud) DeregisterTargetsWithContext(ctx context.Context, i *elbv2.DeregisterTargetsInput) (*elbv2.DeregisterTargetsOutput, error)

+ func (c *Cloud) DescribeELBV2TagsWithContext(ctx context.Context, i *elbv2.DescribeTagsInput) (*elbv2.DescribeTagsOutput, error)

+ func (c *Cloud) DescribeLoadBalancerAttributesWithContext(ctx context.Context, i *elbv2.DescribeLoadBalancerAttributesInput) (*elbv2.DescribeLoadBalancerAttributesOutput, error)

+ func (c *Cloud) DescribeTargetGroupAttributesWithContext(ctx context.Context, i *elbv2.DescribeTargetGroupAttributesInput) (*elbv2.DescribeTargetGroupAttributesOutput, error)

+ func (c *Cloud) DescribeTargetHealthWithContext(ctx context.Context, i *elbv2.DescribeTargetHealthInput) (*elbv2.DescribeTargetHealthOutput, error)

+ func (c *Cloud) DisassociateWAF(ctx context.Context, resourceArn *string) (*wafregional.DisassociateWebACLOutput, error)

+ func (c *Cloud) GetClusterSubnets() (map[string]util.EC2Tags, error)

+ func (c *Cloud) GetInstancesByIDs(instanceIDs []string) ([]*ec2.Instance, error)

+ func (c *Cloud) GetLoadBalancerByArn(ctx context.Context, arn string) (*elbv2.LoadBalancer, error)

+ func (c *Cloud) GetLoadBalancerByName(ctx context.Context, name string) (*elbv2.LoadBalancer, error)

+ func (c *Cloud) GetResourcesByFilters(tagFilters map[string][]string, resourceTypeFilters ...string) ([]string, error)

+ func (c *Cloud) GetRules(ctx context.Context, listenerArn string) ([]*elbv2.Rule, error)

+ func (c *Cloud) GetSecurityGroupByID(groupID string) (*ec2.SecurityGroup, error)

+ func (c *Cloud) GetSecurityGroupByName(groupName string) (*ec2.SecurityGroup, error)

+ func (c *Cloud) GetSecurityGroupsByName(ctx context.Context, names []string) (groups []*ec2.SecurityGroup, err error)

+ func (c *Cloud) GetSubnetsByNameOrID(ctx context.Context, nameOrIDs []string) (subnets []*ec2.Subnet, err error)

+ func (c *Cloud) GetTargetGroupByArn(ctx context.Context, arn string) (*elbv2.TargetGroup, error)

+ func (c *Cloud) GetTargetGroupByName(ctx context.Context, name string) (*elbv2.TargetGroup, error)

+ func (c *Cloud) GetWebACLSummary(ctx context.Context, resourceArn *string) (*waf.WebACLSummary, error)

+ func (c *Cloud) IsNodeHealthy(instanceid string) (bool, error)

+ func (c *Cloud) ListListenersByLoadBalancer(ctx context.Context, lbArn string) ([]*elbv2.Listener, error)

+ func (c *Cloud) ModifyListenerWithContext(ctx context.Context, i *elbv2.ModifyListenerInput) (*elbv2.ModifyListenerOutput, error)

+ func (c *Cloud) ModifyLoadBalancerAttributesWithContext(ctx context.Context, i *elbv2.ModifyLoadBalancerAttributesInput) (*elbv2.ModifyLoadBalancerAttributesOutput, error)

+ func (c *Cloud) ModifyNetworkInterfaceAttributeWithContext(ctx context.Context, i *ec2.ModifyNetworkInterfaceAttributeInput) (*ec2.ModifyNetworkInterfaceAttributeOutput, error)

+ func (c *Cloud) ModifyRuleWithContext(ctx context.Context, i *elbv2.ModifyRuleInput) (*elbv2.ModifyRuleOutput, error)

+ func (c *Cloud) ModifyTargetGroupAttributesWithContext(ctx context.Context, i *elbv2.ModifyTargetGroupAttributesInput) (*elbv2.ModifyTargetGroupAttributesOutput, error)

+ func (c *Cloud) ModifyTargetGroupWithContext(ctx context.Context, i *elbv2.ModifyTargetGroupInput) (*elbv2.ModifyTargetGroupOutput, error)

+ func (c *Cloud) RegisterTargetsWithContext(ctx context.Context, i *elbv2.RegisterTargetsInput) (*elbv2.RegisterTargetsOutput, error)

+ func (c *Cloud) RemoveELBV2TagsWithContext(ctx context.Context, i *elbv2.RemoveTagsInput) (*elbv2.RemoveTagsOutput, error)

+ func (c *Cloud) RevokeSecurityGroupIngressWithContext(ctx context.Context, i *ec2.RevokeSecurityGroupIngressInput) (*ec2.RevokeSecurityGroupIngressOutput, error)

+ func (c *Cloud) SetIpAddressTypeWithContext(ctx context.Context, i *elbv2.SetIpAddressTypeInput) (*elbv2.SetIpAddressTypeOutput, error)

+ func (c *Cloud) SetSecurityGroupsWithContext(ctx context.Context, i *elbv2.SetSecurityGroupsInput) (*elbv2.SetSecurityGroupsOutput, error)

+ func (c *Cloud) SetSubnetsWithContext(ctx context.Context, i *elbv2.SetSubnetsInput) (*elbv2.SetSubnetsOutput, error)

+ func (c *Cloud) StatusACM() func() error

+ func (c *Cloud) StatusEC2() func() error

+ func (c *Cloud) StatusELBV2() func() error

+ func (c *Cloud) StatusIAM() func() error

+ func (c *Cloud) TagResourcesWithContext(ctx context.Context, i *resourcegroupstaggingapi.TagResourcesInput) (*resourcegroupstaggingapi.TagResourcesOutput, error)

+ func (c *Cloud) UntagResourcesWithContext(ctx context.Context, i *resourcegroupstaggingapi.UntagResourcesInput) (*resourcegroupstaggingapi.UntagResourcesOutput, error)

+ func (c *Cloud) WAFRegionalAvailable() bool

+ func (c *Cloud) WebACLExists(ctx context.Context, webACLId *string) (bool, error)

+ type CloudAPI interface

+ func New(cfg CloudConfig, clusterName string, mc metric.Collector, cc *cache.Config) (CloudAPI, error)

+ type CloudConfig struct

+ APIDebug bool

+ APIMaxRetries int

+ Region string

+ VpcID string

+ func (cfg *CloudConfig) BindEnv() error

+ func (cfg *CloudConfig) BindFlags(fs *pflag.FlagSet)

+ type EC2API interface

+ AuthorizeSecurityGroupIngressWithContext func(context.Context, *ec2.AuthorizeSecurityGroupIngressInput) (*ec2.AuthorizeSecurityGroupIngressOutput, error)

+ CreateEC2TagsWithContext func(context.Context, *ec2.CreateTagsInput) (*ec2.CreateTagsOutput, error)

+ CreateSecurityGroupWithContext func(context.Context, *ec2.CreateSecurityGroupInput) (*ec2.CreateSecurityGroupOutput, error)

+ DeleteEC2TagsWithContext func(context.Context, *ec2.DeleteTagsInput) (*ec2.DeleteTagsOutput, error)

+ DeleteSecurityGroupByID func(string) error

+ GetInstancesByIDs func([]string) ([]*ec2.Instance, error)

+ GetSecurityGroupByID func(string) (*ec2.SecurityGroup, error)

+ GetSecurityGroupByName func(string) (*ec2.SecurityGroup, error)

+ GetSecurityGroupsByName func(context.Context, []string) ([]*ec2.SecurityGroup, error)

+ GetSubnetsByNameOrID func(context.Context, []string) ([]*ec2.Subnet, error)

+ IsNodeHealthy func(string) (bool, error)

+ ModifyNetworkInterfaceAttributeWithContext func(context.Context, *ec2.ModifyNetworkInterfaceAttributeInput) (*ec2.ModifyNetworkInterfaceAttributeOutput, error)

+ RevokeSecurityGroupIngressWithContext func(context.Context, *ec2.RevokeSecurityGroupIngressInput) (*ec2.RevokeSecurityGroupIngressOutput, error)

+ StatusEC2 func() func() error

+ type ELBV2API interface

+ AddELBV2TagsWithContext func(context.Context, *elbv2.AddTagsInput) (*elbv2.AddTagsOutput, error)

+ CreateListenerWithContext func(context.Context, *elbv2.CreateListenerInput) (*elbv2.CreateListenerOutput, error)

+ CreateLoadBalancerWithContext func(context.Context, *elbv2.CreateLoadBalancerInput) (*elbv2.CreateLoadBalancerOutput, error)

+ CreateRuleWithContext func(context.Context, *elbv2.CreateRuleInput) (*elbv2.CreateRuleOutput, error)

+ CreateTargetGroupWithContext func(context.Context, *elbv2.CreateTargetGroupInput) (*elbv2.CreateTargetGroupOutput, error)

+ DeleteListenersByArn func(context.Context, string) error

+ DeleteLoadBalancerByArn func(context.Context, string) error

+ DeleteRuleWithContext func(context.Context, *elbv2.DeleteRuleInput) (*elbv2.DeleteRuleOutput, error)

+ DeleteTargetGroupByArn func(context.Context, string) error

+ DeregisterTargetsWithContext func(context.Context, *elbv2.DeregisterTargetsInput) (*elbv2.DeregisterTargetsOutput, error)

+ DescribeELBV2TagsWithContext func(context.Context, *elbv2.DescribeTagsInput) (*elbv2.DescribeTagsOutput, error)

+ DescribeLoadBalancerAttributesWithContext func(context.Context, *elbv2.DescribeLoadBalancerAttributesInput) (*elbv2.DescribeLoadBalancerAttributesOutput, error)

+ DescribeTargetGroupAttributesWithContext func(context.Context, *elbv2.DescribeTargetGroupAttributesInput) (*elbv2.DescribeTargetGroupAttributesOutput, error)

+ DescribeTargetHealthWithContext func(context.Context, *elbv2.DescribeTargetHealthInput) (*elbv2.DescribeTargetHealthOutput, error)

+ GetLoadBalancerByArn func(context.Context, string) (*elbv2.LoadBalancer, error)

+ GetLoadBalancerByName func(context.Context, string) (*elbv2.LoadBalancer, error)

+ GetRules func(context.Context, string) ([]*elbv2.Rule, error)

+ GetTargetGroupByArn func(context.Context, string) (*elbv2.TargetGroup, error)

+ GetTargetGroupByName func(context.Context, string) (*elbv2.TargetGroup, error)

+ ListListenersByLoadBalancer func(context.Context, string) ([]*elbv2.Listener, error)

+ ModifyListenerWithContext func(context.Context, *elbv2.ModifyListenerInput) (*elbv2.ModifyListenerOutput, error)

+ ModifyLoadBalancerAttributesWithContext func(context.Context, *elbv2.ModifyLoadBalancerAttributesInput) (*elbv2.ModifyLoadBalancerAttributesOutput, error)

+ ModifyRuleWithContext func(context.Context, *elbv2.ModifyRuleInput) (*elbv2.ModifyRuleOutput, error)

+ ModifyTargetGroupAttributesWithContext func(context.Context, *elbv2.ModifyTargetGroupAttributesInput) (*elbv2.ModifyTargetGroupAttributesOutput, error)

+ ModifyTargetGroupWithContext func(context.Context, *elbv2.ModifyTargetGroupInput) (*elbv2.ModifyTargetGroupOutput, error)

+ RegisterTargetsWithContext func(context.Context, *elbv2.RegisterTargetsInput) (*elbv2.RegisterTargetsOutput, error)

+ RemoveELBV2TagsWithContext func(context.Context, *elbv2.RemoveTagsInput) (*elbv2.RemoveTagsOutput, error)

+ SetIpAddressTypeWithContext func(context.Context, *elbv2.SetIpAddressTypeInput) (*elbv2.SetIpAddressTypeOutput, error)

+ SetSecurityGroupsWithContext func(context.Context, *elbv2.SetSecurityGroupsInput) (*elbv2.SetSecurityGroupsOutput, error)

+ SetSubnetsWithContext func(context.Context, *elbv2.SetSubnetsInput) (*elbv2.SetSubnetsOutput, error)

+ StatusELBV2 func() func() error

+ type HealthChecker struct

+ func NewHealthChecker(cloud CloudAPI) *HealthChecker

+ func (c *HealthChecker) Check(_ *http.Request) error

+ func (c *HealthChecker) Name() string

+ type IAMAPI interface

+ StatusIAM func() func() error

+ type ResourceGroupsTaggingAPIAPI interface

+ GetClusterSubnets func() (map[string]util.EC2Tags, error)

+ GetResourcesByFilters func(tagFilters map[string][]string, resourceTypeFilters ...string) ([]string, error)

+ TagResourcesWithContext func(context.Context, *resourcegroupstaggingapi.TagResourcesInput) (*resourcegroupstaggingapi.TagResourcesOutput, error)

+ UntagResourcesWithContext func(context.Context, *resourcegroupstaggingapi.UntagResourcesInput) (*resourcegroupstaggingapi.UntagResourcesOutput, error)

+ type WAFRegionalAPI interface

+ AssociateWAF func(ctx context.Context, resourceArn *string, webACLId *string) (*wafregional.AssociateWebACLOutput, error)

+ DisassociateWAF func(ctx context.Context, resourceArn *string) (*wafregional.DisassociateWebACLOutput, error)

+ GetWebACLSummary func(ctx context.Context, resourceArn *string) (*waf.WebACLSummary, error)

+ WAFRegionalAvailable func() bool

+ WebACLExists func(ctx context.Context, webACLId *string) (bool, error)

?	: This menu
/	: Search site
f or F	: Jump to
y or Y	: Canonical URL