hub

Documentation

Index

• Variables
• type IHub
  • func NewStreamHub(streamCfg *parameter.ServerConf) IHub
• type RoomMap

Variables

var (
	Mapper     RoomMap
	Broadcast  chan *models.BroadcastMessage
	Disconnect chan *models.DisconnectMessage
)

Types

type IHub

type IHub interface {
	CreateStream(ctx context.Context) string

	GetParticipants(ctx context.Context, roomID string) []*models.Participant

	InsertIntoStream(ctx context.Context, roomID string, client *models.Participant)

	DeleteStream(ctx context.Context, roomID string)

	Receiver(ctx context.Context, roomId string, client *models.Participant)

	Broadcaster()
}

func NewStreamHub

func NewStreamHub(streamCfg *parameter.ServerConf) IHub

type RoomMap

type RoomMap struct {
	Map map[string][]*models.Participant
	// contains filtered or unexported fields
}