Versions in this module Expand all Collapse all v0 v0.4.3 Mar 31, 2020 v0.3.6 Mar 31, 2020 Changes in this version + type Queue struct + func NewQueue(db *sql.DB, pipeSyncService domain.PipeSyncService, ...) *Queue + func (pq *Queue) LoadScheduledPipes() ([]*domain.Pipe, error) + func (pq *Queue) MarkPipeSynchronized(pipe *domain.Pipe) error + func (pq *Queue) ScheduleAutomaticPipesSynchronization() error + func (pq *Queue) SchedulePipeSynchronization(workspaceID int, serviceID domain.IntegrationID, pipeID domain.PipeID, ...) error
Go to main page