aws

func ApiGwCreateKafkaEvent ¶

func ApiGwCreateKafkaEvent(ctx context.Context, event events.APIGatewayProxyRequest, key []byte) ([]*kgo.Record, context.Context)

func CloudWatchCreateKafkaEvent ¶

func CloudWatchCreateKafkaEvent(ctx context.Context, event types.CloudWatchEvent, key []byte) ([]*kgo.Record, context.Context)

CloudWatchCreateKafkaEvent retrieves the payload from the event detail

func CreateCloudwatchMetric ¶

func CreateCloudwatchMetric(metric []*cloudwatch.MetricDatum, namespace string)

CreateCloudwatchMetric creates a metric in AWS Cloudwatch

func DynamoDbCreateKafkaEvent ¶

func DynamoDbCreateKafkaEvent(ctx context.Context, event types.DynamoDBEvent, key []byte) ([]*kgo.Record, context.Context)

DynamoDbCreateKafkaEvent retrieves the event

func FetchCredentials ¶

func FetchCredentials(credentialsKey string) types.CredentialsType

FetchCredentials retrieves credentials from AWS Secrets Manager

func GetCloudWatchSource ¶

func GetCloudWatchSource(ctx context.Context, eventSource string) context.Context

GetCloudWatchSource retrieves the source from the event source

func GetCloudWatchTopic ¶

func GetCloudWatchTopic(ctx context.Context, detailType string) context.Context

GetCloudWatchTopic retrieves the topic from the event detail type

func GetDynamoDBSource ¶

func GetDynamoDBSource(eventSourceArn string) string

GetDynamoDBSource retrieves the source from the event source

func GetSecretManagerValue ¶

func GetSecretManagerValue(passwordKey string) string

GetSecretManagerValue retrieves a secret from AWS Secrets Manager

func GetSsmParam ¶

func GetSsmParam(parameterPath string) string

GetSsmParam retrieves a parameter from AWS SSM Parameter Store

func MarshalDynamoDBEventToLocal ¶

func MarshalDynamoDBEventToLocal(event events.DynamoDBEvent) types.DynamoDBEvent

func ReturnListFromString ¶

func ReturnListFromString(body string) []map[string]interface{}