aws

Documentation

Index

• Constants
• Variables
• func GetLocalStack(t testing.TB, envVars []string, readyFns ...func(port string) error) (port string)
• func GetSession(ctx context.Context, parsedConf *service.ParsedConfig, ...) (aws.Config, error)

Constants

const (
	// ErrCodeKMSThrottlingException is defined in the API Reference
	// https://docs.aws.amazon.com/sdk-for-go/api/service/kinesis/#Kinesis.GetRecords
	ErrCodeKMSThrottlingException = "KMSThrottlingException"
)

Variables

var (
	ErrLeaseNotAcquired = errors.New("the shard could not be leased due to a collision")
)

Common errors that might occur throughout checkpointing.

Functions

func GetLocalStack

func GetLocalStack(t testing.TB, envVars []string, readyFns ...func(port string) error) (port string)

TODO: Add config + options pattern or use an already existing library like https://github.com/elgohr/go-localstack

func GetSession

func GetSession(ctx context.Context, parsedConf *service.ParsedConfig, opts ...func(*config.LoadOptions) error) (aws.Config, error)