Versions in this module Expand all Collapse all v0 v0.1.1 Dec 26, 2018 Changes in this version + func NewPostgresStorage(config PostgresDBConfig) (postgres *postgresStorage, err error) + type MemoryStorage struct + func NewMemoryStorage() *MemoryStorage + func (memStore *MemoryStorage) Add(task TaskAttributes) error + func (memStore *MemoryStorage) Close() error + func (memStore *MemoryStorage) Fetch() ([]TaskAttributes, error) + func (memStore *MemoryStorage) Remove(task TaskAttributes) error + type NoOpStorage struct + func NewNoOpStorage() NoOpStorage + func (noop NoOpStorage) Add(task TaskAttributes) error + func (noop NoOpStorage) Close() error + func (noop NoOpStorage) Fetch() ([]TaskAttributes, error) + func (noop NoOpStorage) Remove(task TaskAttributes) error + type PostgresDBConfig struct + DbURL string + type TaskAttributes struct + Duration string + Hash string + IsRecurring string + LastRun string + Name string + NextRun string + Params string + type TaskStore interface + Add func(TaskAttributes) error + Close func() error + Fetch func() ([]TaskAttributes, error) + Remove func(TaskAttributes) error