core

Documentation

Index

• Variables
• func NewFileCache(name, cacheSize, cacheFolder string, maxItems int, getReader ReadFunc) *fileCache
• type Archiver
  • func NewArchiver(ds model.DataStore) Archiver
• type Artwork
  • func NewArtwork(ds model.DataStore, cache ArtworkCache) Artwork
• type ArtworkCache
  • func NewImageCache() ArtworkCache
• type CachedStream
  • func (s *CachedStream) Close() error
  • func (s *CachedStream) Seekable() bool
• type FileCache
• type MediaStreamer
  • func NewMediaStreamer(ds model.DataStore, ffm transcoder.Transcoder, cache TranscodingCache) MediaStreamer
• type ReadFunc
• type Stream
  • func (s *Stream) ContentType() string
  • func (s *Stream) Duration() float32
  • func (s *Stream) EstimatedContentLength() int
  • func (s *Stream) ModTime() time.Time
  • func (s *Stream) Name() string
  • func (s *Stream) Seekable() bool
• type TranscodingCache
  • func NewTranscodingCache() TranscodingCache

Variables

var Set = wire.NewSet(
	NewArtwork,
	NewMediaStreamer,
	NewTranscodingCache,
	NewImageCache,
	NewArchiver,
	transcoder.New,
)

Functions

func NewFileCache

func NewFileCache(name, cacheSize, cacheFolder string, maxItems int, getReader ReadFunc) *fileCache

Types

type Archiver

type Archiver interface {
	ZipAlbum(ctx context.Context, id string, w io.Writer) error
	ZipArtist(ctx context.Context, id string, w io.Writer) error
	ZipPlaylist(ctx context.Context, id string, w io.Writer) error
}

func NewArchiver

func NewArchiver(ds model.DataStore) Archiver

type Artwork

type Artwork interface {
	Get(ctx context.Context, id string, size int, out io.Writer) error
}

func NewArtwork

func NewArtwork(ds model.DataStore, cache ArtworkCache) Artwork

type ArtworkCache

type ArtworkCache FileCache

func NewImageCache

func NewImageCache() ArtworkCache

type CachedStream

type CachedStream struct {
	io.Reader
	io.Seeker
	Cached bool
}

func (*CachedStream) Close

func (s *CachedStream) Close() error

func (*CachedStream) Seekable

func (s *CachedStream) Seekable() bool

type FileCache

type FileCache interface {
	Get(ctx context.Context, arg fmt.Stringer) (*CachedStream, error)
	Ready() bool
}

type MediaStreamer

type MediaStreamer interface {
	NewStream(ctx context.Context, id string, reqFormat string, reqBitRate int) (*Stream, error)
}

func NewMediaStreamer

func NewMediaStreamer(ds model.DataStore, ffm transcoder.Transcoder, cache TranscodingCache) MediaStreamer

type ReadFunc

type ReadFunc func(ctx context.Context, arg fmt.Stringer) (io.Reader, error)

type Stream

type Stream struct {
	io.ReadCloser
	io.Seeker
	// contains filtered or unexported fields
}

func (*Stream) ContentType

func (s *Stream) ContentType() string

func (*Stream) Duration

func (s *Stream) Duration() float32

func (*Stream) EstimatedContentLength

func (s *Stream) EstimatedContentLength() int

func (*Stream) ModTime

func (s *Stream) ModTime() time.Time

func (*Stream) Name

func (s *Stream) Name() string

func (*Stream) Seekable

func (s *Stream) Seekable() bool

type TranscodingCache

type TranscodingCache FileCache

func NewTranscodingCache

func NewTranscodingCache() TranscodingCache