Documentation
¶
Index ¶
- type Auth
- type AuthConfig
- type AuthConfigEntry
- type CleanupFunc
- type GlobalConfig
- type Parser
- type Proxy
- type Registry
- type Server
- func (s *Server) Errors() <-chan error
- func (s *Server) HandleHealth(w http.ResponseWriter, r *http.Request)
- func (s *Server) HandlePlaylist(body io.Reader, output io.Writer, path string, slug string) error
- func (s *Server) HandleSegment(body io.Reader, output io.Writer, path string, slug string) error
- func (s *Server) HandleUpload(w http.ResponseWriter, r *http.Request)
- func (s *Server) Wait()
- type Sink
- type StaticAuth
Constants ¶
This section is empty.
Variables ¶
This section is empty.
Functions ¶
This section is empty.
Types ¶
type Auth ¶
type Auth interface {
// Auth checks whether the user has access to the passed relative path
// Note: doesn't check whether the path is actually relative
Auth(user string, pass string, path string) (string, bool)
}
func NewStaticAuth ¶
type AuthConfig ¶
type AuthConfig struct {
Global GlobalConfig
Auth []AuthConfigEntry
}
type AuthConfigEntry ¶
type CleanupFunc ¶
type GlobalConfig ¶
type GlobalConfig struct {
AllowedDirs []string `toml:"allowedDirs"`
}
type Proxy ¶
type Proxy struct {
// contains filtered or unexported fields
}
func (*Proxy) HandleUpload ¶
func (p *Proxy) HandleUpload(w http.ResponseWriter, r *http.Request)
do delete ourselves as delete doesnt work...
type Registry ¶
type Registry struct {
// contains filtered or unexported fields
}
Registry tracks the lifetime of uploaded streams and stream segments
func NewRegistry ¶
func NewRegistry(ctx context.Context, callback CleanupFunc) *Registry
func (*Registry) AddFile ¶
Addfile adds a path to track for a certain stream if the stream doesn't exist yet we assume a timeout, the manifest will have to be uploaded shortly after
type Server ¶
type Server struct {
// contains filtered or unexported fields
}
func (*Server) HandleHealth ¶
func (s *Server) HandleHealth(w http.ResponseWriter, r *http.Request)
func (*Server) HandlePlaylist ¶
func (*Server) HandleSegment ¶
func (*Server) HandleUpload ¶
func (s *Server) HandleUpload(w http.ResponseWriter, r *http.Request)
do delete ourselves as delete doesnt work...
type StaticAuth ¶
type StaticAuth struct {
// contains filtered or unexported fields
}
Source Files
Click to show internal directories.
Click to hide internal directories.