events

package
v0.0.0-...-e075ff3 Latest Latest
Warning

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

Go to latest
Published: Feb 27, 2024 License: MIT Imports: 5 Imported by: 0

Documentation

Index

Constants

View Source
const (
	DeleteImageRequestTopic = "delete_image_request"
)

Variables

This section is empty.

Functions

func NewImagesEvents

func NewImagesEvents(cfg KafkaConfig, logger *logrus.Logger) *imagesEvents

func NewMoviesEvents

func NewMoviesEvents(cfg KafkaConfig, logger *logrus.Logger) *moviesEvents

Types

type ImagesEventsMQ

type ImagesEventsMQ interface {
	DeleteImageRequest(ctx context.Context, id string, category string) error
}

type KafkaConfig

type KafkaConfig struct {
	Brokers []string
}

type MoviesEventsMQ

type MoviesEventsMQ interface {
	MovieDeleted(ctx context.Context, id int32) error
}

Directories

Path Synopsis
Package mock_events is a generated GoMock package.
Package mock_events is a generated GoMock package.

Jump to

Keyboard shortcuts

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