events

package

v0.0.0-...-e075ff3 Latest Latest Go to latest Published: Feb 27, 2024 License: MIT Imports: 5 Imported by: 0

Details

View Source

const (
	DeleteImageRequestTopic = "delete_image_request"
)

This section is empty.

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

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

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

type KafkaConfig struct {
	Brokers []string
}

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

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