streaming

Apr 5, 2024

Changes in this version

type Streamer

+ func (streamer *Streamer) SetPreamble(preamble []byte)

Jul 30, 2018

Changes in this version

type AccessController

+ func (control *AccessController) SetInhibit(inhibit bool)

type Client

+ func (client *Client) SetInhibit(inhibit bool)

type Command

+ const StreamerCommandAllow

+ const StreamerCommandInhibit

type Connection

+ ClientAddress string

+ Closed bool

type ConnectionRequest

+ Ok bool

+ Waiter *sync.WaitGroup

type Streamer

+ func (streamer *Streamer) SetInhibit(inhibit bool)

Jun 8, 2018

Changes in this version

type Configuration

+ Notifications []struct{ ... }

type Streamer

+ func (streamer *Streamer) SetNotifier(events event.Notifiable)

Feb 7, 2018

Changes in this version

+ var ErrAlreadyConnected = errors.New("restreamer: socket is already connected")

+ var ErrAlreadyRunning = errors.New("restreamer: service is already active")

+ var ErrInvalidProtocol = errors.New("restreamer: unsupported protocol")

+ var ErrInvalidResponse = errors.New("restreamer: unsupported response code")

+ var ErrLimitExceeded = errors.New("restreamer: Resource too large for cache")

+ var ErrNoConnection = errors.New("restreamer: socket not connected")

+ var ErrNoLength = errors.New("restreamer: Fetching of remote resource with unknown length not supported")

+ var ErrNoUrl = errors.New("restreamer: no parseable upstream URL")

+ var ErrNotRunning = errors.New("restreamer: service is not running")

+ var ErrOffline = errors.New("restreamer: refusing connection on an offline stream")

+ var ErrPoolFull = errors.New("restreamer: maximum number of active connections exceeded")

+ var ErrShortRead = errors.New("restreamer: Short read, not all data was transferred in one go")

+ var ErrSlowRead = errors.New("restreamer: send buffer overrun, increase client bandwidth")

+ func Etag(data []byte) string

+ func Get(url *url.URL, timeout time.Duration) (reader io.Reader, header http.Header, status int, length int64, err error)

+ func ServeStreamError(writer http.ResponseWriter, status int)

+ type AccessController struct

+ func NewAccessController(maxconnections uint) *AccessController

+ func (control *AccessController) Accept(remoteaddr string, streamer *Streamer) bool

+ func (control *AccessController) Release(streamer *Streamer)

+ func (control *AccessController) SetLogger(logger util.JsonLogger)

+ type Client struct

+ ReadTimeout time.Duration

+ Wait time.Duration

+ func NewClient(uris []string, streamer *Streamer, timeout uint, reconnect uint, ...) (*Client, error)

+ func (client *Client) Close() error

+ func (client *Client) Connect()

+ func (client *Client) Connected() bool

+ func (client *Client) SetCollector(stats api.Collector)

+ func (client *Client) SetLogger(logger util.JsonLogger)

+ func (client *Client) SetStateListener(listener connectCloser)

+ func (client *Client) Status() string

+ func (client *Client) StatusCode() int

+ type Command int

+ const StreamerCommandAdd

+ const StreamerCommandRemove

+ type Configuration struct

+ FullConnections uint

+ InputBuffer uint

+ Listen string

+ Log string

+ MaxConnections uint

+ NoStats bool

+ OutputBuffer uint

+ Profile bool

+ ReadTimeout uint

+ Reconnect uint

+ Resources []struct{ ... }

+ Timeout uint

+ func DefaultConfiguration() Configuration

+ func LoadConfiguration(filename string) (Configuration, error)

+ type Connection struct

+ Queue chan mpegts.Packet

+ func NewConnection(destination http.ResponseWriter, qsize int, clientaddr string) *Connection

+ func (conn *Connection) Serve()

+ func (conn *Connection) SetLogger(logger util.JsonLogger)

+ type ConnectionBroker interface

+ Accept func(remoteaddr string, streamer *Streamer) bool

+ Release func(streamer *Streamer)

+ type ConnectionRequest struct

+ Address string

+ Command Command

+ Connection *Connection

+ type Proxy struct

+ func NewProxy(uri string, timeout uint, cache uint) (*Proxy, error)

+ func (proxy *Proxy) ServeHTTP(writer http.ResponseWriter, request *http.Request)

+ func (proxy *Proxy) SetLogger(logger util.JsonLogger)

+ func (proxy *Proxy) SetStatistics(stats api.Statistics)

+ func (proxy *Proxy) Shutdown()

+ func (proxy *Proxy) Start()

+ type StateManager struct

+ func NewStateManager() *StateManager

+ func (manager *StateManager) Notify()

+ func (manager *StateManager) Register(channel chan<- bool)

+ func (manager *StateManager) Unregister(channel chan<- bool)

+ type Streamer struct

+ func NewStreamer(qsize uint, broker ConnectionBroker) *Streamer

+ func (streamer *Streamer) ServeHTTP(writer http.ResponseWriter, request *http.Request)

+ func (streamer *Streamer) SetCollector(stats api.Collector)

+ func (streamer *Streamer) SetLogger(logger util.JsonLogger)

+ func (streamer *Streamer) Stream(queue <-chan mpegts.Packet) error