compiler

Documentation

Index

• Variables
• func Compile(ctx context.Context, projectID string, sourcesClient sources.Sources, ...) (*api.Dataset, error)
• func GetChannelVideoIDs(ctx context.Context, seerClient seer.Seer, channelID string) ([]string, error)
• func GetPlaylistVideoIDs(ctx context.Context, seerClient seer.Seer, playlistID string) ([]string, error)
• func ResolveVideos(ctx context.Context, seerClient seer.Seer, ds datastore.DataStore, ...) error

Variables

var ErrNoVideos = errors.New("dataset has no videos")

Functions

func Compile

func Compile(
	ctx context.Context,
	projectID string,
	sourcesClient sources.Sources,
	seer seer.Seer,
	ds datastore.DataStore,
	dc datacache.DataCache,
	saveInterval time.Duration,
	saved chan<- *api.Dataset,
	onProgress chan<- struct{},
	log *zap.Logger,
) (*api.Dataset, error)

func GetChannelVideoIDs

func GetChannelVideoIDs(
	ctx context.Context,
	seerClient seer.Seer,
	channelID string,
) ([]string, error)

GetChannelVideoIDs returns all video IDs for a channel

func GetPlaylistVideoIDs

func GetPlaylistVideoIDs(
	ctx context.Context,
	seerClient seer.Seer,
	playlistID string,
) ([]string, error)

GetPlaylistVideoIDs returns all video IDs for a playlist

func ResolveVideos

func ResolveVideos(
	ctx context.Context,
	seerClient seer.Seer,
	ds datastore.DataStore,
	videos []*api.Video,
	resolvedVideo chan<- *api.Video,
	log *zap.Logger,
) error

ResolveVideos resolved the Details field for each video in videos. If resolvedVideo is not nil, then each video's details will be sent to resolvedVideo as they are resolved.