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 GeoIPConfig struct

+ Database string

+ InternalNetworks []string

+ Whitelist []string

+ type SecurityConfig struct

+ AllowedCORSDomains []string

+ GeoIP GeoIPConfig

+ type ServerConfig struct

+ 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 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