videoserver

package module

Go to main page

Versions in this module

v0

v0.6.0

Oct 25, 2024

Changes in this version

+ const EVENT_ARCHIVE_CLOSE_FILE

+ const EVENT_ARCHIVE_CREATE_FILE

+ const EVENT_ARCHIVE_START_CAST

+ const EVENT_CHAN_KEYFRAME

+ const EVENT_CHAN_PACKET

+ const EVENT_CHAN_STOP

+ const EVENT_HLS_CLOSE_FILE

+ const EVENT_HLS_PLAYLIST_CREATE

+ const EVENT_HLS_PLAYLIST_PREPARE

+ const EVENT_HLS_PLAYLIST_RESTART

+ const EVENT_HLS_REMOVE_CHUNK

+ const EVENT_HLS_REMOVE_OUTDATED

+ const EVENT_HLS_REMOVE_OUTDATED_SEGMENT

+ const EVENT_HLS_START_CAST

+ const EVENT_HLS_WRITE_TRAIL

+ const EVENT_MP4_CLOSE

+ const EVENT_MP4_SAVE_MINIO

+ const EVENT_MP4_WRITE

+ const EVENT_MP4_WRITE_TRAIL

+ const EVENT_NO_START

+ const EVENT_SEGMENT_CUT

+ const EVENT_STREAMING_AUDIO_MET

+ const EVENT_STREAMING_CODEC_MET

+ const EVENT_STREAMING_CODEC_UPDATE_SIGNAL

+ const EVENT_STREAMING_DIAL

+ const EVENT_STREAMING_DONE

+ const EVENT_STREAMING_EXIT_SIGNAL

+ const EVENT_STREAMING_HLS_CAST

+ const EVENT_STREAMING_MP4_CAST

+ const EVENT_STREAMING_PACKET_SIGNAL

+ const EVENT_STREAMING_RESTART

+ const EVENT_STREAMING_RUN

+ const EVENT_STREAMING_START

+ const EVENT_STREAMING_STATUS_UPDATE

+ const EVENT_STREAMING_STOP_SIGNAL

+ const EVENT_STREAMING_UNKNOWN_SIGNAL

+ const EVENT_STREAM_CAST_PACKET

+ const EVENT_STREAM_CLIENT_ADD

+ const EVENT_STREAM_CLIENT_DELETE

+ const EVENT_STREAM_CODEC_ADD

+ const EVENT_STREAM_STATUS_UPDATE

+ const EVENT_WS_PING

+ const SCOPE_ARCHIVE

+ const SCOPE_CONFIGURATION

+ const SCOPE_HLS

+ const SCOPE_MP4

+ const SCOPE_STREAMING

+ const STOP_SIGNAL_DISCONNECT

+ const STOP_SIGNAL_ERR

+ const STOP_SIGNAL_NO_VIDEO

+ const STOP_SIGNAL_STOP_DIAL

+ var ErrTimeFailure = fmt.Errorf("bad packet times")

+ func UploadToMinio(minioStorage storage.ArchiveStorage, ...) (string, error)

+ type StopSignal uint8

+ type StreamArchiveWrapper struct

v0.5.2

Sep 16, 2024

Changes in this version

+ const EVENT_APP_CORS_CONFIG

+ const SCOPE_APP

+ var ErrNullArchive = fmt.Errorf("archive == nil")

type StreamsStorage

+ func (streams *StreamsStorage) AddCodecForStream(streamID uuid.UUID, codecs []av.CodecData)

+ func (streams *StreamsStorage) AddViewer(streamID uuid.UUID) (uuid.UUID, chan av.Packet, error)

+ func (streams *StreamsStorage) CastPacket(streamID uuid.UUID, pck av.Packet, hlsEnabled, archiveEnabled bool) error

+ func (streams *StreamsStorage) DeleteViewer(streamID, clientID uuid.UUID)

+ func (streams *StreamsStorage) GetAllStreamsIDS() []uuid.UUID

