mqs

type BoltDbConfig struct {
	FileName string `mapstructure:"filename"`
}

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

type IronMQ struct {

	// Protects the map
	sync.Mutex
	// contains filtered or unexported fields
}

type IronMQConfig struct {
	Token       string `mapstructure:"token"`
	ProjectId   string `mapstructure:"project_id"`
	Host        string `mapstructure:"host"`
	Scheme      string `mapstructure:"scheme"`
	Port        uint16 `mapstructure:"port"`
	QueuePrefix string `mapstructure:"queue_prefix"`
}

type MemoryMQ struct {
	// WorkQueue A buffered channel that we can send work requests on.
	PriorityQueues []chan *models.Task
	Ticker         *time.Ticker
	BTree          *btree.BTree
	Timeouts       map[string]*TaskItem
	// Protects B-tree and Timeouts
	// If this becomes a bottleneck, consider separating the two mutexes. The
	// goroutine to clear up timed out messages could also become a bottleneck at
	// some point. May need to switch to bucketing of some sort.
	Mutex sync.Mutex
}

type Mock struct {
	FakeApp   *models.App
	Apps      []*models.App
	FakeRoute *models.Route
	Routes    []*models.Route
}

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

type TaskItem struct {
	Task    *models.Task
	StartAt time.Time
}