View Source
const DYNAMODB_LIMIT_EXCEEDED_SLEEP = 10 * time.Second

    How long to sleep if a limit-exceeded event happens

    View Source

      Number of times to retry if a throttling-related exception occurs

      View Source
      const DYNAMODB_THROTTLE_SLEEP = 5 * time.Second

        How long to sleep when a throttle-event happens


        View Source
        var AttributeMap = map[string]string{
        	"delay_seconds":              "DelaySeconds",
        	"max_message_size":           "MaximumMessageSize",
        	"message_retention_seconds":  "MessageRetentionPeriod",
        	"receive_wait_time_seconds":  "ReceiveMessageWaitTimeSeconds",
        	"visibility_timeout_seconds": "VisibilityTimeout",
        	"policy":                     "Policy",
        	"redrive_policy":             "RedrivePolicy",
        	"arn":                        "QueueArn",
        View Source
        var LambdaFunctionRegexp = `^(arn:aws:lambda:)?([a-z]{2}-[a-z]+-\d{1}:)?(\d{12}:)?(function:)?([a-zA-Z0-9-_]+)(:(\$LATEST|[a-zA-Z0-9-_]+))?$`
        View Source
        var SNSAttributeMap = map[string]string{
        	"display_name":    "DisplayName",
        	"policy":          "Policy",
        	"delivery_policy": "DeliveryPolicy",

          Mutable attributes


          func FQDN

          func FQDN(name string) string

          func HostedZoneIDForRegion

          func HostedZoneIDForRegion(region string) string

            Returns the hosted zone ID for an S3 website endpoint region. This can be used as input to the aws_route53_record resource's zone_id argument.

            func IGAttachStateRefreshFunc

            func IGAttachStateRefreshFunc(conn *ec2.EC2, id string, expected string) resource.StateRefreshFunc

              IGAttachStateRefreshFunc returns a resource.StateRefreshFunc that is used watch the state of an internet gateway's attachment.

              func IGStateRefreshFunc

              func IGStateRefreshFunc(conn *ec2.EC2, id string) resource.StateRefreshFunc

                IGStateRefreshFunc returns a resource.StateRefreshFunc that is used to watch an internet gateway.

                func InstanceStateRefreshFunc

                func InstanceStateRefreshFunc(conn *ec2.EC2, instanceID string) resource.StateRefreshFunc

                  InstanceStateRefreshFunc returns a resource.StateRefreshFunc that is used to watch an EC2 instance.

                  func NGStateRefreshFunc

                  func NGStateRefreshFunc(conn *ec2.EC2, id string) resource.StateRefreshFunc

                    NGStateRefreshFunc returns a resource.StateRefreshFunc that is used to watch a NAT Gateway.

                    func Provider

                    func Provider() terraform.ResourceProvider

                      Provider returns a terraform.ResourceProvider.

                      func SGStateRefreshFunc

                      func SGStateRefreshFunc(conn *ec2.EC2, id string) resource.StateRefreshFunc

                        SGStateRefreshFunc returns a resource.StateRefreshFunc that is used to watch a security group.

                        func SpotInstanceStateRefreshFunc

                        func SpotInstanceStateRefreshFunc(
                        	conn *ec2.EC2, sir ec2.SpotInstanceRequest) resource.StateRefreshFunc

                          SpotInstanceStateRefreshFunc returns a resource.StateRefreshFunc that is used to watch an EC2 spot instance request

                          func SubnetStateRefreshFunc

                          func SubnetStateRefreshFunc(conn *ec2.EC2, id string) resource.StateRefreshFunc

                            SubnetStateRefreshFunc returns a resource.StateRefreshFunc that is used to watch a Subnet.

                            func VPCStateRefreshFunc

                            func VPCStateRefreshFunc(conn *ec2.EC2, id string) resource.StateRefreshFunc

                              VPCStateRefreshFunc returns a resource.StateRefreshFunc that is used to watch a VPC.

                              func WebsiteDomainUrl

                              func WebsiteDomainUrl(region string) string


                              type AWSClient

                              type AWSClient struct {
                              	// contains filtered or unexported fields

                              type ByGroupPair

                              type ByGroupPair []*ec2.UserIdGroupPair

                                ByGroupPair implements sort.Interface for []*ec2.UserIDGroupPairs based on GroupID or GroupName field (only one should be set).

                                func (ByGroupPair) Len

                                func (b ByGroupPair) Len() int

                                func (ByGroupPair) Less

                                func (b ByGroupPair) Less(i, j int) bool

                                func (ByGroupPair) Swap

                                func (b ByGroupPair) Swap(i, j int)

                                type Config

                                type Config struct {
                                	AccessKey     string
                                	SecretKey     string
                                	CredsFilename string
                                	Profile       string
                                	Token         string
                                	Region        string
                                	MaxRetries    int
                                	AllowedAccountIds   []interface{}
                                	ForbiddenAccountIds []interface{}
                                	DynamoDBEndpoint string
                                	KinesisEndpoint  string
                                	Ec2Endpoint      string
                                	IamEndpoint      string
                                	ElbEndpoint      string
                                	Insecure         bool

                                func (*Config) Client

                                func (c *Config) Client() (interface{}, error)

                                  Client configures and returns a fully initialized AWSClient

                                  func (*Config) ValidateAccountId

                                  func (c *Config) ValidateAccountId(iamconn *iam.IAM) error

                                    ValidateAccountId returns a context-specific error if the configured account id is explicitly forbidden or not authorised; and nil if it is authorised.

                                    func (*Config) ValidateCredentials

                                    func (c *Config) ValidateCredentials(iamconn *iam.IAM) error

                                      Validate credentials early and fail before we do any graph walking. In the case of an IAM role/profile with insuffecient privileges, fail silently

                                      func (*Config) ValidateRegion

                                      func (c *Config) ValidateRegion() error

                                        ValidateRegion returns an error if the configured region is not a valid aws region and nil otherwise.

                                        type LambdaPolicy

                                        type LambdaPolicy struct {
                                        	Version   string
                                        	Statement []LambdaPolicyStatement
                                        	Id        string

                                        type LambdaPolicyStatement

                                        type LambdaPolicyStatement struct {
                                        	Condition map[string]map[string]string
                                        	Action    string
                                        	Resource  string
                                        	Effect    string
                                        	Principal map[string]string
                                        	Sid       string

                                        type S3Website

                                        type S3Website struct {
                                        	Endpoint, Domain string

                                        func WebsiteEndpoint

                                        func WebsiteEndpoint(bucket string, region string) *S3Website

                                        type TunnelInfo

                                        type TunnelInfo struct {
                                        	Tunnel1Address      string
                                        	Tunnel1PreSharedKey string
                                        	Tunnel2Address      string
                                        	Tunnel2PreSharedKey string

                                        type XmlIpsecTunnel

                                        type XmlIpsecTunnel struct {
                                        	OutsideAddress string `xml:"vpn_gateway>tunnel_outside_address>ip_address"`
                                        	PreSharedKey   string `xml:"ike>pre_shared_key"`

                                        type XmlVpnConnectionConfig

                                        type XmlVpnConnectionConfig struct {
                                        	Tunnels []XmlIpsecTunnel `xml:"ipsec_tunnel"`

                                        func (XmlVpnConnectionConfig) Len

                                        func (slice XmlVpnConnectionConfig) Len() int

                                        func (XmlVpnConnectionConfig) Less

                                        func (slice XmlVpnConnectionConfig) Less(i, j int) bool

                                        func (XmlVpnConnectionConfig) Swap

                                        func (slice XmlVpnConnectionConfig) Swap(i, j int)

                                        Source Files