stream

func (*Repos) DeleteStream ¶ added in v0.9.5

func (r *Repos) 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 (*Repos) FindStream ¶ added in v0.9.5

func (r *Repos) 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.EndpointDB @Error 400 @Error 404 @Router /v1/internal/streams/find [get]

func (*Repos) ListStreams ¶ added in v0.9.5

func (r *Repos) 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 (*Repos) NewStream ¶ added in v0.9.5

func (r *Repos) 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.NewEditEndpoint true "Stream endpoint object" @Success 201 body int "EndpointDB ID" @Error 400 @Router /v1/internal/streams [post]

func (*Repos) PublishStream ¶ added in v0.9.5

func (r *Repos) 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 "EndpointDB ID" @Error 401 @Router /v1/internal/stream/publish [post]

func (*Repos) UnpublishStream ¶ added in v0.9.5

func (r *Repos) 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]

func (*Repos) UpdateStream ¶ added in v0.9.5

func (r *Repos) UpdateStream(c echo.Context) error

UpdateStream updates an existing position @Summary UpdateStream stream endpoint @ID update-stream @Tags stream-endpoints @Accept json @Param endpoint body stream.NewEditEndpoint true "Endpoint object" @Success 200 @Router /v1/internal/streams/{endpointid} [put]