handler

package
v1.1.1 Latest Latest
Warning

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

 Go to latest Published: Jan 26, 2021 License: AGPL-3.0 Imports: 15 Imported by: 0

Documentation

Index

Constants

This section is empty.

Variables

This section is empty.

Functions

func Init 

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

Types

type CatalogHandler added in v1.1.0 

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

CatalogHandler ...

func NewCatalogHandler added in v1.1.0 

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

NewCatalogHandler ...

func (*CatalogHandler) Sync added in v1.1.0 

func (h *CatalogHandler) Sync(ctx context.Context, req *rpc_catalog.SyncCatalogRequest, rsp *rpc_catalog.SyncCatalogResponse) error

Sync ...

type CinemaHandler 

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

CinemaHandler ...

func NewCinemaHandler 

func NewCinemaHandler(
	cinemaService service.CinemaService,
) *CinemaHandler

NewCinemaHandler ...

func (*CinemaHandler) Create 

func (h *CinemaHandler) Create(ctx context.Context, req *rpc_catalog_cinema.CreateCinemaRequest, rsp *rpc_catalog_cinema.CreateCinemaResponse) error

func (*CinemaHandler) Delete 

func (h *CinemaHandler) Delete(ctx context.Context, req *rpc_catalog_cinema.DeleteCinemaRequest, rsp *rpc_catalog_cinema.DeleteCinemaResponse) error

func (*CinemaHandler) Get 

func (h *CinemaHandler) Get(ctx context.Context, req *rpc_catalog_cinema.GetCinemaRequest, rsp *rpc_catalog_cinema.GetCinemaResponse) error

func (*CinemaHandler) GetCity 

func (h *CinemaHandler) GetCity(ctx context.Context, req *rpc_catalog_cinema.GetCinemaCityRequest, rsp *rpc_catalog_cinema.GetCinemaCityResponse) error

func (*CinemaHandler) GetHalls 

func (h *CinemaHandler) GetHalls(ctx context.Context, req *rpc_catalog_cinema.GetCinemaHallsRequest, rsp *rpc_catalog_cinema.GetCinemaHallsResponse) error

func (*CinemaHandler) GetSeances 

func (h *CinemaHandler) GetSeances(ctx context.Context, req *rpc_catalog_cinema.GetCinemaSeancesRequest, rsp *rpc_catalog_cinema.GetCinemaSeancesResponse) error

func (*CinemaHandler) IsExist 

func (h *CinemaHandler) IsExist(ctx context.Context, req *rpc_catalog_cinema.IsExistCinemaRequest, rsp *empty.Empty) error

func (*CinemaHandler) Paginate 

func (h *CinemaHandler) Paginate(ctx context.Context, req *rpc_catalog_cinema.PaginateCinemaRequest, rsp *rpc_catalog_cinema.PaginateCinemaResponse) error

func (*CinemaHandler) Sync 

func (h *CinemaHandler) Sync(ctx context.Context, req *rpc_catalog_cinema.SyncCinemaRequest, rsp *rpc_catalog_cinema.SyncCinemaResponse) error

Sync ...

func (*CinemaHandler) Update 

func (h *CinemaHandler) Update(ctx context.Context, req *rpc_catalog_cinema.UpdateCinemaRequest, rsp *rpc_catalog_cinema.UpdateCinemaResponse) error

type CityHandler 

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

CityHandler ...

func NewCityHandler 

func NewCityHandler(
	cityService service.CityService,
) *CityHandler

NewCityHandler ...

func (*CityHandler) Create 

func (h *CityHandler) Create(ctx context.Context, req *rpc_catalog_city.CreateCityRequest, rsp *rpc_catalog_city.CreateCityResponse) error

func (*CityHandler) Delete 

func (h *CityHandler) Delete(ctx context.Context, req *rpc_catalog_city.DeleteCityRequest, rsp *rpc_catalog_city.DeleteCityResponse) error

func (*CityHandler) Get 

func (h *CityHandler) Get(ctx context.Context, req *rpc_catalog_city.GetCityRequest, rsp *rpc_catalog_city.GetCityResponse) error

func (*CityHandler) GetCinemas 

