kafka

package

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

Details

View Source

const (
	TopicIngredientsNew = "ingredients.new"
	TopicIngredientsReq = "ingredients.req"
	TopicIngredients    = "ingredients"
)

View Source

const (
	KeyCorrelationID = "correlation_id"
)

This section is empty.

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

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

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

func (w AddIngredientWorker) Stop() error

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

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

func (w FindIngredientsWorker) Stop() error

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

func NewAddIngredientWorker(ingredientService service.Service, brokers []string) (Worker, error)

func NewFindIngredientsWorker(ingredientService service.Service, brokers []string) (Worker, error)