animeaggregator

Documentation

Index

• func CreatePaginationResponse(page int64, elements int64, count int64) *grpc_animeaggregator_v1.PaginationResponse
• func NewGRPCService(animeMappingSvc animemapping.Service, animeSvc anime.Service, ...) grpc_animeaggregator_v1.AnimeAggregatorServiceServer
• type Service
  • func NewService(db database.DB, cacher cacher.Cacher, ...) Service

Functions

func CreatePaginationResponse

func CreatePaginationResponse(
	page int64,
	elements int64,
	count int64,
) *grpc_animeaggregator_v1.PaginationResponse

func NewGRPCService

func NewGRPCService(
	animeMappingSvc animemapping.Service,
	animeSvc anime.Service,
	animeAggregatorSvc Service,
) grpc_animeaggregator_v1.AnimeAggregatorServiceServer

Types

type Service

type Service interface {
	Refresh(ctx context.Context) (*domain.RefreshAnimeAggregatorAggregateResult, error)

	FilterAnime(ctx context.Context, query params.FilterAggregatedAnimeParams) (count int64, animes []*domain.AggregatedAnime, err error)
	ListSeasons(ctx context.Context) ([]enum.Season, error)
	ListFormats(ctx context.Context) ([]enum.Format, error)
	ListStatuses(ctx context.Context) ([]enum.Status, error)
	ListSeasonYears(ctx context.Context) ([]*int, error)
	ListStudios(ctx context.Context) ([]*domain.Studio, error)
	ListGenres(ctx context.Context) ([]*domain.Genre, error)
	ListTags(ctx context.Context) ([]*domain.Tag, error)
}

func NewService

func NewService(
	db database.DB,
	cacher cacher.Cacher,
	animeAggregatorIndexSvc animeaggregatorindex.Service,
	imageProcessorClient imageprocessorclient.Client,
) Service