func (h *CityHandler) GetCinemas(ctx context.Context, req *rpc_catalog_city.GetCityCinemasRequest, rsp *rpc_catalog_city.GetCityCinemasResponse) error

func (*CityHandler) GetSeances 

func (h *CityHandler) GetSeances(ctx context.Context, req *rpc_catalog_city.GetCitySeancesRequest, rsp *rpc_catalog_city.GetCitySeancesResponse) error

func (*CityHandler) GetTimezone added in v1.0.2 

func (h *CityHandler) GetTimezone(ctx context.Context, req *rpc_catalog_city.GetCityTimezoneRequest, rsp *rpc_catalog_city.GetCityTimezoneResponse) error

func (*CityHandler) IsExist 

func (h *CityHandler) IsExist(ctx context.Context, req *rpc_catalog_city.IsExistCityRequest, rsp *empty.Empty) error

func (*CityHandler) Paginate 

func (h *CityHandler) Paginate(ctx context.Context, req *rpc_catalog_city.PaginateCityRequest, rsp *rpc_catalog_city.PaginateCityResponse) error

func (*CityHandler) Sync 

func (h *CityHandler) Sync(ctx context.Context, req *rpc_catalog_city.SyncCityRequest, rsp *rpc_catalog_city.SyncCityResponse) error

Sync ...

func (*CityHandler) Update 

func (h *CityHandler) Update(ctx context.Context, req *rpc_catalog_city.UpdateCityRequest, rsp *rpc_catalog_city.UpdateCityResponse) error

type CombineHandler 

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

CombineHandler ...

func NewCombineHandler 

func NewCombineHandler(
	combineService service.CombineService,
) *CombineHandler

NewCombineHandler ...

func (*CombineHandler) Sync 

func (h *CombineHandler) Sync(ctx context.Context, req *rpc_catalog_combine.SyncCombineRequest, rsp *rpc_catalog_combine.SyncCombineResponse) error

Sync ...

type DiscountHandler added in v1.1.0 

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

DiscountHandler ...

func NewDiscountHandler added in v1.1.0 

func NewDiscountHandler(
	discountService service.DiscountService,
) *DiscountHandler

NewDiscountHandler ...

func (*DiscountHandler) Get added in v1.1.0 

func (h *DiscountHandler) Get(ctx context.Context, req *rpc_catalog_discount.GetDiscountRequest, rsp *rpc_catalog_discount.GetDiscountResponse) error

func (*DiscountHandler) IsExist added in v1.1.0 

func (h *DiscountHandler) IsExist(ctx context.Context, req *rpc_catalog_discount.IsExistDiscountRequest, rsp *empty.Empty) error

func (*DiscountHandler) Paginate added in v1.1.0 

func (h *DiscountHandler) Paginate(ctx context.Context, req *rpc_catalog_discount.PaginateDiscountRequest, rsp *rpc_catalog_discount.PaginateDiscountResponse) error

func (*DiscountHandler) Sync added in v1.1.0 

func (h *DiscountHandler) Sync(ctx context.Context, req *rpc_catalog_discount.SyncDiscountRequest, rsp *rpc_catalog_discount.SyncDiscountResponse) error

Sync ...

func (*DiscountHandler) SyncPrices added in v1.1.0 

func (h *DiscountHandler) SyncPrices(ctx context.Context, req *rpc_catalog_discount.SyncPricesDiscountRequest, rsp *rpc_catalog_discount.SyncDiscountResponse) error

SyncPrices ...

type HallHandler 

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

HallHandler ...

func NewHallHandler 

func NewHallHandler(
	hallService service.HallService,
) *HallHandler

NewHallHandler ...

func (*HallHandler) Create 

func (h *HallHandler) Create(ctx context.Context, req *rpc_catalog_hall.CreateHallRequest, rsp *rpc_catalog_hall.CreateHallResponse) error

func (*HallHandler) Delete 

func (h *HallHandler) Delete(ctx context.Context, req *rpc_catalog_hall.DeleteHallRequest, rsp *rpc_catalog_hall.DeleteHallResponse) error

func (*HallHandler) Get 

func (h *HallHandler) Get(ctx context.Context, req *rpc_catalog_hall.GetHallRequest, rsp *rpc_catalog_hall.GetHallResponse) error

func (*HallHandler) IsExist 

