go__sqs_demo/aws.go

package main

import (
	"fmt"

	"github.com/aws/aws-sdk-go-v2/aws"
)

type endpointResolver struct {
	region string
}

func (e endpointResolver) ResolveEndpoint(service, region string, options ...interface{}) (aws.Endpoint, error) {
	if service != `SQS` {
		return aws.Endpoint{}, fmt.Errorf("trying to resolve non-SQS service: %s", service)
	}
	ep := aws.Endpoint{
		URL:               "http://localhost:4566/",
		HostnameImmutable: false,
		PartitionID:       "000000000000",
		SigningName:       "",
		SigningRegion:     e.region,
		SigningMethod:     "",
		Source:            0,
	}
	if region != "" {
		ep.URL = fmt.Sprintf("https://sqs.%s.amazonaws.com/", region)
	}
	return ep, nil
}