connectionhub

Documentation

Index

• Variables
• type Client
  • func (c Client) ReadPump()
  • func (c Client) WritePump()
• type Connection
• type ConnectionNamespaces
• type ConnectionRoom
• type MesageTarget
  • func (t MesageTarget) String() string
• type Message
• type MessageDestinations
• type WsMessage

Variables

var ConnectionHub = connectionHub{
	Rooms: ConnectionNamespaces{
		Roles:        make(map[string]map[*Connection]*Client),
		Organization: make(map[string]map[*Connection]*Client),
		Usernames:    make(map[string]map[*Connection]*Client),
	},
	Emit:       make(chan Message),
	Broadcast:  make(chan Message),
	Register:   make(chan Client),
	Unregister: make(chan Client),
	Clients:    make(clients),
}

Types

type Client

type Client struct {
	User         string
	Organization string
	Roles        []string
	Username     string
	Conn         *Connection
}

func (Client) ReadPump

func (c Client) ReadPump()

func (Client) WritePump

func (c Client) WritePump()

pump incoming messages to connection hub

type Connection

type Connection struct {
	Ws   *websocket.Conn
	Send chan []byte
}

type ConnectionNamespaces

type ConnectionNamespaces struct {
	// index rooms clients by connections to allow better access
	Roles        map[string]map[*Connection]*Client
	Organization map[string]map[*Connection]*Client
	Usernames    map[string]map[*Connection]*Client
}

type ConnectionRoom

type ConnectionRoom struct {
	RoomId  string
	Members string
}

type MesageTarget

type MesageTarget string

const (
	User         MesageTarget = "user"
	Organization MesageTarget = "organization"
	Role         MesageTarget = "role"
)

func (MesageTarget) String

func (t MesageTarget) String() string

type Message

type Message struct {
	Broadcast    bool
	Data         []byte
	Destinations MessageDestinations
	Origin       string
}

type MessageDestinations

type MessageDestinations struct {
	Usernames     []string
	Users         []string
	Roles         []string
	Organizations []string
}

type WsMessage

type WsMessage struct {
	Broadcast     bool                   `json:"broadcast"`
	Users         []string               `json:"users"`
	Roles         []string               `json:"roles"`
	Organizations []string               `json:"organizations"`
	Usernames     []string               `json:"usernames"`
	Payload       map[string]interface{} `json:"payload"`
}