evalphobia /
aws-sdk-go-v2-wrapper
| 1 | package config |
||
| 2 | |||
| 3 | import "github.com/aws/aws-sdk-go-v2/aws" |
||
| 4 | |||
| 5 | type Endpoints struct { |
||
|
introduced
by
|
|||
| 6 | Athena string |
||
| 7 | CloudwatchLogs string |
||
| 8 | DynamoDB string |
||
| 16 | SSM string |
||
| 17 | } |
||
| 18 | |||
| 19 | func (e Endpoints) HasAthena() bool { |
||
| 20 | if e.Athena != "" { |
||
| 21 | return true |
||
| 22 | } |
||
| 23 | return EnvAthenaEndpoint() != "" |
||
| 24 | } |
||
| 25 | |||
| 26 | func (e Endpoints) GetAthena() aws.ResolveWithEndpoint { |
||
| 27 | envvar := EnvAthenaEndpoint() |
||
| 28 | if envvar != "" { |
||
| 29 | return aws.ResolveWithEndpointURL(envvar) |
||
| 31 | return aws.ResolveWithEndpointURL(e.Athena) |
||
| 32 | } |
||
| 33 | |||
| 34 | func (e Endpoints) HasCloudwatchLogs() bool { |
||
| 35 | if e.CloudwatchLogs != "" { |
||
| 36 | return true |
||
| 37 | } |
||
| 38 | return EnvCloudwatchLogsEndpoint() != "" |
||
| 39 | } |
||
| 40 | |||
| 41 | func (e Endpoints) GetCloudwatchLogs() aws.ResolveWithEndpoint { |
||
| 42 | envvar := EnvCloudwatchLogsEndpoint() |
||
| 43 | if envvar != "" { |
||
| 44 | return aws.ResolveWithEndpointURL(envvar) |
||
| 46 | return aws.ResolveWithEndpointURL(e.CloudwatchLogs) |
||
| 47 | } |
||
| 48 | |||
| 49 | func (e Endpoints) HasDynamoDB() bool { |
||
| 50 | if e.DynamoDB != "" { |
||
| 51 | return true |
||
| 52 | } |
||
| 53 | return EnvDynamoDBEndpoint() != "" |
||
| 54 | } |
||
| 55 | |||
| 56 | func (e Endpoints) GetDynamoDB() aws.ResolveWithEndpoint { |
||
| 57 | envvar := EnvDynamoDBEndpoint() |
||
| 58 | if envvar != "" { |
||
| 59 | return aws.ResolveWithEndpointURL(envvar) |
||
| 61 | return aws.ResolveWithEndpointURL(e.DynamoDB) |
||
| 62 | } |
||
| 63 | |||
| 64 | func (e Endpoints) HasEC2() bool { |
||
| 65 | if e.EC2 != "" { |
||
| 66 | return true |
||
| 67 | } |
||
| 68 | return EnvEC2Endpoint() != "" |
||
| 69 | } |
||
| 70 | |||
| 71 | func (e Endpoints) GetEC2() aws.ResolveWithEndpoint { |
||
| 72 | envvar := EnvEC2Endpoint() |
||
| 73 | if envvar != "" { |
||
| 74 | return aws.ResolveWithEndpointURL(envvar) |
||
| 76 | return aws.ResolveWithEndpointURL(e.EC2) |
||
| 77 | } |
||
| 78 | |||
| 79 | func (e Endpoints) HasPinpoint() bool { |
||
| 80 | if e.Pinpoint != "" { |
||
| 81 | return true |
||
| 82 | } |
||
| 83 | return EnvPinpointEndpoint() != "" |
||
| 84 | } |
||
| 85 | |||
| 86 | func (e Endpoints) GetPinpoint() aws.ResolveWithEndpoint { |
||
| 87 | envvar := EnvPinpointEndpoint() |
||
| 88 | if envvar != "" { |
||
| 89 | return aws.ResolveWithEndpointURL(envvar) |
||
| 91 | return aws.ResolveWithEndpointURL(e.Pinpoint) |
||
| 92 | } |
||
| 93 | |||
| 94 | func (e Endpoints) HasPinpointEmail() bool { |
||
| 95 | if e.PinpointEmail != "" { |
||
| 96 | return true |
||
| 97 | } |
||
| 98 | return EnvPinpointEmailEndpoint() != "" |
||
| 99 | } |
||
| 100 | |||
| 101 | func (e Endpoints) GetPinpointEmail() aws.ResolveWithEndpoint { |
||
| 102 | envvar := EnvPinpointEmailEndpoint() |
||
| 103 | if envvar != "" { |
||
| 104 | return aws.ResolveWithEndpointURL(envvar) |
||
| 106 | return aws.ResolveWithEndpointURL(e.PinpointEmail) |
||
| 107 | } |
||
| 108 | |||
| 109 | func (e Endpoints) HasKMS() bool { |
||
| 110 | if e.KMS != "" { |
||
| 111 | return true |
||
| 112 | } |
||
| 113 | return EnvKMSEndpoint() != "" |
||
| 114 | } |
||
| 115 | |||
| 116 | func (e Endpoints) GetKMS() aws.ResolveWithEndpoint { |
||
| 117 | envvar := EnvKMSEndpoint() |
||
| 118 | if envvar != "" { |
||
| 119 | return aws.ResolveWithEndpointURL(envvar) |
||
| 121 | return aws.ResolveWithEndpointURL(e.KMS) |
||
| 122 | } |
||
| 123 | |||
| 124 | func (e Endpoints) HasS3() bool { |
||
| 125 | if e.S3 != "" { |
||
| 126 | return true |
||
| 127 | } |
||
| 128 | return EnvS3Endpoint() != "" |
||
| 129 | } |
||
| 130 | |||
| 131 | func (e Endpoints) GetS3() aws.ResolveWithEndpoint { |
||
| 132 | envvar := EnvS3Endpoint() |
||
| 133 | if envvar != "" { |
||
| 134 | return aws.ResolveWithEndpointURL(envvar) |
||
| 136 | return aws.ResolveWithEndpointURL(e.S3) |
||
| 137 | } |
||
| 138 | |||
| 139 | func (e Endpoints) HasSES() bool { |
||
| 140 | if e.SES != "" { |
||
| 141 | return true |
||
| 142 | } |
||
| 143 | return EnvSESEndpoint() != "" |
||
| 144 | } |
||
| 145 | |||
| 146 | func (e Endpoints) GetSES() aws.ResolveWithEndpoint { |
||
| 147 | envvar := EnvSESEndpoint() |
||
| 148 | if envvar != "" { |
||
| 149 | return aws.ResolveWithEndpointURL(envvar) |
||
| 151 | return aws.ResolveWithEndpointURL(e.SES) |
||
| 152 | } |
||
| 153 | |||
| 154 | func (e Endpoints) HasSQS() bool { |
||
| 155 | if e.SQS != "" { |
||
| 156 | return true |
||
| 157 | } |
||
| 158 | return EnvSQSEndpoint() != "" |
||
| 159 | } |
||
| 160 | |||
| 161 | func (e Endpoints) GetSQS() aws.ResolveWithEndpoint { |
||
| 162 | envvar := EnvSQSEndpoint() |
||
| 163 | if envvar != "" { |
||
| 164 | return aws.ResolveWithEndpointURL(envvar) |
||
| 166 | return aws.ResolveWithEndpointURL(e.SQS) |
||
| 167 | } |
||
| 168 | |||
| 169 | func (e Endpoints) HasSSM() bool { |
||
| 170 | if e.SSM != "" { |
||
| 171 | return true |
||
| 172 | } |
||
| 173 | return EnvSSMEndpoint() != "" |
||
| 174 | } |
||
| 175 | |||
| 176 | func (e Endpoints) GetSSM() aws.ResolveWithEndpoint { |
||
| 177 | envvar := EnvSSMEndpoint() |
||
| 178 | if envvar != "" { |
||
| 179 | return aws.ResolveWithEndpointURL(envvar) |
||
| 183 |
Loading history...