biz

Documentation

Index

• func Close()
• func Entry(method string, peer *signal.Peer, msg json.RawMessage, ...)
• func Init(dcID, nodeID, rpcID, eventID string, natsURL string)
• func WatchServiceNodes(service string, state discovery.NodeStateType, node discovery.Node)
• type BroadcastMsg
• type CloseMsg
• type JoinMsg
• type LeaveMsg
• type LoginMsg
• type MediaInfo
• type PublishMsg
• type PublishOptions
• type PublishResponseMsg
• type RTCInfo
• type RoomInfo
• type StreamAddMsg
• type StreamRemoveMsg
• type SubscribeMsg
• type SubscribeResponseMsg
• type TrackInfo
• type TrackMap
• type TrickleMsg
• type UnpublishMsg
• type UnsubscribeMsg
• type UserInfo

Functions

func Close

func Close()

Close func

func Entry

func Entry(method string, peer *signal.Peer, msg json.RawMessage, accept signal.RespondFunc, reject signal.RejectFunc)

Entry is the biz entry

func Init

func Init(dcID, nodeID, rpcID, eventID string, natsURL string)

Init func

func WatchServiceNodes

func WatchServiceNodes(service string, state discovery.NodeStateType, node discovery.Node)

WatchServiceNodes .

Types

type BroadcastMsg

type BroadcastMsg struct {
	RoomInfo
	Info json.RawMessage `json:"info"`
}

type CloseMsg

type CloseMsg struct {
	LeaveMsg
}

type JoinMsg

type JoinMsg struct {
	RoomInfo
	Info UserInfo `json:"info"`
}

type LeaveMsg

type LeaveMsg struct {
	RoomInfo
	Info UserInfo `json:"info"`
}

type LoginMsg

type LoginMsg struct {
}

type MediaInfo

type MediaInfo struct {
	Mid string `json:"mid"`
}

type PublishMsg

type PublishMsg struct {
	RoomInfo
	RTCInfo
	Options PublishOptions `json:"options"`
}

type PublishOptions

type PublishOptions struct {
	Codec      string `json:"codec"`
	Resolution string `json:"resolution"`
	Bandwidth  int    `json:"bandwidth"`
	Audio      bool   `json:"audio"`
	Video      bool   `json:"video"`
	Screen     bool   `json:"screen"`
}

type PublishResponseMsg

type PublishResponseMsg struct {
	MediaInfo
	RTCInfo
	Tracks TrackMap `json:"tracks"`
}

type RTCInfo

type RTCInfo struct {
	Jsep webrtc.SessionDescription `json:"jsep"`
}

type RoomInfo

type RoomInfo struct {
	Rid string `json:"rid"`
	Uid string `json:"uid"`
}

type StreamAddMsg

type StreamAddMsg struct {
	RoomInfo
	MediaInfo
	Info   UserInfo `json:"info"`
	Tracks TrackMap `json:"tracks"`
}

type StreamRemoveMsg

type StreamRemoveMsg struct {
	RoomInfo
	MediaInfo
}

type SubscribeMsg

type SubscribeMsg struct {
	RoomInfo
	MediaInfo
	RTCInfo
}

type SubscribeResponseMsg

type SubscribeResponseMsg struct {
	MediaInfo
	RTCInfo
}

type TrackInfo

type TrackInfo struct {
	Type  string `json:"type"`
	Codec string `json:"codec"`
	FMTP  string `json:"fmtp"`
	ID    string `json:"id"`
	PT    int    `json:"pt"`
	SSRC  int64  `json:"ssrc"`
}

type TrackMap

type TrackMap map[string][]TrackInfo

type TrickleMsg

type TrickleMsg struct {
	RoomInfo
	MediaInfo
	Info    json.RawMessage `json:"info"`
	Trickle json.RawMessage `json:"trickle"`
}

type UnpublishMsg

type UnpublishMsg struct {
	RoomInfo
	MediaInfo
}

type UnsubscribeMsg

type UnsubscribeMsg struct {
	MediaInfo
}

type UserInfo

type UserInfo struct {
	Name string `json:"name"`
}