Documentation ¶
Index ¶
Constants ¶
This section is empty.
Variables ¶
This section is empty.
Functions ¶
This section is empty.
Types ¶
type ProductionManager ¶
type ProductionManager struct { FaktoryClient *faktory.Client // contains filtered or unexported fields }
ProductionManager the stucture holding all data associated with faktory
func (*ProductionManager) GenerateJobsForTopic ¶
func (pm *ProductionManager) GenerateJobsForTopic(topic string, payload string) bool
GenerateJobsForTopic generates a job for each subscriber attached to this topic with the provided data
func (*ProductionManager) InitalizeFaktoryConnection ¶
func (pm *ProductionManager) InitalizeFaktoryConnection()
InitalizeFaktoryConnection starts a connection with the faktory server
func (*ProductionManager) PushNewJob ¶
func (pm *ProductionManager) PushNewJob(url string, filterExp string, payload string) bool
PushNewJob adds a new job into the queue
func (*ProductionManager) SeedTopicSubcriptionMap ¶
func (pm *ProductionManager) SeedTopicSubcriptionMap()
SeedTopicSubcriptionMap grabs a fresh copy of all subscribers from the Database grouped by to topic
Click to show internal directories.
Click to hide internal directories.