aws

Documentation

Index

• Constants
• Variables
• func GetSession(parsedConf *service.ParsedConfig, opts ...func(*aws.Config)) (*session.Session, error)
• func GetSessionFromConf(c bsession.Config, opts ...func(*aws.Config)) (*session.Session, 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 GetSession

func GetSession(parsedConf *service.ParsedConfig, opts ...func(*aws.Config)) (*session.Session, error)

GetSession attempts to create an AWS session based on the parsedConfig

func GetSessionFromConf

func GetSessionFromConf(c bsession.Config, opts ...func(*aws.Config)) (*session.Session, error)

GetSessionFromConf attempts to create an AWS session based on Config.