server

Documentation

Index

• func Entry(port int, pubSub pubsub.PubSub, querySched scheduler.Scheduler, ...) error
• type Server
  • func NewServer(querySched scheduler.Scheduler, dlSched scheduler.Scheduler, pub pubsub.PubSub, ...) *Server
  • func (s *Server) BulkScheduleVideoDownloads(ctx context.Context, req api.BulkScheduleVideoDownloads) (*api.Void, error)
  • func (s *Server) CancelVideoDownload(ctx context.Context, req api.CancelVideoDownload) (*api.Void, error)
  • func (s *Server) GetBulkChannelsDetails(ctx context.Context, req api.GetBulkChannelsDetailsRequest) (*api.GetBulkChannelsDetailsResponse, error)
  • func (s *Server) GetBulkPlaylistsDetails(ctx context.Context, req api.GetBulkPlaylistsDetailsRequest) (*api.GetBulkPlaylistsDetailsResponse, error)
  • func (s *Server) GetBulkVideosDetails(ctx context.Context, req api.GetBulkVideosDetailsRequest) (*api.GetBulkVideosDetailsResponse, error)
  • func (s *Server) GetChannelDetails(ctx context.Context, req api.GetChannelDetailsRequest) (*api.GetChannelDetailsResponse, error)
  • func (s *Server) GetChannelVideoIDs(ctx context.Context, req api.GetChannelVideoIDsRequest) (*api.GetChannelVideoIDsResponse, error)
  • func (s *Server) GetPlaylistDetails(ctx context.Context, req api.GetPlaylistDetailsRequest) (*api.GetPlaylistDetailsResponse, error)
  • func (s *Server) GetPlaylistVideoIDs(ctx context.Context, req api.GetPlaylistVideoIDsRequest) (*api.GetPlaylistVideoIDsResponse, error)
  • func (s *Server) GetVideoDetails(ctx context.Context, req api.GetVideoDetailsRequest) (*api.GetVideoDetailsResponse, error)
  • func (s *Server) ListCache(ctx context.Context, req api.ListCacheRequest) (*api.ListCacheResponse, error)
  • func (s *Server) ListVideoDownloads(ctx context.Context, req api.Void) (*api.VideoDownloads, error)
  • func (s *Server) ListenAndServe(port int) error
  • func (s *Server) PurgeVideo(ctx context.Context, req api.PurgeVideo) (*api.Void, error)
  • func (s *Server) ScheduleVideoDownload(ctx context.Context, req api.ScheduleVideoDownload) (*api.Void, error)

Functions

func Entry

func Entry(
	port int,
	pubSub pubsub.PubSub,
	querySched scheduler.Scheduler,
	dlSched scheduler.Scheduler,
	infoCache infocache.InfoCache,
	vidCache vidcache.VidCache,
	thumbCache thumbcache.ThumbCache,
	cachedVideoIDs cachedset.CachedSet,
	hound hound.Hound,
	dlOpts *ytdl.Options,
	concurrency int,
	disableDownloads bool,
	log *zap.Logger,
) error

Types

type Server

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

func NewServer

func NewServer(
	querySched scheduler.Scheduler,
	dlSched scheduler.Scheduler,
	pub pubsub.PubSub,
	infoCache infocache.InfoCache,
	vidCache vidcache.VidCache,
	thumbCache thumbcache.ThumbCache,
	cachedVideoIDs cachedset.CachedSet,
	log *zap.Logger,
) *Server

func (*Server) BulkScheduleVideoDownloads

func (s *Server) BulkScheduleVideoDownloads(
	ctx context.Context,
	req api.BulkScheduleVideoDownloads,
) (*api.Void, error)

func (*Server) CancelVideoDownload

func (s *Server) CancelVideoDownload(
	ctx context.Context,
	req api.CancelVideoDownload,
) (*api.Void, error)

func (*Server) GetBulkChannelsDetails

func (s *Server) GetBulkChannelsDetails(
	ctx context.Context,
	req api.GetBulkChannelsDetailsRequest,
) (*api.GetBulkChannelsDetailsResponse, error)

func (*Server) GetBulkPlaylistsDetails

func (s *Server) GetBulkPlaylistsDetails(
	ctx context.Context,
	req api.GetBulkPlaylistsDetailsRequest,
) (*api.GetBulkPlaylistsDetailsResponse, error)

func (*Server) GetBulkVideosDetails

func (s *Server) GetBulkVideosDetails(
	ctx context.Context,
	req api.GetBulkVideosDetailsRequest,
) (*api.GetBulkVideosDetailsResponse, error)

func (*Server) GetChannelDetails

func (s *Server) GetChannelDetails(ctx context.Context, req api.GetChannelDetailsRequest) (*api.GetChannelDetailsResponse, error)

func (*Server) GetChannelVideoIDs

func (s *Server) GetChannelVideoIDs(ctx context.Context, req api.GetChannelVideoIDsRequest) (*api.GetChannelVideoIDsResponse, error)

func (*Server) GetPlaylistDetails

func (s *Server) GetPlaylistDetails(ctx context.Context, req api.GetPlaylistDetailsRequest) (*api.GetPlaylistDetailsResponse, error)

func (*Server) GetPlaylistVideoIDs

func (s *Server) GetPlaylistVideoIDs(ctx context.Context, req api.GetPlaylistVideoIDsRequest) (*api.GetPlaylistVideoIDsResponse, error)

func (*Server) GetVideoDetails

func (s *Server) GetVideoDetails(
	ctx context.Context,
	req api.GetVideoDetailsRequest,
) (*api.GetVideoDetailsResponse, error)

func (*Server) ListCache

func (s *Server) ListCache(ctx context.Context, req api.ListCacheRequest) (*api.ListCacheResponse, error)

func (*Server) ListVideoDownloads

func (s *Server) ListVideoDownloads(
	ctx context.Context,
	req api.Void,
) (*api.VideoDownloads, error)

func (*Server) ListenAndServe

func (s *Server) ListenAndServe(port int) error

func (*Server) PurgeVideo

func (s *Server) PurgeVideo(ctx context.Context, req api.PurgeVideo) (*api.Void, error)

func (*Server) ScheduleVideoDownload

func (s *Server) ScheduleVideoDownload(
	ctx context.Context,
	req api.ScheduleVideoDownload,
) (*api.Void, error)