Documentation ¶
Index ¶
- Constants
- Variables
- func DynamoDBMarshalMap(v interface{}) (map[string]types.AttributeValue, error)
- func DynamoDBPutItem(ctx context.Context, params *dynamodb.PutItemInput) (*dynamodb.PutItemOutput, error)
- func DynamoDBQuery(ctx context.Context, params *dynamodb.QueryInput) (*dynamodb.QueryOutput, error)
- func DynamoDBScan(ctx context.Context, params *dynamodb.ScanInput) (*dynamodb.ScanOutput, error)
- func DynamoDBUnmarshalListOfMaps(v interface{}, result []map[string]types.AttributeValue) error
- func DynamoDBUnmarshalMap(v interface{}, result map[string]types.AttributeValue) error
- func DynamoDBUpdateItem(ctx context.Context, params *dynamodb.UpdateItemInput) (*dynamodb.UpdateItemOutput, error)
- func EventBridgePutEvents(ctx context.Context, detail, source, eventBusName string) error
- func SQSSendMessage(ctx context.Context, queue, message, groupdId string) error
- func SecretGetValue(ctx context.Context, secretId string) (*secretsmanager.GetSecretValueOutput, error)
Constants ¶
const (
AWS_REGION = "us-east-1"
)
Variables ¶
var (
BOOKING_MSG_GROUP_ID = "process.booking"
)
Functions ¶
func DynamoDBMarshalMap ¶
func DynamoDBMarshalMap(v interface{}) (map[string]types.AttributeValue, error)
DynamoDBMarshalMap marshals Go value type to a map of AttributeValues.
func DynamoDBPutItem ¶
func DynamoDBPutItem(ctx context.Context, params *dynamodb.PutItemInput) (*dynamodb.PutItemOutput, error)
DynamoDBPutItem initializes the DynamoDB Client and creates a new item, or replaces an old item with a new item.
func DynamoDBQuery ¶
func DynamoDBQuery(ctx context.Context, params *dynamodb.QueryInput) (*dynamodb.QueryOutput, error)
DynamoDBQuery initializes the DynamoDB Client and finds items based on primary key values. It returns all items with that partition key value.
func DynamoDBScan ¶
DynamoDBScan initializes the DynamoDB Client and reads every item in a table or a secondary index. It returns one or more items and item attributes.
func DynamoDBUnmarshalListOfMaps ¶
func DynamoDBUnmarshalListOfMaps(v interface{}, result []map[string]types.AttributeValue) error
DynamoDBUnmarshalListOfMaps returns a list of items with the values of result object.
func DynamoDBUnmarshalMap ¶
func DynamoDBUnmarshalMap(v interface{}, result map[string]types.AttributeValue) error
DynamoDBUnmarshalMap returns an item with the values of result object.
func DynamoDBUpdateItem ¶
func DynamoDBUpdateItem(ctx context.Context, params *dynamodb.UpdateItemInput) (*dynamodb.UpdateItemOutput, error)
DynamoDBUpdateItem initializes the DynamoDB Client and edits an existing item's attributes, or adds a new item to the table if it does not already exist.
func EventBridgePutEvents ¶
EventBridgePutEvents send custom events to the specified Amazon EventBridge Event Bus Name.
func SQSSendMessage ¶
SQSSendMessage initializes the SQS client and delivers message to the specified queue.
func SecretGetValue ¶
func SecretGetValue(ctx context.Context, secretId string) (*secretsmanager.GetSecretValueOutput, error)
SecretGetValue initializes the Secrets Manager client and retrieves the contents of the encrypted fields.
Types ¶
This section is empty.