dynamodb

Documentation

Index

• func FetchAndPopulateRedis() error
• func ListenForNewURL(redisClient *redis.Client)
• func ListenForNewUrl(ctx *gin.Context, redisClient *redis.Client)
• func RemoveUrl(shortUrl string) (string, error)
• func SaveUrlMapping(shortUrl, originalUrl, userid string) error
• type DynamoDBEntry
• type DynamoDBService
  • func InitializeDynamoDB() *DynamoDBService

Functions

func FetchAndPopulateRedis

func FetchAndPopulateRedis() error

Fetches data from dynamodb on cold restart and populates data to redis

func ListenForNewURL

func ListenForNewURL(redisClient *redis.Client)

ListenForNewURL listens for new URL added events from Redis and saves to DynamoDB

func ListenForNewUrl

func ListenForNewUrl(ctx *gin.Context, redisClient *redis.Client)

Listens to redis subscription for new push events

func RemoveUrl

func RemoveUrl(shortUrl string) (string, error)

func SaveUrlMapping

func SaveUrlMapping(shortUrl, originalUrl, userid string) error

save url mapping to dynamodb

Types

type DynamoDBEntry

type DynamoDBEntry struct {
	ShortURL    string
	OriginalURL string
	UserID      string
}

DynamoDBEntry represents the structure of data in DynamoDB

type DynamoDBService

type DynamoDBService struct {
	// contains filtered or unexported fields
}

DynamoDB wrapper

func InitializeDynamoDB

func InitializeDynamoDB() *DynamoDBService