fix(inputs.cloudwatch): enable custom endpoint support (#12657)

This commit is contained in:
Joshua Powers 2023-02-10 11:15:30 -07:00 committed by GitHub
parent 4d0f05980e
commit f206c27d89
No known key found for this signature in database
GPG Key ID: 4AEE18F83AFDEB23
1 changed files with 9 additions and 4 deletions

View File

@ -182,14 +182,19 @@ func (c *CloudWatch) initializeCloudWatch() error {
return err
}
cfg, err := c.CredentialConfig.Credentials()
awsCreds, err := c.CredentialConfig.Credentials()
if err != nil {
return err
}
c.client = cwClient.NewFromConfig(cfg, func(options *cwClient.Options) {
// Disable logging
options.ClientLogMode = 0
var customResolver cwClient.EndpointResolver
if c.CredentialConfig.EndpointURL != "" && c.CredentialConfig.Region != "" {
customResolver = cwClient.EndpointResolverFromURL(c.CredentialConfig.EndpointURL)
}
c.client = cwClient.NewFromConfig(awsCreds, func(options *cwClient.Options) {
options.EndpointResolver = customResolver
options.ClientLogMode = 0
options.HTTPClient = &http.Client{
// use values from DefaultTransport
Transport: &http.Transport{