stream

package
v0.9.8 Latest Latest
Warning

This package is not in the latest version of its module.

Go to latest
Published: May 18, 2025 License: GPL-3.0 Imports: 12 Imported by: 0

Documentation

Index

Constants

This section is empty.

Variables

This section is empty.

Functions

This section is empty.

Types

type Repos added in v0.9.5

type Repos interface {
	PublishStream(c echo.Context) error
	UnpublishStream(c echo.Context) error
	ListStreams(c echo.Context) error
	FindStream(c echo.Context) error
	NewStream(c echo.Context) error
	EditStream(c echo.Context) error
	DeleteStream(c echo.Context) error
}

Repos encapsulates the dependency

func NewRepos added in v0.9.5

func NewRepos(db *sqlx.DB) Repos

NewRepos creates our data store

type Store added in v0.9.6

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

Repos encapsulates the dependency

func (*Store) DeleteStream added in v0.9.6

func (s *Store) DeleteStream(c echo.Context) error

DeleteStream deletes a stream endpoint

@Summary Delete stream endpoint @ID delete-stream @Tags stream-endpoints @Accept json @Param endpointid path int true "Endpoint ID" @Success 200 @Router /v1/internal/streams/{endpointid} [delete]

func (*Store) EditStream added in v0.9.6

func (s *Store) EditStream(c echo.Context) error

EditStream edits an existing position @Summary Edit stream endpoint @ID edit-stream @Tags stream-endpoints @Accept json @Param endpoint body stream.EndpointAddEditDTO true "Endpoint object" @Success 200 {object} stream.Endpoint @Router /v1/internal/streams/{endpointid} [put]

func (*Store) FindStream added in v0.9.6

func (s *Store) FindStream(c echo.Context) error

FindStream handles finding a stream @Summary Finds stream @Description finds existing stream @ID find-stream @Tags stream-endpoints @Accept json @Param endpoint body stream.FindEndpoint true "Find Endpoint object" @Success 200 {object} stream.Endpoint @Error 400 @Error 404 @Router /v1/internal/streams/find [get]

func (*Store) ListStreams added in v0.9.6

func (s *Store) ListStreams(c echo.Context) error

ListStreams handles a listing stream endpoints

@Summary ListStreams stream endpoints @Description Lists all stream endpoints; this is for Nginx RTMP module @Description containing the application, name, authentication and start and end times @ID get-stream @Tags stream-endpoints @Accept json @Success 200 {array} stream.Endpoint @Router /v1/internal/streams [get]

func (*Store) NewStream added in v0.9.6

func (s *Store) NewStream(c echo.Context) error

NewStream handles a creating a stream endpoint

@Summary NewStream stream endpoint @Description Creates a new stream endpoint; this is for Nginx RTMP module @Description containing the application, name, authentication and start and end times @ID new-stream @Tags stream-endpoints @Accept json @Param endpoint body stream.EndpointAddEditDTO true "Stream endpoint object" @Success 201 {object} stream.Endpoint @Error 400 @Router /v1/internal/streams [post]

func (*Store) PublishStream added in v0.9.6

func (s *Store) PublishStream(c echo.Context) error

PublishStream handles a stream publish request

@Summary Publish a stream @Description Checks existing stream endpoints and changes it to active; this is for Nginx RTMP module @Description containing the application, name and pwd @ID publish-stream @Tags stream-endpoints @Accept json @P aram event body @Success 200 body int "Endpoint published" @Error 401 @Router /v1/internal/stream/publish [post]

func (*Store) UnpublishStream added in v0.9.6

func (s *Store) UnpublishStream(c echo.Context) error

UnpublishStream handles a stream unpublish request

@Summary Unpublish a stream @Description Checks existing stream endpoints and changes it to inactive; this is for Nginx RTMP module @Description containing the application, name, authentication and start and end times @ID unpublish-stream @Tags stream-endpoints @Accept json @P aram event body @Success 200 body int @Error 401 @Router /v1/internal/stream/unpublish [post]

Jump to

Keyboard shortcuts

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