Documentation ¶
Index ¶
Constants ¶
This section is empty.
Variables ¶
View Source
var WaitMaxDuration = 5 * time.Second
Functions ¶
This section is empty.
Types ¶
type ConnectionInterface ¶
type ConnectionInterface interface {
Insert(...interface{}) error
}
type DatabaseInterface ¶
type DatabaseInterface interface {
Migrate(string)
}
type Heartbeater ¶
type Heartbeater struct {
// contains filtered or unexported fields
}
func NewHeartbeater ¶
func NewHeartbeater(queue QueueInterface, ticker TickerInterface) Heartbeater
func (Heartbeater) Beat ¶
func (beater Heartbeater) Beat(job *Job)
func (Heartbeater) Halt ¶
func (beater Heartbeater) Halt()
type Initializer ¶
type Initializer struct{}
func (Initializer) InitializeDBMap ¶
func (Initializer) InitializeDBMap(dbMap *gorp.DbMap)
type Job ¶
type Queue ¶
type Queue struct {
// contains filtered or unexported fields
}
func NewQueue ¶
func NewQueue(database DatabaseInterface, clock clock, config Config) *Queue
type QueueGauge ¶
type QueueGauge struct {
// contains filtered or unexported fields
}
func NewQueueGauge ¶
func NewQueueGauge(queue queue, timer <-chan time.Time) QueueGauge
func (QueueGauge) Run ¶
func (g QueueGauge) Run()
type QueueInterface ¶
type TickerInterface ¶
Click to show internal directories.
Click to hide internal directories.