Versions in this module Expand all Collapse all v1 v1.15.1 Jun 9, 2025 Changes in this version + func Coalesce(values ...string) string + func GetConfig(opts Options) *aws.Config + func GetConfigV2(accessKey string, secretKey string, sessionToken string, region string, ...) (awsv2.Config, error) + type Clients struct + Dynamo *DynamoDBClients + ParameterStore *ParameterStoreClients + Secret *SecretManagerClients + type DeprecatedKafkaIAM struct + AccessKey string + IamRoleArn string + Region string + SecretKey string + SessionToken string + StsSessionName string + type DeprecatedPostgresIAM struct + AccessKey string + SecretKey string + type DynamoDBClients struct + DynamoDB dynamodbiface.DynamoDBAPI + func (c *DynamoDBClients) New(session *session.Session) + type EnvironmentSettings struct + Metadata map[string]string + func NewEnvironmentSettings(md map[string]string) (EnvironmentSettings, error) + type KafkaClients struct + ConsumerGroup sarama.ConsumerGroup + Producer sarama.SyncProducer + func (c *KafkaClients) New(session *session.Session, tokenProvider *mskTokenProvider) error + type KafkaOptions struct + Brokers []string + Config *sarama.Config + ConsumerGroup string + MaxMessageBytes int + type KinesisClients struct + Credentials *credentials.Credentials + Kinesis kinesisiface.KinesisAPI + Region string + func (c *KinesisClients) New(session *session.Session) + func (c *KinesisClients) Stream(ctx context.Context, streamName string) (*string, error) + func (c *KinesisClients) WorkerCfg(ctx context.Context, stream, consumer, mode string) *config.KinesisClientLibConfiguration + type MockDynamoDB struct + BatchWriteItemWithContextFn func(ctx context.Context, input *dynamodb.BatchWriteItemInput, op ...request.Option) (*dynamodb.BatchWriteItemOutput, error) + DeleteItemWithContextFn func(ctx context.Context, input *dynamodb.DeleteItemInput, op ...request.Option) (*dynamodb.DeleteItemOutput, error) + GetItemWithContextFn func(ctx context.Context, input *dynamodb.GetItemInput, op ...request.Option) (*dynamodb.GetItemOutput, error) + PutItemWithContextFn func(ctx context.Context, input *dynamodb.PutItemInput, op ...request.Option) (*dynamodb.PutItemOutput, error) + TransactWriteItemsWithContextFn func(aws.Context, *dynamodb.TransactWriteItemsInput, ...request.Option) (*dynamodb.TransactWriteItemsOutput, error) + func (m *MockDynamoDB) BatchWriteItemWithContext(ctx context.Context, input *dynamodb.BatchWriteItemInput, op ...request.Option) (*dynamodb.BatchWriteItemOutput, error) + func (m *MockDynamoDB) DeleteItemWithContext(ctx context.Context, input *dynamodb.DeleteItemInput, op ...request.Option) (*dynamodb.DeleteItemOutput, error) + func (m *MockDynamoDB) GetItemWithContext(ctx context.Context, input *dynamodb.GetItemInput, op ...request.Option) (*dynamodb.GetItemOutput, error) + func (m *MockDynamoDB) PutItemWithContext(ctx context.Context, input *dynamodb.PutItemInput, op ...request.Option) (*dynamodb.PutItemOutput, error) + func (m *MockDynamoDB) TransactWriteItemsWithContext(ctx context.Context, input *dynamodb.TransactWriteItemsInput, ...) (*dynamodb.TransactWriteItemsOutput, error) + type MockParameterStore struct + DescribeParametersFn func(context.Context, *ssm.DescribeParametersInput, ...request.Option) (*ssm.DescribeParametersOutput, error) + GetParameterFn func(context.Context, *ssm.GetParameterInput, ...request.Option) (*ssm.GetParameterOutput, error) + func (m *MockParameterStore) DescribeParametersWithContext(ctx context.Context, input *ssm.DescribeParametersInput, ...) (*ssm.DescribeParametersOutput, error) + func (m *MockParameterStore) GetParameterWithContext(ctx context.Context, input *ssm.GetParameterInput, option ...request.Option) (*ssm.GetParameterOutput, error) + type MockSecretManager struct + GetSecretValueFn func(context.Context, *secretsmanager.GetSecretValueInput, ...request.Option) (*secretsmanager.GetSecretValueOutput, error) + func (m *MockSecretManager) GetSecretValueWithContext(ctx context.Context, input *secretsmanager.GetSecretValueInput, ...) (*secretsmanager.GetSecretValueOutput, error) + type Options struct + AccessKey string + AssumeRoleARN string + ConnectionString string + Endpoint string + Logger logger.Logger + PoolConfig *pgxpool.Config + Properties map[string]string + Region string + SecretKey string + SessionName string + SessionToken string + type ParameterStoreClients struct + Store ssmiface.SSMAPI + func (c *ParameterStoreClients) New(session *session.Session) + type Provider interface + Close func() error + DynamoDB func() *DynamoDBClients + Kafka func(KafkaOptions) (*KafkaClients, error) + Kinesis func() *KinesisClients + ParameterStore func() *ParameterStoreClients + S3 func() *S3Clients + SecretManager func() *SecretManagerClients + Ses func() *SesClients + Sns func() *SnsClients + SnsSqs func() *SnsSqsClients + Sqs func() *SqsClients + UpdatePostgres func(context.Context, *pgxpool.Config) + func NewProvider(ctx context.Context, opts Options, cfg *aws.Config) (Provider, error) + type S3Clients struct + Downloader *s3manager.Downloader + S3 *s3.S3 + Uploader *s3manager.Uploader + func (c *S3Clients) New(session *session.Session) + type SecretManagerClients struct + Manager secretsmanageriface.SecretsManagerAPI + func (c *SecretManagerClients) New(session *session.Session) + type SesClients struct + Ses *ses.SES + func (c *SesClients) New(session *session.Session) + type SnsClients struct + Sns *sns.SNS + func (c *SnsClients) New(session *session.Session) + type SnsSqsClients struct + Sns *sns.SNS + Sqs *sqs.SQS + Sts *sts.STS + func (c *SnsSqsClients) New(session *session.Session) + type SqsClients struct + Sqs sqsiface.SQSAPI + func (c *SqsClients) New(session *session.Session) + func (c *SqsClients) QueueURL(ctx context.Context, queueName string) (*string, error) + type StaticAuth struct + func (a *StaticAuth) Close() error + func (a *StaticAuth) DynamoDB() *DynamoDBClients + func (a *StaticAuth) Kafka(opts KafkaOptions) (*KafkaClients, error) + func (a *StaticAuth) Kinesis() *KinesisClients + func (a *StaticAuth) ParameterStore() *ParameterStoreClients + func (a *StaticAuth) S3() *S3Clients + func (a *StaticAuth) SecretManager() *SecretManagerClients + func (a *StaticAuth) Ses() *SesClients + func (a *StaticAuth) Sns() *SnsClients + func (a *StaticAuth) SnsSqs() *SnsSqsClients + func (a *StaticAuth) Sqs() *SqsClients + func (a *StaticAuth) UpdatePostgres(ctx context.Context, poolConfig *pgxpool.Config) + func (a *StaticAuth) WithMockClients(clients *Clients)
Go to main page