aws

package

v0.5.24 Latest Latest Go to latest Published: Feb 3, 2021 License: Apache-2.0 Imports: 16 Imported by: 0

Details

Valid go.mod file
Redistributable license
Tagged version
Stable version
Learn more about best practices

Repository

github.com/lyft/flyteplugins

Links

Open Source Insights

Documentation ¶

Overview ¶

AWS-specific logic to handle execution and monitoring of batch jobs.

Index ¶

Constants
func Init(ctx context.Context, cfg *Config) (err error)
func MustRegisterSubSection(key config.SectionKey, cfg config.Config) config.Section
func SetClient(c Client)
type Client
- func GetClient() (c Client, err error)
type Config
- func GetConfig() *Config
- func (cfg Config) GetPFlagSet(prefix string) *pflag.FlagSet
- func (cfg Config) GetSdkConfig() (aws.Config, error)
type RateLimiterConfig

Constants ¶

View Source

const (
	EnvSharedCredFilePath                  = "AWS_SHARED_CREDENTIALS_FILE"
	EnvAwsProfile                          = "AWS_PROFILE"
	ErrEmptyCredentials   errors.ErrorCode = "EMPTY_CREDS"
	ErrUnknownHost        errors.ErrorCode = "UNKNOWN_HOST"
)

View Source

const ConfigSectionKey = "aws"

Variables ¶

This section is empty.

Functions ¶

func Init ¶

func Init(ctx context.Context, cfg *Config) (err error)

Initializes singleton AWS Client if one hasn't been initialized yet.

func MustRegisterSubSection ¶

func MustRegisterSubSection(key config.SectionKey, cfg config.Config) config.Section

func SetClient ¶

func SetClient(c Client)

Types ¶

type Client ¶

type Client interface {
	GetSession() *session.Session
	GetSdkConfig() *aws.Config
	GetConfig() *Config
	GetHostName() string
}

A generic AWS Client that can be used for all AWS Client libraries.

func GetClient ¶

func GetClient() (c Client, err error)

Gets singleton AWS Client.

type Config ¶

type Config struct {
	Region    string            `json:"region" pflag:",AWS Region to connect to."`
	AccountID string            `json:"accountId" pflag:",AWS Account Identifier."`
	Retries   int               `json:"retries" pflag:",Number of retries."`
	LogLevel  aws.ClientLogMode `json:"logLevel" pflag:"-,Defines the Sdk Log Level."`
}

Config section for AWS Package

func GetConfig ¶

func GetConfig() *Config

Gets loaded config for AWS

func (Config) GetPFlagSet ¶

func (cfg Config) GetPFlagSet(prefix string) *pflag.FlagSet

GetPFlagSet will return strongly types pflags for all fields in Config and its nested types. The format of the flags is json-name.json-sub-name... etc.

func (Config) GetSdkConfig ¶ added in v0.5.23

func (cfg Config) GetSdkConfig() (aws.Config, error)

type RateLimiterConfig ¶

type RateLimiterConfig struct {
	Rate  int64 `json:"rate" pflag:",Allowed rate of calls per second."`
	Burst int   `json:"burst" pflag:",Allowed burst rate of calls."`
}

Source Files ¶

View all Source files

?	: This menu
/	: Search site
f or F	: Jump to
y or Y	: Canonical URL