state

Feb 4, 2021

Changes in this version

+ const DynamoTableName

+ const TTLDefault

+ type DownloadedObject struct

+ Filename string

+ Object string

+ type DynamoDBStater struct

+ BackfillInterval time.Duration

+ Session *session.Session

+ func NewDynamoDBStater(session *session.Session, backfillHrs int) (*DynamoDBStater, error)

+ func (d *DynamoDBStater) ProcessedObjects() (map[string]time.Time, error)

+ func (d *DynamoDBStater) SetProcessed(s3object string) error

+ type FileStater struct

+ BackfillInterval time.Duration

+ Service string

+ StateDir string

+ func NewFileStater(stateDir, service string, backfillHrs int) *FileStater

+ func (f *FileStater) ProcessedObjects() (map[string]time.Time, error)

+ func (f *FileStater) SetProcessed(object string) error

+ type Record struct

+ S3Object string

+ TTL int64

+ Time time.Time

+ type Stater interface

+ ProcessedObjects func() (map[string]time.Time, error)

+ SetProcessed func(object string) error