+ func (streams *StreamsStorage) GetCodecsDataForStream(streamID uuid.UUID) ([]av.CodecData, error)

+ func (streams *StreamsStorage) GetStreamArchiveStorage(streamID uuid.UUID) *streamArhive

+ func (streams *StreamsStorage) GetStreamInfo(streamID uuid.UUID) (string, []StreamType)

+ func (streams *StreamsStorage) GetVerboseLevelForStream(streamID uuid.UUID) VerboseLevel

+ func (streams *StreamsStorage) IsArchiveEnabledForStream(streamID uuid.UUID) (bool, error)

+ func (streams *StreamsStorage) StreamExists(streamID uuid.UUID) bool

+ func (streams *StreamsStorage) TypeExistsForStream(streamID uuid.UUID, streamType StreamType) bool

+ func (streams *StreamsStorage) UpdateArchiveStorageForStream(streamID uuid.UUID, archiveStorage *streamArhive) error

+ func (streams *StreamsStorage) UpdateStreamStatus(streamID uuid.UUID, status bool) error

v0.5.1

Sep 16, 2024

Changes in this version

+ const EVENT_API_CORS_ENABLE

+ const EVENT_API_PREPARE

+ const EVENT_API_REQUEST

+ const EVENT_API_START

+ const EVENT_WS_CORS_ENABLE

+ const EVENT_WS_PREPARE

+ const EVENT_WS_REQUEST

+ const EVENT_WS_START

+ const EVENT_WS_UPGRADER

+ const SCOPE_API_SERVER

+ const SCOPE_WS_SERVER

type VideoConfiguration

+ Verbose VerboseLevel

v0.5.0

Sep 11, 2024

Changes in this version

+ const SCOPE_STREAM

+ const STREAM_TYPE_HLS

+ const STREAM_TYPE_MSE

+ const STREAM_TYPE_RTSP

+ const STREAM_TYPE_UNDEFINED

+ const VERBOSE_ADD

+ const VERBOSE_ALL

+ const VERBOSE_NONE

+ const VERBOSE_SIMPLE

+ var ErrNotSupportedStorage = fmt.Errorf("not supported storage")

+ var ErrStreamTypeNotExists = fmt.Errorf("stream type does not exists")

+ var ErrStreamTypeNotSupported = fmt.Errorf("stream type is not supported")

+ var SCOPE_WS_HANDLER = "ws_handler"

+ func MutexLocked(m *sync.Mutex) bool

+ func RWMutexLocked(rw *sync.RWMutex) bool

+ func RWMutexRLocked(rw *sync.RWMutex) bool

type APIConfiguration

+ Verbose VerboseLevel

type Application

+ func (app *Application) RunStream(ctx context.Context, streamID uuid.UUID) error

+ func (app *Application) SetStreamArchive(streamID uuid.UUID, archiveStorage *streamArhive) error

type EnablePostData

+ OutputTypes []string

type StreamConfiguration

+ SupportedOutputTypes []StreamType

+ type StreamType uint16

+ func (iotaIdx StreamType) String() string

type StreamsStorage

+ func (sm *StreamsStorage) GetStream(id uuid.UUID) (string, []StreamType)

+ type VerboseLevel uint16

+ func NewVerboseLevelFrom(str string) VerboseLevel

v0.4.0

Aug 18, 2022

Changes in this version

+ var ErrStreamDisconnected = fmt.Errorf("Disconnected")

+ var ErrStreamHasNoVideo = fmt.Errorf("Stream has no video")

+ type APIConfiguration struct

+ Enabled bool

+ Host string

+ Mode string

+ Port int32

type Application

+ APICfg APIConfiguration

+ HLS HLSInfo

+ VideoServerCfg VideoConfiguration

+ type HLSInfo struct

+ Capacity uint

+ Directory string

+ MsPerSegment int64

+ WindowSize uint

type StreamConfiguration

+ func NewStreamConfiguration(streamURL string, supportedTypes []string) *StreamConfiguration

