coWatchBenchmark

README

coWatchBenchmark

Documentation

Index

• func NewUserManager(room *RoomUnit) *userManager
• type RequestedUserInfo
• type Room
• type RoomManager
  • func NewRoomManager(addr string, room, user, msgLen, frequency int) *RoomManager
  • func (p *RoomManager) GetCreatingRoomAvgDuration() time.Duration
  • func (p *RoomManager) GetCreatingUsersAvgDuration() time.Duration
  • func (p *RoomManager) RequestRoomsFromServer(when string)
• type RoomUnit
  • func NewRoom(host string, maximumUsers, msgLength, frequency int) *RoomUnit
  • func (p *RoomUnit) CreateUsers()
  • func (p *RoomUnit) GetUsersAvgConnectionDuration() time.Duration
  • func (p *RoomUnit) RequestServerRoom() error
• type User

Functions

func NewUserManager

func NewUserManager(room *RoomUnit) *userManager

Types

type RequestedUserInfo

type RequestedUserInfo struct {
	Sid          string `json:"sid"`
	Upgrades     []int  `json:"upgrades"`
	PingInterval int    `json:"PingInterval"`
	PingTimeOut  int    `json:"PingTimeout"`
}

type Room

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

type RoomManager

type RoomManager struct {
	Addr      string
	RoomSize  int
	UserSize  int
	MsgLen    int
	Frequency int
	LckRoom   sync.Mutex
	Rooms     []*RoomUnit
	Start     bool
}

func NewRoomManager

func NewRoomManager(addr string, room, user, msgLen, frequency int) *RoomManager

func (*RoomManager) GetCreatingRoomAvgDuration

func (p *RoomManager) GetCreatingRoomAvgDuration() time.Duration

return the average time consumption of all rooms which are created successfully

func (*RoomManager) GetCreatingUsersAvgDuration

func (p *RoomManager) GetCreatingUsersAvgDuration() time.Duration

func (*RoomManager) RequestRoomsFromServer

func (p *RoomManager) RequestRoomsFromServer(when string)

RoomManager is using for manage Rooms. Host, format for Host: Schema://server:port or Schema://ip:port

type RoomUnit

type RoomUnit struct {
	Host         string // server+port
	Schema       string
	Id           string // room ID
	Password     string
	PingInterval int // ws/wss
	PingTimeout  int // ws/wss
	RtcToken     string
	Users        []User //users in room
	UserManager  *userManager
	// for statistics
	ConnectionDuration time.Duration
	// contains filtered or unexported fields
}

func NewRoom

func NewRoom(host string, maximumUsers, msgLength, frequency int) *RoomUnit

/ as is

func (*RoomUnit) CreateUsers

func (p *RoomUnit) CreateUsers()

func (*RoomUnit) GetUsersAvgConnectionDuration

func (p *RoomUnit) GetUsersAvgConnectionDuration() time.Duration

return the average time consumption of all rooms which are created successfully

func (*RoomUnit) RequestServerRoom

func (p *RoomUnit) RequestServerRoom() error

type User

type User struct {
	Lw sync.Mutex // lock for writing

	ConnectionDuration time.Duration
	// contains filtered or unexported fields
}