broadcast

Documentation

Index

• Constants
• func BroadcastByAll(value string)
• func BroadcastByAppID(appID string, value string)
• func BroadcastByAppIDs(appIDs []string, value string)
• func BroadcastByLiveID(liveID string, value string)
• func BroadcastByLiveIDs(liveIDs []string, value string)
• func BroadcastBySessionID(sessionID string, value string)
• func BroadcastBySessionIDs(sessionIDs []string, value string)
• func BroadcastEntry(liveID string, value string, sessionID string)
• func GroupWriteData(conns []*connectionm.Connection, data []byte)
• func NextWriteDataToCh(conns []*connectionm.Connection, data []byte)
• func WriteData(conns []*connectionm.Connection, data []byte)
• func WriteDataToCh(conns []*connectionm.Connection, data []byte)

Constants

const (
	GroupLen = 1000
)

Functions

func BroadcastByAll

func BroadcastByAll(value string)

func BroadcastByAppID

func BroadcastByAppID(appID string, value string)

func BroadcastByAppIDs

func BroadcastByAppIDs(appIDs []string, value string)

func BroadcastByLiveID

func BroadcastByLiveID(liveID string, value string)

func BroadcastByLiveIDs

func BroadcastByLiveIDs(liveIDs []string, value string)

func BroadcastBySessionID

func BroadcastBySessionID(sessionID string, value string)

func BroadcastBySessionIDs

func BroadcastBySessionIDs(sessionIDs []string, value string)

func BroadcastEntry

func BroadcastEntry(liveID string, value string, sessionID string)

入场消息广播，广播给直播间除自身以外所有人

func GroupWriteData

func GroupWriteData(conns []*connectionm.Connection, data []byte)

func NextWriteDataToCh

func NextWriteDataToCh(conns []*connectionm.Connection, data []byte)

func WriteData

func WriteData(conns []*connectionm.Connection, data []byte)

func WriteDataToCh

func WriteDataToCh(conns []*connectionm.Connection, data []byte)