+ type StreamInfoShorten struct

+ StreamID string

+ type StreamsInfoShortenList struct

+ Data []StreamInfoShorten

+ type StreamsStorage struct

+ Streams map[uuid.UUID]*StreamConfiguration

+ func NewStreamsStorageDefault() StreamsStorage

+ type VideoConfiguration struct

+ Host string

+ Mode string

+ Port int32

v0.3.2

Nov 13, 2021

Changes in this version

+ func DisableCamera(app *Application) func(ctx *gin.Context)

+ func EnableCamera(app *Application) func(ctx *gin.Context)

type Application

+ func (app *Application) StartAPIServer()

+ func (app *Application) StartStream(k uuid.UUID)

+ func (app *Application) StartVideoServer()

+ type EnablePostData struct

+ GUID uuid.UUID

+ StreamTypes []string

+ URL string

type ServerConfiguration

+ APIHTTPPort int

+ VideoHTTPPort int

type ServerInfo

+ APIHTTPPort int

+ VideoHTTPPort int

v0.3.1

Oct 12, 2020

v0.3.0

Oct 12, 2020

Changes in this version

type Application

+ CorsConfig *cors.Config

type ConfigurationArgs

+ CorsConfig CorsConfiguration

+ type CorsConfiguration struct

+ AllowCredentials bool

+ AllowHeaders []string

+ AllowMethods []string

+ AllowOrigins []string

+ ExposeHeaders []string

+ UseCORS bool

type StreamConfiguration

+ SupportedStreamTypes []string

v0.2.1

Oct 1, 2020

v0.2.0

Oct 1, 2020

Changes in this version

+ var ErrStreamNotFound = fmt.Errorf("Stream not found for provided ID")

+ func HLSWrapper(app *Application) func(ctx *gin.Context)

+ func ListWrapper(app *Application) func(ctx *gin.Context)

+ func StatusWrapper(app *Application) func(ctx *gin.Context)

+ func WebSocketWrapper(app *Application) func(ctx *gin.Context)

+ type Application struct

+ HlsCapacity uint

+ HlsDirectory string

+ HlsMsPerSegment int64

+ HlsWindowSize uint

+ Server *ServerInfo

+ Streams StreamsMap

+ func NewApplication(cfg *ConfigurationArgs) (*Application, error)

+ func (app *Application) StartHTTPServer()

+ func (app *Application) StartStreams()

type ConfigurationArgs

+ func NewConfiguration(fname string) (*ConfigurationArgs, error)

type ServerConfiguration

+ HTTPAddr string

+ type ServerInfo struct

+ HTTPAddr string

+ HTTPPort int

type StreamArg

+ StreamTypes []string

+ type StreamsMap struct

+ Streams map[uuid.UUID]*StreamConfiguration

v0.1.0

Jul 17, 2020

Changes in this version

+ func StartHTTPServer(cfg *AppConfiguration)

+ func StartStreams(cfg *AppConfiguration)

+ type AppConfiguration struct

+ HlsCapacity uint

+ HlsDirectory string

+ HlsMsPerSegment int64

+ HlsWindowSize uint

+ Server ServerConfiguration

+ Streams map[uuid.UUID]*StreamConfiguration

+ func NewAppConfiguration(fname string) (*AppConfiguration, error)

+ type ConfigurationArgs struct

+ HlsCapacity uint

+ HlsDirectory string

+ HlsMsPerSegment int64

+ HlsWindowSize uint

+ Server ServerConfiguration

+ Streams []StreamArg

+ type ServerConfiguration struct

+ HTTPPort string

+ type StreamArg struct

+ GUID string

+ URL string

+ type StreamConfiguration struct

+ Clients map[uuid.UUID]viewer

+ Codecs []av.CodecData

+ HlsChanel chan av.Packet

+ Status bool

+ URL string

?	: This menu
/	: Search site
f or F	: Jump to
y or Y	: Canonical URL