producer

package
Version: v0.0.0-...-9f5b622 Latest Latest
Warning

This package is not in the latest version of its module.

Go to latest
Published: Sep 26, 2020 License: MIT Imports: 4 Imported by: 0

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

Jump to

Keyboard shortcuts

? : This menu
/ : Search site
f or F : Jump to
y or Y : Canonical URL