Versions in this module Expand all Collapse all v0 v0.7.0 Aug 22, 2018 Changes in this version + const DefaultDatabaseURI + const DefaultDriver + const DefaultEnabled + type Config struct + DatabaseDriver string + DatabaseURI string + Enabled bool + func NewConfig() Config + type Connection struct + Cancel chan struct{} + Config Config + SQL *sql.DB + WatchChan *time.Ticker + func NewConnection(config Config) *Connection + func (c *Connection) Close() error + func (c *Connection) Connect() error + func (c *Connection) ReadAll() (tasks []provider.Task, err error) + func (c *Connection) ReadTask(key string, task *provider.Task) error + func (c *Connection) WatchTasks(cb func(t provider.Task)) + func (c *Connection) WriteTask(t *provider.Task) error + type SourceProvider struct + Config Config + Connection *Connection + QuitChan chan bool + TaskFlow chan provider.Task + func NewSourceProvider(config Config) *SourceProvider + func (p *SourceProvider) Read() (err error) + func (p SourceProvider) OnTaskUpdate(fn func(*provider.Task) error) + func (p SourceProvider) Stop() error + func (p SourceProvider) String() string + func (p SourceProvider) TaskDone(t *provider.Task) error + func (p SourceProvider) TaskError(t *provider.Task, err error) error + func (p SourceProvider) TaskStarted(t *provider.Task) error
Go to main page