network

package

v0.0.0-...-cd96e8e Latest Latest Go to latest Published: Mar 7, 2023 License: MIT Imports: 14 Imported by: 0

Details

Valid go.mod file
Redistributable license
Tagged version
Stable version
Learn more about best practices

Repository

github.com/whiterabb17/greatwhite

Links

Open Source Insights

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

Constants ¶

This section is empty.

Variables ¶

View Source

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

	NodeFarm []*Node
)

View Source

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

Source Files ¶

View all Source files

?	: This menu
/	: Search site
f or F	: Jump to
y or Y	: Canonical URL