func (h *HallHandler) IsExist(ctx context.Context, req *rpc_catalog_hall.IsExistHallRequest, rsp *empty.Empty) error

func (*HallHandler) Paginate 

func (h *HallHandler) Paginate(ctx context.Context, req *rpc_catalog_hall.PaginateHallRequest, rsp *rpc_catalog_hall.PaginateHallResponse) error

func (*HallHandler) Sync 

func (h *HallHandler) Sync(ctx context.Context, req *rpc_catalog_hall.SyncHallRequest, rsp *rpc_catalog_hall.SyncHallResponse) error

Sync ...

func (*HallHandler) Update 

func (h *HallHandler) Update(ctx context.Context, req *rpc_catalog_hall.UpdateHallRequest, rsp *rpc_catalog_hall.UpdateHallResponse) error

type MovieHandler 

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

MovieHandler ...

func NewMovieHandler 

func NewMovieHandler(
	movieService service.MovieService,
) *MovieHandler

NewMovieHandler ...

func (*MovieHandler) Create 

func (h *MovieHandler) Create(ctx context.Context, req *rpc_catalog_movie.CreateMovieRequest, rsp *rpc_catalog_movie.CreateMovieResponse) error

func (*MovieHandler) Delete 

func (h *MovieHandler) Delete(ctx context.Context, req *rpc_catalog_movie.DeleteMovieRequest, rsp *rpc_catalog_movie.DeleteMovieResponse) error

func (*MovieHandler) FindMoviesByName 

func (h *MovieHandler) FindMoviesByName(ctx context.Context, req *rpc_catalog_movie.FindMoviesByNameRequest, rsp *rpc_catalog_movie.FindMoviesByNameResponse) error

func (*MovieHandler) Format 

func (h *MovieHandler) Format(ctx context.Context, req *rpc_catalog_movie.FormatMovieRequest, rsp *rpc_catalog_movie.FormatMovieResponse) error

Format ...

func (*MovieHandler) Get 

func (h *MovieHandler) Get(ctx context.Context, req *rpc_catalog_movie.GetMovieRequest, rsp *rpc_catalog_movie.GetMovieResponse) error

func (*MovieHandler) GetSeances 

func (h *MovieHandler) GetSeances(ctx context.Context, req *rpc_catalog_movie.GetMovieSeancesRequest, rsp *rpc_catalog_movie.GetMovieSeancesResponse) error

func (*MovieHandler) GetSoon 

func (h *MovieHandler) GetSoon(ctx context.Context, req *rpc_catalog_movie.GetMoviesSoonRequest, rsp *rpc_catalog_movie.GetMoviesSoonResponse) error

func (*MovieHandler) GetToday 

func (h *MovieHandler) GetToday(ctx context.Context, req *rpc_catalog_movie.GetMoviesTodayRequest, rsp *rpc_catalog_movie.GetMoviesTodayResponse) error

func (*MovieHandler) IsExist 

func (h *MovieHandler) IsExist(ctx context.Context, req *rpc_catalog_movie.IsExistMovieRequest, rsp *empty.Empty) error

func (*MovieHandler) Paginate 

func (h *MovieHandler) Paginate(ctx context.Context, req *rpc_catalog_movie.PaginateMovieRequest, rsp *rpc_catalog_movie.PaginateMovieResponse) error

func (*MovieHandler) Sync 

func (h *MovieHandler) Sync(ctx context.Context, req *rpc_catalog_movie.SyncMovieRequest, rsp *rpc_catalog_movie.SyncMovieResponse) error

Sync ...

func (*MovieHandler) Update 

func (h *MovieHandler) Update(ctx context.Context, req *rpc_catalog_movie.UpdateMovieRequest, rsp *rpc_catalog_movie.UpdateMovieResponse) error

func (*MovieHandler) UpdateMoviesParent 

func (h *MovieHandler) UpdateMoviesParent(ctx context.Context, req *rpc_catalog_movie.UpdateMoviesParentRequest, rsp *rpc_catalog_movie.UpdateMoviesParentResponse) error

type ScheduleHandler 

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

ScheduleHandler ...

func NewScheduleHandler 

func NewScheduleHandler(
	scheduleService service.ScheduleService,
) *ScheduleHandler

