network

Documentation

Index

• Variables
• func BroadCastToAll(event string, message MyEventData)
• func BroadCastToRoom(room, event string, message MyEventData)
• func BuildHandler(w *astilectron.Window, m bootstrap.MessageIn) (payload interface{}, err error)
• func DeleteFromClientDB(coloum string, value string, tablePtr models.ClientInfo)
• func DeleteFromGeneralDB(coloum string, value string, genpacket models.Packet)
• func FindChannel(id string) (*gophersocket.Channel, error)
• func GetJson(m *bootstrap.MessageIn, parseTo interface{}) (err error)
• func ListeningHandler(_ *astilectron.Window, m bootstrap.MessageIn) (payload interface{}, err error)
• func ReadFromClientDB(coloum string, value string)
• func ReadFromGeneralDB(coloum string, value string)
• func SendAck(channel *gophersocket.Channel, ackEvent string, message MyEventData) (result string, err error)
• func SendToChannel(channel *gophersocket.Channel, event string, message MyEventData)
• func SendToFrontend(focusedWin *astilectron.Window, eventMsg, msg string)
• func ServeNode(name string, port string) error
• func StartListener(server *gophersocket.Server)
• func UpdateClientDBVals(coloum string, value string)
• func UpdateGeneralDBVals(coloum string, value string)
• func Watchman(server *gophersocket.Server, scope *gophersocket.Channel)
• func WriteToClientDB(data []string)
• func WriteToGeneralDB(packet *models.Packet)
• type Event
• type Message
• type MyEventData
• type Node
  • func CreateNode(name string, port string) *Node
• type Subscription

Variables

var (
	MainServer   *gophersocket.Server
	MainChannel  *gophersocket.Channel
	ChannelRooms []string

	NodeFarm []*Node
)

var Nodes []*Node

Functions

func BroadCastToAll

func BroadCastToAll(event string, message MyEventData)

func BroadCastToRoom

func BroadCastToRoom(room, event string, message MyEventData)

func BuildHandler

func BuildHandler(w *astilectron.Window, m bootstrap.MessageIn) (payload interface{}, err error)

func DeleteFromClientDB

func DeleteFromClientDB(coloum string, value string, tablePtr models.ClientInfo)

func DeleteFromGeneralDB

func DeleteFromGeneralDB(coloum string, value string, genpacket models.Packet)

func FindChannel

func FindChannel(id string) (*gophersocket.Channel, error)

func GetJson

func GetJson(m *bootstrap.MessageIn, parseTo interface{}) (err error)

var packet models.Packet err := GetJsonPacket(m, &packet)

func ListeningHandler

func ListeningHandler(_ *astilectron.Window, m bootstrap.MessageIn) (payload interface{}, err error)

handleMessages handles messages

func ReadFromClientDB

func ReadFromClientDB(coloum string, value string)

Create

func ReadFromGeneralDB

func ReadFromGeneralDB(coloum string, value string)

Create

func SendAck

func SendAck(channel *gophersocket.Channel, ackEvent string, message MyEventData) (result string, err error)

func SendToChannel

func SendToChannel(channel *gophersocket.Channel, event string, message MyEventData)

func SendToFrontend

func SendToFrontend(focusedWin *astilectron.Window, eventMsg, msg string)

func ServeNode

func ServeNode(name string, port string) error

func StartListener

func StartListener(server *gophersocket.Server)

func UpdateClientDBVals

func UpdateClientDBVals(coloum string, value string)

func UpdateGeneralDBVals

func UpdateGeneralDBVals(coloum string, value string)

func Watchman

func Watchman(server *gophersocket.Server, scope *gophersocket.Channel)

func WriteToClientDB

func WriteToClientDB(data []string)

func WriteToGeneralDB

func WriteToGeneralDB(packet *models.Packet)

Types

type Event

type Event struct {
	EvtType   string
	User      string
	Timestamp int
	Text      string
}

Event is to define the event

type Message

type Message struct {
	User      string
	Timestamp int
	Message   string
}

Message is the data structure of messages

type MyEventData

type MyEventData struct {
	Data string
}

type Node

type Node struct {
	Name     string
	Port     string
	Server   *gophersocket.Server
	MainRoom string
	Channel  *gophersocket.Channel
}

func CreateNode

func CreateNode(name string, port string) *Node

type Subscription

type Subscription struct {
	Archive []Event
	New     <-chan Event
}

Subscription is to manage subscribe events