moonsub-kim

package main

import (
	"context"
	"sync"
	"time"

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

moonsub-kim

package main

import (
	"github.com/mitchellh/mapstructure"
	"github.com/spf13/viper"
)

type Config struct {
	MysqlHost string `mapstructure:"MYSQL_HOST"`
	LogLevel  string `mapstructure:"LOG_LEVEL"`

moonsub-kim

package main

const (
	envAWSEndpoint  = "AWS_ENDPOINT"
	envAWSRegion    = "AWS_REGION"
)

func main() {
	endPoint := os.Getenv(envAWSEndpoint)
	region := os.Getenv(envAWSRegion)

moonsub-kim

var startTime time.Time

trace := &httptrace.ClientTrace {
    TLSHandshakeStart: func() {
      startTime = time.Now()
    },
    TLSHandshakeDone: func(s tls.ConnectionState, err error) {
      fmt.Sprintf("%v elapsed", time.Now() - startTime)
    },
}

moonsub-kim

package main

import (
    "log"
    "sync"
    "time"

    "github.com/aws/aws-sdk-go/aws"
    "github.com/aws/aws-sdk-go/aws/credentials"
    "github.com/aws/aws-sdk-go/aws/session"

moonsub-kim

package main

const (
	envAWSEndpoint  = "AWS_ENDPOINT"
	envAWSRegion    = "AWS_REGION"
)

func main() {
	endPoint := os.Getenv(envAWSEndpoint)
	region := os.Getenv(envAWSRegion)

moonsub-kim

var timeout time.Time = 30 * time.Millisecond
var maxRetry int = 3

func queryWithRetry(ctx context.Context, input *dynamodb.QueryInput) (*dynamodb.QueryOutput, error) {
	for i := 0; i < maxRetry; i++ {
		res, err := func() (*dynamodb.QueryOutput, error) {
			timeoutCtx, cancel := context.WithTimeout(ctx, timeout)
			defer cancel()
			return dynamoDB.Query(input)
		}()