services

Documentation

Index

• func CacheAndArchive(ctx context.Context, app *infrastructure.AppState, key string, id int, ...)
• func FetchCantorInfo(ctx context.Context, db *pgxpool.Pool, id int) (infrastructure.CantorInfo, error)
• func GetPreviousRate(db *pgxpool.Pool, id int, currency string) (int64, error)
• func SaveToArchive(db *pgxpool.Pool, cantorID int, currency string, buyRate, sellRate int64)
• func ScrapeAndProcess(ctx context.Context, app *infrastructure.AppState, ...) (*pb.RateResponse, infrastructure.ProcessedRates, error)
• func UpdateCacheAndNotify(ctx context.Context, app *infrastructure.AppState, cantorID int, curr string, ...)

Functions

func CacheAndArchive

func CacheAndArchive(ctx context.Context, app *infrastructure.AppState, key string, id int, curr string,
	resp *pb.RateResponse, rates infrastructure.ProcessedRates)

func FetchCantorInfo

func FetchCantorInfo(ctx context.Context, db *pgxpool.Pool, id int) (infrastructure.CantorInfo, error)

func GetPreviousRate

func GetPreviousRate(db *pgxpool.Pool, id int, currency string) (int64, error)

func SaveToArchive

func SaveToArchive(db *pgxpool.Pool, cantorID int, currency string, buyRate, sellRate int64)

func ScrapeAndProcess

func ScrapeAndProcess(ctx context.Context, app *infrastructure.AppState, ci infrastructure.CantorInfo, id int, currency string) (*pb.RateResponse, infrastructure.ProcessedRates, error)

func UpdateCacheAndNotify

func UpdateCacheAndNotify(ctx context.Context, app *infrastructure.AppState, cantorID int, curr string, rates infrastructure.ProcessedRates)