kafka

Documentation

Index

• Constants
• func NewController(recipeService service.Service, kafkaBrokerURLs string) (controller.Controller, error)
• type AddRecipeWorker
  • func (w AddRecipeWorker) Process(ctx context.Context) error
  • func (w AddRecipeWorker) Stop() error
• type FindRecipesWorker
  • func (w FindRecipesWorker) Process(ctx context.Context) error
  • func (w FindRecipesWorker) Stop() error
• type RecipeNutritionFactsWorker
  • func (w RecipeNutritionFactsWorker) Process(ctx context.Context) error
  • func (w RecipeNutritionFactsWorker) Stop() error
• type Worker
  • func NewAddRecipeWorker(recipeService service.Service, brokers []string) (Worker, error)
  • func NewFindRecipesWorker(recipeService service.Service, brokers []string) (Worker, error)
  • func NewRecipeNutritionFactsWorker(recipeService service.Service, brokers []string) (Worker, error)

Constants

const (
	TopicRecipesNew     = "recipes.new"
	TopicRecipesReq     = "recipes.req"
	TopicRecipes        = "recipes"
	TopicNutritionFacts = "nutritionfacts"
)

const (
	KeyCorrelationID = "correlation_id"
)

Functions

func NewController

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

Types

type AddRecipeWorker

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

func (AddRecipeWorker) Process

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

func (AddRecipeWorker) Stop

func (w AddRecipeWorker) Stop() error

type FindRecipesWorker

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

func (FindRecipesWorker) Process

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

func (FindRecipesWorker) Stop

func (w FindRecipesWorker) Stop() error

type RecipeNutritionFactsWorker

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

func (RecipeNutritionFactsWorker) Process

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

func (RecipeNutritionFactsWorker) Stop

func (w RecipeNutritionFactsWorker) Stop() error

type Worker

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

func NewAddRecipeWorker

func NewAddRecipeWorker(recipeService service.Service, brokers []string) (Worker, error)

func NewFindRecipesWorker

func NewFindRecipesWorker(recipeService service.Service, brokers []string) (Worker, error)

func NewRecipeNutritionFactsWorker

func NewRecipeNutritionFactsWorker(recipeService service.Service, brokers []string) (Worker, error)