consumer

Documentation

Index

• type TCPConsumer
  • func NewTCPConsumer(ip string, port, maxStreamers int, streamPrefix string) *TCPConsumer
  • func (sc *TCPConsumer) GetStream(streamID string) (consumer.StreamConnection, error)
  • func (sc *TCPConsumer) Start() error
  • func (sc *TCPConsumer) Stop() error
• type TCPStreamConnection
  • func NewTCPStreamConnection(streamID string, streamType consts.StreamType, streamQuality consts.Quality, ...) *TCPStreamConnection
  • func (sc *TCPStreamConnection) AddConnection(quality consts.Quality, conn interface{}) error
  • func (sc *TCPStreamConnection) Close(quality consts.Quality) error
  • func (sc *TCPStreamConnection) GetNextChunk(quality consts.Quality) ([]byte, error)
  • func (sc *TCPStreamConnection) GetOutputChan(quality consts.Quality) (<-chan []byte, error)
  • func (sc *TCPStreamConnection) HandleStream(quality consts.Quality) error
  • func (sc *TCPStreamConnection) IsOpen() bool

Types

type TCPConsumer

type TCPConsumer struct {
	// contains filtered or unexported fields
}

func NewTCPConsumer

func NewTCPConsumer(ip string, port, maxStreamers int, streamPrefix string) *TCPConsumer

func (*TCPConsumer) GetStream

func (sc *TCPConsumer) GetStream(streamID string) (consumer.StreamConnection, error)

func (*TCPConsumer) Start

func (sc *TCPConsumer) Start() error

func (*TCPConsumer) Stop

func (sc *TCPConsumer) Stop() error

type TCPStreamConnection

type TCPStreamConnection struct {
	consumer.BaseStreamConnection

	sync.Mutex
	// contains filtered or unexported fields
}

TCPStreamConnection represents an in use and read-only stream connection

func NewTCPStreamConnection

func NewTCPStreamConnection(streamID string, streamType consts.StreamType, streamQuality consts.Quality, connection *net.TCPConn) *TCPStreamConnection

func (*TCPStreamConnection) AddConnection

func (sc *TCPStreamConnection) AddConnection(quality consts.Quality, conn interface{}) error

func (*TCPStreamConnection) Close

func (sc *TCPStreamConnection) Close(quality consts.Quality) error

func (*TCPStreamConnection) GetNextChunk

func (sc *TCPStreamConnection) GetNextChunk(quality consts.Quality) ([]byte, error)

func (*TCPStreamConnection) GetOutputChan

func (sc *TCPStreamConnection) GetOutputChan(quality consts.Quality) (<-chan []byte, error)

func (*TCPStreamConnection) HandleStream

func (sc *TCPStreamConnection) HandleStream(quality consts.Quality) error

func (*TCPStreamConnection) IsOpen

func (sc *TCPStreamConnection) IsOpen() bool