aws

Documentation

Index

• func ApiGwCreateKafkaEvent(ctx context.Context, event events.APIGatewayProxyRequest, key []byte) ([]*kgo.Record, context.Context)
• func CloudWatchCreateKafkaEvent(ctx context.Context, event types.CloudWatchEvent, key []byte) ([]*kgo.Record, context.Context)
• func CreateCloudwatchMetric(metric []*cloudwatch.MetricDatum, namespace string)
• func DynamoDbCreateKafkaEvent(ctx context.Context, event types.DynamoDBEvent, key []byte) ([]*kgo.Record, context.Context)
• func FetchCredentials(credentialsKey string) types.CredentialsType
• func GetCloudWatchSource(ctx context.Context, eventSource string) context.Context
• func GetCloudWatchTopic(ctx context.Context, detailType string) context.Context
• func GetDynamoDBSource(eventSourceArn string) string
• func GetSecretManagerValue(passwordKey string) string
• func GetSsmParam(parameterPath string) string
• func MarshalDynamoDBEventToLocal(event events.DynamoDBEvent) types.DynamoDBEvent
• func ReturnListFromString(body string) []map[string]interface{}

Functions

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{}