websocket

package

v0.0.0-...-b4d0808 Latest Latest Go to latest Published: May 9, 2020 License: BSD-2-Clause Imports: 19 Imported by: 0

Details

Valid go.mod file
Redistributable license
Tagged version
Stable version
Learn more about best practices

Repository

github.com/use-go/websocket-streamserver

Links

Open Source Insights

Documentation ¶

Index ¶

Constants
func SendWsControl(conn *websocket.Conn, ctrlType int, data []byte) (err error)
func SendWsStatus(conn *websocket.Conn, level, code string, req int) (err error)
type WebSocketConfig
type WebSocketService

Constants ¶

View Source

const (
	WSStatusStatus = "status"
	WSStatusError  = "error"
)

WS Status

View Source

const (
	WSPktAudio   = 8
	WSPktVideo   = 9
	WSPktControl = 18
)

1byte type

View Source

const (
	WSCConnect     = 0
	WSCPlay        = 1
	WSCPlay2       = 2
	WSCResume      = 3
	WSCPause       = 4
	WSCSeek        = 5
	WSCStop        = 6
	WSCClose       = 7
	WSCPublish     = 8
	WSCOnMetaData  = 9
	WSCStreamBegin = 11
	WSCStreamEnd   = 12
)

WS Control Cmd

View Source

const (
	NetconnectionCallFailed           = "NetConnection.Call.Failed"
	NetconnectionConnectAppShutdown   = "NetConnection.Connect.AppShutdown"
	NetconnectionConnectClosed        = "NetConnection.Connect.Closed"
	NetconnectionConnectFailed        = "NetConnection.Connect.Failed"
	NetconnectionConnectIdleTimeout   = "NetConnection.Connect.IdleTimeout"
	NetconnectionConnectInvalidApp    = "NetConnection.Connect.InvalidApp"
	NetconnectionConnectRejected      = "NetConnection.Connect.Rejected"
	NetconnectionConnectSuccess       = "NetConnection.Connect.Success"
	NetStreamBufferEmpty              = "NetStream.Buffer.Empty"
	NetStreamBufferFlush              = "NetStream.Buffer.Flush"
	NetStreamBufferFull               = "NetStream.Buffer.Full"
	NetStreamFailed                   = "NetStream.Failed"
	NetStreamPauseNotify              = "NetStream.Pause.Notify"
	NetStreamPlayFailed               = "NetStream.Play.Failed"
	NetStreamPlayFileStructureInvalid = "NetStream.Play.FileStructureInvalid"
	NetStreamPlayPublishNotify        = "NetStream.Play.PublishNotify"
	NetStreamPlayReset                = "NetStream.Play.Reset"
	NetStreamPlayStart                = "NetStream.Play.Start"
	NetStreamPlayStop                 = "NetStream.Play.Stop"
	NetStreamPlayStreamNotFound       = "NetStream.Play.StreamNotFound"
	NetStreamPlayUnpublishNotify      = "NetStream.Play.UnpublishNotify"
	NetStreamPublishBadName           = "NetStream.Publish.BadName"
	NetStreamPublishIdle              = "NetStream.Publish.Idle"
	NetStreamPublishStart             = "NetStream.Publish.Start"
	NetStreamRecordAlreadyExists      = "NetStream.Record.AlreadyExists"
	NetStreamRecordFailed             = "NetStream.Record.Failed"
	NetStreamRecordNoAccess           = "NetStream.Record.NoAccess"
	NetStreamRecordStart              = "NetStream.Record.Start"
	NetStreamRecordStop               = "NetStream.Record.Stop"
	NetStreamSeekFailed               = "NetStream.Seek.Failed"
	NetStreamSeekInvalidTime          = "NetStream.Seek.InvalidTime"
	NetStreamSeekNotify               = "NetStream.Seek.Notify"
	NetStreamStepNotify               = "NetStream.Step.Notify"
	NetStreamUnpauseNotify            = "NetStream.Unpause.Notify"
	NetStreamUnpublishSuccess         = "NetStream.Unpublish.Success"
	NetStreamVideoDimensionChange     = "NetStream.Video.DimensionChange"
)

const string resource

Variables ¶

This section is empty.

Functions ¶

func SendWsControl ¶

func SendWsControl(conn *websocket.Conn, ctrlType int, data []byte) (err error)

SendWsControl Control command

func SendWsStatus ¶

func SendWsStatus(conn *websocket.Conn, level, code string, req int) (err error)

SendWsStatus code to client

Types ¶

type WebSocketConfig ¶

type WebSocketConfig struct {
	Port  int    `json:"Port"`
	Route string `json:"Route"`
}

WebSocketConfig to store webservice configuration information

type WebSocketService ¶

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

WebSocketService to handle webservice business

func (*WebSocketService) GetType ¶

func (websockService *WebSocketService) GetType() string

GetType interface implemention

func (*WebSocketService) HandleTask ¶

func (websockService *WebSocketService) HandleTask(task wssapi.Task) (err error)

HandleTask interface implemention

func (*WebSocketService) Init ¶

func (websockService *WebSocketService) Init(msg *wssapi.Msg) (err error)

Init interface implemention to init current websocket

func (*WebSocketService) ProcessMessage ¶

func (websockService *WebSocketService) ProcessMessage(msg *wssapi.Msg) (err error)

ProcessMessage interface implemention

func (*WebSocketService) ServeHTTP ¶

func (websockService *WebSocketService) ServeHTTP(w http.ResponseWriter, req *http.Request)

func (*WebSocketService) SetParent ¶

func (websockService *WebSocketService) SetParent(parent wssapi.MsgHandler)

SetParent handler for websocketservice

func (*WebSocketService) Start ¶

func (websockService *WebSocketService) Start(msg *wssapi.Msg) (err error)

Start interface implemention

func (*WebSocketService) Stop ¶

func (websockService *WebSocketService) Stop(msg *wssapi.Msg) (err error)

Stop interface implemention

Source Files ¶

View all Source files

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