importtime

Documentation

Overview

Allows reading/writing last imported time for a given dataset. This is used by importer lambda function to determine if it needs to send a data imported notification, because if we get a flurry of zip files arriving we don't want to spam users.

Index

• func GetDatasetImportUnixTimeSec(fs fileaccess.FileAccess, configBucket string, datasetID string) (int, error)
• func SaveDatasetImportUnixTimeSec(fs fileaccess.FileAccess, log logger.ILogger, configBucket string, ...) error
• type LastImportTimes

Functions

func GetDatasetImportUnixTimeSec

func GetDatasetImportUnixTimeSec(fs fileaccess.FileAccess, configBucket string, datasetID string) (int, error)

GetDatasetImportUnixTimeSec - Returns the last unix time seconds timestamp that the dataset with given datasetID was imported or 0 if never

func SaveDatasetImportUnixTimeSec

func SaveDatasetImportUnixTimeSec(fs fileaccess.FileAccess, log logger.ILogger, configBucket string, datasetID string, unixTimeSec int) error

Types

type LastImportTimes

type LastImportTimes struct {
	Times map[string]int `json:"times"`
}