aws

Sep 11, 2023

Changes in this version

+ 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