gobble

type Config struct {
	WaitMaxDuration time.Duration
	MaxQueueLength  int
}

type ConnectionInterface interface {
	Insert(...interface{}) error
}

type DB struct {
	Connection *gorp.DbMap
}

type DatabaseInterface interface {
	Migrate(string)
}

type Heartbeater struct {
	// contains filtered or unexported fields
}

type Initializer struct{}

type Job struct {
	ID          int       `db:"id"`
	WorkerID    string    `db:"worker_id"`
	Payload     string    `db:"payload"`
	Version     int64     `db:"version"`
	RetryCount  int       `db:"retry_count"`
	ActiveAt    time.Time `db:"active_at"`
	ShouldRetry bool      `db:"-"`
}

type Queue struct {
	// contains filtered or unexported fields
}

type QueueGauge struct {
	// contains filtered or unexported fields
}

type QueueInterface interface {
	Enqueue(*Job, ConnectionInterface) (*Job, error)
	Reserve(string) <-chan *Job
	Dequeue(*Job)
	Requeue(*Job)
	Len() (int, error)
}

type Ticker struct {
	// contains filtered or unexported fields
}

type TickerInterface interface {
	Tick() <-chan time.Time
	Start()
	Stop()
}

type Worker struct {
	ID string
	// contains filtered or unexported fields
}