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{}
Constants ¶
This section is empty.
Variables ¶
This section is empty.
Functions ¶
func ApiGwCreateKafkaEvent ¶
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 ¶
GetCloudWatchSource retrieves the source from the event source
func GetCloudWatchTopic ¶
GetCloudWatchTopic retrieves the topic from the event detail type
func GetDynamoDBSource ¶
GetDynamoDBSource retrieves the source from the event source
func GetSecretManagerValue ¶
GetSecretManagerValue retrieves a secret from AWS Secrets Manager
func GetSsmParam ¶
GetSsmParam retrieves a parameter from AWS SSM Parameter Store
func MarshalDynamoDBEventToLocal ¶
func MarshalDynamoDBEventToLocal(event events.DynamoDBEvent) types.DynamoDBEvent
func ReturnListFromString ¶
Types ¶
This section is empty.
Source Files
Click to show internal directories.
Click to hide internal directories.