Service Clients

// All service clients:
import "github.com/aws/aws-sdk-go-v2/service/<service>"

// Constructor
func New(config aws.Config) *<ServiceName>

// Each API operation:
func (c *<ServiceName>) <OperationName>Request(input *<OperationName>Input) <OperationName>Request

// Typed request
type <OperationName>Request struct {
    Input *<OperationName>Input
    Copy  func(*<OperationName>Input) <OperationName>Request
    // unexported aws.Request
}
func (r <OperationName>Request) Send() (*<OperationName>Output, error)
func (r <OperationName>Request) Presign(expireTime time.Duration) (string, error)

// Pager (for paginated operations)
type <OperationName>Pager struct { ... }
func (r <OperationName>Request) Paginate() *<OperationName>Pager
func (p *<OperationName>Pager) Next() bool
func (p *<OperationName>Pager) CurrentPage() *<OperationName>Output
func (p *<OperationName>Pager) Err() error

// Waiters (service-specific)
func (c *<ServiceName>) WaitUntil<State>(ctx aws.Context, input *<Input>, opts ...aws.WaiterOption) error

import "github.com/aws/aws-sdk-go-v2/service/s3/s3iface"

// In test code:
type MockS3 struct { s3iface.S3API }
func (m *MockS3) GetObjectRequest(input *s3.GetObjectInput) s3.GetObjectRequest { ... }

import (
    "github.com/aws/aws-sdk-go-v2/aws"
    "github.com/aws/aws-sdk-go-v2/aws/external"
    "github.com/aws/aws-sdk-go-v2/service/dynamodb"
)

cfg, _ := external.LoadDefaultAWSConfig()
cfg.Region = "us-east-1"
svc := dynamodb.New(cfg)

// PutItem
req := svc.PutItemRequest(&dynamodb.PutItemInput{
    TableName: aws.String("my-table"),
    Item: map[string]dynamodb.AttributeValue{
        "id": {S: aws.String("123")},
        "name": {S: aws.String("example")},
    },
})
resp, err := req.Send()

// GetItem
getReq := svc.GetItemRequest(&dynamodb.GetItemInput{
    TableName: aws.String("my-table"),
    Key: map[string]dynamodb.AttributeValue{
        "id": {S: aws.String("123")},
    },
})
getResp, err := getReq.Send()
if name, ok := getResp.Item["name"]; ok {
    fmt.Println(*name.S)
}

// Paginate Scan
scanReq := svc.ScanRequest(&dynamodb.ScanInput{
    TableName: aws.String("my-table"),
})
p := scanReq.Paginate()
for p.Next() {
    page := p.CurrentPage()
    for _, item := range page.Items {
        fmt.Println(item)
    }
}

import (
    "github.com/aws/aws-sdk-go-v2/aws"
    "github.com/aws/aws-sdk-go-v2/aws/external"
    "github.com/aws/aws-sdk-go-v2/service/lambda"
)

cfg, _ := external.LoadDefaultAWSConfig()
cfg.Region = "us-east-1"
svc := lambda.New(cfg)

req := svc.InvokeRequest(&lambda.InvokeInput{
    FunctionName:   aws.String("my-function"),
    Payload:        []byte(`{"key": "value"}`),
    InvocationType: lambda.InvocationTypeRequestResponse,
})
resp, err := req.Send()
if err != nil { panic(err) }
fmt.Println("Status:", *resp.StatusCode)
fmt.Println("Response:", string(resp.Payload))

import (
    "github.com/aws/aws-sdk-go-v2/aws"
    "github.com/aws/aws-sdk-go-v2/aws/external"
    "github.com/aws/aws-sdk-go-v2/service/sqs"
)

cfg, _ := external.LoadDefaultAWSConfig()
cfg.Region = "us-east-1"
svc := sqs.New(cfg)

// Send message
sendReq := svc.SendMessageRequest(&sqs.SendMessageInput{
    QueueUrl:    aws.String("https://sqs.us-east-1.amazonaws.com/123456789012/my-queue"),
    MessageBody: aws.String("Hello, SQS!"),
})
sendResp, err := sendReq.Send()

// Receive messages
recvReq := svc.ReceiveMessageRequest(&sqs.ReceiveMessageInput{
    QueueUrl:            aws.String("https://sqs.us-east-1.amazonaws.com/123456789012/my-queue"),
    MaxNumberOfMessages: aws.Int64(10),
    WaitTimeSeconds:     aws.Int64(20), // long polling
})
recvResp, err := recvReq.Send()
for _, msg := range recvResp.Messages {
    fmt.Println(*msg.Body)
    // Delete message after processing
    delReq := svc.DeleteMessageRequest(&sqs.DeleteMessageInput{
        QueueUrl:      aws.String("..."),
        ReceiptHandle: msg.ReceiptHandle,
    })
    delReq.Send()
}

import (
    "github.com/aws/aws-sdk-go-v2/aws"
    "github.com/aws/aws-sdk-go-v2/aws/external"
    "github.com/aws/aws-sdk-go-v2/service/ec2"
)

cfg, _ := external.LoadDefaultAWSConfig()
cfg.Region = "us-east-1"
svc := ec2.New(cfg)

// Describe instances with pagination
req := svc.DescribeInstancesRequest(&ec2.DescribeInstancesInput{})
p := req.Paginate()
for p.Next() {
    page := p.CurrentPage()
    for _, r := range page.Reservations {
        for _, i := range r.Instances {
            fmt.Println(*i.InstanceId, i.State.Name)
        }
    }
}

// Wait until instance is running
err := svc.WaitUntilInstanceRunning(aws.BackgroundContext(), &ec2.DescribeInstancesInput{
    InstanceIds: []string{"i-1234567890abcdef0"},
})

// Example service name constants (each in its respective package)
const ServiceName = "s3"       // service/s3
const ServiceName = "ec2"      // service/ec2
const ServiceName = "dynamodb" // service/dynamodb
const ServiceName = "iam"      // service/iam
// etc.