subscriber

Documentation

Index

• func Init(s micro.Service, c *dig.Container) error
• type CinemaSubscriber
  • func NewCinemaSubscriber(cinemaService service.CinemaService, configurator *plugin_configurator.Plugin) *CinemaSubscriber
  • func (e *CinemaSubscriber) Handle(ctx context.Context, msg *pb_catalog_cinema.CinemaEvent) error
• type CitySubscriber
  • func NewCitySubscriber(cityService service.CityService, configurator *plugin_configurator.Plugin) *CitySubscriber
  • func (e *CitySubscriber) Handle(ctx context.Context, msg *pb_catalog_city.CityEvent) error
• type CombineSubscriber
  • func NewCombineSubscriber(combineService service.CombineService, ...) *CombineSubscriber
  • func (e *CombineSubscriber) Handle(ctx context.Context, msg *pb_catalog_combine.CombineEvent) error
• type HallSubscriber
  • func NewHallSubscriber(hallService service.HallService, configurator *plugin_configurator.Plugin) *HallSubscriber
  • func (e *HallSubscriber) Handle(ctx context.Context, msg *pb_catalog_hall.HallEvent) error
• type MovieSubscriber
  • func NewMovieSubscriber(movieService service.MovieService, configurator *plugin_configurator.Plugin) *MovieSubscriber
  • func (e *MovieSubscriber) Handle(ctx context.Context, msg *pb_catalog_movie.MovieEvent) error
• type ScheduleSubscriber
  • func NewScheduleSubscriber(scheduleService service.ScheduleService, ...) *ScheduleSubscriber
  • func (e *ScheduleSubscriber) Handle(ctx context.Context, msg *pb_catalog_schedule.ScheduleEvent) error
• type SeanceSubscriber
  • func NewSeanceSubscriber(seanceService service.SeanceService, configurator *plugin_configurator.Plugin) *SeanceSubscriber
  • func (e *SeanceSubscriber) Handle(ctx context.Context, msg *pb_catalog_seance.SeanceEvent) error

Functions

func Init

func Init(s micro.Service, c *dig.Container) error

Types

type CinemaSubscriber

type CinemaSubscriber struct {
	Configuration struct {
		Name string `json:"name"`
	} `json:"configuration"`
	// contains filtered or unexported fields
}

CinemaSubscriber struct

func NewCinemaSubscriber

func NewCinemaSubscriber(cinemaService service.CinemaService, configurator *plugin_configurator.Plugin) *CinemaSubscriber

NewCinemaSubscriber init subscriber

func (*CinemaSubscriber) Handle

func (e *CinemaSubscriber) Handle(ctx context.Context, msg *pb_catalog_cinema.CinemaEvent) error

Handle ...

type CitySubscriber

type CitySubscriber struct {
	Configuration struct {
		Name string `json:"name"`
	} `json:"configuration"`
	// contains filtered or unexported fields
}

CitySubscriber struct

func NewCitySubscriber

func NewCitySubscriber(cityService service.CityService, configurator *plugin_configurator.Plugin) *CitySubscriber

NewCitySubscriber init subscriber

func (*CitySubscriber) Handle

func (e *CitySubscriber) Handle(ctx context.Context, msg *pb_catalog_city.CityEvent) error

Handle ...

type CombineSubscriber

type CombineSubscriber struct {
	Configuration struct {
		Name string `json:"name"`
	} `json:"configuration"`
	// contains filtered or unexported fields
}

CombineSubscriber struct

func NewCombineSubscriber

func NewCombineSubscriber(combineService service.CombineService, configurator *plugin_configurator.Plugin) *CombineSubscriber

NewCombineSubscriber init subscriber

func (*CombineSubscriber) Handle

func (e *CombineSubscriber) Handle(ctx context.Context, msg *pb_catalog_combine.CombineEvent) error

Handle ...

type HallSubscriber

type HallSubscriber struct {
	Configuration struct {
		Name string `json:"name"`
	} `json:"configuration"`
	// contains filtered or unexported fields
}

HallSubscriber struct

func NewHallSubscriber

func NewHallSubscriber(hallService service.HallService, configurator *plugin_configurator.Plugin) *HallSubscriber

NewHallSubscriber init subscriber

func (*HallSubscriber) Handle

func (e *HallSubscriber) Handle(ctx context.Context, msg *pb_catalog_hall.HallEvent) error

Handle ...

type MovieSubscriber

type MovieSubscriber struct {
	Configuration struct {
		Name string `json:"name"`
	} `json:"configuration"`
	// contains filtered or unexported fields
}

MovieSubscriber struct

func NewMovieSubscriber

func NewMovieSubscriber(movieService service.MovieService, configurator *plugin_configurator.Plugin) *MovieSubscriber

NewMovieSubscriber init subscriber

func (*MovieSubscriber) Handle

func (e *MovieSubscriber) Handle(ctx context.Context, msg *pb_catalog_movie.MovieEvent) error

Handle ...

type ScheduleSubscriber

type ScheduleSubscriber struct {
	Configuration struct {
		Name string `json:"name"`
	} `json:"configuration"`
	// contains filtered or unexported fields
}

ScheduleSubscriber struct

func NewScheduleSubscriber

func NewScheduleSubscriber(scheduleService service.ScheduleService, configurator *plugin_configurator.Plugin) *ScheduleSubscriber

NewScheduleSubscriber init subscriber

func (*ScheduleSubscriber) Handle

func (e *ScheduleSubscriber) Handle(ctx context.Context, msg *pb_catalog_schedule.ScheduleEvent) error

Handle ...

type SeanceSubscriber

type SeanceSubscriber struct {
	Configuration struct {
		Name string `json:"name"`
	} `json:"configuration"`
	// contains filtered or unexported fields
}

SeanceSubscriber struct

func NewSeanceSubscriber

func NewSeanceSubscriber(seanceService service.SeanceService, configurator *plugin_configurator.Plugin) *SeanceSubscriber

NewSeanceSubscriber init subscriber

func (*SeanceSubscriber) Handle

func (e *SeanceSubscriber) Handle(ctx context.Context, msg *pb_catalog_seance.SeanceEvent) error

Handle ...