wssapi

package

v0.0.0-...-b4d0808 Latest Latest Go to latest Published: May 9, 2020 License: BSD-2-Clause Imports: 9 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 CheckHeader(headers map[string]string) bool
func EncodeWSPCtrlMsg(code, seq string, headers map[string]string, payload string) string
func HandleTask(task Task) error
func SetHandler(hdlr MsgHandler)
type BitReader
type Msg
type MsgHandler
type Set
- func NewSet() *Set
type Task
type WSPInit
type WSPMessage
- func DecodeWSPCtrlMsg(data []byte) (ret *WSPMessage, err error)

Constants ¶

View Source

const (
	OBJProcess         = "HostProcess"
	OBJRTMPServer      = "RTMPServer"
	OBJWebSocketServer = "WebsocketServer"
	OBJBackendServer   = "BackendServer"
	OBJStreamerServer  = "StreamerServer"
	OBJRTSPServer      = "RTSPServer"
	OBJHLSServer       = "HLSServer"
	OBJDASHServer      = `DASHServer`
)

Server Type

View Source

const (
	MsgFlvTag            = "MSG.NetStream.Type.FLVTag"
	MsgGetSourceNotify   = "MSG.NetStream.GetSource.Notify.Async"
	MsgGetSourceFailed   = "MSG.NetStream.GetSource.Failed"
	MsgSourceClosedForce = "MSG.NetStream.SourceClosed.Force"
	MsgPublishStart      = "MSG.NetStream.Publish.Start"
	MsgPublishStop       = "MSG.NetStream.Publish.Stop"
	MsgPlayStart         = "MSG.NetStream.Play.Start"
	MsgPlayStop          = "MSG.NetStream.Play.Stop"
)

MSG Type to handle different Event

View Source

const (
	WSPVersion = "WSP/1.1"
	WSPCInit   = "INIT"
	WSPCJoin   = "JOIN"
	WSPWrap    = "WRAP"
	WSPRtsp    = "RTSP"
)

wsp Control Cmd Type

Variables ¶

This section is empty.

Functions ¶

func CheckHeader ¶

func CheckHeader(headers map[string]string) bool

CheckHeader ok or not

func EncodeWSPCtrlMsg ¶

func EncodeWSPCtrlMsg(code, seq string, headers map[string]string, payload string) string

EncodeWSPCtrlMsg return client request msg

func HandleTask ¶

func HandleTask(task Task) error

HandleTask to deal Task from service bus

func SetHandler ¶

func SetHandler(hdlr MsgHandler)

SetHandler to associate the action handler for some object

Types ¶

type BitReader ¶

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

BitReader read data by bit

func (*BitReader) BitsLeft ¶

func (bitReader *BitReader) BitsLeft() int

BitsLeft to get left Bits

func (*BitReader) CopyBits ¶

func (bitReader *BitReader) CopyBits(num int) int

CopyBits function

func (*BitReader) Init ¶

func (bitReader *BitReader) Init(data []byte)

Init bit array

func (*BitReader) Read32Bits ¶

func (bitReader *BitReader) Read32Bits() uint32

Read32Bits for 32bit

func (*BitReader) ReadBit ¶

func (bitReader *BitReader) ReadBit() int

ReadBit from Array

func (*BitReader) ReadBits ¶

func (bitReader *BitReader) ReadBits(num int) int

ReadBits from stream

func (*BitReader) ReadExponentialGolombCode ¶

func (bitReader *BitReader) ReadExponentialGolombCode() int

ReadExponentialGolombCode from stream

func (*BitReader) ReadSE ¶

func (bitReader *BitReader) ReadSE() int

ReadSE function

type Msg ¶

type Msg struct {
	Type    string // MSG Type to handle different Event
	Version string
	Param1  interface{}
	Param2  interface{}
	Params  *list.List
}

Msg type content of the websocket

type MsgHandler ¶

type MsgHandler interface {
	Init(msg *Msg) error
	Start(msg *Msg) error
	Stop(msg *Msg) error
	GetType() string
	HandleTask(task Task) error
	ProcessMessage(msg *Msg) error
}

MsgHandler : interface for websocket msg

type Set ¶

type Set struct {
	sync.RWMutex
	// contains filtered or unexported fields
}

Set for cmd Status change

func NewSet ¶

func NewSet() *Set

NewSet to New a Set Object

func (*Set) Add ¶

func (set *Set) Add(item interface{})

Add to Set item true

func (*Set) Del ¶

func (set *Set) Del(item interface{})

Del to remove

func (*Set) Has ¶

func (set *Set) Has(item interface{}) bool

Has to retrive item

type Task ¶

type Task interface {
	Receiver() string
	Type() string
}

Task type of the msg

type WSPInit ¶

type WSPInit struct {
	Proto string
	Host  string
	Port  uint
	Seq   uint
}

WSPInit Msg Package

type WSPMessage ¶

type WSPMessage struct {
	Msg     string
	MsgType string
	Headers map[string]string
	Payload string
}

WSPMessage hold a WSP Message

func DecodeWSPCtrlMsg ¶

func DecodeWSPCtrlMsg(data []byte) (ret *WSPMessage, err error)

DecodeWSPCtrlMsg decode ctrl msg & classify the msg type

Source Files ¶

View all Source files

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