streamserver

Sep 25, 2024

Changes in this version

+ var Config *ServerConfig

+ var ConfigPath string

+ func CachePlayer() error

+ func LoadPlaylist() error

+ func LoadServerConfig(path string) error

+ func Restart()

+ func Run(configPath string)

+ func SavePlaylist(p m3uprovider.PlaylistConfig) error

+ func SaveServerConfig(config ServerConfig) error

type ServerConfig

+ Auth json.RawMessage

+ Epg string

+ LogFile string

+ NumWorkers int

+ Playlist string

+ Port int

+ ScanTime int

+ Security SecurityConfig

+ Timeout int

+ func (c *ServerConfig) Merge(other ServerConfig)

Sep 7, 2025

Changes in this version

type ChannelsHandler

+ func (p *ChannelsHandler) Start(ctx context.Context)

+ func (p *ChannelsHandler) UpdateSources(ctx context.Context) error

type ConfigData

+ CacheDir string

+ EPGScanTime int

type EPGHandler

+ func (e *EPGHandler) Start(ctx context.Context)

+ func (e *EPGHandler) UpdateSources(ctx context.Context)

Sep 5, 2025

Changes in this version

+ type APIHandler struct

+ func NewAPIHandler(config *ServerConfig, restartChan *chan bool, channels *ChannelsHandler) *APIHandler

+ func (h *APIHandler) RegisterRoutes(r *mux.Router) *mux.Router

+ type ChannelsHandler struct

+ func NewChannelsHandler(config *ServerConfig) *ChannelsHandler

+ func (p *ChannelsHandler) GetChannel(id string) *streamEntry

+ func (p *ChannelsHandler) Load(ctx context.Context) error

+ func (p *ChannelsHandler) RegisterRoutes(r *mux.Router) *mux.Router

+ type ConfigData struct

+ Auth json.RawMessage

+ Epg string

+ LogFile string

+ LogLevel string

+ NumWorkers int

+ Playlist string

+ Port int

+ ScanTime int

+ Security SecurityConfig

+ Timeout int

+ func (c *ConfigData) Merge(other ConfigData)

+ type EPGHandler struct

+ func NewEPGHandler(config *ServerConfig) *EPGHandler

+ func (e *EPGHandler) RegisterRoutes(r *mux.Router) *mux.Router

+ type GeoIPConfig struct

+ Database string

+ InternalNetworks []string

+ Whitelist []string

+ type PlayerHandler struct

+ func NewPlayerHandler(config *ServerConfig) *PlayerHandler

+ func (p *PlayerHandler) CachePlayer() error

+ func (p *PlayerHandler) RegisterRoutes(r *mux.Router) *mux.Router

+ type SecurityConfig struct

+ AllowedCORSDomains []string

+ GeoIP GeoIPConfig

+ type ServerConfig struct

+ func NewServerConfig(path string) *ServerConfig

+ func (c *ServerConfig) Get() ConfigData

+ func (c *ServerConfig) GetAuth() json.RawMessage

+ func (c *ServerConfig) GetEpg() string

+ func (c *ServerConfig) GetNumWorkers() int

+ func (c *ServerConfig) GetPath() string

+ func (c *ServerConfig) GetPlaylist() string

+ func (c *ServerConfig) GetScanTime() int

+ func (c *ServerConfig) GetSecurity() SecurityConfig

+ func (c *ServerConfig) GetTimeout() int

+ func (c *ServerConfig) Load(path string) error

+ func (c *ServerConfig) Save() error

+ func (c *ServerConfig) Set(data ConfigData)

+ func (c *ServerConfig) SetAuth(auth json.RawMessage)

+ func (c *ServerConfig) SetEpg(epg string)

+ func (c *ServerConfig) SetNumWorkers(numWorkers int)

+ func (c *ServerConfig) SetPath(path string)

+ func (c *ServerConfig) SetPlaylist(playlist string)

+ func (c *ServerConfig) SetScanTime(scanTime int)

+ func (c *ServerConfig) SetSecurity(security SecurityConfig)

+ func (c *ServerConfig) SetTimeout(timeout int)

type StreamServer

+ func NewStreamServer(configPath string) *StreamServer

+ func (s *StreamServer) Restart()

+ func (s *StreamServer) Run()

Sep 16, 2024

Changes in this version

type StreamServerConfig

+ Epg string

Sep 15, 2024

Changes in this version

+ func LoadStreams() error

+ func Routes(next *mux.Router) http.Handler

+ type LRUCache struct

+ func NewLRUCache(capacity int) *LRUCache

+ func (l *LRUCache) Get(key string) string

+ func (l *LRUCache) Put(key string, value string)

+ type LocalStream struct

+ func NewImageStream(image, id string) *LocalStream

+ func (stream *LocalStream) Cleanup()

+ func (stream *LocalStream) Serve(w http.ResponseWriter, r *http.Request)

+ func (stream *LocalStream) Start() error

+ func (stream *LocalStream) Stop() error

+ type Node struct

type Stream

+ func (stream *Stream) Do(method, URI string) (*http.Response, error)

type StreamServerConfig

+ Timeout int

Sep 13, 2024

Changes in this version

+ func MonitorStreamsNoWorkers()

type Stream

+ func (stream *Stream) GenerateHttpRequest(opts StreamRequestOptions) (*http.Request, error)

+ func (stream *Stream) Get(URI string, timeout int) (*http.Response, error)

Sep 10, 2024

Changes in this version

type StreamServerConfig

+ UseHttps bool

Sep 10, 2024

Changes in this version

+ func StreamServer(next *mux.Router) http.Handler

Sep 8, 2024

Changes in this version

type StreamServerConfig

+ KodiSupport bool

Sep 7, 2024

Changes in this version

+ func AddStreams(playlist *m3uparser.M3UPlaylist) error

+ func Clear()

+ func HandleInternalStream(w http.ResponseWriter, r *http.Request)

+ func HandleStreamPlaylist(w http.ResponseWriter, r *http.Request)

+ func HandleStreamRequest(w http.ResponseWriter, r *http.Request)

+ func MonitorStreams(cancel <-chan bool, signal chan<- bool)

+ func SetupHandlers(r *mux.Router)

+ func Shutdown()

+ func Start(data json.RawMessage)

+ func StreamCount() int

+ type Stream struct

+ func (stream *Stream) HealthCheck(timeout int)

+ func (stream *Stream) HttpHeaders() map[string]string

+ func (stream *Stream) HttpRequest(opts StreamRequestOptions) (*http.Request, error)

+ func (stream *Stream) Serve(w http.ResponseWriter, r *http.Request) error

+ type StreamRequestOptions struct

+ Method string

+ Path string

+ Query string

+ type StreamServerConfig struct

+ DefaultTimeout int

+ HideInactive bool

+ NoServiceImage string

+ NumWorkers int

+ Playlist string

+ ScanTime int