NewScheduleHandler ...

func (*ScheduleHandler) Paginate 

func (h *ScheduleHandler) Paginate(ctx context.Context, req *rpc_catalog_schedule.PaginateScheduleRequest, rsp *rpc_catalog_schedule.PaginateScheduleResponse) error

func (*ScheduleHandler) Sync 

func (h *ScheduleHandler) Sync(ctx context.Context, req *rpc_catalog_schedule.SyncScheduleRequest, rsp *rpc_catalog_schedule.SyncScheduleResponse) error

Sync ...

type SeanceHandler 

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

SeanceHandler ...

func NewSeanceHandler 

func NewSeanceHandler(
	seanceService service.SeanceService,
	discountService service.DiscountService,
) *SeanceHandler

NewSeanceHandler ...

func (*SeanceHandler) Create 

func (h *SeanceHandler) Create(ctx context.Context, req *rpc_catalog_seance.CreateSeanceRequest, rsp *rpc_catalog_seance.CreateSeanceResponse) error

func (*SeanceHandler) Delete 

func (h *SeanceHandler) Delete(ctx context.Context, req *rpc_catalog_seance.DeleteSeanceRequest, rsp *rpc_catalog_seance.DeleteSeanceResponse) error

func (*SeanceHandler) Get 

func (h *SeanceHandler) Get(ctx context.Context, req *rpc_catalog_seance.GetSeanceRequest, rsp *rpc_catalog_seance.GetSeanceResponse) error

func (*SeanceHandler) GetCinema 

func (h *SeanceHandler) GetCinema(ctx context.Context, req *rpc_catalog_seance.GetSeanceCinemaRequest, rsp *rpc_catalog_seance.GetSeanceCinemaResponse) error

func (*SeanceHandler) GetCity 

func (h *SeanceHandler) GetCity(ctx context.Context, req *rpc_catalog_seance.GetSeanceCityRequest, rsp *rpc_catalog_seance.GetSeanceCityResponse) error

func (*SeanceHandler) GetHall 

func (h *SeanceHandler) GetHall(ctx context.Context, req *rpc_catalog_seance.GetSeanceHallRequest, rsp *rpc_catalog_seance.GetSeanceHallResponse) error

func (*SeanceHandler) GetLocal 

func (h *SeanceHandler) GetLocal(ctx context.Context, req *rpc_catalog_seance.GetSeanceLocalRequest, rsp *rpc_catalog_seance.GetSeanceLocalResponse) error

func (*SeanceHandler) GetMovie 

func (h *SeanceHandler) GetMovie(ctx context.Context, req *rpc_catalog_seance.GetSeanceMovieRequest, rsp *rpc_catalog_seance.GetSeanceMovieResponse) error

func (*SeanceHandler) IsExist 

func (h *SeanceHandler) IsExist(ctx context.Context, req *rpc_catalog_seance.IsExistSeanceRequest, rsp *empty.Empty) error

func (*SeanceHandler) Paginate 

func (h *SeanceHandler) Paginate(ctx context.Context, req *rpc_catalog_seance.PaginateSeanceRequest, rsp *rpc_catalog_seance.PaginateSeanceResponse) error

func (*SeanceHandler) Sync 

func (h *SeanceHandler) Sync(ctx context.Context, req *rpc_catalog_seance.SyncSeanceRequest, rsp *rpc_catalog_seance.SyncSeanceResponse) error

Sync ...

func (*SeanceHandler) SyncSeanceDiscounts 

func (h *SeanceHandler) SyncSeanceDiscounts(ctx context.Context, req *rpc_catalog_seance.SyncSeanceDiscountsRequest, rsp *rpc_catalog_seance.SyncSeanceDiscountsResponse) error

SyncSeanceDiscounts ...

func (*SeanceHandler) Update 

func (h *SeanceHandler) Update(ctx context.Context, req *rpc_catalog_seance.UpdateSeanceRequest, rsp *rpc_catalog_seance.UpdateSeanceResponse) error

Source Files

View all Source files

Jump to

Keyboard shortcuts

? : This menu
/ : Search site
f or F : Jump to
y or Y : Canonical URL
go.dev uses cookies from Google to deliver and enhance the quality of its services and to analyze traffic. Learn more.