awswrapper

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

func DynamoDBScan(ctx context.Context, params *dynamodb.ScanInput) (*dynamodb.ScanOutput, error)

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

func EventBridgePutEvents(ctx context.Context, detail, source, eventBusName string) error

EventBridgePutEvents send custom events to the specified Amazon EventBridge Event Bus Name.

func SQSSendMessage

func SQSSendMessage(ctx context.Context, queue, message, groupdId string) error

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.