Documentation
¶
Index ¶
- Constants
- Variables
- func SetLogger(l *zap.SugaredLogger)
- type AddParams
- type DBTX
- type GetParams
- type Poller
- func (p Poller) CompleteTask(t *Task)
- func (p Poller) IncomingTasks() <-chan *Task
- func (p *Poller) IsShutdown() bool
- func (p *Poller) Process() error
- func (p Poller) ProgressTask(t *Task, progress float64) error
- func (p Poller) RejectTask(t *Task) error
- func (p Poller) ReleaseTask(t *Task) error
- func (p *Poller) Shutdown()
- func (p Poller) StartTask(t *Task) error
- type Queries
- func (q *Queries) Add(ctx context.Context, arg AddParams) (*Task, error)
- func (q *Queries) Get(ctx context.Context, id uint32) (*Task, error)
- func (q *Queries) GetBySDHash(ctx context.Context, sdHash string) (*Task, error)
- func (q *Queries) List(ctx context.Context) ([]*Task, error)
- func (q *Queries) Poll(ctx context.Context) (*Task, error)
- func (q *Queries) Release(ctx context.Context, id uint32) error
- type Queue
- func (q Queue) Add(url, sdHash, _type string) (*Task, error)
- func (q Queue) Complete(id uint32) error
- func (q Queue) Get(id uint32) (*Task, error)
- func (q Queue) GetBySDHash(sdHash string) (*Task, error)
- func (q Queue) List() ([]*Task, error)
- func (q Queue) Poll() (*Task, error)
- func (q Queue) Reject(id uint32) error
- func (q Queue) Release(id uint32) error
- func (q Queue) Start(id uint32) error
- func (q *Queue) StartPoller(workers int) *Poller
- func (q Queue) UpdateProgress(id uint32, progress float64) error
- type Task
Constants ¶
View Source
const ( StatusNew = "new" StatusPending = "pending" StatusStarted = "started" StatusRejected = "rejected" StatusReleased = "released" StatusCompleted = "completed" )
Variables ¶
View Source
var InitialMigration = `` /* 443-byte string literal not displayed */
Functions ¶
func SetLogger ¶
func SetLogger(l *zap.SugaredLogger)
Types ¶
type DBTX ¶
type DBTX interface { ExecContext(context.Context, string, ...interface{}) (sql.Result, error) PrepareContext(context.Context, string) (*sql.Stmt, error) QueryContext(context.Context, string, ...interface{}) (*sql.Rows, error) QueryRowContext(context.Context, string, ...interface{}) *sql.Row BeginTx(context.Context, *sql.TxOptions) (*sql.Tx, error) }
type Poller ¶
type Poller struct {
// contains filtered or unexported fields
}
func (Poller) CompleteTask ¶
func (Poller) IncomingTasks ¶
func (*Poller) IsShutdown ¶
func (Poller) RejectTask ¶
func (Poller) ReleaseTask ¶
type Queries ¶
type Queries struct {
// contains filtered or unexported fields
}
func (*Queries) GetBySDHash ¶
type Queue ¶
type Queue struct {
// contains filtered or unexported fields
}
func (*Queue) StartPoller ¶
Click to show internal directories.
Click to hide internal directories.