Documentation ¶
Index ¶
- func RegisterFormat(name, contentType string, parser Parse)
- type Parse
- type PipelineState
- func (p *PipelineState) CacheAlbumId(album string, artist string, albumId string)
- func (p *PipelineState) CreateSubscriber() chan *ProgressMessage
- func (p *PipelineState) GetCachedAlbumId(album string, artist string) (string, bool)
- func (p *PipelineState) GetSubscribers() []chan *ProgressMessage
- func (p *PipelineState) RemoveSubscriber(s chan *ProgressMessage)
- type PipelineStats
- type ProgressMessage
- type SpotifySong
Constants ¶
This section is empty.
Variables ¶
This section is empty.
Functions ¶
func RegisterFormat ¶
Types ¶
type PipelineState ¶
type PipelineState struct { Id string ProcessedSongs chan *SpotifySong Stats PipelineStats StartTime time.Time // contains filtered or unexported fields }
func GetRunningPipeline ¶
func GetRunningPipeline(id string) *PipelineState
func Process ¶
func Process(context *echo.Context, songs []*SpotifySong) (*PipelineState, error)
func RunImportPipeline ¶
func (*PipelineState) CacheAlbumId ¶
func (p *PipelineState) CacheAlbumId(album string, artist string, albumId string)
func (*PipelineState) CreateSubscriber ¶
func (p *PipelineState) CreateSubscriber() chan *ProgressMessage
func (*PipelineState) GetCachedAlbumId ¶
func (p *PipelineState) GetCachedAlbumId(album string, artist string) (string, bool)
func (*PipelineState) GetSubscribers ¶
func (p *PipelineState) GetSubscribers() []chan *ProgressMessage
func (*PipelineState) RemoveSubscriber ¶
func (p *PipelineState) RemoveSubscriber(s chan *ProgressMessage)
type PipelineStats ¶
type ProgressMessage ¶
type ProgressMessage struct { Stats PipelineStats NotFoundSong *SpotifySong }
Click to show internal directories.
Click to hide internal directories.