kafka

package

v0.0.0-...-1afb120 Latest Latest Go to latest Published: Mar 2, 2023 License: MIT Imports: 17 Imported by: 0

Details

Valid go.mod file
Redistributable license
Tagged version
Stable version
Learn more about best practices

Repository

github.com/tony-spark/recipetor-backend

Documentation ¶

Index ¶

Constants
func NewController(nutritionService service.Service, kafkaBrokerURLs string) (controller.Controller, error)
type RecipeWorker
- func (w RecipeWorker) Process(ctx context.Context) error
- func (w RecipeWorker) Stop() error
type Worker
- func NewRecipeWorker(nutritionService service.Service, brokers []string) (Worker, error)

Constants ¶

View Source

const (
	TopicRecipes        = "recipes"
	TopicIngredients    = "ingredients"
	TopicNutritionFacts = "nutritionfacts"
	TopicIngredientsReq = "ingredients.req"
)

View Source

const (
	KeyCorrelationID = "correlation_id"
)

Variables ¶

This section is empty.

Functions ¶

func NewController ¶

func NewController(nutritionService service.Service, kafkaBrokerURLs string) (controller.Controller, error)

Types ¶

type RecipeWorker ¶

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

func (RecipeWorker) Process ¶

func (w RecipeWorker) Process(ctx context.Context) error

func (RecipeWorker) Stop ¶

func (w RecipeWorker) Stop() error

type Worker ¶

type Worker interface {
	Process(ctx context.Context) error
	Stop() error
}

func NewRecipeWorker ¶

func NewRecipeWorker(nutritionService service.Service, brokers []string) (Worker, error)

Source Files ¶

View all Source files

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