producer

Documentation

Index

• type ProductionManager
  • func (pm *ProductionManager) GenerateJobsForTopic(topic string, payload string) bool
  • func (pm *ProductionManager) InitalizeFaktoryConnection()
  • func (pm *ProductionManager) PushNewJob(url string, filterExp string, payload string) bool
  • func (pm *ProductionManager) SeedTopicSubcriptionMap()

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