subscriber

Documentation

Index

• func Init(s micro.Service, c *dig.Container) error
• type CatalogSubscriber
  • func NewCatalogSubscriber(combine service.CombineService, city service.CityService, ...) *CatalogSubscriber
  • func (e *CatalogSubscriber) Sync(ctx context.Context, msg *pb_shared.SyncRequest) error
• type CinemaSubscriber
  • func NewCinemaSubscriber(cinemaService service.CinemaService) *CinemaSubscriber
  • func (e *CinemaSubscriber) Sync(ctx context.Context, msg *pb_shared.SyncRequest) error
• type CitySubscriber
  • func NewCitySubscriber(cityService service.CityService) *CitySubscriber
  • func (e *CitySubscriber) Sync(ctx context.Context, msg *pb_shared.SyncRequest) error
• type CombineSubscriber
  • func NewCombineSubscriber(combineService service.CombineService) *CombineSubscriber
  • func (e *CombineSubscriber) Sync(ctx context.Context, msg *pb_shared.SyncRequest) error
• type DiscountSubscriber
  • func NewDiscountSubscriber(discountService service.DiscountService) *DiscountSubscriber
  • func (e *DiscountSubscriber) Sync(ctx context.Context, msg *pb_shared.SyncRequest) error
  • func (e *DiscountSubscriber) SyncPrices(ctx context.Context, msg *pb_shared.SyncRequest) error
• type HallSubscriber
  • func NewHallSubscriber(hallService service.HallService) *HallSubscriber
  • func (e *HallSubscriber) Sync(ctx context.Context, msg *pb_shared.SyncRequest) error
• type MovieSubscriber
  • func NewMovieSubscriber(movieService service.MovieService) *MovieSubscriber
  • func (e *MovieSubscriber) Format(ctx context.Context, msg *pb_shared.SyncRequest) error
  • func (e *MovieSubscriber) Sync(ctx context.Context, msg *pb_shared.SyncRequest) error
• type ScheduleSubscriber
  • func NewScheduleSubscriber(scheduleService service.ScheduleService) *ScheduleSubscriber
  • func (e *ScheduleSubscriber) Sync(ctx context.Context, msg *pb_shared.SyncRequest) error
• type SeanceSubscriber
  • func NewSeanceSubscriber(seanceService service.SeanceService, discountService service.DiscountService) *SeanceSubscriber
  • func (e *SeanceSubscriber) Sync(ctx context.Context, msg *pb_shared.SyncRequest) error
  • func (e *SeanceSubscriber) SyncToSeance(ctx context.Context, msg *pb_shared.SyncRequest) error

Functions

func Init

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

Types

type CatalogSubscriber

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

CatalogSubscriber struct

func NewCatalogSubscriber

func NewCatalogSubscriber(
	combine service.CombineService,
	city service.CityService,
	cinema service.CinemaService,
	hall service.HallService,
	movie service.MovieService,
	seance service.SeanceService,
	discount service.DiscountService,
	schedule service.ScheduleService,
) *CatalogSubscriber

NewCatalogSubscriber init subscriber

func (*CatalogSubscriber) Sync

func (e *CatalogSubscriber) Sync(ctx context.Context, msg *pb_shared.SyncRequest) error

Sync ...

type CinemaSubscriber

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

CinemaSubscriber struct

func NewCinemaSubscriber

func NewCinemaSubscriber(cinemaService service.CinemaService) *CinemaSubscriber

NewCinemaSubscriber init subscriber

func (*CinemaSubscriber) Sync

func (e *CinemaSubscriber) Sync(ctx context.Context, msg *pb_shared.SyncRequest) error

Sync ...

type CitySubscriber

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

CitySubscriber struct

func NewCitySubscriber

func NewCitySubscriber(cityService service.CityService) *CitySubscriber

NewCitySubscriber init subscriber

func (*CitySubscriber) Sync

func (e *CitySubscriber) Sync(ctx context.Context, msg *pb_shared.SyncRequest) error

Sync ...

type CombineSubscriber

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

CombineSubscriber struct

func NewCombineSubscriber

func NewCombineSubscriber(combineService service.CombineService) *CombineSubscriber

NewCombineSubscriber init subscriber

func (*CombineSubscriber) Sync

func (e *CombineSubscriber) Sync(ctx context.Context, msg *pb_shared.SyncRequest) error

Sync ...

type DiscountSubscriber

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

SeanceSubscriber struct

func NewDiscountSubscriber

func NewDiscountSubscriber(
	discountService service.DiscountService,
) *DiscountSubscriber

NewSeanceSubscriber init subscriber

func (*DiscountSubscriber) Sync

func (e *DiscountSubscriber) Sync(ctx context.Context, msg *pb_shared.SyncRequest) error

Sync ...

func (*DiscountSubscriber) SyncPrices

func (e *DiscountSubscriber) SyncPrices(ctx context.Context, msg *pb_shared.SyncRequest) error

SyncPrices ...

type HallSubscriber

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

HallSubscriber struct

func NewHallSubscriber

func NewHallSubscriber(hallService service.HallService) *HallSubscriber

NewHallSubscriber init subscriber

func (*HallSubscriber) Sync

func (e *HallSubscriber) Sync(ctx context.Context, msg *pb_shared.SyncRequest) error

Sync ...

type MovieSubscriber

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

MovieSubscriber struct

func NewMovieSubscriber

func NewMovieSubscriber(movieService service.MovieService) *MovieSubscriber

NewMovieSubscriber init subscriber

func (*MovieSubscriber) Format

func (e *MovieSubscriber) Format(ctx context.Context, msg *pb_shared.SyncRequest) error

Format ...

func (*MovieSubscriber) Sync

func (e *MovieSubscriber) Sync(ctx context.Context, msg *pb_shared.SyncRequest) error

Sync ...

type ScheduleSubscriber

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

ScheduleSubscriber struct

func NewScheduleSubscriber

func NewScheduleSubscriber(scheduleService service.ScheduleService) *ScheduleSubscriber

NewScheduleSubscriber init subscriber

func (*ScheduleSubscriber) Sync

func (e *ScheduleSubscriber) Sync(ctx context.Context, msg *pb_shared.SyncRequest) error

Handle ...

type SeanceSubscriber

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

SeanceSubscriber struct

func NewSeanceSubscriber

func NewSeanceSubscriber(
	seanceService service.SeanceService,
	discountService service.DiscountService,
) *SeanceSubscriber

NewSeanceSubscriber init subscriber

func (*SeanceSubscriber) Sync

func (e *SeanceSubscriber) Sync(ctx context.Context, msg *pb_shared.SyncRequest) error

Sync ...

func (*SeanceSubscriber) SyncToSeance

func (e *SeanceSubscriber) SyncToSeance(ctx context.Context, msg *pb_shared.SyncRequest) error

SyncToSeance ...