proc

Documentation

Index

• func InitializeAwsSourceEngine(ctx context.Context, natsOptions auth.NATSOptions, awsAuthConfig AwsAuthConfig, ...) (*discovery.Engine, error)
• type AwsAuthConfig
  • func (c AwsAuthConfig) GetAWSConfig(region string) (aws.Config, error)

Functions

func InitializeAwsSourceEngine

func InitializeAwsSourceEngine(ctx context.Context, natsOptions auth.NATSOptions, awsAuthConfig AwsAuthConfig, maxParallel int) (*discovery.Engine, error)

InitializeAwsSourceEngine initializes an Engine with AWS sources, returns the engine, and an error if any. The xontext provided will be used for the rate limit buckets and should not be cancelled until the source is shut down

Types

type AwsAuthConfig

type AwsAuthConfig struct {
	Strategy        string
	AccessKeyID     string
	SecretAccessKey string
	ExternalID      string
	TargetRoleARN   string
	Profile         string
	AutoConfig      bool

	Regions []string
}

func (AwsAuthConfig) GetAWSConfig

func (c AwsAuthConfig) GetAWSConfig(region string) (aws.Config, error)